[ https://issues.apache.org/jira/browse/BEAM-7420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16861043#comment-16861043 ]
Maximilian Michels commented on BEAM-7420: ------------------------------------------ Thank you for the response. I figured that you somehow excluded the Flink runtime manually. Actually, the Runner jar is completely self-contained. You can spin up a Flink cluster and run a Beam pipeline from it. Setting the dependencies to {{provided}} would mean this is no longer possible. We could probably work around this by 1) re-adding the runtime dependencies in the example pom and 2) only require the dependencies during testing e.g. {{testCompile}}. > Including the Flink runner causes exceptions unless running in a flink > environment > ---------------------------------------------------------------------------------- > > Key: BEAM-7420 > URL: https://issues.apache.org/jira/browse/BEAM-7420 > Project: Beam > Issue Type: Bug > Components: runner-flink > Reporter: Mike Kaplinskiy > Assignee: Maximilian Michels > Priority: Major > > 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. -- This message was sent by Atlassian JIRA (v7.6.3#76005)