[
https://issues.apache.org/jira/browse/BEAM-11732?focusedWorklogId=546391&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-546391
]
ASF GitHub Bot logged work on BEAM-11732:
-----------------------------------------
Author: ASF GitHub Bot
Created on: 03/Feb/21 00:59
Start Date: 03/Feb/21 00:59
Worklog Time Spent: 10m
Work Description: ibzib merged pull request #13874:
URL: https://github.com/apache/beam/pull/13874
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
Issue Time Tracking
-------------------
Worklog Id: (was: 546391)
Time Spent: 1h 10m (was: 1h)
> 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
> Priority: P1
> Fix For: 2.28.0
>
> Time Spent: 1h 10m
> Remaining Estimate: 0h
>
> 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)
