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