Hi guys,
I was trying to use flink sql to consume data from kafka source, the format of
which is debezium-avro-confluent. And I encountered a AvroTypeException saying
that "Found something, expecting union", where something is not a type but a
field that I defined in the schema registery.
So
Hi, yu'an:
Many thanks for your reply, it has been fixed :), it turns out to be related to
some local environmental settings.
Best regards,
Edwin
At 2022-03-03 15:58:43, "yu'an huang" wrote:
Hi Edwin,
I suddenly realised that I replied to you dire
Hi all,
I was trying to run flink-tpcds tests on flink v1.15-snapshot, and I added
"jobmanager.adaptive-batch-scheduler.default-source-parallelism: 8" along with
some other configurations to the conf yaml file to enable adaptive job
scheduler. But it turned out the source parallelism kept unch
Hi all,
I was trying to build flink source code by using mvn clean install -DskipTests
command, and it turned out report build failure and the following error info:
[ERROR] Failed to execute goal
org.apache.maven.plugins:maven-compiler-plugin:3.8.0:testCompile
(default-testCompile) on projec
