flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gyula Fóra <gyf...@apache.org>
Subject Strange error in Kafka consumer
Date Thu, 21 Apr 2016 09:28:30 GMT
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

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message