AW: AW: StreamingFileSink with ParquetAvroWriters

2021-01-15 Thread Jan Oelschlegel
Sorry, wrong build. It is not in the jar. Von: Jan Oelschlegel Gesendet: Freitag, 15. Januar 2021 12:52 An: Dawid Wysakowicz ; user@flink.apache.org Betreff: AW: AW: StreamingFileSink with ParquetAvroWriters Yes, after unzipping it is in the jar: [cid:image001.jpg@01D6EB3F.136D8560] Von

AW: AW: StreamingFileSink with ParquetAvroWriters

2021-01-15 Thread Jan Oelschlegel
Yes, after unzipping it is in the jar: [cid:image002.jpg@01D6EB3D.33BCC530] Von: Dawid Wysakowicz Gesendet: Freitag, 15. Januar 2021 12:10 An: Jan Oelschlegel ; user@flink.apache.org Betreff: Re: AW: StreamingFileSink with ParquetAvroWriters Have you checked if the class (org/apache/parquet

AW: StreamingFileSink with ParquetAvroWriters

2021-01-15 Thread Jan Oelschlegel
Hi Yun, thanks for your answer. I’m not very familiar with parquet and I expected it to be as easy as by using the Table-API of Flink. But obviously not 😊 Now the error is gone, but why do you choose this specific version? Can it be a newer one or older one? And now I got following error: org

Re: AW: StreamingFileSink with ParquetAvroWriters

2021-01-15 Thread Dawid Wysakowicz
Have you checked if the class (org/apache/parquet/avro/AvroParquetWriter) is in the jar that you are submitting. On 15/01/2021 12:05, Jan Oelschlegel wrote: > > Hi Dawid, > >   > > i used the official maven archetype for a Flink project based on scala > from here[1] > >   > > mvn archetype:generat

AW: StreamingFileSink with ParquetAvroWriters

2021-01-15 Thread Jan Oelschlegel
Hi Dawid, i used the official maven archetype for a Flink project based on scala from here[1] mvn archetype:generate \ -DarchetypeGroupId=org.apache.flink \ -DarchetypeArtifactId=flink-quickstart-scala \ -DarchetypeVersion=1.11.2 [1] https