問題タブ [dstream]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
107 問題
0
投票する
1
に答える
763
参照
python-3.x - 私の関数を呼び出すと、pyspark updateStateByKeyが失敗します
ステートフル ストリーミングのサンプル コードを実行しようとしていますが、エラーで失敗します。発生する理由を取得できません。
cloudera vm 5.13.3 上の 3.6 python を使用した Spark 2.3
実行オプション:
私のコードは次のとおりです。
ストリームは機能しており、ソケットをリッスンしていますが、端末アプリケーションで行を入力しようとすると失敗します
エラー：
おそらく根本的な原因は関数updatetotalcountにあります。変換updateStateByKey(updatetotalcount)にコメントすると、出力に結果が出力されます。
Pls のアドバイス、なぜこのエラーが発生するのですか?