flink1.10 提交java sql ddl程序異常

  flink1.10對ddl這塊支持比較完善,最近用java寫了個ddl kafka的demo測試。在ide本地環境中執行沒有問題,但將任務打包提交的flink 集羣時提交就報錯,無法執行,異常如下:  看異常好像是ddl寫錯了,本地運行正常,說明沒有問題。使用flink sql-client客戶端測試報一樣的錯,flink lib下沒有對應的包,將包放到lib下,使用sql-client執行正
相關文章
相關標籤/搜索