[jira] [Created] (BEAM-11732) flink-clients dependency must be provided by user.

["Kyle Weaver (Jira)" <ji...@apache.org>]

Kyle Weaver created BEAM-11732:
----------------------------------

             Summary: flink-clients dependency must be provided by user.
                 Key: BEAM-11732
                 URL: https://issues.apache.org/jira/browse/BEAM-11732
             Project: Beam
          Issue Type: Bug
          Components: runner-flink
            Reporter: Kyle Weaver
            Assignee: Kyle Weaver
             Fix For: 2.28.0


In https://github.com/apache/beam/pull/13658 we changed flink-clients from compile to runtimeOnly. This had the unintended consequence of requiring the user to provide the flink-clients dependency themselves in order to run Flink on local mode, otherwise they will get the error below.

I'm guessing this happens because runtime dependencies are not included in Beam's generated pom.xml: https://github.com/apache/beam/blob/3d6cb85e4961585ae9c4fa3c7226916fef68998f/buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy#L1387-L1389

----

Caused by: java.lang.IllegalStateException: No ExecutorFactory found to execute the application.
    at org.apache.flink.core.execution.DefaultExecutorServiceLoader.getExecutorFactory (DefaultExecutorServiceLoader.java:88)
    at org.apache.flink.api.java.ExecutionEnvironment.executeAsync (ExecutionEnvironment.java:1043)
    at org.apache.flink.api.java.ExecutionEnvironment.execute (ExecutionEnvironment.java:958)
    at org.apache.beam.runners.flink.FlinkPipelineExecutionEnvironment.executePipeline (FlinkPipelineExecutionEnvironment.java:153)
    at org.apache.beam.runners.flink.FlinkRunner.run (FlinkRunner.java:97)
    at org.apache.beam.sdk.Pipeline.run (Pipeline.java:322)
    at org.apache.beam.sdk.Pipeline.run (Pipeline.java:308)
    at org.apache.beam.samples.sql.BeamSqlAvroExample.main (BeamSqlAvroExample.java:106)
    at org.codehaus.mojo.exec.ExecJavaMojo$1.run (ExecJavaMojo.java:254)
    at java.lang.Thread.run (Thread.java:834)





--
This message was sent by Atlassian Jira
(v8.3.4#803005)