問題タブ [flinkml]
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.
28 問題
0
投票する
1
に答える
252
参照
scala - Flink: エラー解析の数値形式
Zeppelin を使用して、Flink (Scala) で K-means モデルを開発しようとしています。これは私の簡単なコードの一部です:
データを印刷するか、予測メソッドを使用すると、次のエラーが発生しました:
データをロードしたのが私のせいなのか、それともそのようなものに関連しているのかはわかりません。
助けてくれてありがとう！:)
0
投票する
1
に答える
721
参照
java - Flink ウィンドウと折り畳み機能を使用すると、要素が欠落していますか?
ウィンドウとフォールド関数を使用して要素を集約しようとすると、一部の要素が集約されません。Kafka からの要素を消費(value:0, value:1, value:2, value:3)し、それらを奇数および偶数の値として集計します。
出力は次のとおりです。
10 ～ 13 の数字が欠落しており、これはランダムな数字のセットで発生します。以下のコードで何が欠けているか、またすべての要素を確実に処理するにはどうすればよいか、誰かが提案できますか?