Hey, I have encountered a strange error in the kafka consumer. This only happened once in my local machine so far but just wanted to let you know.
java.lang.Exception: The periodic offset committer encountered an error: org/apache/flink/shaded/org/apache/curator/HandleHolder$2 at com.king.rbea.flink.functions.source.PeriodicOffsetCommitter.run(PeriodicOffsetCommitter.java:81) Caused by: java.lang.NoClassDefFoundError: org/apache/flink/shaded/org/apache/curator/HandleHolder$2 at org.apache.flink.shaded.org.apache.curator.HandleHolder.internalClose(HandleHolder.java:131) at org.apache.flink.shaded.org.apache.curator.HandleHolder.closeAndReset(HandleHolder.java:77) at org.apache.flink.shaded.org.apache.curator.ConnectionState.reset(ConnectionState.java:217) at org.apache.flink.shaded.org.apache.curator.ConnectionState.checkTimeouts(ConnectionState.java:193) at org.apache.flink.shaded.org.apache.curator.ConnectionState.getZooKeeper(ConnectionState.java:87) at org.apache.flink.shaded.org.apache.curator.CuratorZookeeperClient.getZooKeeper(CuratorZookeeperClient.java:115) at org.apache.flink.shaded.org.apache.curator.utils.EnsurePath$InitialHelper$1.call(EnsurePath.java:148) at org.apache.flink.shaded.org.apache.curator.RetryLoop.callWithRetry(RetryLoop.java:107) at org.apache.flink.shaded.org.apache.curator.utils.EnsurePath$InitialHelper.ensure(EnsurePath.java:141) at org.apache.flink.shaded.org.apache.curator.utils.EnsurePath.ensure(EnsurePath.java:99) at org.apache.flink.streaming.connectors.kafka.internals.ZookeeperOffsetHandler.setOffsetInZooKeeper(ZookeeperOffsetHandler.java:132) at org.apache.flink.streaming.connectors.kafka.internals.ZookeeperOffsetHandler.writeOffsets(ZookeeperOffsetHandler.java:91) at com.king.rbea.flink.functions.source.PeriodicOffsetCommitter.run(PeriodicOffsetCommitter.java:75) # # A fatal error has been detected by the Java Runtime Environment: # # SIGBUS (0xa) at pc=0x000000010bbe9eb9, pid=15341, tid=37635 # # JRE version: Java(TM) SE Runtime Environment (8.0_60-b27) (build 1.8.0_60-b27) # Java VM: Java HotSpot(TM) 64-Bit Server VM (25.60-b23 mixed mode bsd-amd64 compressed oops) # Problematic frame: # C [libzip.dylib+0x2eb9] newEntry+0x154 # # Failed to write core dump. Core dumps have been disabled. To enable core dumping, try "ulimit -c unlimited" before starting Java again # # An error report file with more information is saved as: # /Users/gyulafora/git/SPLAT/rbea-on-flink/hs_err_pid15341.log Compiled method (nm) 2980240 107 n 0 java.util.zip.ZipFile::getEntry (native) total in heap [0x000000010dcf8c90,0x000000010dcf8ff0] = 864 relocation [0x000000010dcf8db8,0x000000010dcf8df8] = 64 main code [0x000000010dcf8e00,0x000000010dcf8ff0] = 496 Cheers, Gyula
