Hello All

I use Flink in order to filter data from Hdfs and write it back as CSV.

I keep getting the "Checking and uploading JAR files" on every DataSet
filtering action or
executionEnvironment execution.

I use ExecutionEnvironment.createRemoteEnvironment(ip+jars..) because I
launch Flink from
a J2EE Aplication Server .

The Jars serialization and transportation takes a huge part of the
execution time .
Is there a way to force Flink to pass the Jars only once?

Please advise

Thanks,

Hanan Meyer

Reply via email to