Как запустить WordCount Example Program Apache Flink?

Question

[Mykyta_M]

Добрый вечер!
Подскажите, пожалуйста, не могу разобраться. Установил Apache Flink. Не получается запустить WordCount Example Program . Я так понимаю, что необходимо установить еще и модули для Пайтон? Как это сделать? Через Pip ничего не вышло.
Пишет: ImportError: No module named flink.plan.Environment для python 2 и No module named flink для python 3

Код программы:

from flink.plan.Environment import get_environment
from flink.functions.GroupReduceFunction import GroupReduceFunction

class Adder(GroupReduceFunction):
  def reduce(self, iterator, collector):
    count, word = iterator.next()
    count += sum([x[0] for x in iterator])
    collector.collect((count, word))

env = get_environment()
data = env.from_elements("Who's there?",
 "I think I hear them. Stand, ho! Who's there?")

data \
  .flat_map(lambda x, c: [(1, word) for word in x.lower().split()]) \
  .group_by(1) \
  .reduce_group(Adder(), combinable=True) \
  .output()

env.execute(local=True)

Пробую запустить на виртуальной машине Ubuntu 16.04. С Линуксом плохо знаком еще. Возможно, необходимо добавить Flink в Path? (с этим то же проблемы). Программу поместил в папку Flink и оттуда запускал