Druid batch ingestion issue

Hi,

I am facing below exception in Hadoop batch ingestion. Although I can see segment file created on Hdfs, the MR job doesn’t succeed with error.

Can anyone help me with this?

2018-12-27 06:45:44,863 INFO [main] io.druid.indexer.JobHelper: Creating new ZipEntry[00000.smoosh]
2018-12-27 06:45:48,041 INFO [main] io.druid.indexer.JobHelper: Creating new ZipEntry[version.bin]
2018-12-27 06:45:48,041 INFO [main] io.druid.indexer.JobHelper: Creating new ZipEntry[meta.smoosh]
2018-12-27 06:45:48,046 ERROR [main] io.druid.indexer.JobHelper: Exception in retry loop
java.io.IOException: Stream closed
	at org.apache.hadoop.crypto.CryptoOutputStream.checkStream(CryptoOutputStream.java:250)
	at org.apache.hadoop.crypto.CryptoOutputStream.flush(CryptoOutputStream.java:237)
	at java.io.FilterOutputStream.flush(FilterOutputStream.java:140)
	at java.io.DataOutputStream.flush(DataOutputStream.java:123)
	at io.druid.indexer.JobHelper$2.push(JobHelper.java:234)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:498)
	at org.apache.hadoop.io.retry.RetryInvocationHandler.invokeMethod(RetryInvocationHandler.java:258)
	at org.apache.hadoop.io.retry.RetryInvocationHandler.invoke(RetryInvocationHandler.java:104)
	at com.sun.proxy.$Proxy74.push(Unknown Source)
	at io.druid.indexer.JobHelper.serializeOutIndex(JobHelper.java:245)
	at io.druid.indexer.IndexGeneratorJob$IndexGeneratorReducer.reduce(IndexGeneratorJob.java:621)
	at io.druid.indexer.IndexGeneratorJob$IndexGeneratorReducer.reduce(IndexGeneratorJob.java:462)
	at org.apache.hadoop.mapreduce.Reducer.run(Reducer.java:171)
	at org.apache.hadoop.mapred.ReduceTask.runNewReducer(ReduceTask.java:627)
	at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:389)
	at org.apache.hadoop.mapred.YarnChild$2.run(YarnChild.java:168)
	at java.security.AccessController.doPrivileged(Native Method)
	at javax.security.auth.Subject.doAs(Subject.java:422)
	at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1724)