yanghua commented on issue #6567: [FLINK-10074] Allowable number of checkpoint
failures
URL: https://github.com/apache/flink/pull/6567#issuecomment-434257204
@azagrebin OK, agree.
This is an automated message from the Apache
yanghua commented on issue #6567: [FLINK-10074] Allowable number of checkpoint
failures
URL: https://github.com/apache/flink/pull/6567#issuecomment-434220095
Hi @azagrebin I am currently busy with several other PRs and hope it will
be merged into Flink 1.7.0. When those PRs are fixed, I
yanghua commented on issue #6567: [FLINK-10074] Allowable number of checkpoint
failures
URL: https://github.com/apache/flink/pull/6567#issuecomment-423940208
@azagrebin thanks for your suggestion, I agree and reconsider more details.
Considering that @tillrohrmann has said that the
yanghua commented on issue #6567: [FLINK-10074] Allowable number of checkpoint
failures
URL: https://github.com/apache/flink/pull/6567#issuecomment-423453821
hi @tillrohrmann what do you think about the latest implementation?
yanghua commented on issue #6567: [FLINK-10074] Allowable number of checkpoint
failures
URL: https://github.com/apache/flink/pull/6567#issuecomment-422427072
hi @tillrohrmann I have refactored this PR and counted the failure number in
the `CheckpointCoordinator`. I think I should push the
yanghua commented on issue #6567: [FLINK-10074] Allowable number of checkpoint
failures
URL: https://github.com/apache/flink/pull/6567#issuecomment-421948370
@tillrohrmann I originally wanted to do it in the checkpoint coordinator
when I first implemented it, but when I touched
yanghua commented on issue #6567: [FLINK-10074] Allowable number of checkpoint
failures
URL: https://github.com/apache/flink/pull/6567#issuecomment-421931626
@tweise Any comments or opinions? The current count implementation is for a
single sub task instance, not the job level. Maybe
yanghua commented on issue #6567: [FLINK-10074] Allowable number of checkpoint
failures
URL: https://github.com/apache/flink/pull/6567#issuecomment-421282760
Hi @tillrohrmann , Currently it is applied to the sub task instance (TM)
instead of the checkpoint coordinator (JM) as a complement
yanghua commented on issue #6567: [FLINK-10074] Allowable number of checkpoint
failures
URL: https://github.com/apache/flink/pull/6567#issuecomment-419137130
@azagrebin thanks for your suggestion, refactored this PR.
This is
yanghua commented on issue #6567: [FLINK-10074] Allowable number of checkpoint
failures
URL: https://github.com/apache/flink/pull/6567#issuecomment-419073463
@tillrohrmann and @zentol if you have time, can you have a look at this PR?
yanghua commented on issue #6567: [FLINK-10074] Allowable number of checkpoint
failures
URL: https://github.com/apache/flink/pull/6567#issuecomment-418295546
@azagrebin thanks for your suggestion, I have refactored this PR, please
review again~
yanghua commented on issue #6567: [FLINK-10074] Allowable number of checkpoint
failures
URL: https://github.com/apache/flink/pull/6567#issuecomment-415303507
@tillrohrmann When you have free time, please review this PR. thanks.
yanghua commented on issue #6567: [FLINK-10074] Allowable number of checkpoint
failures
URL: https://github.com/apache/flink/pull/6567#issuecomment-413486884
cc @tillrohrmann
This is an automated message from the Apache Git
13 matches
Mail list logo
