stevenzwu commented on pull request #14595:
URL: https://github.com/apache/flink/pull/14595#issuecomment-778692513
@davidwys @sjwiesman I'd like to reopen this request. Now the additional
requirement is to retrieve `JobID` to trigger jobmanager failover. e.g.
https://github.com/apac
stevenzwu commented on pull request #14595:
URL: https://github.com/apache/flink/pull/14595#issuecomment-758870877
@sjwiesman thx. I should have looked into the iterator code first.
This is an automated message from the Apach
stevenzwu commented on pull request #14595:
URL: https://github.com/apache/flink/pull/14595#issuecomment-758765285
@davidwys yes, the motivation is to be able to cancel the job after a
certain number of elements. I didn't realize that closing the iterator from
CloseableIterator can cancel
stevenzwu commented on pull request #14595:
URL: https://github.com/apache/flink/pull/14595#issuecomment-757566603
Regarding the whitespace format change, I have run `mvn
com.diffplug.spotless:spotless-maven-plugin:apply` to verify
-
stevenzwu commented on pull request #14595:
URL: https://github.com/apache/flink/pull/14595#issuecomment-757065274
@flinkbot run azure
This is an automated message from the Apache Git Service.
To respond to the message, pleas
stevenzwu commented on pull request #14595:
URL: https://github.com/apache/flink/pull/14595#issuecomment-757065274
@flinkbot run azure
This is an automated message from the Apache Git Service.
To respond to the message, pleas
