Support the Flink Runner
Closed this issue · 1 comments
mattcasters commented
- Beam Job Config Dialog
- Pipeline execution options
- ...
mattcasters commented
The local direct runner works. Now we need another main to run on the Flink master.
Then we can run something like:
flink run -c org.kettle.beam.pipeline.flink.MainFlink fat-kettle-beam.jar transformation.ktr metastore.json FlinkBeamJobConfigName