damccorm opened a new issue, #21378:
URL: https://github.com/apache/beam/issues/21378
Got the following exception with spark runner and GroupIntoBatches transform:
Caused by: java.lang.UnsupportedOperationException: Canceling a timer by ID
is not yet supported.
at
org.apache.beam.runners.core.InMemoryTimerInternals.deleteTimer(InMemoryTimerInternals.java:158)
at
org.apache.beam.runners.core.SimpleDoFnRunner$TimerInternalsTimer.clear(SimpleDoFnRunner.java:1198)
at
org.apache.beam.sdk.transforms.GroupIntoBatches$GroupIntoBatchesDoFn.processElement(GroupIntoBatches.java:474)
The InMemoryTimerInternals.deleteTimer with a timeDomain is not supported:
public void deleteTimer(
StateNamespace namespace, String timerId, String timerFamilyId, TimeDomain
timeDomain) {
throw new UnsupportedOperationException("Canceling a timer by ID is not yet
supported.");
}
However, this function is called by
SimpleDoFnRunner$TimerInternalsTimer.clear:
public void clear() {
this.timerInternals.deleteTimer(this.namespace, this.timerId,
this.timerFamilyId, this.spec.getTimeDomain());
}
Which is called by GroupIntoBatches$GroupIntoBatchesDoFn.processElement.
Imported from Jira
[BEAM-14018](https://issues.apache.org/jira/browse/BEAM-14018). Original Jira
may contain additional context.
Reported by: wenqing.yang.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
