1

我正在使用 spark-cassandra-connector 通过 cassandra 表中的 spark 执行一些分析。一切正常,直到我将我的一个文本文件更改为时间戳字段。一旦我完成它给我一个错误

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