lean>() {
> @Override
> public Boolean call(scala.Tuple2 t) {
> return (!t._2().isEmpty());
> }
> };
>
> The windowed operation is then:
>
> JavaPairDStream cdr_kv =
> cdr_filtered.reduceByKeyAndWindow(appendString, removeString,
> Durations.seconds(WINDOW_DURATIO
IDE_DURATION),
PARTITIONS, filterEmptyRecords);
After a few hours of operation, this function raises the following exception:
"Neither previous window has value for key, nor new values found. Are you sure
your key class hashes consistently?"
I've found this post from 2013:
https://
ds);
After a few hours of operation, this function raises the following
exception:
"Neither previous window has value for key, nor new values found. Are you
sure your key class hashes consistently?"
I've found this post from 2013:
https://groups.google.com/forum/#!msg/spark-use
