Hi,
I have *flink 1.19 *installation and start *sql-client locally*, like this:
*./bin/sql-client.sh*
then execute *SET 'table.sql-dialect' = 'hive'*;
and have this exception:
*[ERROR] Could not execute SQL statement.
Reason:java.lang.ClassNotFoundException: org.antlr.runtime.tree.Tree*
I'm
Hi Kafka users!
I have a legacy kafka cluster that hosts a topic of click stream events. Topic
is consumed by 10 instances of an app with the same consumer group. Sometimes I
see exception is logs of those consumers like this:
org.apache.kafka.common.protocol.types.SchemaException: Error
