All, It sounds like https://issues.apache.org/jira/browse/KAFKA-4725 is a regression in an earlier release and worth fixing. I've marked it blocker for 0.10.2.0. I'll plan to roll a new RC once it is committed (some stress testing of the one-line patch is currently ongoing).
-Ewen On Fri, Feb 3, 2017 at 3:35 PM, Vahid S Hashemian <vahidhashem...@us.ibm.com > wrote: > Hi Ewen, > > I tested the quickstart with this release candidate on Ubuntu, Windows (32 > and 64 bit) and Mac. > Everything looks good, except for one issue on Windows 7 32 bit when > running the WordCount demo application from the Kafka Streams step. > > Running that command gave me this error, and as a result, no data was > written to the output topic: > > [2017-02-03 14:11:23,444] WARN Unexpected state transition from > ASSIGNING_PARTITIONS to NOT_RUNNING > (org.apache.kafka.streams.processor.internals.StreamThread) > Exception in thread "StreamThread-1" java.lang.ExceptionInInitializerError > at org.rocksdb.RocksDB.loadLibrary(RocksDB.java:64) > at org.rocksdb.RocksDB.<clinit>(RocksDB.java:35) > at org.rocksdb.Options.<clinit>(Options.java:22) > at > org.apache.kafka.streams.state.internals.RocksDBStore. > openDB(RocksDBStore.java:115) > at > org.apache.kafka.streams.state.internals.RocksDBStore. > init(RocksDBStore.java:148) > at > org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStor > e.init(ChangeLoggingKeyValueBytesStore.java:39) > at > org.apache.kafka.streams.state.internals.MeteredKeyValueStore$7.run( > MeteredKeyValueStore.java:100) > at > org.apache.kafka.streams.processor.internals.StreamsMetricsImpl. > measureLatencyNs(StreamsMetricsImpl.java:188) > at > org.apache.kafka.streams.state.internals.MeteredKeyValueStore.init( > MeteredKeyValueStore.java:131) > at > org.apache.kafka.streams.state.internals.CachingKeyValueStore.init( > CachingKeyValueStore.java:62) > at > org.apache.kafka.streams.processor.internals.AbstractTask. > initializeStateStores(AbstractTask.java:86) > at > org.apache.kafka.streams.processor.internals.StreamTask.<init>(StreamTask. > java:141) > at > org.apache.kafka.streams.processor.internals. > StreamThread.createStreamTask(StreamThread.java:834) > at > org.apache.kafka.streams.processor.internals.StreamThread$TaskCreator. > createTask(StreamThread.java:1207) > at > org.apache.kafka.streams.processor.internals.StreamThread$ > AbstractTaskCreator.retryWithBackoff(StreamThread.java:1180) > at > org.apache.kafka.streams.processor.internals.StreamThread.addStreamTasks( > StreamThread.java:937) > at > org.apache.kafka.streams.processor.internals.StreamThread.access$500( > StreamThread.java:69) > at > org.apache.kafka.streams.processor.internals.StreamThread$1. > onPartitionsAssigned(StreamThread.java:236) > at > org.apache.kafka.clients.consumer.internals.ConsumerCoordinator. > onJoinComplete(ConsumerCoordinator.java:255) > at > org.apache.kafka.clients.consumer.internals.AbstractCoordinator. > joinGroupIfNeeded(AbstractCoordinator.java:339) > at > org.apache.kafka.clients.consumer.internals.AbstractCoordinator. > ensureActiveGroup(AbstractCoordinator.java:303) > at > org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll( > ConsumerCoordinator.java:286) > at > org.apache.kafka.clients.consumer.KafkaConsumer. > pollOnce(KafkaConsumer.java:1030) > at > org.apache.kafka.clients.consumer.KafkaConsumer.poll( > KafkaConsumer.java:995) > at > org.apache.kafka.streams.processor.internals.StreamThread.runLoop( > StreamThread.java:582) > at > org.apache.kafka.streams.processor.internals. > StreamThread.run(StreamThread.java:368) > Caused by: java.lang.UnsupportedOperationException > at > org.rocksdb.util.Environment.getJniLibraryName(Environment.java:48) > at > org.rocksdb.NativeLibraryLoader.<clinit>(NativeLibraryLoader.java:19) > ... 26 more > [2017-02-03 14:11:26,319] WARN Unexpected state transition from > NOT_RUNNING to PENDING_SHUTDOWN > (org.apache.kafka.streams.processor.internals.StreamThread) > > > This step worked fine on the other environments. I'm not sure if it is due > to a bug, or it's isolated to my test environment. > > --Vahid > > > > > From: Ewen Cheslack-Postava <e...@confluent.io> > To: dev@kafka.apache.org, "us...@kafka.apache.org" > <us...@kafka.apache.org>, "kafka-clie...@googlegroups.com" > <kafka-clie...@googlegroups.com> > Date: 02/01/2017 03:45 PM > Subject: [VOTE] 0.10.2.0 RC0 > > > > Hello Kafka users, developers and client-developers, > > This is the first candidate for release of Apache Kafka 0.10.2.0. > > This is a minor version release of Apache Kafka. It includes 19 new KIPs. > See the release notes and release plan ( > https://cwiki.apache.org/confluence/display/KAFKA/Release+Plan+0.10.2.0) > for more details. A few feature highlights: SASL-SCRAM support, improved > client compatibility to allow use of clients newer than the broker, > session > windows and global tables in the Kafka Streams API, single message > transforms in the Kafka Connect framework. > > Release notes for the 0.10.2.0 release: > http://home.apache.org/~ewencp/kafka-0.10.2.0-rc0/RELEASE_NOTES.html > > *** Please download, test and vote by Monday February 6th 5pm PST *** > (Note the longer window to vote to account for the normal 7 days ending in > the middle of the weekend.) > > Kafka's KEYS file containing PGP keys we use to sign the release: > http://kafka.apache.org/KEYS > > * Release artifacts to be voted upon (source and binary): > http://home.apache.org/~ewencp/kafka-0.10.2.0-rc0/ > > * Maven artifacts to be voted upon: > https://repository.apache.org/content/groups/staging/ > > * Javadoc: > http://home.apache.org/~ewencp/kafka-0.10.2.0-rc0/javadoc/ > > * Tag to be voted upon (off 0.10.2 branch) is the 0.10.2.0 tag: > https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=tag;h= > 33ebac1f138f17b86002df05e55a9f5cff47f48a > > > > * Documentation: > http://kafka.apache.org/0102/documentation.html > > * Protocol: > http://kafka.apache.org/0102/protocol.html > > * Successful Jenkins builds for the 0.10.2 branch: > Unit/integration tests: > https://builds.apache.org/job/kafka-0.10.2-jdk7/60/ > System tests: > https://jenkins.confluent.io/job/system-test-kafka-branch-builder/697 > > Thanks, > Ewen Cheslack-Postava > > > > >
