You are viewing a plain text version of this content. The canonical link for it is here.
Posted to github@beam.apache.org by "ddebowczyk92 (via GitHub)" <gi...@apache.org> on 2023/08/31 13:35:13 UTC
[GitHub] [beam] ddebowczyk92 opened a new issue, #28258: [Bug]: FlinkDetachedRunnerResult violates the contract by not properly handling wait times of less than 1 ms
ddebowczyk92 opened a new issue, #28258:
URL: https://github.com/apache/beam/issues/28258
### What happened?
According to the documentation on the [`PipelineResult.waitUntilFinish(Duration duration)` ](https://github.com/apache/beam/blob/f91bb68b2e9df3788914898c03fdf42445f912d5/sdks/java/core/src/main/java/org/apache/beam/sdk/PipelineResult.java#L50), if `duration` value is less than 1ms it should wait infinitely. `FlinkDetachedRunnerResult` breaks this contract - if the provided will be less than 1ms it will skip the `while` loop and return the state immediately.
### Issue Priority
Priority: 2 (default / most bugs should be filed as P2)
### Issue Components
- [ ] Component: Python SDK
- [ ] Component: Java SDK
- [ ] Component: Go SDK
- [ ] Component: Typescript SDK
- [ ] Component: IO connector
- [ ] Component: Beam examples
- [ ] Component: Beam playground
- [ ] Component: Beam katas
- [ ] Component: Website
- [ ] Component: Spark Runner
- [X] Component: Flink Runner
- [ ] Component: Samza Runner
- [ ] Component: Twister2 Runner
- [ ] Component: Hazelcast Jet Runner
- [ ] Component: Google Cloud Dataflow Runner
--
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: github-unsubscribe@beam.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [beam] ddebowczyk92 commented on issue #28258: [Bug]: FlinkDetachedRunnerResult violates the contract by not properly handling wait times of less than 1 ms
Posted by "ddebowczyk92 (via GitHub)" <gi...@apache.org>.
ddebowczyk92 commented on issue #28258:
URL: https://github.com/apache/beam/issues/28258#issuecomment-1701188795
.take-issue
--
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: github-unsubscribe@beam.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [beam] je-ik closed issue #28258: [Bug]: FlinkDetachedRunnerResult violates the contract by not properly handling wait times of less than 1 ms
Posted by "je-ik (via GitHub)" <gi...@apache.org>.
je-ik closed issue #28258: [Bug]: FlinkDetachedRunnerResult violates the contract by not properly handling wait times of less than 1 ms
URL: https://github.com/apache/beam/issues/28258
--
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: github-unsubscribe@beam.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [beam] je-ik commented on issue #28258: [Bug]: FlinkDetachedRunnerResult violates the contract by not properly handling wait times of less than 1 ms
Posted by "je-ik (via GitHub)" <gi...@apache.org>.
je-ik commented on issue #28258:
URL: https://github.com/apache/beam/issues/28258#issuecomment-1729064226
Closed via #28262.
--
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: github-unsubscribe@beam.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org