Details
-
Bug
-
Status: Resolved
-
P2
-
Resolution: Fixed
-
None
-
None
Description
The FlinkPipelineOptions imports various Flink enums which make it impossible to e.g. run the direct runner with the same classpath but without the flink runtime. The fix is potentially easy - make the arguments strings and convert them to enums at the callsites.
Attachments
Issue Links
- relates to
-
BEAM-7544 [workaround available] Please provide a build against scala 2.12 for Flink runner
- Resolved
- links to