Flink 1.13 with GCP Object storage

2022-06-29 Thread Krzysztof Chmielewski
Hi, I'm trying to read data from GCP Object Store with Flink's File source 1.13.6 I followed instruction from [1] But when I started my job on Flink cluster I have this exception: No FileSystem for scheme: gs Any ideas? Cheers [1] https://nightlies.apache.org/flink/flink-docs-release-1.13/docs

Re: Flink 1.13 with GCP Object storage

2022-06-29 Thread Krzysztof Chmielewski
Ok, the problem was that I had few conflicting versions of hadoop-common lib on class path. When I fix the dependencies, it start working. Cheers. śr., 29 cze 2022 o 18:20 Krzysztof Chmielewski < krzysiek.chmielew...@gmail.com> napisał(a): > Hi, > I'm trying to read data from GCP Object Store wi