search

hazelcast / hazelcast-jet

Distributed Stream and Batch Processing
https://jet-start.sh
Other
1.1k stars 205 forks source link

Getting "Invalid lambda deserialization" exception in word count example #326

Closed mukul4u2005 closed 7 years ago

mukul4u2005 commented 7 years ago

Creating Jet instance 1 Feb 23, 2017 4:04:02 PM com.hazelcast.instance.DefaultAddressPicker INFO: [LOCAL] [jet] [0.3] [3.8-RC1] Prefer IPv4 stack is true. Feb 23, 2017 4:04:02 PM com.hazelcast.instance.DefaultAddressPicker INFO: [LOCAL] [jet] [0.3] [3.8-RC1] Picked [10.162.55.6]:5701, using socket ServerSocket[addr=/0:0:0:0:0:0:0:0,localport=5701], bind any local is true Feb 23, 2017 4:04:02 PM com.hazelcast.system INFO: [10.162.55.6]:5701 [jet] [0.3] [3.8-RC1] Hazelcast 3.8-RC1 (20170201 - 609ebbc) starting at [10.162.55.6]:5701 Feb 23, 2017 4:04:02 PM com.hazelcast.system INFO: [10.162.55.6]:5701 [jet] [0.3] [3.8-RC1] Copyright (c) 2008-2016, Hazelcast, Inc. All Rights Reserved. Feb 23, 2017 4:04:02 PM com.hazelcast.system INFO: [10.162.55.6]:5701 [jet] [0.3] [3.8-RC1] Configured Hazelcast Serialization version : 1 Feb 23, 2017 4:04:02 PM com.hazelcast.spi.impl.operationservice.impl.BackpressureRegulator INFO: [10.162.55.6]:5701 [jet] [0.3] [3.8-RC1] Backpressure is disabled Feb 23, 2017 4:04:03 PM com.hazelcast.instance.Node INFO: [10.162.55.6]:5701 [jet] [0.3] [3.8-RC1] Creating MulticastJoiner Feb 23, 2017 4:04:03 PM com.hazelcast.jet.impl.JetService INFO: [10.162.55.6]:5701 [jet] [0.3] [3.8-RC1] Starting Jet 0.3 (20170206 - 5c8738d) Feb 23, 2017 4:04:03 PM com.hazelcast.jet.impl.JetService INFO: [10.162.55.6]:5701 [jet] [0.3] [3.8-RC1] Setting number of cooperative threads and default parallelism to 2 Feb 23, 2017 4:04:03 PM com.hazelcast.jet.impl.JetService INFO: [10.162.55.6]:5701 [jet] [0.3] [3.8-RC1] o o o o---o o---o o o---o o o---o o-o-o o o---o o-o-o | | / \ / | | | / \ | | | | |
o---o o---o o o-o | o o---o o---o | | o-o |
| | | | / | | | | | | | \ | | |
o o o o o---o o---o o---o o---o o o o---o o o--o o---o o
Feb 23, 2017 4:04:03 PM com.hazelcast.jet.impl.JetService INFO: [10.162.55.6]:5701 [jet] [0.3] [3.8-RC1] Copyright (c) 2008-2017, Hazelcast, Inc. All Rights Reserved. Feb 23, 2017 4:04:03 PM com.hazelcast.spi.impl.operationexecutor.impl.OperationExecutorImpl INFO: [10.162.55.6]:5701 [jet] [0.3] [3.8-RC1] Starting 4 partition threads Feb 23, 2017 4:04:03 PM com.hazelcast.spi.impl.operationexecutor.impl.OperationExecutorImpl INFO: [10.162.55.6]:5701 [jet] [0.3] [3.8-RC1] Starting 3 generic threads (1 dedicated for priority tasks) Feb 23, 2017 4:04:03 PM com.hazelcast.core.LifecycleService INFO: [10.162.55.6]:5701 [jet] [0.3] [3.8-RC1] [10.162.55.6]:5701 is STARTING Feb 23, 2017 4:04:06 PM com.hazelcast.system INFO: [10.162.55.6]:5701 [jet] [0.3] [3.8-RC1] Cluster version set to 3.8 Feb 23, 2017 4:04:06 PM com.hazelcast.internal.cluster.impl.MulticastJoiner INFO: [10.162.55.6]:5701 [jet] [0.3] [3.8-RC1]

Members [1] { Member [10.162.55.6]:5701 - 642563f8-8abf-4cbb-9290-7b131a5bb84d this }

Creating Jet instance 2 Feb 23, 2017 4:04:06 PM com.hazelcast.core.LifecycleService INFO: [10.162.55.6]:5701 [jet] [0.3] [3.8-RC1] [10.162.55.6]:5701 is STARTED Feb 23, 2017 4:04:06 PM com.hazelcast.instance.DefaultAddressPicker INFO: [LOCAL] [jet] [0.3] [3.8-RC1] Prefer IPv4 stack is true. Feb 23, 2017 4:04:06 PM com.hazelcast.instance.DefaultAddressPicker INFO: [LOCAL] [jet] [0.3] [3.8-RC1] Picked [10.162.55.6]:5703, using socket ServerSocket[addr=/0:0:0:0:0:0:0:0,localport=5703], bind any local is true Feb 23, 2017 4:04:06 PM com.hazelcast.system INFO: [10.162.55.6]:5703 [jet] [0.3] [3.8-RC1] Hazelcast 3.8-RC1 (20170201 - 609ebbc) starting at [10.162.55.6]:5703 Feb 23, 2017 4:04:06 PM com.hazelcast.system INFO: [10.162.55.6]:5703 [jet] [0.3] [3.8-RC1] Copyright (c) 2008-2016, Hazelcast, Inc. All Rights Reserved. Feb 23, 2017 4:04:06 PM com.hazelcast.system INFO: [10.162.55.6]:5703 [jet] [0.3] [3.8-RC1] Configured Hazelcast Serialization version : 1 Feb 23, 2017 4:04:06 PM com.hazelcast.spi.impl.operationservice.impl.BackpressureRegulator INFO: [10.162.55.6]:5703 [jet] [0.3] [3.8-RC1] Backpressure is disabled Feb 23, 2017 4:04:07 PM com.hazelcast.instance.Node INFO: [10.162.55.6]:5703 [jet] [0.3] [3.8-RC1] Creating MulticastJoiner Feb 23, 2017 4:04:07 PM com.hazelcast.jet.impl.JetService INFO: [10.162.55.6]:5703 [jet] [0.3] [3.8-RC1] Starting Jet 0.3 (20170206 - 5c8738d) Feb 23, 2017 4:04:07 PM com.hazelcast.jet.impl.JetService INFO: [10.162.55.6]:5703 [jet] [0.3] [3.8-RC1] Setting number of cooperative threads and default parallelism to 2 Feb 23, 2017 4:04:07 PM com.hazelcast.jet.impl.JetService INFO: [10.162.55.6]:5703 [jet] [0.3] [3.8-RC1] o o o o---o o---o o o---o o o---o o-o-o o o---o o-o-o | | / \ / | | | / \ | | | | |
o---o o---o o o-o | o o---o o---o | | o-o |
| | | | / | | | | | | | \ | | |
o o o o o---o o---o o---o o---o o o o---o o o--o o---o o
Feb 23, 2017 4:04:07 PM com.hazelcast.jet.impl.JetService INFO: [10.162.55.6]:5703 [jet] [0.3] [3.8-RC1] Copyright (c) 2008-2017, Hazelcast, Inc. All Rights Reserved. Feb 23, 2017 4:04:07 PM com.hazelcast.spi.impl.operationexecutor.impl.OperationExecutorImpl INFO: [10.162.55.6]:5703 [jet] [0.3] [3.8-RC1] Starting 4 partition threads Feb 23, 2017 4:04:07 PM com.hazelcast.spi.impl.operationexecutor.impl.OperationExecutorImpl INFO: [10.162.55.6]:5703 [jet] [0.3] [3.8-RC1] Starting 3 generic threads (1 dedicated for priority tasks) Feb 23, 2017 4:04:07 PM com.hazelcast.core.LifecycleService INFO: [10.162.55.6]:5703 [jet] [0.3] [3.8-RC1] [10.162.55.6]:5703 is STARTING Feb 23, 2017 4:04:07 PM com.hazelcast.internal.cluster.impl.MulticastJoiner INFO: [10.162.55.6]:5703 [jet] [0.3] [3.8-RC1] Trying to join to discovered node: [10.162.55.6]:5701 Feb 23, 2017 4:04:07 PM com.hazelcast.nio.tcp.InitConnectionTask INFO: [10.162.55.6]:5703 [jet] [0.3] [3.8-RC1] Connecting to /10.162.55.6:5701, timeout: 0, bind-any: true Feb 23, 2017 4:04:07 PM com.hazelcast.nio.tcp.SocketAcceptorThread INFO: [10.162.55.6]:5701 [jet] [0.3] [3.8-RC1] Accepting socket connection from /10.162.55.6:49760 Feb 23, 2017 4:04:07 PM com.hazelcast.nio.tcp.TcpIpConnectionManager INFO: [10.162.55.6]:5703 [jet] [0.3] [3.8-RC1] Established socket connection between /10.162.55.6:49760 and /10.162.55.6:5701 Feb 23, 2017 4:04:07 PM com.hazelcast.nio.tcp.TcpIpConnectionManager INFO: [10.162.55.6]:5701 [jet] [0.3] [3.8-RC1] Established socket connection between /10.162.55.6:5701 and /10.162.55.6:49760 Feb 23, 2017 4:04:14 PM com.hazelcast.internal.cluster.ClusterService INFO: [10.162.55.6]:5701 [jet] [0.3] [3.8-RC1]

Members [2] { Member [10.162.55.6]:5701 - 642563f8-8abf-4cbb-9290-7b131a5bb84d this Member [10.162.55.6]:5703 - 4ad40f05-f147-4839-9272-4d9968d9466c }

Feb 23, 2017 4:04:14 PM com.hazelcast.system INFO: [10.162.55.6]:5703 [jet] [0.3] [3.8-RC1] Cluster version set to 3.8 Feb 23, 2017 4:04:14 PM com.hazelcast.internal.cluster.ClusterService INFO: [10.162.55.6]:5703 [jet] [0.3] [3.8-RC1]

Members [2] { Member [10.162.55.6]:5701 - 642563f8-8abf-4cbb-9290-7b131a5bb84d Member [10.162.55.6]:5703 - 4ad40f05-f147-4839-9272-4d9968d9466c this }

Feb 23, 2017 4:04:16 PM com.hazelcast.instance.Node WARNING: [10.162.55.6]:5703 [jet] [0.3] [3.8-RC1] Config seed port is 5701 and cluster size is 2. Some of the ports seem occupied! Feb 23, 2017 4:04:16 PM com.hazelcast.core.LifecycleService INFO: [10.162.55.6]:5703 [jet] [0.3] [3.8-RC1] [10.162.55.6]:5703 is STARTED These books will be analyzed: adventures-of-sherlock-holmes.txt Feb 23, 2017 4:04:16 PM com.hazelcast.internal.partition.impl.PartitionStateManager INFO: [10.162.55.6]:5701 [jet] [0.3] [3.8-RC1] Initializing cluster partition table arrangement... anderson-fairy-tales.txt anna-karenina.txt around-the-world-in-eighty-days.txt a-tale-of-two-cities.txt awakening.txt benjamin-franklin-autobiography.txt beyond-good-and-evil.txt brothers-karamazov.txt canterbury-tales.txt clarissa-harlowe.txt confessions-of-st-augustine.txt connecticut-yankee.txt crime-punishment.txt critique-of-pure-reason.txt david-copperfield.txt decameron.txt divine-comedy.txt don-juan.txt don-quixote.txt dorian-gray.txt dracula.txt edgar-allan-poe-works-1.txt edgar-allan-poe-works-2.txt edgar-allan-poe-works-3.txt emma.txt faust.txt frankenstein.txt gilded-age.txt great-expectations.txt grimm-brothers.txt gullivers-travels.txt guy-de-maupassant-shorts.txt hard-times.txt heart-of-darkness.txt history-of-peloponnesian-war.txt hound-of-the-baskervilles.txt huckleberry-finn.txt iliad.txt ivanhoe.txt king-james-bible.txt land-of-oz.txt leaves-of-grass.txt les-miserables.txt leviathan.txt little-women.txt madame-bovary.txt man-who-was-thursday.txt mark-twain-mysterious-strangers.txt meditations.txt michel-montaigne-essays.txt middlemarch.txt moby-dick.txt monte-cristo.txt my-secret-life.txt north-and-south.txt notebooks-of-leonardo-da-vinci.txt odyssey.txt olaudah-equiano.txt oliver-twist.txt origin-of-species.txt paradise-lost.txt peter-pan.txt portrait-of-artist-as-a-young-man.txt practice-and-science-of-drawing.txt pride-and-prejudice.txt problems-of-philosophy.txt relativity-special-and-general-theory.txt return-of-sherlock-holmes.txt room-with-a-view.txt satyricon.txt scarlet-letter.txt sense-sensibility.txt shakespeare-complete-works.txt short-history-of-world.txt siddharta.txt sorrows-of-young-werther.txt souls-of-black-folk.txt swanns-way.txt the-30000-dollar-request.txt the-jungle.txt the-republic.txt the-trial.txt three-musketeers.txt through-the-looking-glass.txt thus-spake-zarathustra.txt time-machine.txt tom-sawyer.txt ulysses.txt uncle-toms-cabin.txt utopia.txt walden-and-duty-of-civil-disobedience.txt war-and-peace.txt war-of-the-worlds.txt wealth-of-nations.txt what-is-man.txt wuthering-heights.txt

Counting words... Feb 23, 2017 4:04:16 PM com.hazelcast.jet.impl.operation.ExecuteJobOperation INFO: [10.162.55.6]:5701 [jet] [0.3] [3.8-RC1] Start executing job 0. Feb 23, 2017 4:04:17 PM com.hazelcast.jet.impl.operation.InitOperation INFO: [10.162.55.6]:5701 [jet] [0.3] [3.8-RC1] Initializing execution plan for job 0 from [10.162.55.6]:5701. Feb 23, 2017 4:04:17 PM com.hazelcast.jet.impl.operation.InitOperation INFO: [10.162.55.6]:5703 [jet] [0.3] [3.8-RC1] Initializing execution plan for job 0 from [10.162.55.6]:5701. Feb 23, 2017 4:04:17 PM com.hazelcast.jet.impl.operation.InitOperation SEVERE: [10.162.55.6]:5703 [jet] [0.3] [3.8-RC1] java.io.IOException: unexpected exception type com.hazelcast.nio.serialization.HazelcastSerializationException: java.io.IOException: unexpected exception type at com.hazelcast.internal.serialization.impl.SerializationUtil.handleException(SerializationUtil.java:61) at com.hazelcast.internal.serialization.impl.AbstractSerializationService.readObject(AbstractSerializationService.java:272) at com.hazelcast.internal.serialization.impl.ByteArrayObjectDataInput.readObject(ByteArrayObjectDataInput.java:599) at com.hazelcast.jet.impl.execution.init.CustomClassLoadedObject.read(CustomClassLoadedObject.java:54) at com.hazelcast.jet.impl.execution.init.VertexDef.readData(VertexDef.java:108) at com.hazelcast.internal.serialization.impl.DataSerializableSerializer.readInternal(DataSerializableSerializer.java:156) at com.hazelcast.internal.serialization.impl.DataSerializableSerializer.read(DataSerializableSerializer.java:104) at com.hazelcast.internal.serialization.impl.DataSerializableSerializer.read(DataSerializableSerializer.java:49) at com.hazelcast.internal.serialization.impl.StreamSerializerAdapter.read(StreamSerializerAdapter.java:48) at com.hazelcast.internal.serialization.impl.AbstractSerializationService.readObject(AbstractSerializationService.java:266) at com.hazelcast.internal.serialization.impl.ByteArrayObjectDataInput.readObject(ByteArrayObjectDataInput.java:599) at com.hazelcast.jet.impl.util.Util.readList(Util.java:136) at com.hazelcast.jet.impl.execution.init.ExecutionPlan.readData(ExecutionPlan.java:202) at com.hazelcast.internal.serialization.impl.DataSerializableSerializer.readInternal(DataSerializableSerializer.java:156) at com.hazelcast.internal.serialization.impl.DataSerializableSerializer.read(DataSerializableSerializer.java:104) at com.hazelcast.internal.serialization.impl.DataSerializableSerializer.read(DataSerializableSerializer.java:49) at com.hazelcast.internal.serialization.impl.StreamSerializerAdapter.read(StreamSerializerAdapter.java:48) at com.hazelcast.internal.serialization.impl.AbstractSerializationService.toObject(AbstractSerializationService.java:184) at com.hazelcast.jet.impl.execution.init.CustomClassLoadedObject.deserializeWithCustomClassLoader(CustomClassLoadedObject.java:61) at com.hazelcast.jet.impl.operation.InitOperation.lambda$readInternal$1(InitOperation.java:71) at com.hazelcast.jet.impl.operation.InitOperation$$Lambda$141/852682394.get(Unknown Source) at com.hazelcast.jet.impl.operation.InitOperation.run(InitOperation.java:49) at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:186) at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:401) at com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.process(OperationThread.java:117) at com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.run(OperationThread.java:102) Caused by: java.io.IOException: unexpected exception type at java.io.ObjectStreamClass.throwMiscException(ObjectStreamClass.java:1538) at java.io.ObjectStreamClass.invokeReadResolve(ObjectStreamClass.java:1110) at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1810) at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) at java.io.ObjectInputStream.readArray(ObjectInputStream.java:1707) at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1345) at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:1993) at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1918) at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801) at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) at java.io.ObjectInputStream.readArray(ObjectInputStream.java:1707) at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1345) at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:1993) at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1918) at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801) at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) at java.io.ObjectInputStream.readObject(ObjectInputStream.java:371) at com.hazelcast.jet.impl.execution.init.CustomClassLoadedObject$Serializer.read(CustomClassLoadedObject.java:104) at com.hazelcast.jet.impl.execution.init.CustomClassLoadedObject$Serializer.read(CustomClassLoadedObject.java:85) at com.hazelcast.internal.serialization.impl.StreamSerializerAdapter.read(StreamSerializerAdapter.java:48) at com.hazelcast.internal.serialization.impl.AbstractSerializationService.readObject(AbstractSerializationService.java:266) ... 24 more Caused by: java.lang.reflect.InvocationTargetException at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:483) at java.lang.invoke.SerializedLambda.readResolve(SerializedLambda.java:230) at sun.reflect.GeneratedMethodAccessor1.invoke(Unknown Source) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:483) at java.io.ObjectStreamClass.invokeReadResolve(ObjectStreamClass.java:1104) ... 43 more Caused by: java.lang.IllegalArgumentException: Invalid lambda deserialization at WordCount.$deserializeLambda$(WordCount.java:1) ... 52 more

Feb 23, 2017 4:04:17 PM com.hazelcast.jet.impl.operation.ExecuteJobOperation INFO: [10.162.55.6]:5701 [jet] [0.3] [3.8-RC1] Execution of job 0 completed in 412ms. Feb 23, 2017 4:04:17 PM com.hazelcast.core.LifecycleService INFO: [10.162.55.6]:5701 [jet] [0.3] [3.8-RC1] [10.162.55.6]:5701 is SHUTTING_DOWN Feb 23, 2017 4:04:17 PM com.hazelcast.internal.partition.impl.MigrationManager INFO: [10.162.55.6]:5701 [jet] [0.3] [3.8-RC1] Shutdown request of [10.162.55.6]:5701 is handled Feb 23, 2017 4:04:17 PM com.hazelcast.internal.partition.impl.MigrationManager INFO: [10.162.55.6]:5701 [jet] [0.3] [3.8-RC1] Re-partitioning cluster data... Migration queue size: 135 Feb 23, 2017 4:04:18 PM com.hazelcast.instance.Node INFO: [10.162.55.6]:5701 [jet] [0.3] [3.8-RC1] Shutting down multicast service... Feb 23, 2017 4:04:18 PM com.hazelcast.internal.cluster.ClusterService INFO: [10.162.55.6]:5703 [jet] [0.3] [3.8-RC1] Old master [10.162.55.6]:5701 left the cluster, assigning new master Member [10.162.55.6]:5703 - 4ad40f05-f147-4839-9272-4d9968d9466c this Feb 23, 2017 4:04:18 PM com.hazelcast.nio.tcp.TcpIpConnection INFO: [10.162.55.6]:5703 [jet] [0.3] [3.8-RC1] Connection[id=1, /10.162.55.6:49760->/10.162.55.6:5701, endpoint=[10.162.55.6]:5701, alive=false, type=MEMBER] closed. Reason: Removing member [10.162.55.6]:5701, uuid: 642563f8-8abf-4cbb-9290-7b131a5bb84d, requested by: [10.162.55.6]:5701 Feb 23, 2017 4:04:18 PM com.hazelcast.instance.Node INFO: [10.162.55.6]:5701 [jet] [0.3] [3.8-RC1] Shutting down connection manager... Feb 23, 2017 4:04:18 PM com.hazelcast.nio.tcp.TcpIpConnection INFO: [10.162.55.6]:5701 [jet] [0.3] [3.8-RC1] Connection[id=1, /10.162.55.6:5701->/10.162.55.6:49760, endpoint=[10.162.55.6]:5703, alive=false, type=MEMBER] closed. Reason: TcpIpConnectionManager is stopping Feb 23, 2017 4:04:18 PM com.hazelcast.internal.cluster.ClusterService INFO: [10.162.55.6]:5703 [jet] [0.3] [3.8-RC1] Removing Member [10.162.55.6]:5701 - 642563f8-8abf-4cbb-9290-7b131a5bb84d Feb 23, 2017 4:04:18 PM com.hazelcast.internal.cluster.ClusterService INFO: [10.162.55.6]:5703 [jet] [0.3] [3.8-RC1]

Members [1] { Member [10.162.55.6]:5703 - 4ad40f05-f147-4839-9272-4d9968d9466c this }

Feb 23, 2017 4:04:18 PM com.hazelcast.transaction.TransactionManagerService INFO: [10.162.55.6]:5703 [jet] [0.3] [3.8-RC1] Committing/rolling-back alive transactions of Member [10.162.55.6]:5701 - 642563f8-8abf-4cbb-9290-7b131a5bb84d, UUID: 642563f8-8abf-4cbb-9290-7b131a5bb84d Feb 23, 2017 4:04:18 PM com.hazelcast.instance.Node INFO: [10.162.55.6]:5701 [jet] [0.3] [3.8-RC1] Shutting down node engine... Feb 23, 2017 4:04:18 PM com.hazelcast.instance.NodeExtension INFO: [10.162.55.6]:5701 [jet] [0.3] [3.8-RC1] Destroying node NodeExtension. Feb 23, 2017 4:04:18 PM com.hazelcast.instance.Node INFO: [10.162.55.6]:5701 [jet] [0.3] [3.8-RC1] Hazelcast Shutdown is completed in 1099 ms. Feb 23, 2017 4:04:18 PM com.hazelcast.core.LifecycleService INFO: [10.162.55.6]:5701 [jet] [0.3] [3.8-RC1] [10.162.55.6]:5701 is SHUTDOWN Feb 23, 2017 4:04:18 PM com.hazelcast.core.LifecycleService INFO: [10.162.55.6]:5703 [jet] [0.3] [3.8-RC1] [10.162.55.6]:5703 is SHUTTING_DOWN Feb 23, 2017 4:04:18 PM com.hazelcast.internal.partition.impl.MigrationManager INFO: [10.162.55.6]:5703 [jet] [0.3] [3.8-RC1] Shutdown request of [10.162.55.6]:5703 is handled Feb 23, 2017 4:04:18 PM com.hazelcast.internal.partition.InternalPartitionService INFO: [10.162.55.6]:5703 [jet] [0.3] [3.8-RC1] Fetching most recent partition table! my version: 949 Feb 23, 2017 4:04:18 PM com.hazelcast.internal.partition.InternalPartitionService INFO: [10.162.55.6]:5703 [jet] [0.3] [3.8-RC1] Most recent partition table version: 949 Feb 23, 2017 4:04:18 PM com.hazelcast.instance.Node INFO: [10.162.55.6]:5703 [jet] [0.3] [3.8-RC1] Shutting down multicast service... Feb 23, 2017 4:04:18 PM com.hazelcast.instance.Node INFO: [10.162.55.6]:5703 [jet] [0.3] [3.8-RC1] Shutting down connection manager... Feb 23, 2017 4:04:18 PM com.hazelcast.instance.Node INFO: [10.162.55.6]:5703 [jet] [0.3] [3.8-RC1] Shutting down node engine... Feb 23, 2017 4:04:19 PM com.hazelcast.instance.NodeExtension INFO: [10.162.55.6]:5703 [jet] [0.3] [3.8-RC1] Destroying node NodeExtension. Feb 23, 2017 4:04:19 PM com.hazelcast.instance.Node INFO: [10.162.55.6]:5703 [jet] [0.3] [3.8-RC1] Hazelcast Shutdown is completed in 1126 ms. Feb 23, 2017 4:04:19 PM com.hazelcast.core.LifecycleService INFO: [10.162.55.6]:5703 [jet] [0.3] [3.8-RC1] [10.162.55.6]:5703 is SHUTDOWN Exception in thread "main" java.util.concurrent.ExecutionException: com.hazelcast.nio.serialization.HazelcastSerializationException: java.io.IOException: unexpected exception type at com.hazelcast.spi.impl.operationservice.impl.InvocationFuture.resolveAndThrowIfException(InvocationFuture.java:88) at com.hazelcast.spi.impl.AbstractInvocationFuture.get(AbstractInvocationFuture.java:155) at WordCount.go(WordCount.java:151) at WordCount.main(WordCount.java:143) Caused by: com.hazelcast.nio.serialization.HazelcastSerializationException: java.io.IOException: unexpected exception type at com.hazelcast.internal.serialization.impl.SerializationUtil.handleException(SerializationUtil.java:61) at com.hazelcast.internal.serialization.impl.AbstractSerializationService.readObject(AbstractSerializationService.java:272) at com.hazelcast.internal.serialization.impl.ByteArrayObjectDataInput.readObject(ByteArrayObjectDataInput.java:599) at com.hazelcast.jet.impl.execution.init.CustomClassLoadedObject.read(CustomClassLoadedObject.java:54) at com.hazelcast.jet.impl.execution.init.VertexDef.readData(VertexDef.java:108) at com.hazelcast.internal.serialization.impl.DataSerializableSerializer.readInternal(DataSerializableSerializer.java:156) at com.hazelcast.internal.serialization.impl.DataSerializableSerializer.read(DataSerializableSerializer.java:104) at com.hazelcast.internal.serialization.impl.DataSerializableSerializer.read(DataSerializableSerializer.java:49) at com.hazelcast.internal.serialization.impl.StreamSerializerAdapter.read(StreamSerializerAdapter.java:48) at com.hazelcast.internal.serialization.impl.AbstractSerializationService.readObject(AbstractSerializationService.java:266) at com.hazelcast.internal.serialization.impl.ByteArrayObjectDataInput.readObject(ByteArrayObjectDataInput.java:599) at com.hazelcast.jet.impl.util.Util.readList(Util.java:136) at com.hazelcast.jet.impl.execution.init.ExecutionPlan.readData(ExecutionPlan.java:202) at com.hazelcast.internal.serialization.impl.DataSerializableSerializer.readInternal(DataSerializableSerializer.java:156) at com.hazelcast.internal.serialization.impl.DataSerializableSerializer.read(DataSerializableSerializer.java:104) at com.hazelcast.internal.serialization.impl.DataSerializableSerializer.read(DataSerializableSerializer.java:49) at com.hazelcast.internal.serialization.impl.StreamSerializerAdapter.read(StreamSerializerAdapter.java:48) at com.hazelcast.internal.serialization.impl.AbstractSerializationService.toObject(AbstractSerializationService.java:184) at com.hazelcast.jet.impl.execution.init.CustomClassLoadedObject.deserializeWithCustomClassLoader(CustomClassLoadedObject.java:61) at com.hazelcast.jet.impl.operation.InitOperation.lambda$readInternal$1(InitOperation.java:71) at com.hazelcast.jet.impl.operation.InitOperation$$Lambda$141/852682394.get(Unknown Source) at com.hazelcast.jet.impl.operation.InitOperation.run(InitOperation.java:49) at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:186) at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:401) at com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.process(OperationThread.java:117) at com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.run(OperationThread.java:102) at ------ submitted from ------.(Unknown Source) at com.hazelcast.spi.impl.operationservice.impl.InvocationFuture.resolve(InvocationFuture.java:114) at com.hazelcast.spi.impl.AbstractInvocationFuture$1.run(AbstractInvocationFuture.java:243) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745) at com.hazelcast.util.executor.HazelcastManagedThread.executeRun(HazelcastManagedThread.java:76) at com.hazelcast.util.executor.HazelcastManagedThread.run(HazelcastManagedThread.java:92) at ------ submitted from ------.(Unknown Source) at com.hazelcast.spi.impl.operationservice.impl.InvocationFuture.resolve(InvocationFuture.java:114) at com.hazelcast.spi.impl.operationservice.impl.InvocationFuture.resolveAndThrowIfException(InvocationFuture.java:75) ... 3 more Caused by: java.io.IOException: unexpected exception type at java.io.ObjectStreamClass.throwMiscException(ObjectStreamClass.java:1538) at java.io.ObjectStreamClass.invokeReadResolve(ObjectStreamClass.java:1110) at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1810) at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) at java.io.ObjectInputStream.readArray(ObjectInputStream.java:1707) at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1345) at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:1993) at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1918) at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801) at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) at java.io.ObjectInputStream.readArray(ObjectInputStream.java:1707) at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1345) at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:1993) at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1918) at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801) at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) at java.io.ObjectInputStream.readObject(ObjectInputStream.java:371) at com.hazelcast.jet.impl.execution.init.CustomClassLoadedObject$Serializer.read(CustomClassLoadedObject.java:104) at com.hazelcast.jet.impl.execution.init.CustomClassLoadedObject$Serializer.read(CustomClassLoadedObject.java:85) at com.hazelcast.internal.serialization.impl.StreamSerializerAdapter.read(StreamSerializerAdapter.java:48) at com.hazelcast.internal.serialization.impl.AbstractSerializationService.readObject(AbstractSerializationService.java:266) at com.hazelcast.internal.serialization.impl.ByteArrayObjectDataInput.readObject(ByteArrayObjectDataInput.java:599) at com.hazelcast.jet.impl.execution.init.CustomClassLoadedObject.read(CustomClassLoadedObject.java:54) at com.hazelcast.jet.impl.execution.init.VertexDef.readData(VertexDef.java:108) at com.hazelcast.internal.serialization.impl.DataSerializableSerializer.readInternal(DataSerializableSerializer.java:156) at com.hazelcast.internal.serialization.impl.DataSerializableSerializer.read(DataSerializableSerializer.java:104) at com.hazelcast.internal.serialization.impl.DataSerializableSerializer.read(DataSerializableSerializer.java:49) at com.hazelcast.internal.serialization.impl.StreamSerializerAdapter.read(StreamSerializerAdapter.java:48) at com.hazelcast.internal.serialization.impl.AbstractSerializationService.readObject(AbstractSerializationService.java:266) at com.hazelcast.internal.serialization.impl.ByteArrayObjectDataInput.readObject(ByteArrayObjectDataInput.java:599) at com.hazelcast.jet.impl.util.Util.readList(Util.java:136) at com.hazelcast.jet.impl.execution.init.ExecutionPlan.readData(ExecutionPlan.java:202) at com.hazelcast.internal.serialization.impl.DataSerializableSerializer.readInternal(DataSerializableSerializer.java:156) at com.hazelcast.internal.serialization.impl.DataSerializableSerializer.read(DataSerializableSerializer.java:104) at com.hazelcast.internal.serialization.impl.DataSerializableSerializer.read(DataSerializableSerializer.java:49) at com.hazelcast.internal.serialization.impl.StreamSerializerAdapter.read(StreamSerializerAdapter.java:48) at com.hazelcast.internal.serialization.impl.AbstractSerializationService.toObject(AbstractSerializationService.java:184) at com.hazelcast.jet.impl.execution.init.CustomClassLoadedObject.deserializeWithCustomClassLoader(CustomClassLoadedObject.java:61) at com.hazelcast.jet.impl.operation.InitOperation.lambda$readInternal$1(InitOperation.java:71) at com.hazelcast.jet.impl.operation.InitOperation$$Lambda$141/852682394.get(Unknown Source) at com.hazelcast.jet.impl.operation.InitOperation.run(InitOperation.java:49) at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:186) at com.hazelcast.spi.impl.operationservice.impl.OperationRunnerImpl.run(OperationRunnerImpl.java:401) at com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.process(OperationThread.java:117) at com.hazelcast.spi.impl.operationexecutor.impl.OperationThread.run(OperationThread.java:102) Caused by: java.lang.reflect.InvocationTargetException at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:483) at java.lang.invoke.SerializedLambda.readResolve(SerializedLambda.java:230) at sun.reflect.GeneratedMethodAccessor1.invoke(Unknown Source) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:483) at java.io.ObjectStreamClass.invokeReadResolve(ObjectStreamClass.java:1104) ... 43 more Caused by: java.lang.IllegalArgumentException: Invalid lambda deserialization at WordCount.$deserializeLambda$(WordCount.java:1) ... 52 more

mukul4u2005 commented 7 years ago

This is working fine if I start only one node, if there are two nodes cluster then it's throwing this exception.

viliam-durina commented 7 years ago

Have you compiled with Eclipse? It has known issues regarding lambda deserialization. Can you try to build with maven and run?

mukul4u2005 commented 7 years ago

Yes This was build issue due to checkstyle connector on eclipse.