The flink-clients dependency is correct.
We will need additional information to debug the Job execution failures,
because these can happen due to all kind of reasons.
Things like the full stacktrace, or exceptions from the logging output.
Additionally, I would recommend to base your project on the quickstarts
<https://ci.apache.org/projects/flink/flink-docs-stable/dev/project-configuration.html#maven-quickstart>.
On 3/3/2021 4:55 PM, Abdullah bin Omar wrote:
Hi,
I am running a code (Example Program) from [1], and followed the [2]
for the dependencies. I used this in the pom.xml:
<projectxmlns=/"http://maven.apache.org/POM/4.0.0
<http://maven.apache.org/POM/4.0.0>"/xmlns:xsi=/"http://www.w3.org/2001/XMLSchema-instance
<http://www.w3.org/2001/XMLSchema-instance>"/xsi:schemaLocation=/"http://maven.apache.org/POM/4.0.0
<http://maven.apache.org/POM/4.0.0>
https://maven.apache.org/xsd/maven-4.0.0.xsd
<https://maven.apache.org/xsd/maven-4.0.0.xsd>"/>
<modelVersion>4.0.0</modelVersion>
<groupId>org.apache.flink </groupId>
<artifactId>newinput</artifactId>
<version>0.0.1-SNAPSHOT</version>
<dependencies>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-streaming-java_2.11</artifactId>
<version>1.12.0</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
<version>1.7.5</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
<version>1.7.5</version>
</dependency>
</dependencies>
</project>
I got an error, No Executor Factory Found
After that, I add flink-clients dependencies in the pom.xml
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-clients_2.11</artifactId>
<type>jar</type>
<version>1.12.0</version>
<scope>provided</scope>
</dependency>
Then the previous error (No Executor Factory Found) was removed.
However, a new bunch of error appeared (like Job execution failed)
[1]
https://ci.apache.org/projects/flink/flink-docs-master/docs/dev/datastream/overview/
<https://ci.apache.org/projects/flink/flink-docs-master/docs/dev/datastream/overview/>
[2]
https://ci.apache.org/projects/flink/flink-docs-stable/dev/project-configuration.html#project-configuration
<https://ci.apache.org/projects/flink/flink-docs-stable/dev/project-configuration.html#project-configuration>
*/_Questions:_/*
(1) is the flink-clients dependencies correct?
(2) I just opened a maven project in Eclipse IDE, and am using the
flink-1.12 version.I used the java code similar to Example Program
[1], and using the above dependencies in pom.xml
I am wondering that are those steps correct? or something missing to
install or add anything in the code/pom.xml?
Thank you
Best Regards,
Abdullah
