I think your confusion is caused by using using "mvn clean", instead of
"mvn clean package".
"mvn clean" cleans up, deleting jars and such, whereas "mvn package"
compiles the code and packages a jar.
On 3/4/2021 3:41 PM, Abdullah bin Omar wrote:
Hi Chesnay,
Thank you for your reply. Sorry for coming up late.
I follow the maven quickstart. when I run the pom.xml in m2Maven clean
way. Then it gives me this output in console:
SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in
[jar:file:/Users/abdullah/.p2/pool/plugins/org.eclipse.m2e.maven.runtime.slf4j.simple_1.16.0.20200610-1735/jars/slf4j-simple-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in
[file:/Users/abdullah/eclipse/java-2020-12/Eclipse.app/Contents/Eclipse/configuration/org.eclipse.osgi/5/0/.cp/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings
<http://www.slf4j.org/codes.html#multiple_bindings> for an explanation.
SLF4J: Actual binding is of type [org.slf4j.impl.SimpleLoggerFactory]
SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in
[jar:file:/Users/abdullah/.p2/pool/plugins/org.eclipse.m2e.maven.runtime.slf4j.simple_1.16.0.20200610-1735/jars/slf4j-simple-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in
[file:/Users/abdullah/eclipse/java-2020-12/Eclipse.app/Contents/Eclipse/configuration/org.eclipse.osgi/5/0/.cp/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings
<http://www.slf4j.org/codes.html#multiple_bindings> for an explanation.
SLF4J: Actual binding is of type [org.slf4j.impl.SimpleLoggerFactory]
[INFO] Scanning for projects...
[INFO]
[INFO] ---------------------< org.apache.flink:newinput
>----------------------
[INFO] Building newinput 0.0.1-SNAPSHOT
[INFO] --------------------------------[ jar
]---------------------------------
[INFO]
[INFO] --- maven-clean-plugin:2.5:clean (default-clean) @ newinput ---
[INFO] Deleting /Users/abdullah/Documents/newinput/target
[INFO]
------------------------------------------------------------------------
[INFO] BUILD SUCCESS
[INFO]
------------------------------------------------------------------------
[INFO] Total time:0.281 s
[INFO] Finished at: 2021-03-04T08:10:00-06:00
[INFO]
------------------------------------------------------------------------
and now when I run the code, it shows this error:
Error: Could not find or load main class newinput.count
Caused by: java.lang.ClassNotFoundException: newinput.count
*_Question:_*
in quickstarts
<https://ci.apache.org/projects/flink/flink-docs-stable/dev/project-configuration.html#maven-quickstart>,
it said in build project section,
You will find a JAR file that contains your application, plus
connectors and libraries that you may have added as dependencies to
the application: |target/<artifact-id>-<version>.jar|.
If you use a different class than /StreamingJob/ as the application’s
main class / entry point, we recommend you change the
|mainClass| setting in the |pom.xml| file accordingly.
I do not Understand the above two lines.
The class name that I used is named "count": so different from a
streaming job.
*Is something I missed due to not understanding those two lines?*
*
*
*Thank you!*
On Wed, Mar 3, 2021 at 2:49 PM Chesnay Schepler <ches...@apache.org
<mailto:ches...@apache.org>> wrote:
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
