Skip to content

Commit d06f604

Browse files
committed
Revert "Update runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkGroupAlsoByWindowViaWindowSet.java"
This reverts commit 838cccd.
1 parent ba96c69 commit d06f604

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkGroupAlsoByWindowViaWindowSet.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -524,7 +524,7 @@ JavaDStream<WindowedValue<KV<K, Iterable<InputT>>>> groupByKeyAndWindow(
524524
pairDStream.updateStateByKey(
525525
// Raw cast to AbstractFunction1 suppresses Scala 2.12 (collection.Seq) vs
526526
// Scala 2.13 (immutable.Seq) type difference — safe at runtime due to erasure.
527-
(scala.Function2) updateFunc,
527+
(scala.runtime.AbstractFunction1) updateFunc,
528528
pairDStream.defaultPartitioner(pairDStream.defaultPartitioner$default$1()),
529529
true,
530530
JavaSparkContext$.MODULE$.fakeClassTag());

0 commit comments

Comments
 (0)