1

spark-cassandra-connector を使用して、cassandra テーブルで spark を介して分析を実行しています。テキストファイルの1つをタイムスタンプフィールドに変更するまで、すべてが正常に機能していました。私がそれをしたら、それは私にエラーを与えます

com.datastax.driver.core.exceptions.InvalidTypeException: Invalid 32-bits integer value, expecting 4 bytes but got 0

私のコードは次のとおりです。

JavaRDD<CassandraRow> rddd = functions.cassandraTable("test",
            "activity_log");
System.out.println("rddd--- "+rddd.toArray());

私のコードに問題はありますか?

4

0 に答える 0