Sandeep Kapoor created KAFKA-6888:
-------------------------------------

             Summary: java.lang.UnsatisfiedLinkError: 
librocksdbjni4271925274440341234.dll:  âÑX
                 Key: KAFKA-6888
                 URL: https://issues.apache.org/jira/browse/KAFKA-6888
             Project: Kafka
          Issue Type: Bug
          Components: streams
    Affects Versions: 1.1.0, 0.11.0.0
         Environment: Windows 7, Java 8, Kafka-Streams 1.1.0 and 0.11.0.0 
versions
            Reporter: Sandeep Kapoor


Hi Team,

I am Window 7 user and using *kafka-streams* 1.1.0 (Latest) version. When I am 
executing my code, I am getting the issue "StreamThread-1" 
**java.lang.UnsatisfiedLinkError:** 
*C:\Users\sandeep\AppData\Local\Temp\librocksdbjni4271925274440341234.dll:  
âÑX*". Earlier I was trying my code with 0.11.0.0 version, and was getting 
"*RocksDB on windows (librocksdbjni-win64.dll)- Can't find dependent 
libraries*". Then as per ([https://github.com/facebook/rocksdb/issues/1302)] 
thread I downloaded and installed **Visual C++ runtime for Visual Studio 2015** 
and upgraded  the kafka-stream version from 0.11.0.0 to 1.1.0. But still I am 
getting the same exception (java.lang.UnsatisfiedLinkError). Only thing changed 
is that instead of "Can't find dependent libraries" now I am getting  "âÑX" ( a 
strange expression).

Also I checked that in my maven dependencies I am using RocksDbJni version 
5.7.3 and it contains "librocksdbjni-win64.dll" file as well.

*Please find below the exception, I am getting (with kafka-streams version 
1.1.0) :*  -

Exception in thread 
"streams-starter-app-862326ca-30c0-468d-898c-e40d4578f1c7-StreamThread-1" 
java.lang.UnsatisfiedLinkError: 
C:\Users\sandeep\AppData\Local\Temp\librocksdbjni4271925274440341234.dll:  âÑX
     at java.lang.ClassLoader$NativeLibrary.load(Native Method)
     at java.lang.ClassLoader.loadLibrary0(ClassLoader.java:1929)
     at java.lang.ClassLoader.loadLibrary(ClassLoader.java:1814)
     at java.lang.Runtime.load0(Runtime.java:809)
     at java.lang.System.load(System.java:1083)
     at 
org.rocksdb.NativeLibraryLoader.loadLibraryFromJar(NativeLibraryLoader.java:78)
     at org.rocksdb.NativeLibraryLoader.loadLibrary(NativeLibraryLoader.java:56)
     at org.rocksdb.RocksDB.loadLibrary(RocksDB.java:64)
     at org.rocksdb.RocksDB.<clinit>(RocksDB.java:35)
     at org.rocksdb.Options.<clinit>(Options.java:25)
     at 
org.apache.kafka.streams.state.internals.RocksDBStore.openDB(RocksDBStore.java:116)
     at 
org.apache.kafka.streams.state.internals.RocksDBStore.init(RocksDBStore.java:167)
     at 
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStore.init(ChangeLoggingKeyValueBytesStore.java:40)
     at 
org.apache.kafka.streams.state.internals.CachingKeyValueStore.init(CachingKeyValueStore.java:63)
     at 
org.apache.kafka.streams.state.internals.InnerMeteredKeyValueStore.init(InnerMeteredKeyValueStore.java:160)
     at 
org.apache.kafka.streams.state.internals.MeteredKeyValueBytesStore.init(MeteredKeyValueBytesStore.java:102)
     at 
org.apache.kafka.streams.processor.internals.AbstractTask.registerStateStores(AbstractTask.java:225)
     at 
org.apache.kafka.streams.processor.internals.StreamTask.initializeStateStores(StreamTask.java:162)
     at 
org.apache.kafka.streams.processor.internals.AssignedTasks.initializeNewTasks(AssignedTasks.java:88)
     at 
org.apache.kafka.streams.processor.internals.TaskManager.updateNewAndRestoringTasks(TaskManager.java:316)
     at 
org.apache.kafka.streams.processor.internals.StreamThread.runOnce(StreamThread.java:789)
     at 
org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:750)
     at 
org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:720)
 INFO stream-client [streams-starter-app-862326ca-30c0-468d-898c-e40d4578f1c7] 
State transition from ERROR to PENDING_SHUTDOWN 
(org.apache.kafka.streams.KafkaStreams:261)

*Please find below the exception, (with kafka-streams version 0.11.0.0 and 
prior to installing "Visual C++ runtime for Visual Studio 2015") : -*

WARN stream-thread 
[streams-starter-app-4be266bc-fcc9-4c1e-93be-807e3736d6cb-StreamThread-1] 
Unexpected state transition from ASSIGNING_PARTITIONS to DEAD. 
(org.apache.kafka.streams.processor.internals.StreamThread:978) 
 INFO stream-client [streams-starter-app-4be266bc-fcc9-4c1e-93be-807e3736d6cb] 
State transition from REBALANCING to PENDING_SHUTDOWN. 
(org.apache.kafka.streams.KafkaStreams:229) 
 java.lang.UnsatisfiedLinkError: 
C:\Users\sandeep\AppData\Local\Temp\librocksdbjni6620964825573124271.dll: Can't 
find dependent libraries
     at java.lang.ClassLoader$NativeLibrary.load(Native Method)
     at java.lang.ClassLoader.loadLibrary0(ClassLoader.java:1929)
     at java.lang.ClassLoader.loadLibrary(ClassLoader.java:1814)
     at java.lang.Runtime.load0(Runtime.java:809)
     at java.lang.System.load(System.java:1083)
     at 
org.rocksdb.NativeLibraryLoader.loadLibraryFromJar(NativeLibraryLoader.java:78)
     at org.rocksdb.NativeLibraryLoader.loadLibrary(NativeLibraryLoader.java:56)
     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:121)
     at 
org.apache.kafka.streams.state.internals.RocksDBStore.init(RocksDBStore.java:173)
     at 
org.apache.kafka.streams.state.internals.ChangeLoggingKeyValueBytesStore.init(ChangeLoggingKeyValueBytesStore.java:40)
     at 
org.apache.kafka.streams.state.internals.MeteredKeyValueStore$7.run(MeteredKeyValueStore.java:99)
     at 
org.apache.kafka.streams.processor.internals.StreamsMetricsImpl.measureLatencyNs(StreamsMetricsImpl.java:187)
     at 
org.apache.kafka.streams.state.internals.MeteredKeyValueStore.init(MeteredKeyValueStore.java:130)
     at 
org.apache.kafka.streams.state.internals.CachingKeyValueStore.init(CachingKeyValueStore.java:58)
     at 
org.apache.kafka.streams.processor.internals.AbstractTask.initializeStateStores(AbstractTask.java:201)
     at 
org.apache.kafka.streams.processor.internals.StreamTask.<init>(StreamTask.java:140)
     at 
org.apache.kafka.streams.processor.internals.StreamThread.createStreamTask(StreamThread.java:1234)
     at 
org.apache.kafka.streams.processor.internals.StreamThread$TaskCreator.createTask(StreamThread.java:294)
     at 
org.apache.kafka.streams.processor.internals.StreamThread$AbstractTaskCreator.retryWithBackoff(StreamThread.java:254)
     at 
org.apache.kafka.streams.processor.internals.StreamThread.addStreamTasks(StreamThread.java:1313)
     at 
org.apache.kafka.streams.processor.internals.StreamThread.access$1100(StreamThread.java:73)
     at 
org.apache.kafka.streams.processor.internals.StreamThread$RebalanceListener.onPartitionsAssigned(StreamThread.java:183)
     at 
org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.onJoinComplete(ConsumerCoordinator.java:265)
     at 
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.joinGroupIfNeeded(AbstractCoordinator.java:363)
     at 
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:310)
     at 
org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:297)
     at 
org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1078)
     at 
org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1043)
     at 
org.apache.kafka.streams.processor.internals.StreamThread.pollRequests(StreamThread.java:582)
     at 
org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:553)
     at 
org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:527)
 INFO stream-thread 
[streams-starter-app-4be266bc-fcc9-4c1e-93be-807e3736d6cb-StreamThread-1] 
Informed thread to shut down 
(org.apache.kafka.streams.processor.internals.StreamThread:900) 
 WARN stream-thread 
[streams-starter-app-4be266bc-fcc9-4c1e-93be-807e3736d6cb-StreamThread-1] 
Unexpected state transition from DEAD to PENDING_SHUTDOWN. 
(org.apache.kafka.streams.processor.internals.StreamThread:978) 
 INFO stream-client [streams-starter-app-4be266bc-fcc9-4c1e-93be-807e3736d6cb] 
Stopped Kafka Streams process. (org.apache.kafka.streams.KafkaStreams:514) 
 INFO stream-client [streams-starter-app-4be266bc-fcc9-4c1e-93be-807e3736d6cb] 
State transition from PENDING_SHUTDOWN to NOT_RUNNING. 
(org.apache.kafka.streams.KafkaStreams:229)

I think, the bug(#1302) reported here in 
([https://github.com/facebook/rocksdb/issues/1302]) this thread is still not 
fixed. So, I am creating this issue as this is not listed in the current list 
of issues in apache site . Can you please provide some fix to this issue, as I 
am not able to proceed my first program in kafka-streams.

Thanks in advance.

With Regards,
 Sandeep Kapoor



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to