0熱
2答えて
には、dstream.checkpoint(checkpointInterval)とspark.streaming.receiver.writeAheadLog.enableの間のリンクがあります。
1熱
1答えて
デフォルトのpersist()は、シリアル化されていないオブジェクトとしてJVMヒープにデータを格納するのはなぜですか?
0熱
1答えて
1熱
1答えて
Python - 整数または文字列をスパークストリーミングに送信
-1熱
1答えて
java.lang.ClassNotFoundException:com.datastax.spark.connector.japi.rdd.CassandraTableScanJavaRDD
1熱
1答えて
FlinkとSparkStreamingのチェックポイントメカニズムの相違点
1熱
3答えて
0熱
1答えて
Sparkストリーミングチェックポイントの読み込み後のエラー