Hi Folks,
I am switching some pipelines from SparkRunner to the FlinkRunner on beam
2.7
I started with a very simple pipeline which just reads from multiple kafka
sources, flatten those and then apply a regular DoFn.
On my first try of the pipeline (from command line using a fat jar) like:
```
java -cp my-fat.jar FQCN --configuration=foo --runner=FlinkRunner
```
complains with:
```
Exception in thread "main" java.lang.IllegalStateException: No translator
known for org.apache.beam.sdk.io.Read$Unbounded
at
org.apache.beam.runners.core.construction.PTransformTranslation.urnForTransform(PTransformTranslation.java:164)
at
org.apache.beam.runners.flink.FlinkStreamingPipelineTranslator.visitPrimitiveTransform(FlinkStreamingPipelineTranslator.java:100)
...
...
at org.apache.beam.sdk.Pipeline.run(Pipeline.java:299)
```
On my build.gradle i just replaced my spark-runner with this:
``
runtime "org.apache.beam:beam-runners-flink_2.11:2.7.0"
``
Am i missing something?
--
JC
