Thanks @caizhi , let me look this
On Monday, September 13, 2021, 10:24:03 PM EDT, Caizhi Weng
wrote:
Hi!
This seems to be caused by some mismatching types in your source definition and
your workflow. If possible could you describe the schema of your Kafka source
and paste your datast
Hi!
This seems to be caused by some mismatching types in your source definition
and your workflow. If possible could you describe the schema of your Kafka
source and paste your datastream / Table / SQL code here?
Dhiru 于2021年9月14日周二 上午3:49写道:
> *I am not sure when we try to receive data from Ap
I am not sure when we try to receive data from Apache Kafka I get this error ,
but works good for me when I try to run via Conflunece kafka
java.lang.ClassCastException: class java.lang.String cannot be cast to class
scala.Product (java.lang.String is in module java.base of loader 'bootstrap';