lukecwik commented on pull request #12241:
URL: https://github.com/apache/beam/pull/12241#issuecomment-658393808
Run Python2_PVR_Flink PreCommit
This is an automated message from the Apache Git Service.
To respond to the mess
lukecwik commented on pull request #12241:
URL: https://github.com/apache/beam/pull/12241#issuecomment-658294246
Run Python2_PVR_Flink PreCommit
This is an automated message from the Apache Git Service.
To respond to the mess
lukecwik commented on pull request #12241:
URL: https://github.com/apache/beam/pull/12241#issuecomment-658269143
Run Python2_PVR_Flink PreCommit
This is an automated message from the Apache Git Service.
To respond to the mess
lukecwik commented on pull request #12241:
URL: https://github.com/apache/beam/pull/12241#issuecomment-658244351
> Could you please explain more about the race condition here?
threadsafe_watermark_estimator can become None in the finally block after
the `if threadsafe_restriction_tra
lukecwik commented on pull request #12241:
URL: https://github.com/apache/beam/pull/12241#issuecomment-658243038
Run Python2_PVR_Flink PreCommit
This is an automated message from the Apache Git Service.
To respond to the mess
lukecwik commented on pull request #12241:
URL: https://github.com/apache/beam/pull/12241#issuecomment-657716085
R: @boyuanzz
This is an automated message from the Apache Git Service.
To respond to the message, please log on