Jared has a good point, what is mvn dependency:tree showing?
On Wed, Nov 22, 2017 at 7:54 AM, Jared Stehler <
jared.steh...@intellifylearning.com> wrote:
> Protobuf is notorious for throwing things like “class not found” when
> built and run with different versions of the library; I believe flink
Protobuf is notorious for throwing things like “class not found” when built
and run with different versions of the library; I believe flink is using
protobuf 2.5.0 and you mentioned using 2.6.1, which I think would be a
possible cause of this issue.
--
Jared Stehler
Chief Architect - Intellify Lea
But wouldn't a failed dependency show another ClassNotFoundException?
On Tuesday, 21 November 2017 20:31:58 CET Gordon Weakliem wrote:
> Isn't one cause for ClassNotFoundException that the class can't load due to
> failed dependencies or a failure in a static constructor?
>
> If jar -tf target/pr
Isn't one cause for ClassNotFoundException that the class can't load due to
failed dependencies or a failure in a static constructor?
If jar -tf target/program.jar | grep MeasurementTable shows the class is
present, are there other dependencies missing? You may need to add runtime
dependencies int
Hi Shankara,
sorry for the late response, but honestly, I cannot think of a reason that
some of your program's classes (using only a single jar file) are found some
others are not, except for the class not being in the jar.
Or there's some class loader issue in the Flink Beam runner (which I fin
Hi Nico,
- how do you run the job?
>> If we run same program in flink local then it works fine. For
flink local we used command line
mvn package exec:java
-Dexec.mainClass=com.huawei.ccn.intelliom.ims.tmon.TMon
-Dexec.args="--threshold=Measurment:0:4001:1:90:85:CPU
--broke
Hi Shankara,
can you give us some more details, e.g.
- how do you run the job?
- how do you add/include the jar with the missing class?
- is that jar file part of your program's jar or separate?
- is the missing class, i.e. "com.huawei.ccn.intelliom.ims.MeasurementTable
$measurementTable" (an inner
Hi,
I am using flink 2.1.0 version and protobuf-java 2.6.1 version.
I am getting below exception for protobuf generated class. I have included
jar which is having that class.
Can you please help me to check it.
org.apache.beam.sdk.util.UserCodeException:
org.apache.flink.streaming.runtime.