Hi Anitha,
As far as I can tell the problem is with avro itself. We upgraded avro
version we use underneath in Flink 1.12.0. In 1.11.x we used avro 1.8.2,
while starting from 1.12.x we use avro 1.10.0. Maybe that's the problem.
You could try to upgrading the avro version in your program. Just
Hi Piotr,
*The code i wrtten in 1.13.1*
public final class BigQuerySourceFunction extends
RichSourceFunction implements ResultTypeQueryable {
@Override
public void open(Configuration parameters) throws Exception {
deserializer.open(RuntimeContextInitializationContextAdapters.deserialization
Hey,
Could you be more specific about how it is not working? A compiler error
that there is no such class as RuntimeContextInitializationContextAdapters?
This class has been introduced in Flink 1.12 in FLINK-18363 [1]. I don't
know this code and I also don't know where it's documented, but:
a) may
Hi,
I developed a flink connector to read data from bigquery . The Bigquery
read rows are in AVRO format.
I tried it with 1.13.1 its working fine. But my requirement is 1.11.0, in
that case the code:
deserializer.open(RuntimeContextInitializationContextAdapters.deserializationAdapter(getRuntimeCon
