Hi colleagues,I build my app (fat jar) with no errors with these dependencies:
<dependency> <groupId>org.apache.flink</groupId>
<artifactId>flink-connector-kafka-0.8_2.10</artifactId>
<version>1.2.0</version> </dependency>
<dependency> <groupId>org.apache.flink</groupId>
<artifactId>flink-java</artifactId> <version>1.2.0</version> </dependency>
<dependency> <groupId>org.apache.flink</groupId>
<artifactId>flink-streaming-java_2.10</artifactId> <version>1.2.0</version>
</dependency> <dependency> <groupId>org.apache.flink</groupId>
<artifactId>flink-clients_2.10</artifactId> <version>1.2.0</version>
</dependency>
When I deploy the fat jar built by above to Flink cluster, I get JM not
accessible or similar errors and issues.When I add this dependency below in my
app pom.xml on TOP OF EVERYTHING listed above, rebuild, then redeploy,
everything works.
<dependency> <groupId>org.apache.flink</groupId>
<artifactId>flink-runtime_2.11</artifactId> <version>1.2.0</version>
</dependency>
Why do I need this dependency above? Why should it be ABOVE everything? And why
doesnt it work when its located BELOW everything?Thanks and regards.
