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 with the same name and the same package in your project should do the trick. AG <goebel.aa...@gmail.com> 于2021年12月22日周三 03:38写道： > 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 > <https://cloud.google.com/storage/docs/transcoding> which I can't turn > off. Essentially flink see's a .gz file in my cloud bucket and wants to > read it as a gzip, but the google filesystem that gets called is reading it > as inflated and I get the error "Not in Gzip Format". > > I tried shading the jar and submitting on k8s but Flink fails to recognize > the new class. I'm wondering if there's a way to go about doing this that > doesn't require rebuilding Flink from scratch? > > Warm regards, > > Aaron > >
