Hi, Please properly subscribe to the mailing list so that the community can receive email notifications for your messages. To subscribe, send empty email to user-subscr...@ignite.apache.org and follow simple instructions in the reply.
kadsank wrote > Please try to run the programe on flink cluster because I think the Static > initialization and serialization of object are causing the problem. > > > Error log: > > Cluster configuration: Standalone cluster with JobManager at > /192.168.140.53:6123 > Using address 192.168.140.53:6123 to connect to JobManager. > JobManager web interface address http://192.168.140.53:8081 > Starting execution of program > [10:08:25] __________ ________________ > [10:08:25] / _/ ___/ |/ / _/_ __/ __/ > [10:08:25] _/ // (7 7 // / / / / _/ > [10:08:25] /___/\___/_/|_/___/ /_/ /___/ > [10:08:25] > [10:08:25] ver. 2.0.0-SNAPSHOT#20170110-sha1:ff0caf81 > [10:08:25] 2016 Copyright(C) Apache Software Foundation > [10:08:25] > [10:08:25] Ignite documentation: http://ignite.apache.org > [10:08:25] > [10:08:25] Quiet mode. > [10:08:25] ^-- Logging to file > '/opt/apache-ignite-fabric-2.0.0-SNAPSHOT-bin/work/log/ignite-5468b9c1.0.log' > [10:08:25] ^-- To see **FULL** console log here add -DIGNITE_QUIET=false > or "-v" to ignite.{sh|bat} > [10:08:25] > [10:08:25] OS: Linux 2.6.32-431.el6.x86_64 amd64 > [10:08:25] VM information: Java(TM) SE Runtime Environment 1.8.0_71-b15 > Oracle Corporation Java HotSpot(TM) 64-Bit Server VM 25.71-b15 > [10:08:25] Configured plugins: > [10:08:25] ^-- None > [10:08:25] > [10:08:25] Message queue limit is set to 0 which may lead to potential > OOMEs when running cache operations in FULL_ASYNC or PRIMARY_SYNC modes > due to message queues growth on sender and receiver sides. > [10:08:25] Security status [authentication=off, tls/ssl=off] > [10:08:27] To start Console Management & Monitoring run > ignitevisorcmd.{sh|bat} > [10:08:27] > [10:08:27] Ignite node started OK (id=5468b9c1) > [10:08:27] Topology snapshot [ver=201, servers=2, clients=0, CPUs=48, > heap=28.0GB] > Submitting job with JobID: 2bd79002612254209186cd6aeec8e043. Waiting for > job completion. > Connected to JobManager at > Actor[akka.tcp://flink@192.168.140.53:6123/user/jobmanager#1956747552] > 02/23/2017 10:08:28 Job execution switched to status RUNNING. > 02/23/2017 10:08:28 Source: Custom Source -> Flat Map -> Sink: > Unnamed(1/1) switched to SCHEDULED > 02/23/2017 10:08:28 Source: Custom Source -> Flat Map -> Sink: > Unnamed(1/1) switched to DEPLOYING > 02/23/2017 10:08:28 Source: Custom Source -> Flat Map -> Sink: > Unnamed(1/1) switched to RUNNING > 02/23/2017 10:08:28 Source: Custom Source -> Flat Map -> Sink: > Unnamed(1/1) switched to FAILED > java.lang.NoClassDefFoundError: Could not initialize class > org.apache.ignite.sink.flink.IgniteSink$SinkContext$Holder > at > org.apache.ignite.sink.flink.IgniteSink$SinkContext.getStreamer(IgniteSink.java:201) > at > org.apache.ignite.sink.flink.IgniteSink$SinkContext.access$100(IgniteSink.java:175) > at > org.apache.ignite.sink.flink.IgniteSink.invoke(IgniteSink.java:165) > at > org.apache.flink.streaming.api.operators.StreamSink.processElement(StreamSink.java:39) > at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:391) > at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:376) > at > org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutput.collect(AbstractStreamOperator.java:366) > at > org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutput.collect(AbstractStreamOperator.java:349) > at > org.apache.flink.streaming.api.operators.TimestampedCollector.collect(TimestampedCollector.java:51) > at flink_ignite_sink$Splitter.flatMap(flink_ignite_sink.java:189) > at flink_ignite_sink$Splitter.flatMap(flink_ignite_sink.java:1) > at > org.apache.flink.streaming.api.operators.StreamFlatMap.processElement(StreamFlatMap.java:48) > at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:391) > at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:376) > at > org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutput.collect(AbstractStreamOperator.java:366) > at > org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutput.collect(AbstractStreamOperator.java:349) > at > org.apache.flink.streaming.api.operators.StreamSource$NonTimestampContext.collect(StreamSource.java:161) > at > org.apache.flink.streaming.connectors.kafka.internals.AbstractFetcher.emitRecord(AbstractFetcher.java:225) > at > org.apache.flink.streaming.connectors.kafka.internal.Kafka09Fetcher.run(Kafka09Fetcher.java:253) > at java.lang.Thread.run(Thread.java:745) > > 02/23/2017 10:08:28 Job execution switched to status FAILING. > java.lang.NoClassDefFoundError: Could not initialize class > org.apache.ignite.sink.flink.IgniteSink$SinkContext$Holder > at > org.apache.ignite.sink.flink.IgniteSink$SinkContext.getStreamer(IgniteSink.java:201) > at > org.apache.ignite.sink.flink.IgniteSink$SinkContext.access$100(IgniteSink.java:175) > at > org.apache.ignite.sink.flink.IgniteSink.invoke(IgniteSink.java:165) > at > org.apache.flink.streaming.api.operators.StreamSink.processElement(StreamSink.java:39) > at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:391) > at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:376) > at > org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutput.collect(AbstractStreamOperator.java:366) > at > org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutput.collect(AbstractStreamOperator.java:349) > at > org.apache.flink.streaming.api.operators.TimestampedCollector.collect(TimestampedCollector.java:51) > at flink_ignite_sink$Splitter.flatMap(flink_ignite_sink.java:189) > at flink_ignite_sink$Splitter.flatMap(flink_ignite_sink.java:1) > at > org.apache.flink.streaming.api.operators.StreamFlatMap.processElement(StreamFlatMap.java:48) > at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:391) > at > org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:376) > at > org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutput.collect(AbstractStreamOperator.java:366) > at > org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutput.collect(AbstractStreamOperator.java:349) > at > org.apache.flink.streaming.api.operators.StreamSource$NonTimestampContext.collect(StreamSource.java:161) > at > org.apache.flink.streaming.connectors.kafka.internals.AbstractFetcher.emitRecord(AbstractFetcher.java:225) > at > org.apache.flink.streaming.connectors.kafka.internal.Kafka09Fetcher.run(Kafka09Fetcher.java:253) > at java.lang.Thread.run(Thread.java:745) > 02/23/2017 10:08:28 Job execution switched to status FAILED. > [10:08:29] Ignite node stopped OK [uptime=00:00:01:343] > > ------------------------------------------------------------ > The program finished with the following exception: > > java.lang.NullPointerException > at > org.apache.flink.client.CliFrontend.executeProgram(CliFrontend.java:784) > at org.apache.flink.client.CliFrontend.run(CliFrontend.java:253) > at > org.apache.flink.client.CliFrontend.parseParameters(CliFrontend.java:1005) > at org.apache.flink.client.CliFrontend.main(CliFrontend.java:1048) It looks like you don't have all required Ignite libraries on the Flink cluster. Can this be the case? -Val -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/java-lang-NoClassDefFoundError-Could-not-initialize-class-org-apache-ignite-sink-flink-IgniteSink-Sir-tp10703p10842.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.
