xiamuyingu

I submited a FlinkSQL project which receive data from kafka and write print table. It works. I submited a FlinkSQL project which receive data from kafka and write hdfs table....

I found probable cause. I moved flink-shaded-hadoop-3-uber-3.1.1.7.2.9.0-173-9.0.jar to directory /streampark/lib, and when I execute startup.sh, the error happened. I moved flink-shaded-hadoop-3-uber-3.1.1.7.2.9.0-173-9.0.jar out from directory /streampark/lib, and when I execute startup.sh,...