Hi,
The root cause is not "java.lang.NoClassDefFound". The job has been
running but could not edit the config map
"myJob--jobmanager-leader" and it
seems finally disconnected with the API server. Is there another job
with the same cluster id (myJob) ?
I would also
Hi!
I don't quite understand this question, but I suppose you first run the
table program and then run the data stream program and you want the results
of the two programs to be identical?
If this is the case, the job will run twice as Flink will not cache the
result of a job, so in each run the
Hi!
There is a message saying "java.lang.NoClassDefFound Error:
org/apache/hadoop/hdfs/HdfsConfiguration" in your log file. Are you
visiting HDFS in your job? If yes it seems that your Flink distribution or
your cluster is lacking hadoop classes. Please make sure that there are
hadoop jars in the
I think there is no easy way to access the configuration. There is
GlobalConfiguration but it's marked Internal and I think it's even
discouraged inside core Flink.
However, usually you have full access to the Configuraiton inside your main
and you can simply pass it or the desired option to your
