Re: Overwriting Flink Core InputStreamFactory

Hi! I see that you're submitting your job to Flink in a k8s environment. Could you explain in detail how do you submit your job? For example did you put your user jar under the lib directory and build a docker image from it? Flink regards user classes as higher priority ones, so adding the class

Overwriting Flink Core InputStreamFactory

I included the package org.apache.flink.api.common.io.compression in my intellij project and added the class GzipInflaterInputStreamFactory. The class just redefined the method `getCommonFileExtensions` to not recognize "gzip". I need this because of google cloud's transcoding