Re: Writing to Avro from pyflink

2021-04-26 Thread Edward Yang
://issues.apache.org/jira/browse/FLINK-21012 > > Regards, > Dian > > 2021年4月25日 下午11:56,Edward Yang 写道: > > Hi Dian, > > I tried your suggestion but had the same error message unfortunately. I > also tried file:/ and file:// with the same error, not sure what's go

Re: Writing to Avro from pyflink

2021-04-25 Thread Edward Yang
nly need file:///{os.getcwd()}/lib/flink-sql-avro-1.12.2.jar > . Could you remove flink-avro-1.12.2.jar and avro-1.10.2.jar and try > again? > > Regards, > Dian > > 2021年4月24日 上午8:29,Edward Yang 写道: > > I've been trying to write to the avro format with pyflink 1.12.2

Writing to Avro from pyflink

2021-04-23 Thread Edward Yang
I've been trying to write to the avro format with pyflink 1.12.2 on ubuntu, I've tested my code with an iterator writing to csv and everything works as expected. Reading through the flink documentation I see that I should add jar dependencies to work with avro. I downloaded three jar files that I b