kl0u commented on issue #11307: [FLINK-16371] [BulkWriter] Fix Hadoop 
Compression BulkWriter
URL: https://github.com/apache/flink/pull/11307#issuecomment-596939522
 
 
   > Regarding the Integration test, I just wanted to add that the 
NotSerializableException is thrown during StreamingFileSink execution saying 
that the CompressionCodec implementation being used is a non serializable 
field. It doesn't say HadoopCompressionBulkWriter is non serializable. Is a 
separate IT required?
   
   @zenfenan You mean there is already a test failing with a 
`NotSerializableException ` or that when you run it with a job it fails? If 
there is already a test, could you point me to which one it is?

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


With regards,
Apache Git Services

Reply via email to