flinkx yarn-per-job提交异常
- 主要言語
- Java
- スター
- 4.1k
- フォーク
- 1.7k
- PR マージ指標
- 30日以内にマージされた PR はありません
説明
当前环境standalone，yarn-session模式都可以正确提交运行任务，在执行yarn-per-job模式时提示com.dtstack.flinkx.sink.format.BaseRichOutputFormat; local class incompatible: stream classdesc serialVersionUID = 3881343828446844740, local class serialVersionUID = 5581361262466724234
以下是异常日志截图和日志文件
[application_1648013223986_0032.log](https://github.com/DTStack/chunjun/files/8348136/application_1648013223986_0032.log)
[nohup.log](https://github.com/DTStack/chunjun/files/8348147/nohup.log)
コントリビューションガイド
調査の方向性
まず application_1648013223986_0032.log と nohup.log を読み、次に、成功した standalone と yarn-session のサブミッションを、issue に記載されている失敗した yarn-per-job の実行と比較します。報告された環境でサブミッションを再現し、BaseRichOutputFormat の serialVersionUID の不一致を追跡します。原因を特定し、yarn-per-job のサブミッションがこの非互換性なしで実行されることを確認できれば完了です。
索引モデルが issue の本文から書いたものです。
評価
- 技術スタック
- java
- 領域
- data-engineering, distributed-systems
- issue の種類
- バグ
- 難易度
- 4/5
- 見積もり時間
- 3〜5日
- 活発さ
- 停滞
- 明瞭さ
- 説明が足りない
- 初心者へのやさしさ
- 25/100