[ https://issues.apache.org/jira/browse/FLINK-9440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16501647#comment-16501647 ]
ASF GitHub Bot commented on FLINK-9440: --------------------------------------- Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6096#discussion_r193043954 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/ProcessOperator.java --- @@ -114,12 +114,22 @@ public long currentWatermark() { @Override public void registerProcessingTimeTimer(long time) { - throw new UnsupportedOperationException("Setting timers is only supported on a KeyedStream."); + throw new UnsupportedOperationException(UNSUPPORTED_REGISTER_TIMER_MSG); } @Override public void registerEventTimeTimer(long time) { - throw new UnsupportedOperationException("Setting timers is only supported on a KeyedStream."); + throw new UnsupportedOperationException(UNSUPPORTED_REGISTER_TIMER_MSG); + } + + @Override + public void deleteProcessingTimeTimer(long time) { + throw new UnsupportedOperationException(UNSUPPORTED_DELETE_TIMER_MSG); + } + + @Override + public void deleteEventTimeTimer(long time) { + throw new UnsupportedOperationException(UNSUPPORTED_DELETE_TIMER_MSG); } --- End diff -- https://issues.apache.org/jira/browse/FLINK-9529 > Allow cancelation and reset of timers > ------------------------------------- > > Key: FLINK-9440 > URL: https://issues.apache.org/jira/browse/FLINK-9440 > Project: Flink > Issue Type: Bug > Components: Streaming > Affects Versions: 1.4.2 > Reporter: Elias Levy > Assignee: Stefan Richter > Priority: Major > > Currently the {{TimerService}} allows one to register timers, but it is not > possible to delete a timer or to reset a timer to a new value. If one wishes > to reset a timer, one must also handle the previous inserted timer callbacks > and ignore them. > I would be useful if the API allowed one to remove and reset timers. -- This message was sent by Atlassian JIRA (v7.6.3#76005)