https://community.cloudera.com/t5/Support-Questions/Failed-to-write-to-HDFS-due-to-java-lang/m-p/270015#M207229 <P>Unable to persist merged avro fiels to HDFS using PutHDFS processor in nifi with compression codec as 'SNAPPY'. Getting below exception.</P> <P>&nbsp;</P> <P class="p1"><SPAN class="s1">o.apache.nifi.processors.hadoop.PutHDFS PutHDFS[id=cc59cc35-87b1-3868-8e40-a311596c48d2] Failed to write to HDFS due to java.lang.UnsatisfiedLinkError: org.apache.hadoop.util.NativeCodeLoader.buildSupportsSnappy()Z: java.lang.UnsatisfiedLinkError: org.apache.hadoop.util.NativeCodeLoader.buildSupportsSnappy()Z</SPAN></P> <P class="p1"><SPAN class="s1">java.lang.UnsatisfiedLinkError: org.apache.hadoop.util.NativeCodeLoader.buildSupportsSnappy()Z</SPAN></P> <P class="p1"><SPAN class="s1">at org.apache.hadoop.util.NativeCodeLoader.buildSupportsSnappy(Native Method)</SPAN></P> <P class="p1"><SPAN class="s1">at org.apache.hadoop.io.compress.SnappyCodec.checkNativeCodeLoaded(SnappyCodec.java:63)</SPAN></P> <P class="p1"><SPAN class="s1">at org.apache.hadoop.io.compress.SnappyCodec.getCompressorType(SnappyCodec.java:136)</SPAN></P> <P class="p1"><SPAN class="s1">at org.apache.hadoop.io.compress.CodecPool.getCompressor(CodecPool.java:150)</SPAN></P> <P class="p1"><SPAN class="s1">at org.apache.hadoop.io.compress.CompressionCodec$Util.createOutputStreamWithCodecPool(CompressionCodec.java:131)</SPAN></P> <P class="p1"><SPAN class="s1">at org.apache.hadoop.io.compress.SnappyCodec.createOutputStream(SnappyCodec.java:102)</SPAN></P> <P class="p1"><SPAN class="s1">at org.apache.nifi.processors.hadoop.PutHDFS$1$1.process(PutHDFS.java:318)</SPAN></P> <P class="p1"><SPAN class="s1">at org.apache.nifi.controller.repository.StandardProcessSession.read(StandardProcessSession.java:2235)</SPAN></P> <P class="p1"><SPAN class="s1">at org.apache.nifi.controller.repository.StandardProcessSession.read(StandardProcessSession.java:2203)</SPAN></P> <P class="p1"><SPAN class="s1">at org.apache.nifi.processors.hadoop.PutHDFS$1.run(PutHDFS.java:305)</SPAN></P> <P class="p1"><SPAN class="s1">at java.security.AccessController.doPrivileged(Native Method)</SPAN></P> <P class="p1"><SPAN class="s1">at javax.security.auth.Subject.doAs(Subject.java:360)</SPAN></P> <P class="p1"><SPAN class="s1">at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1942)</SPAN></P> <P class="p1"><SPAN class="s1">at org.apache.nifi.processors.hadoop.PutHDFS.onTrigger(PutHDFS.java:235)</SPAN></P> <P class="p1"><SPAN class="s1">at org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)</SPAN></P> <P class="p1"><SPAN class="s1">at org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1165)</SPAN></P> <P class="p1"><SPAN class="s1">at org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:203)</SPAN></P> <P class="p1"><SPAN class="s1">at org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:117)</SPAN></P> <P class="p1"><SPAN class="s1">at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)</SPAN></P> <P class="p1"><SPAN class="s1">at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)</SPAN></P> <P class="p1"><SPAN class="s1">at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)</SPAN></P> <P class="p1"><SPAN class="s1">at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)</SPAN></P> <P class="p1"><SPAN class="s1">at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)</SPAN></P> <P class="p1"><SPAN class="s1">at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)</SPAN></P> <P class="p1"><SPAN class="s1">at java.lang.Thread.run(Thread.java:748)</SPAN></P> Mon, 09 Sep 2019 13:20:36 GMT harikumar_0810_ 2019-09-09T13:20:36Z