flinkcdc mysql DataStream API 問題解析
根據(jù)描述的代碼和問題，可能存在以下問題：
-
版本不匹配：
- flink 的版本（1.15.1）與使用的 Flink CDC 聲明的版本（2.1.1）不匹配。應(yīng)該使用與 Flink CDC 相對應(yīng)的 Flink 版本，即 1.13.6。
-
相關(guān) JAR 包不對應(yīng)：
- 除了驅(qū)動程序之外，F(xiàn)link CDC 所依賴的 JAR 包的版本也需要與聲明的版本一致。因此，應(yīng)該將 ide 中依賴的非 Flink JAR 包（例如阿里巴巴的 FastJSON）復(fù)制到 Flink 的 lib 目錄（%FLINK_HOME%/lib）中，并確保版本與 Flink CDC 需要的版本相符。
修復(fù)以上問題后，代碼才能正常運行。
? 版權(quán)聲明
文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載。
THE END
