search

wdm0006 / flink-python-examples

A collection of examples using flinks new python API
242 stars 73 forks source link

Refactor/compatible with flink 1.0.3 #1

Closed shahinism closed 8 years ago

shahinism commented 8 years ago

type definition is not necessary anymore since apache/flink@ab84707 commit removes it. Actually It'll raise TypeError like:

TypeError: flat_map() takes 2 positional arguments but 3 were given

If you try to define types. Also I've made a change in runner.py to make it able to get pyflink*.py from command line argument.

Thanks

wdm0006 commented 8 years ago

Awesome, thank you for the help!