When I'm running generate-synthetic-data pipeline with Flink runner.
JobManager got the following NPE see below, and then got [Bug]: Issue #2997
ยท apache/hop (github.com) <https://github.com/apache/hop/issues/2997>
Caused by: java.lang.NullPointerException
at org.apache.flink.runtime.jobgraph.JobGraph
.addNodesThatHaveNoNewPredecessors(JobGraph.java:457)
at org.apache.flink.runtime.jobgraph.JobGraph
.getVerticesSortedTopologicallyFromSources(JobGraph.java:446)
at org.apache.flink.runtime.executiongraph.DefaultExecutionGraphBuilder
.buildGraph(DefaultExecutionGraphBuilder.java:188)
at org.apache.flink.runtime.scheduler.DefaultExecutionGraphFactory
.createAndRestoreExecutionGraph(DefaultExecutionGraphFactory.java:107)
Can you give any clue or advice on running just any pipeline on Flink
cluster?
--
Sincerely yours
Mikhail Khludnev
