[GitHub] [flink] flinkbot edited a comment on pull request #17702: [docs][typos] fix typos that memory is miswritten as jobmanager in st…
flinkbot edited a comment on pull request #17702: URL: https://github.com/apache/flink/pull/17702#issuecomment-962396104 ## CI report: * 59d92362b9fa27b1f609e10034f96e2dacd87e61 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26077) * e0da7e9e7debc4784fa8a98ee604254aea213aaf UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17702: [docs][typos] fix typos that memory is miswritten as jobmanager in st…
flinkbot edited a comment on pull request #17702: URL: https://github.com/apache/flink/pull/17702#issuecomment-962396104 ## CI report: * 59d92362b9fa27b1f609e10034f96e2dacd87e61 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26077) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17702: [docs][typos] fix typos that memory is miswritten as jobmanager in st…
flinkbot edited a comment on pull request #17702: URL: https://github.com/apache/flink/pull/17702#issuecomment-962396104 ## CI report: * 59d92362b9fa27b1f609e10034f96e2dacd87e61 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26077) * e0da7e9e7debc4784fa8a98ee604254aea213aaf UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17702: [docs][typos] fix typos that memory is miswritten as jobmanager in st…
flinkbot edited a comment on pull request #17702: URL: https://github.com/apache/flink/pull/17702#issuecomment-962396104 ## CI report: * 59d92362b9fa27b1f609e10034f96e2dacd87e61 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26077) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17702: [docs][typos] fix typos that memory is miswritten as jobmanager in st…
flinkbot edited a comment on pull request #17702: URL: https://github.com/apache/flink/pull/17702#issuecomment-962396104 ## CI report: * 59d92362b9fa27b1f609e10034f96e2dacd87e61 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26077) * e0da7e9e7debc4784fa8a98ee604254aea213aaf UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17702: [docs][typos] fix typos that memory is miswritten as jobmanager in st…
flinkbot edited a comment on pull request #17702: URL: https://github.com/apache/flink/pull/17702#issuecomment-962396104 ## CI report: * 59d92362b9fa27b1f609e10034f96e2dacd87e61 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26077) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17702: [docs][typos] fix typos that memory is miswritten as jobmanager in st…
flinkbot edited a comment on pull request #17702: URL: https://github.com/apache/flink/pull/17702#issuecomment-962396104 ## CI report: * 59d92362b9fa27b1f609e10034f96e2dacd87e61 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26077) * e0da7e9e7debc4784fa8a98ee604254aea213aaf UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17702: [docs][typos] fix typos that memory is miswritten as jobmanager in st…
flinkbot edited a comment on pull request #17702: URL: https://github.com/apache/flink/pull/17702#issuecomment-962396104 ## CI report: * 59d92362b9fa27b1f609e10034f96e2dacd87e61 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26077) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17702: [docs][typos] fix typos that memory is miswritten as jobmanager in st…
flinkbot edited a comment on pull request #17702: URL: https://github.com/apache/flink/pull/17702#issuecomment-962396104 ## CI report: * 59d92362b9fa27b1f609e10034f96e2dacd87e61 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26077) * e0da7e9e7debc4784fa8a98ee604254aea213aaf UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17702: [docs][typos] fix typos that memory is miswritten as jobmanager in st…
flinkbot edited a comment on pull request #17702: URL: https://github.com/apache/flink/pull/17702#issuecomment-962396104 ## CI report: * 59d92362b9fa27b1f609e10034f96e2dacd87e61 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26077) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17702: [docs][typos] fix typos that memory is miswritten as jobmanager in st…
flinkbot edited a comment on pull request #17702: URL: https://github.com/apache/flink/pull/17702#issuecomment-962396104 ## CI report: * 59d92362b9fa27b1f609e10034f96e2dacd87e61 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26077) * e0da7e9e7debc4784fa8a98ee604254aea213aaf UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17702: [docs][typos] fix typos that memory is miswritten as jobmanager in st…
flinkbot edited a comment on pull request #17702: URL: https://github.com/apache/flink/pull/17702#issuecomment-962396104 ## CI report: * 59d92362b9fa27b1f609e10034f96e2dacd87e61 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26077) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17702: [docs][typos] fix typos that memory is miswritten as jobmanager in st…
flinkbot edited a comment on pull request #17702: URL: https://github.com/apache/flink/pull/17702#issuecomment-962396104 ## CI report: * 59d92362b9fa27b1f609e10034f96e2dacd87e61 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26077) * e0da7e9e7debc4784fa8a98ee604254aea213aaf UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17702: [docs][typos] fix typos that memory is miswritten as jobmanager in st…
flinkbot edited a comment on pull request #17702: URL: https://github.com/apache/flink/pull/17702#issuecomment-962396104 ## CI report: * 59d92362b9fa27b1f609e10034f96e2dacd87e61 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26077) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17702: [docs][typos] fix typos that memory is miswritten as jobmanager in st…
flinkbot edited a comment on pull request #17702: URL: https://github.com/apache/flink/pull/17702#issuecomment-962396104 ## CI report: * 59d92362b9fa27b1f609e10034f96e2dacd87e61 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26077) * e0da7e9e7debc4784fa8a98ee604254aea213aaf UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[jira] [Updated] (FLINK-24807) Fix the issues in checkpoints with iteration
[ https://issues.apache.org/jira/browse/FLINK-24807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24807: --- Labels: pull-request-available (was: ) > Fix the issues in checkpoints with iteration > > > Key: FLINK-24807 > URL: https://issues.apache.org/jira/browse/FLINK-24807 > Project: Flink > Issue Type: Sub-task > Components: Library / Machine Learning >Affects Versions: 0.1.0 >Reporter: Yun Gao >Assignee: Yun Gao >Priority: Major > Labels: pull-request-available > > We have met some more issues in supporting checkpoints with iteration: > # Support snapshotting Replayer Operator and per-round wrapper. > # Fix the issues that after head tasks finished, the coordinator continues > emitting CoordinatorCheckpointEvent, which made the checkpoint fails due to > events not sending. > # Support raw operator state inside the iteration. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[GitHub] [flink-ml] gaoyunhaii opened a new pull request #25: [FLINK-24807][iteration] Fix the issues in checkpoints with iteration
gaoyunhaii opened a new pull request #25: URL: https://github.com/apache/flink-ml/pull/25 We have met some more issues in supporting checkpoints with iteration: 1. Support snapshotting Replayer Operator and per-round wrapper. 2. Fix the issues that after head tasks finished, the coordinator continues emitting CoordinatorCheckpointEvent, which made the checkpoint fails due to events not sending. 3. Support raw operator state inside the iteration. Specially for the second point, Currently the HeadCoordinator would emit CoordinatorCheckpointEvent to the tasks so that the GloballyAlignedEvent would not be interleave with the checkpoint barrier. However, if the tasks are finished and we continue emitting the event, the checkpoint would fail due to there are failed operator events. To address this issue, we would stop emitting CoordinatorCheckpointEvent after the head operator is terminating, namely it received the GloballyAlignedEvent marking terminating. The third point is required since operators like `withBroadcast` might rely on raw operator state to snapshot the cached records. This is necessary since the normal operator state always resides in the memory, which might be not enough. -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17702: [docs][typos] fix typos that memory is miswritten as jobmanager in st…
flinkbot edited a comment on pull request #17702: URL: https://github.com/apache/flink/pull/17702#issuecomment-962396104 ## CI report: * 59d92362b9fa27b1f609e10034f96e2dacd87e61 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26077) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot commented on pull request #17702: [docs][typos] fix typos that memory is miswritten as jobmanager in st…
flinkbot commented on pull request #17702: URL: https://github.com/apache/flink/pull/17702#issuecomment-962396176 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the progress of the review. ## Automated Checks Last check on commit 59d92362b9fa27b1f609e10034f96e2dacd87e61 (Sat Nov 06 05:08:13 UTC 2021) **Warnings:** * Documentation files were touched, but no `docs/content.zh/` files: Update Chinese documentation or file Jira ticket. * **Invalid pull request title: No valid Jira ID provided** Mention the bot in a comment to re-run the automated checks. ## Review Progress * ❓ 1. The [description] looks good. * ❓ 2. There is [consensus] that the contribution should go into to Flink. * ❓ 3. Needs [attention] from. * ❓ 4. The change fits into the overall [architecture]. * ❓ 5. Overall code [quality] is good. Please see the [Pull Request Review Guide](https://flink.apache.org/contributing/reviewing-prs.html) for a full explanation of the review process. The Bot is tracking the review progress through labels. Labels are applied according to the order of the review items. For consensus, approval by a Flink committer of PMC member is required Bot commands The @flinkbot bot supports the following commands: - `@flinkbot approve description` to approve one or more aspects (aspects: `description`, `consensus`, `architecture` and `quality`) - `@flinkbot approve all` to approve all aspects - `@flinkbot approve-until architecture` to approve everything until `architecture` - `@flinkbot attention @username1 [@username2 ..]` to require somebody's attention - `@flinkbot disapprove architecture` to remove an approval you gave earlier -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot commented on pull request #17702: [docs][typos] fix typos that memory is miswritten as jobmanager in st…
flinkbot commented on pull request #17702: URL: https://github.com/apache/flink/pull/17702#issuecomment-962396104 ## CI report: * 59d92362b9fa27b1f609e10034f96e2dacd87e61 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] mincwang opened a new pull request #17702: [docs][typos] fix typos that memory is miswritten as jobmanager in st…
mincwang opened a new pull request #17702: URL: https://github.com/apache/flink/pull/17702 …ate_backends.md ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them on each deployment (during recovery).)* ## Brief change log *(for example:)* - *The TaskInfo is stored in the blob store on job creation time as a persistent artifact* - *Deployments RPC transmits only the blob storage reference* - *TaskManagers retrieve the TaskInfo from the blob cache* ## Verifying this change *(Please pick either of the following options)* This change is a trivial rework / code cleanup without any test coverage. *(or)* This change is already covered by existing tests, such as *(please describe tests)*. *(or)* This change added tests and can be verified as follows: *(example:)* - *Added integration tests for end-to-end deployment with large payloads (100MB)* - *Extended integration test for recovery after master (JobManager) failure* - *Added test that validates that TaskInfo is transferred only once across recoveries* - *Manually verified the change by running a 4 node cluser with 2 JobManagers and 4 TaskManagers, a stateful streaming program, and killing one JobManager and two TaskManagers during the execution, verifying that recovery happens correctly.* ## Does this pull request potentially affect one of the following parts: - Dependencies (does it add or upgrade a dependency): (yes / no) - The public API, i.e., is any changed class annotated with `@Public(Evolving)`: (yes / no) - The serializers: (yes / no / don't know) - The runtime per-record code paths (performance sensitive): (yes / no / don't know) - Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Kubernetes/Yarn, ZooKeeper: (yes / no / don't know) - The S3 file system connector: (yes / no / don't know) ## Documentation - Does this pull request introduce a new feature? (yes / no) - If yes, how is the feature documented? (not applicable / docs / JavaDocs / not documented) -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17674: [FLINK-24755][doc]Add guidance to solve the package sun.misc does not exist
flinkbot edited a comment on pull request #17674: URL: https://github.com/apache/flink/pull/17674#issuecomment-960623713 ## CI report: * f297b14850894166d4395910f68205ebb3e3ce71 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25972) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17674: [FLINK-24755][doc]Add guidance to solve the package sun.misc does not exist
flinkbot edited a comment on pull request #17674: URL: https://github.com/apache/flink/pull/17674#issuecomment-960623713 ## CI report: * f297b14850894166d4395910f68205ebb3e3ce71 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=25972) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] Aitozi commented on pull request #17674: [FLINK-24755][doc]Add guidance to solve the package sun.misc does not exist
Aitozi commented on pull request #17674: URL: https://github.com/apache/flink/pull/17674#issuecomment-962394766 @flinkbot run azure -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[jira] [Created] (FLINK-24808) Support IterationListener for per-round operators
Yun Gao created FLINK-24808: --- Summary: Support IterationListener for per-round operators Key: FLINK-24808 URL: https://issues.apache.org/jira/browse/FLINK-24808 Project: Flink Issue Type: Sub-task Components: Library / Machine Learning Affects Versions: 0.1.0 Reporter: Yun Gao We would need to also support IterationListener for the per-round operators. The difference between onEpochWatermarkIncremented and endInput for per-round operators are if it would be called at the last round (epoch = Integer.MAX_VALUE). This is necessary for some per-round operators that outputs final result. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Assigned] (FLINK-24808) Support IterationListener for per-round operators
[ https://issues.apache.org/jira/browse/FLINK-24808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-24808: --- Assignee: Yun Gao > Support IterationListener for per-round operators > - > > Key: FLINK-24808 > URL: https://issues.apache.org/jira/browse/FLINK-24808 > Project: Flink > Issue Type: Sub-task > Components: Library / Machine Learning >Affects Versions: 0.1.0 >Reporter: Yun Gao >Assignee: Yun Gao >Priority: Major > > We would need to also support IterationListener for the per-round operators. > The difference between onEpochWatermarkIncremented and endInput for per-round > operators are if it would be called at the last round (epoch = > Integer.MAX_VALUE). This is necessary for some per-round operators that > outputs final result. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (FLINK-24807) Fix the issues in checkpoints with iteration
Yun Gao created FLINK-24807: --- Summary: Fix the issues in checkpoints with iteration Key: FLINK-24807 URL: https://issues.apache.org/jira/browse/FLINK-24807 Project: Flink Issue Type: Sub-task Components: Library / Machine Learning Affects Versions: 0.1.0 Reporter: Yun Gao Assignee: Yun Gao We have met some more issues in supporting checkpoints with iteration: # Support snapshotting Replayer Operator and per-round wrapper. # Fix the issues that after head tasks finished, the coordinator continues emitting CoordinatorCheckpointEvent, which made the checkpoint fails due to events not sending. # Support raw operator state inside the iteration. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-24789) IllegalStateException with CheckpointCleaner being closed already
[
https://issues.apache.org/jira/browse/FLINK-24789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17439595#comment-17439595
]
Yun Gao commented on FLINK-24789:
-
[https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=26070=logs=0da23115-68bb-5dcd-192c-bd4c8adebde1=24c3384f-1bcb-57b3-224f-51bf973bbee8=9740]
> IllegalStateException with CheckpointCleaner being closed already
> -
>
> Key: FLINK-24789
> URL: https://issues.apache.org/jira/browse/FLINK-24789
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Checkpointing, Runtime / Coordination
>Affects Versions: 1.14.0
>Reporter: Matthias
>Assignee: David Morávek
>Priority: Critical
> Labels: pull-request-available, test-stability
> Fix For: 1.15.0, 1.14.1
>
> Attachments:
> logs-ci_build-test_ci_build_finegrained_resource_management-1635785399.zip
>
>
> We experienced a failure of {{OperatorCoordinatorSchedulerTest}} in our VVP
> Fork of Flink. The {{finegrained_resource_management}} test run failed with
> an non-0 exit code:
> {code}
> Nov 01 17:19:12 [ERROR] Failed to execute goal
> org.apache.maven.plugins:maven-surefire-plugin:2.22.2:test (default-test) on
> project flink-runtime: There are test failures.
> Nov 01 17:19:12 [ERROR]
> Nov 01 17:19:12 [ERROR] Please refer to
> /__w/1/s/flink-runtime/target/surefire-reports for the individual test
> results.
> Nov 01 17:19:12 [ERROR] Please refer to dump files (if any exist)
> [date].dump, [date]-jvmRun[N].dump and [date].dumpstream.
> Nov 01 17:19:12 [ERROR] ExecutionException The forked VM terminated without
> properly saying goodbye. VM crash or System.exit called?
> Nov 01 17:19:12 [ERROR] Command was /bin/sh -c cd /__w/1/s/flink-runtime &&
> /usr/lib/jvm/java-8-openjdk-amd64/jre/bin/java -Xms256m -Xmx2048m
> -Dmvn.forkNumber=2 -XX:+UseG1GC -jar
> /__w/1/s/flink-runtime/target/surefire/surefirebooter6007815607334336440.jar
> /__w/1/s/flink-runtime/target/surefire 2021-11-01T16-51-51_363-jvmRun2
> surefire6448660128033443499tmp surefire_4131168043975619749001tmp
> Nov 01 17:19:12 [ERROR] Error occurred in starting fork, check output in log
> Nov 01 17:19:12 [ERROR] Process Exit Code: 239
> Nov 01 17:19:12 [ERROR] Crashed tests:
> Nov 01 17:19:12 [ERROR]
> org.apache.flink.runtime.operators.coordination.OperatorCoordinatorSchedulerTest
> Nov 01 17:19:12 [ERROR]
> org.apache.maven.surefire.booter.SurefireBooterForkException:
> ExecutionException The forked VM terminated without properly saying goodbye.
> VM crash or System.exit called?
> Nov 01 17:19:12 [ERROR] Command was /bin/sh -c cd /__w/1/s/flink-runtime &&
> /usr/lib/jvm/java-8-openjdk-amd64/jre/bin/java -Xms256m -Xmx2048m
> -Dmvn.forkNumber=2 -XX:+UseG1GC -jar
> /__w/1/s/flink-runtime/target/surefire/surefirebooter6007815607334336440.jar
> /__w/1/s/flink-runtime/target/surefire 2021-11-01T16-51-51_363-jvmRun2
> surefire6448660128033443499tmp surefire_4131168043975619749001tmp
> Nov 01 17:19:12 [ERROR] Error occurred in starting fork, check output in log
> Nov 01 17:19:12 [ERROR] Process Exit Code: 239
> Nov 01 17:19:12 [ERROR] Crashed tests:
> Nov 01 17:19:12 [ERROR]
> org.apache.flink.runtime.operators.coordination.OperatorCoordinatorSchedulerTest
> Nov 01 17:19:12 [ERROR] at
> org.apache.maven.plugin.surefire.booterclient.ForkStarter.awaitResultsDone(ForkStarter.java:510)
> Nov 01 17:19:12 [ERROR] at
> org.apache.maven.plugin.surefire.booterclient.ForkStarter.runSuitesForkPerTestSet(ForkStarter.java:457)
> {code}
> It looks like the {{testSnapshotAsyncFailureFailsCheckpoint}} caused it even
> though finishing successfully due to a fatal error when shutting down the
> cluster:
> {code}
> 17:07:27,264 [Checkpoint Timer] ERROR
> org.apache.flink.util.FatalExitExceptionHandler [] - FATAL:
> Thread 'Checkpoint Timer' produced an uncaught exception. Stopping the
> process...
> java.util.concurrent.CompletionException:
> java.util.concurrent.CompletionException: java.lang.IllegalStateException:
> CheckpointsCleaner has already been closed
> at
> org.apache.flink.runtime.checkpoint.CheckpointCoordinator.lambda$startTriggeringCheckpoint$7(CheckpointCoordinator.java:626)
> ~[classes/:?]
> at
> java.util.concurrent.CompletableFuture.uniExceptionally(CompletableFuture.java:884)
> ~[?:1.8.0_292]
> at
> java.util.concurrent.CompletableFuture$UniExceptionally.tryFire(CompletableFuture.java:866)
> ~[?:1.8.0_292]
> at
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
> [?:1.8.0_292]
> at
> java.util.concurrent.CompletableFuture.postFire(CompletableFuture.java:575)
> [?:1.8.0_292]
> at
>
[jira] [Commented] (FLINK-24806) RMQSourceITCase.testStopWithSavepoint and testAckFailure failed on azure due to connection error
[
https://issues.apache.org/jira/browse/FLINK-24806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17439594#comment-17439594
]
Yun Gao commented on FLINK-24806:
-
Also cc [~fabian.paul] [~cmick] for I saw you ever working on RabbitMQ related
issues, is this problem similar to the previous timeout issues~?
> RMQSourceITCase.testStopWithSavepoint and testAckFailure failed on azure due
> to connection error
>
>
> Key: FLINK-24806
> URL: https://issues.apache.org/jira/browse/FLINK-24806
> Project: Flink
> Issue Type: Bug
> Components: Connectors/ RabbitMQ
>Affects Versions: 1.15.0
>Reporter: Yun Gao
>Priority: Major
>
> {code:java}
> Nov 05 22:12:57 [INFO] Running
> org.apache.flink.streaming.connectors.rabbitmq.RMQSourceITCase
> Nov 05 22:13:18 [ERROR] Tests run: 3, Failures: 0, Errors: 2, Skipped: 0,
> Time elapsed: 20.921 s <<< FAILURE! - in
> org.apache.flink.streaming.connectors.rabbitmq.RMQSourceITCase
> Nov 05 22:13:18 [ERROR] testStopWithSavepoint Time elapsed: 3.39 s <<<
> ERROR!
> Nov 05 22:13:18 java.io.IOException
> Nov 05 22:13:18 at
> com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:129)
> Nov 05 22:13:18 at
> com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:125)
> Nov 05 22:13:18 at
> com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:396)
> Nov 05 22:13:18 at
> com.rabbitmq.client.impl.recovery.RecoveryAwareAMQConnectionFactory.newConnection(RecoveryAwareAMQConnectionFactory.java:64)
> Nov 05 22:13:18 at
> com.rabbitmq.client.impl.recovery.AutorecoveringConnection.init(AutorecoveringConnection.java:156)
> Nov 05 22:13:18 at
> com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1130)
> Nov 05 22:13:18 at
> com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1087)
> Nov 05 22:13:18 at
> com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1045)
> Nov 05 22:13:18 at
> com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1207)
> Nov 05 22:13:18 at
> org.apache.flink.streaming.connectors.rabbitmq.RMQSourceITCase.getRMQConnection(RMQSourceITCase.java:203)
> Nov 05 22:13:18 at
> org.apache.flink.streaming.connectors.rabbitmq.RMQSourceITCase.setUp(RMQSourceITCase.java:98)
> Nov 05 22:13:18 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native
> Method)
> Nov 05 22:13:18 at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> Nov 05 22:13:18 at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> Nov 05 22:13:18 at java.lang.reflect.Method.invoke(Method.java:498)
> Nov 05 22:13:18 at
> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
> Nov 05 22:13:18 at
> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
> Nov 05 22:13:18
> Nov 05 22:13:18 [ERROR] testAckFailure Time elapsed: 1.842 s <<< ERROR!
> Nov 05 22:13:18 java.io.IOException
> Nov 05 22:13:18 at
> com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:129)
> Nov 05 22:13:18 at
> com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:125)
> Nov 05 22:13:18 at
> com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:396)
> Nov 05 22:13:18 at
> com.rabbitmq.client.impl.recovery.RecoveryAwareAMQConnectionFactory.newConnection(RecoveryAwareAMQConnectionFactory.java:64)
> Nov 05 22:13:18 at
> com.rabbitmq.client.impl.recovery.AutorecoveringConnection.init(AutorecoveringConnection.java:156)
> Nov 05 22:13:18 at
> com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1130)
> Nov 05 22:13:18 at
> com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1087)
> Nov 05 22:13:18 at
> com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1045)
> Nov 05 22:13:18 at
> com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1207)
> Nov 05 22:13:18 at
> org.apache.flink.streaming.connectors.rabbitmq.RMQSourceITCase.getRMQConnection(RMQSourceITCase.java:203)
> Nov 05 22:13:18 at
> org.apache.flink.streaming.connectors.rabbitmq.RMQSourceITCase.setUp(RMQSourceITCase.java:98)
> Nov 05 22:13:18 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native
> Method)
> Nov 05 22:13:18 at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> Nov 05 22:13:18 at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> {code}
>
[jira] [Updated] (FLINK-24806) RMQSourceITCase.testStopWithSavepoint and testAckFailure failed on azure due to connection error
[
https://issues.apache.org/jira/browse/FLINK-24806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-24806:
Description:
{code:java}
Nov 05 22:12:57 [INFO] Running
org.apache.flink.streaming.connectors.rabbitmq.RMQSourceITCase
Nov 05 22:13:18 [ERROR] Tests run: 3, Failures: 0, Errors: 2, Skipped: 0, Time
elapsed: 20.921 s <<< FAILURE! - in
org.apache.flink.streaming.connectors.rabbitmq.RMQSourceITCase
Nov 05 22:13:18 [ERROR] testStopWithSavepoint Time elapsed: 3.39 s <<< ERROR!
Nov 05 22:13:18 java.io.IOException
Nov 05 22:13:18 at
com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:129)
Nov 05 22:13:18 at
com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:125)
Nov 05 22:13:18 at
com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:396)
Nov 05 22:13:18 at
com.rabbitmq.client.impl.recovery.RecoveryAwareAMQConnectionFactory.newConnection(RecoveryAwareAMQConnectionFactory.java:64)
Nov 05 22:13:18 at
com.rabbitmq.client.impl.recovery.AutorecoveringConnection.init(AutorecoveringConnection.java:156)
Nov 05 22:13:18 at
com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1130)
Nov 05 22:13:18 at
com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1087)
Nov 05 22:13:18 at
com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1045)
Nov 05 22:13:18 at
com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1207)
Nov 05 22:13:18 at
org.apache.flink.streaming.connectors.rabbitmq.RMQSourceITCase.getRMQConnection(RMQSourceITCase.java:203)
Nov 05 22:13:18 at
org.apache.flink.streaming.connectors.rabbitmq.RMQSourceITCase.setUp(RMQSourceITCase.java:98)
Nov 05 22:13:18 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native
Method)
Nov 05 22:13:18 at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
Nov 05 22:13:18 at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
Nov 05 22:13:18 at java.lang.reflect.Method.invoke(Method.java:498)
Nov 05 22:13:18 at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
Nov 05 22:13:18 at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
Nov 05 22:13:18
Nov 05 22:13:18 [ERROR] testAckFailure Time elapsed: 1.842 s <<< ERROR!
Nov 05 22:13:18 java.io.IOException
Nov 05 22:13:18 at
com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:129)
Nov 05 22:13:18 at
com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:125)
Nov 05 22:13:18 at
com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:396)
Nov 05 22:13:18 at
com.rabbitmq.client.impl.recovery.RecoveryAwareAMQConnectionFactory.newConnection(RecoveryAwareAMQConnectionFactory.java:64)
Nov 05 22:13:18 at
com.rabbitmq.client.impl.recovery.AutorecoveringConnection.init(AutorecoveringConnection.java:156)
Nov 05 22:13:18 at
com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1130)
Nov 05 22:13:18 at
com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1087)
Nov 05 22:13:18 at
com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1045)
Nov 05 22:13:18 at
com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1207)
Nov 05 22:13:18 at
org.apache.flink.streaming.connectors.rabbitmq.RMQSourceITCase.getRMQConnection(RMQSourceITCase.java:203)
Nov 05 22:13:18 at
org.apache.flink.streaming.connectors.rabbitmq.RMQSourceITCase.setUp(RMQSourceITCase.java:98)
Nov 05 22:13:18 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native
Method)
Nov 05 22:13:18 at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
Nov 05 22:13:18 at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
{code}
[https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=26065=logs=d44f43ce-542c-597d-bf94-b0718c71e5e8=ed165f3f-d0f6-524b-5279-86f8ee7d0e2d=13478]
was:
{code:java}
Nov 05 22:12:57 [INFO] Running
org.apache.flink.streaming.connectors.rabbitmq.RMQSourceITCase
Nov 05 22:13:18 [ERROR] Tests run: 3, Failures: 0, Errors: 2, Skipped: 0, Time
elapsed: 20.921 s <<< FAILURE! - in
org.apache.flink.streaming.connectors.rabbitmq.RMQSourceITCase
Nov 05 22:13:18 [ERROR] testStopWithSavepoint Time elapsed: 3.39 s <<< ERROR!
Nov 05 22:13:18 java.io.IOException
Nov 05 22:13:18 at
com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:129)
Nov 05 22:13:18 at
com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:125)
Nov 05 22:13:18 at
[jira] [Updated] (FLINK-24806) RMQSourceITCase.testStopWithSavepoint and testAckFailure failed on azure due to connection error
[
https://issues.apache.org/jira/browse/FLINK-24806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-24806:
Summary: RMQSourceITCase.testStopWithSavepoint and testAckFailure failed on
azure due to connection error (was: RMQSourceITCase.testStopWithSavepoint
failed on azure due to connection error)
> RMQSourceITCase.testStopWithSavepoint and testAckFailure failed on azure due
> to connection error
>
>
> Key: FLINK-24806
> URL: https://issues.apache.org/jira/browse/FLINK-24806
> Project: Flink
> Issue Type: Bug
> Components: Connectors/ RabbitMQ
>Affects Versions: 1.15.0
>Reporter: Yun Gao
>Priority: Major
>
> {code:java}
> Nov 05 22:12:57 [INFO] Running
> org.apache.flink.streaming.connectors.rabbitmq.RMQSourceITCase
> Nov 05 22:13:18 [ERROR] Tests run: 3, Failures: 0, Errors: 2, Skipped: 0,
> Time elapsed: 20.921 s <<< FAILURE! - in
> org.apache.flink.streaming.connectors.rabbitmq.RMQSourceITCase
> Nov 05 22:13:18 [ERROR] testStopWithSavepoint Time elapsed: 3.39 s <<<
> ERROR!
> Nov 05 22:13:18 java.io.IOException
> Nov 05 22:13:18 at
> com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:129)
> Nov 05 22:13:18 at
> com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:125)
> Nov 05 22:13:18 at
> com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:396)
> Nov 05 22:13:18 at
> com.rabbitmq.client.impl.recovery.RecoveryAwareAMQConnectionFactory.newConnection(RecoveryAwareAMQConnectionFactory.java:64)
> Nov 05 22:13:18 at
> com.rabbitmq.client.impl.recovery.AutorecoveringConnection.init(AutorecoveringConnection.java:156)
> Nov 05 22:13:18 at
> com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1130)
> Nov 05 22:13:18 at
> com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1087)
> Nov 05 22:13:18 at
> com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1045)
> Nov 05 22:13:18 at
> com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1207)
> Nov 05 22:13:18 at
> org.apache.flink.streaming.connectors.rabbitmq.RMQSourceITCase.getRMQConnection(RMQSourceITCase.java:203)
> Nov 05 22:13:18 at
> org.apache.flink.streaming.connectors.rabbitmq.RMQSourceITCase.setUp(RMQSourceITCase.java:98)
> Nov 05 22:13:18 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native
> Method)
> Nov 05 22:13:18 at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> Nov 05 22:13:18 at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> Nov 05 22:13:18 at java.lang.reflect.Method.invoke(Method.java:498)
> Nov 05 22:13:18 at
> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
> Nov 05 22:13:18 at
> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
> {code}
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=26065=logs=d44f43ce-542c-597d-bf94-b0718c71e5e8=ed165f3f-d0f6-524b-5279-86f8ee7d0e2d=13478
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Created] (FLINK-24806) RMQSourceITCase.testStopWithSavepoint failed on azure due to connection error
Yun Gao created FLINK-24806:
---
Summary: RMQSourceITCase.testStopWithSavepoint failed on azure due
to connection error
Key: FLINK-24806
URL: https://issues.apache.org/jira/browse/FLINK-24806
Project: Flink
Issue Type: Bug
Components: Connectors/ RabbitMQ
Affects Versions: 1.15.0
Reporter: Yun Gao
{code:java}
Nov 05 22:12:57 [INFO] Running
org.apache.flink.streaming.connectors.rabbitmq.RMQSourceITCase
Nov 05 22:13:18 [ERROR] Tests run: 3, Failures: 0, Errors: 2, Skipped: 0, Time
elapsed: 20.921 s <<< FAILURE! - in
org.apache.flink.streaming.connectors.rabbitmq.RMQSourceITCase
Nov 05 22:13:18 [ERROR] testStopWithSavepoint Time elapsed: 3.39 s <<< ERROR!
Nov 05 22:13:18 java.io.IOException
Nov 05 22:13:18 at
com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:129)
Nov 05 22:13:18 at
com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:125)
Nov 05 22:13:18 at
com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:396)
Nov 05 22:13:18 at
com.rabbitmq.client.impl.recovery.RecoveryAwareAMQConnectionFactory.newConnection(RecoveryAwareAMQConnectionFactory.java:64)
Nov 05 22:13:18 at
com.rabbitmq.client.impl.recovery.AutorecoveringConnection.init(AutorecoveringConnection.java:156)
Nov 05 22:13:18 at
com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1130)
Nov 05 22:13:18 at
com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1087)
Nov 05 22:13:18 at
com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1045)
Nov 05 22:13:18 at
com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1207)
Nov 05 22:13:18 at
org.apache.flink.streaming.connectors.rabbitmq.RMQSourceITCase.getRMQConnection(RMQSourceITCase.java:203)
Nov 05 22:13:18 at
org.apache.flink.streaming.connectors.rabbitmq.RMQSourceITCase.setUp(RMQSourceITCase.java:98)
Nov 05 22:13:18 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native
Method)
Nov 05 22:13:18 at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
Nov 05 22:13:18 at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
Nov 05 22:13:18 at java.lang.reflect.Method.invoke(Method.java:498)
Nov 05 22:13:18 at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
Nov 05 22:13:18 at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
{code}
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=26065=logs=d44f43ce-542c-597d-bf94-b0718c71e5e8=ed165f3f-d0f6-524b-5279-86f8ee7d0e2d=13478
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Commented] (FLINK-24801) "Post-job: Cache Maven local repo" failed on Azure
[
https://issues.apache.org/jira/browse/FLINK-24801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17439591#comment-17439591
]
Yun Gao commented on FLINK-24801:
-
[https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=26040=logs=c88eea3b-64a0-564d-0031-9fdcd7b8abee=df7c2656-5dff-4a83-9218-19a55665407c=217]
> "Post-job: Cache Maven local repo" failed on Azure
> --
>
> Key: FLINK-24801
> URL: https://issues.apache.org/jira/browse/FLINK-24801
> Project: Flink
> Issue Type: Bug
> Components: Build System / Azure Pipelines
>Affects Versions: 1.15.0
>Reporter: Yun Gao
>Priority: Major
>
> {code:java}
> 2021-11-05T13:49:20.5298458Z Resolved to:
> maven|Linux|kL7EJ8TeMrJ0VZs51DUWRqheXcKK2cN2spGtx9IbVxQ=
> 2021-11-05T13:49:21.0445785Z ApplicationInsightsTelemetrySender will
> correlate events with X-TFS-Session b5cbe6a0-61e7-4345-81b6-efaed3924cbe
> 2021-11-05T13:49:21.0700758Z Getting a pipeline cache artifact with one of
> the following fingerprints:
> 2021-11-05T13:49:21.0702157Z Fingerprint:
> `maven|Linux|kL7EJ8TeMrJ0VZs51DUWRqheXcKK2cN2spGtx9IbVxQ=`
> 2021-11-05T13:49:21.3648278Z There is a cache miss.
> 2021-11-05T13:50:26.4782603Z tar:
> c9692460fbd54c808fca7be315d83578_archive.tar: Wrote only 2048 of 10240 bytes
> 2021-11-05T13:50:26.4784975Z tar: Error is not recoverable: exiting now
> 2021-11-05T13:50:27.0397318Z ApplicationInsightsTelemetrySender correlated 1
> events with X-TFS-Session b5cbe6a0-61e7-4345-81b6-efaed3924cbe
> 2021-11-05T13:50:27.0531774Z ##[error]Process returned non-zero exit code: 2
> 2021-11-05T13:50:27.0666804Z ##[section]Finishing: Cache Maven local repo
> {code}
> [https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=26018=logs=c88eea3b-64a0-564d-0031-9fdcd7b8abee=96bd9872-da2e-43b4-b013-1295f1c23a41=220]
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Commented] (FLINK-24801) "Post-job: Cache Maven local repo" failed on Azure
[
https://issues.apache.org/jira/browse/FLINK-24801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17439590#comment-17439590
]
Yun Gao commented on FLINK-24801:
-
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=26036=logs=c88eea3b-64a0-564d-0031-9fdcd7b8abee=9ef2acf1-23b7-4eb3-b4aa-bc59391a2a54=217
> "Post-job: Cache Maven local repo" failed on Azure
> --
>
> Key: FLINK-24801
> URL: https://issues.apache.org/jira/browse/FLINK-24801
> Project: Flink
> Issue Type: Bug
> Components: Build System / Azure Pipelines
>Affects Versions: 1.15.0
>Reporter: Yun Gao
>Priority: Major
>
> {code:java}
> 2021-11-05T13:49:20.5298458Z Resolved to:
> maven|Linux|kL7EJ8TeMrJ0VZs51DUWRqheXcKK2cN2spGtx9IbVxQ=
> 2021-11-05T13:49:21.0445785Z ApplicationInsightsTelemetrySender will
> correlate events with X-TFS-Session b5cbe6a0-61e7-4345-81b6-efaed3924cbe
> 2021-11-05T13:49:21.0700758Z Getting a pipeline cache artifact with one of
> the following fingerprints:
> 2021-11-05T13:49:21.0702157Z Fingerprint:
> `maven|Linux|kL7EJ8TeMrJ0VZs51DUWRqheXcKK2cN2spGtx9IbVxQ=`
> 2021-11-05T13:49:21.3648278Z There is a cache miss.
> 2021-11-05T13:50:26.4782603Z tar:
> c9692460fbd54c808fca7be315d83578_archive.tar: Wrote only 2048 of 10240 bytes
> 2021-11-05T13:50:26.4784975Z tar: Error is not recoverable: exiting now
> 2021-11-05T13:50:27.0397318Z ApplicationInsightsTelemetrySender correlated 1
> events with X-TFS-Session b5cbe6a0-61e7-4345-81b6-efaed3924cbe
> 2021-11-05T13:50:27.0531774Z ##[error]Process returned non-zero exit code: 2
> 2021-11-05T13:50:27.0666804Z ##[section]Finishing: Cache Maven local repo
> {code}
> [https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=26018=logs=c88eea3b-64a0-564d-0031-9fdcd7b8abee=96bd9872-da2e-43b4-b013-1295f1c23a41=220]
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Commented] (FLINK-24801) "Post-job: Cache Maven local repo" failed on Azure
[
https://issues.apache.org/jira/browse/FLINK-24801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17439589#comment-17439589
]
Yun Gao commented on FLINK-24801:
-
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=26038=logs=c88eea3b-64a0-564d-0031-9fdcd7b8abee=36dd7c3c-6cd0-4fe4-b1f7-7ad76507379a=212
> "Post-job: Cache Maven local repo" failed on Azure
> --
>
> Key: FLINK-24801
> URL: https://issues.apache.org/jira/browse/FLINK-24801
> Project: Flink
> Issue Type: Bug
> Components: Build System / Azure Pipelines
>Affects Versions: 1.15.0
>Reporter: Yun Gao
>Priority: Major
>
> {code:java}
> 2021-11-05T13:49:20.5298458Z Resolved to:
> maven|Linux|kL7EJ8TeMrJ0VZs51DUWRqheXcKK2cN2spGtx9IbVxQ=
> 2021-11-05T13:49:21.0445785Z ApplicationInsightsTelemetrySender will
> correlate events with X-TFS-Session b5cbe6a0-61e7-4345-81b6-efaed3924cbe
> 2021-11-05T13:49:21.0700758Z Getting a pipeline cache artifact with one of
> the following fingerprints:
> 2021-11-05T13:49:21.0702157Z Fingerprint:
> `maven|Linux|kL7EJ8TeMrJ0VZs51DUWRqheXcKK2cN2spGtx9IbVxQ=`
> 2021-11-05T13:49:21.3648278Z There is a cache miss.
> 2021-11-05T13:50:26.4782603Z tar:
> c9692460fbd54c808fca7be315d83578_archive.tar: Wrote only 2048 of 10240 bytes
> 2021-11-05T13:50:26.4784975Z tar: Error is not recoverable: exiting now
> 2021-11-05T13:50:27.0397318Z ApplicationInsightsTelemetrySender correlated 1
> events with X-TFS-Session b5cbe6a0-61e7-4345-81b6-efaed3924cbe
> 2021-11-05T13:50:27.0531774Z ##[error]Process returned non-zero exit code: 2
> 2021-11-05T13:50:27.0666804Z ##[section]Finishing: Cache Maven local repo
> {code}
> [https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=26018=logs=c88eea3b-64a0-564d-0031-9fdcd7b8abee=96bd9872-da2e-43b4-b013-1295f1c23a41=220]
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[GitHub] [flink] flinkbot edited a comment on pull request #17699: [FLINK-20370][table] Fix wrong results when sink primary key is not the same with query result's changelog upsert key
flinkbot edited a comment on pull request #17699: URL: https://github.com/apache/flink/pull/17699#issuecomment-961963701 ## CI report: * 0c179381e200fa5f41136a61235ce4e4106de419 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26047) * 6405f23e7550d1d71ea9340703d85cdc61b3702b Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26076) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[jira] [Commented] (FLINK-24077) HBaseConnectorITCase.testTableSink
[
https://issues.apache.org/jira/browse/FLINK-24077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17439588#comment-17439588
]
Yun Gao commented on FLINK-24077:
-
[https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=26033=logs=d44f43ce-542c-597d-bf94-b0718c71e5e8=ed165f3f-d0f6-524b-5279-86f8ee7d0e2d=13012]
> HBaseConnectorITCase.testTableSink
> --
>
> Key: FLINK-24077
> URL: https://issues.apache.org/jira/browse/FLINK-24077
> Project: Flink
> Issue Type: Bug
> Components: Connectors / HBase, Table SQL / Ecosystem
>Affects Versions: 1.14.0, 1.15.0
>Reporter: Xintong Song
>Priority: Critical
> Labels: test-stability
> Fix For: 1.15.0, 1.14.1
>
>
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=23160=logs=d44f43ce-542c-597d-bf94-b0718c71e5e8=ed165f3f-d0f6-524b-5279-86f8ee7d0e2d=12962
> {code}
> Aug 31 05:10:58 Tests run: 9, Failures: 1, Errors: 0, Skipped: 0, Time
> elapsed: 73.758 sec <<< FAILURE! - in
> org.apache.flink.connector.hbase2.HBaseConnectorITCase
> Aug 31 05:10:58
> testTableSink(org.apache.flink.connector.hbase2.HBaseConnectorITCase) Time
> elapsed: 6.516 sec <<< FAILURE!
> Aug 31 05:10:58 java.lang.AssertionError:
> Aug 31 05:10:58 Different elements in arrays: expected 8 elements and
> received 3
> Aug 31 05:10:58 expected: [+I[1, 10, Hello-1, 100, 1.01, false, Welt-1],
> +I[2, 20, Hello-2, 200, 2.02, true, Welt-2], +I[3, 30, Hello-3, 300, 3.03,
> false, Welt-3], +I[4, 40, null, 400, 4.04, true, Welt-4], +I[5, 50, Hello-5,
> 500, 5.05, false, Welt-5], +I[6, 60, Hello-6, 600, 6.06, true, Welt-6], +I[7,
> 70, Hello-7, 700, 7.07, false, Welt-7], +I[8, 80, null, 800, 8.08, true,
> Welt-8]]
> Aug 31 05:10:58 received: [+I[1, 10, Hello-1, 100, 1.01, false, Welt-1],
> +I[2, 20, Hello-2, 200, 2.02, true, Welt-2], +I[3, 30, Hello-3, 300, 3.03,
> false, Welt-3]] expected:<8> but was:<3>
> Aug 31 05:10:58 at org.junit.Assert.fail(Assert.java:89)
> Aug 31 05:10:58 at org.junit.Assert.failNotEquals(Assert.java:835)
> Aug 31 05:10:58 at org.junit.Assert.assertEquals(Assert.java:647)
> Aug 31 05:10:58 at
> org.apache.flink.test.util.TestBaseUtils.compareResult(TestBaseUtils.java:395)
> Aug 31 05:10:58 at
> org.apache.flink.test.util.TestBaseUtils.compareResultAsText(TestBaseUtils.java:347)
> Aug 31 05:10:58 at
> org.apache.flink.connector.hbase2.HBaseConnectorITCase.testTableSink(HBaseConnectorITCase.java:284)
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[GitHub] [flink] flinkbot edited a comment on pull request #17699: [FLINK-20370][table] Fix wrong results when sink primary key is not the same with query result's changelog upsert key
flinkbot edited a comment on pull request #17699: URL: https://github.com/apache/flink/pull/17699#issuecomment-961963701 ## CI report: * 0c179381e200fa5f41136a61235ce4e4106de419 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26047) * 6405f23e7550d1d71ea9340703d85cdc61b3702b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support
flinkbot edited a comment on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-818947931 ## CI report: * f90389b51e59a8632d786a20475ea866132b334b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26073) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17387: [FLINK-23486][state] ChangelogUploader metrics
flinkbot edited a comment on pull request #17387: URL: https://github.com/apache/flink/pull/17387#issuecomment-930245327 ## CI report: * 1736c549da6932a76be1268ba1f2091b825d3925 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26071) * 2db1ab776228ba573da1b098ef6692de3b583323 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26072) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17698: [FLINK-24689][runtime-web] Add log's last modify time in log list view
flinkbot edited a comment on pull request #17698: URL: https://github.com/apache/flink/pull/17698#issuecomment-961944542 ## CI report: * f65930f4af73186638267edd631f38806e74e482 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26055) * 90afa69f4588fb080119395484bf7d80d99fe174 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26075) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17698: [FLINK-24689][runtime-web] Add log's last modify time in log list view
flinkbot edited a comment on pull request #17698: URL: https://github.com/apache/flink/pull/17698#issuecomment-961944542 ## CI report: * f65930f4af73186638267edd631f38806e74e482 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26055) * 90afa69f4588fb080119395484bf7d80d99fe174 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17692: [FLINK-24489][CEP] The size of entryCache & eventsBufferCache in the SharedBuffer should be defined with a threshold to limit the num
flinkbot edited a comment on pull request #17692: URL: https://github.com/apache/flink/pull/17692#issuecomment-961748638 ## CI report: * d04e7822113ea65023d9311494cb67343d92fc34 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26017) * d1a9dd220650005d60138be5f69ed5df511c263d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26074) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17692: [FLINK-24489][CEP] The size of entryCache & eventsBufferCache in the SharedBuffer should be defined with a threshold to limit the num
flinkbot edited a comment on pull request #17692: URL: https://github.com/apache/flink/pull/17692#issuecomment-961748638 ## CI report: * d04e7822113ea65023d9311494cb67343d92fc34 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26017) * d1a9dd220650005d60138be5f69ed5df511c263d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17653: FLINK SQL checkpoint不生效
flinkbot edited a comment on pull request #17653: URL: https://github.com/apache/flink/pull/17653#issuecomment-958686553 ## CI report: * 237fb3a04e81602238b87ffc24423fc6f4cfe0ce Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26063) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17658: [FLINK-24684][table-planner] Add to string cast rules using the new CastRule stack
flinkbot edited a comment on pull request #17658: URL: https://github.com/apache/flink/pull/17658#issuecomment-958884763 ## CI report: * 7dfe3c64086dbe4ef1981c8e62512cb34552348b UNKNOWN * 2b2ea981bbd50f98728012ec5c6d0b2aff946361 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26062) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17544: [FLINK-24165][table] Add infrastructure to support metadata for filesystem connector
flinkbot edited a comment on pull request #17544: URL: https://github.com/apache/flink/pull/17544#issuecomment-949353495 ## CI report: * 8ed8594acccabd5105cb3cb6bb046e6b1394fb7d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26061) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] RocMarshal commented on pull request #16962: [FLINK-15352][connector-jdbc] Develop MySQLCatalog to connect Flink with MySQL tables and ecosystem.
RocMarshal commented on pull request #16962: URL: https://github.com/apache/flink/pull/16962#issuecomment-962281767 @Airblader Thank you so much for the review. I made some change. Could you help me to check it again? -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17574: [FLINK-24665][s3] Update Presto Hadoop dependency to v2.7.4-9
flinkbot edited a comment on pull request #17574: URL: https://github.com/apache/flink/pull/17574#issuecomment-952625580 ## CI report: * 756158ada389daca27c32bfa19a5e38e25079a91 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26060) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support
flinkbot edited a comment on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-818947931 ## CI report: * 08d6ae9ba2aeb78d5f2ed2f9e38aef4cf0784ab8 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26059) * f90389b51e59a8632d786a20475ea866132b334b Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26073) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support
flinkbot edited a comment on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-818947931 ## CI report: * 08d6ae9ba2aeb78d5f2ed2f9e38aef4cf0784ab8 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26059) * f90389b51e59a8632d786a20475ea866132b334b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17387: [FLINK-23486][state] ChangelogUploader metrics
flinkbot edited a comment on pull request #17387: URL: https://github.com/apache/flink/pull/17387#issuecomment-930245327 ## CI report: * 440340a1c25c8678f019fdeb802623704f0963d9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26058) * 1736c549da6932a76be1268ba1f2091b825d3925 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26071) * 2db1ab776228ba573da1b098ef6692de3b583323 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26072) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17387: [FLINK-23486][state] ChangelogUploader metrics
flinkbot edited a comment on pull request #17387: URL: https://github.com/apache/flink/pull/17387#issuecomment-930245327 ## CI report: * 440340a1c25c8678f019fdeb802623704f0963d9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26058) * 1736c549da6932a76be1268ba1f2091b825d3925 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26071) * 2db1ab776228ba573da1b098ef6692de3b583323 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17387: [FLINK-23486][state] ChangelogUploader metrics
flinkbot edited a comment on pull request #17387: URL: https://github.com/apache/flink/pull/17387#issuecomment-930245327 ## CI report: * 440340a1c25c8678f019fdeb802623704f0963d9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26058) * 1736c549da6932a76be1268ba1f2091b825d3925 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26071) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17387: [FLINK-23486][state] ChangelogUploader metrics
flinkbot edited a comment on pull request #17387: URL: https://github.com/apache/flink/pull/17387#issuecomment-930245327 ## CI report: * 440340a1c25c8678f019fdeb802623704f0963d9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26058) * 1736c549da6932a76be1268ba1f2091b825d3925 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26071) * 2db1ab776228ba573da1b098ef6692de3b583323 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17387: [FLINK-23486][state] ChangelogUploader metrics
flinkbot edited a comment on pull request #17387: URL: https://github.com/apache/flink/pull/17387#issuecomment-930245327 ## CI report: * 440340a1c25c8678f019fdeb802623704f0963d9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26058) * 1736c549da6932a76be1268ba1f2091b825d3925 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26071) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17387: [FLINK-23486][state] ChangelogUploader metrics
flinkbot edited a comment on pull request #17387: URL: https://github.com/apache/flink/pull/17387#issuecomment-930245327 ## CI report: * 440340a1c25c8678f019fdeb802623704f0963d9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26058) * 1736c549da6932a76be1268ba1f2091b825d3925 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26071) * 2db1ab776228ba573da1b098ef6692de3b583323 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17387: [FLINK-23486][state] ChangelogUploader metrics
flinkbot edited a comment on pull request #17387: URL: https://github.com/apache/flink/pull/17387#issuecomment-930245327 ## CI report: * 440340a1c25c8678f019fdeb802623704f0963d9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26058) * 1736c549da6932a76be1268ba1f2091b825d3925 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26071) * fc8a945beb1ed3c20af3958a13222937e933aaa6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17387: [FLINK-23486][state] ChangelogUploader metrics
flinkbot edited a comment on pull request #17387: URL: https://github.com/apache/flink/pull/17387#issuecomment-930245327 ## CI report: * 440340a1c25c8678f019fdeb802623704f0963d9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26058) * 1736c549da6932a76be1268ba1f2091b825d3925 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26071) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17387: [FLINK-23486][state] ChangelogUploader metrics
flinkbot edited a comment on pull request #17387: URL: https://github.com/apache/flink/pull/17387#issuecomment-930245327 ## CI report: * 440340a1c25c8678f019fdeb802623704f0963d9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26058) * 1736c549da6932a76be1268ba1f2091b825d3925 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26071) * fc8a945beb1ed3c20af3958a13222937e933aaa6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17387: [FLINK-23486][state] ChangelogUploader metrics
flinkbot edited a comment on pull request #17387: URL: https://github.com/apache/flink/pull/17387#issuecomment-930245327 ## CI report: * 440340a1c25c8678f019fdeb802623704f0963d9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26058) * 1736c549da6932a76be1268ba1f2091b825d3925 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26071) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] rkhachatryan commented on a change in pull request #17645: [FLINK-24667][runtime] Fix error handling in ChannelStateCheckpointWriter
rkhachatryan commented on a change in pull request #17645:
URL: https://github.com/apache/flink/pull/17645#discussion_r744018286
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateCheckpointWriter.java
##
@@ -296,6 +298,9 @@ private void runWithChecks(RunnableWithException r) throws
Exception {
r.run();
} catch (Exception e) {
fail(e);
+if (!findThrowable(e, IOException.class).isPresent()) {
Review comment:
Yes, my intention was to not fail the job (but only checkpoint) if the
underlying FS abstraction wraps this into RuntimeException for example (it
shouldn't).
The reasoning behind IOExceptions failing only the current checkpoint is
that they can be transient (e.g. network failure); other exceptions usually
aren't transient (e.g. programmatic errors) and therefore should fail the job.
--
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: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17387: [FLINK-23486][state] ChangelogUploader metrics
flinkbot edited a comment on pull request #17387: URL: https://github.com/apache/flink/pull/17387#issuecomment-930245327 ## CI report: * 440340a1c25c8678f019fdeb802623704f0963d9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26058) * 1736c549da6932a76be1268ba1f2091b825d3925 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26071) * fc8a945beb1ed3c20af3958a13222937e933aaa6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17387: [FLINK-23486][state] ChangelogUploader metrics
flinkbot edited a comment on pull request #17387: URL: https://github.com/apache/flink/pull/17387#issuecomment-930245327 ## CI report: * 440340a1c25c8678f019fdeb802623704f0963d9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26058) * 1736c549da6932a76be1268ba1f2091b825d3925 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26071) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17387: [FLINK-23486][state] ChangelogUploader metrics
flinkbot edited a comment on pull request #17387: URL: https://github.com/apache/flink/pull/17387#issuecomment-930245327 ## CI report: * 440340a1c25c8678f019fdeb802623704f0963d9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26058) * 1736c549da6932a76be1268ba1f2091b825d3925 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26071) * fc8a945beb1ed3c20af3958a13222937e933aaa6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17387: [FLINK-23486][state] ChangelogUploader metrics
flinkbot edited a comment on pull request #17387: URL: https://github.com/apache/flink/pull/17387#issuecomment-930245327 ## CI report: * 440340a1c25c8678f019fdeb802623704f0963d9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26058) * 1736c549da6932a76be1268ba1f2091b825d3925 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26071) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17387: [FLINK-23486][state] ChangelogUploader metrics
flinkbot edited a comment on pull request #17387: URL: https://github.com/apache/flink/pull/17387#issuecomment-930245327 ## CI report: * 440340a1c25c8678f019fdeb802623704f0963d9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26058) * 1736c549da6932a76be1268ba1f2091b825d3925 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26071) * fc8a945beb1ed3c20af3958a13222937e933aaa6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17387: [FLINK-23486][state] ChangelogUploader metrics
flinkbot edited a comment on pull request #17387: URL: https://github.com/apache/flink/pull/17387#issuecomment-930245327 ## CI report: * 440340a1c25c8678f019fdeb802623704f0963d9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26058) * 1736c549da6932a76be1268ba1f2091b825d3925 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26071) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[jira] [Updated] (FLINK-21392) Support to block in connected streams
[ https://issues.apache.org/jira/browse/FLINK-21392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21392: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major stale-minor) Priority: Not a Priority (was: Minor) This issue was labeled "stale-minor" 7 days ago and has not received any updates so it is being deprioritized. If this ticket is actually Minor, please raise the priority and ask a committer to assign you the issue or revive the public discussion. > Support to block in connected streams > - > > Key: FLINK-21392 > URL: https://issues.apache.org/jira/browse/FLINK-21392 > Project: Flink > Issue Type: New Feature > Components: API / DataStream >Reporter: Timo Walther >Priority: Not a Priority > Labels: auto-deprioritized-major, auto-deprioritized-minor > > In many scenarios that involve control streams when using connected streams, > users would like to wait until stream A is "ready" before processing the > stream B. > Internally we already provide input selectable semantics but with problems > around checkpointing. Once those problems are solved, we should expose this > functionality in the main API. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[GitHub] [flink] flinkbot edited a comment on pull request #17387: [FLINK-23486][state] ChangelogUploader metrics
flinkbot edited a comment on pull request #17387: URL: https://github.com/apache/flink/pull/17387#issuecomment-930245327 ## CI report: * 440340a1c25c8678f019fdeb802623704f0963d9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26058) * 1736c549da6932a76be1268ba1f2091b825d3925 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26071) * fc8a945beb1ed3c20af3958a13222937e933aaa6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17387: [FLINK-23486][state] ChangelogUploader metrics
flinkbot edited a comment on pull request #17387: URL: https://github.com/apache/flink/pull/17387#issuecomment-930245327 ## CI report: * 440340a1c25c8678f019fdeb802623704f0963d9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26058) * 1736c549da6932a76be1268ba1f2091b825d3925 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26071) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[jira] [Updated] (FLINK-17723) Written design for flink threading model and guarantees made to the various structual components
[
https://issues.apache.org/jira/browse/FLINK-17723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-17723:
---
Labels: auto-deprioritized-major stale-minor (was:
auto-deprioritized-major)
I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help
the community manage its development. I see this issues has been marked as
Minor but is unassigned and neither itself nor its Sub-Tasks have been updated
for 180 days. I have gone ahead and marked it "stale-minor". If this ticket is
still Minor, please either assign yourself or give an update. Afterwards,
please remove the label or in 7 days the issue will be deprioritized.
> Written design for flink threading model and guarantees made to the various
> structual components
>
>
> Key: FLINK-17723
> URL: https://issues.apache.org/jira/browse/FLINK-17723
> Project: Flink
> Issue Type: Improvement
> Components: Documentation
>Reporter: John Lonergan
>Priority: Minor
> Labels: auto-deprioritized-major, stale-minor
>
> I enjoy using Flink but ...
> Do we have a written design for the threading model including the guarantees
> made by the core framework in terms of threading and concurrency.
> Looking at various existing components such as JDBC and file sinks and other
> non-core facilities.
> Having some difficulty understanding the intended design.
> Want to understand the assumptions I can make about when certain functions
> will be called (for example JDBCOutputFormat open vs flush vs writeRecord vs
> close) and whether this will always be from the same thread or some other
> thread, or whether they might be called concurrently, in order to verify the
> correctness of the code.
> What guarantees are there?
> Does a certain reference need a volatile or even a synchronisation or not.
> What's the design for threading?
> If the intended design is not written down then we have to infer it from the
> code and we will definitiely come to different conclusions and thus bugs and
> leaks. and other avoidable horrors.
> It's really hard writing good MT code and a strong design is necessary to
> provide a framework for the code.
> Some info here
> https://flink.apache.org/contributing/code-style-and-quality-common.html#concurrency-and-threading
> , but this isn't a design and doesn't say how it's meant to work. However
> that page does agree that writing MT code is very hard and this just
> underlines the need for a strong and detailed design for this aspect.
> ==
> Another supporting example.
> When I see code like this ...
> FileOutputFormat
>
> {code:java}
>public void close() throws IOException {
> final FSDataOutputStream s = this.stream;
> if (s != null) {
> this.stream = null;
> s.close();
> }
> }
> {code}
> My feeling is that someone else wasn't sure what the right approach was.
> I can only guess that the author was concerned that someone else was going to
> call the function concurrently, or mess with the class state by some other
> means. And, if that were true then would this code even be MT safe - who
> knows? Ought there be a volatile in there or a plain old sync? Or perhaps
> none of the caution is needed at all (framework guarantees preventing the
> need)?
> Or take a look at the extensive sychronisation efforts in
> https://github.com/apache/flink/blob/master/flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/hadoop/mapred/HadoopOutputFormatBase.java
> is this code correct? Not to mention that fact that this close() method
> might throw an NPE if there is any possiblity that 'this.outputCommitter'
> might not have been initialised in open OR is the framework can ever call
> close() without open() having completed.
> I find if worrying that I see a lot of code in the project that is similarly
> uncertain and inconsistent syncronisation and resource management.
> I would have hoped that the underlying core framework provided guarantees
> that avoided the need to have extensive synchronisation effort in derived or
> auxiliary classes.
> What's the design.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Updated] (FLINK-17804) Follow the spec when decoding Parquet logical DECIMAL type
[
https://issues.apache.org/jira/browse/FLINK-17804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-17804:
---
Labels: auto-deprioritized-major decimal parquet pull-request-available
spark stale-minor (was: auto-deprioritized-major decimal parquet
pull-request-available spark)
I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help
the community manage its development. I see this issues has been marked as
Minor but is unassigned and neither itself nor its Sub-Tasks have been updated
for 180 days. I have gone ahead and marked it "stale-minor". If this ticket is
still Minor, please either assign yourself or give an update. Afterwards,
please remove the label or in 7 days the issue will be deprioritized.
> Follow the spec when decoding Parquet logical DECIMAL type
> --
>
> Key: FLINK-17804
> URL: https://issues.apache.org/jira/browse/FLINK-17804
> Project: Flink
> Issue Type: Bug
> Components: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
>Affects Versions: 1.10.1
>Reporter: Sergii Mikhtoniuk
>Priority: Minor
> Labels: auto-deprioritized-major, decimal, parquet,
> pull-request-available, spark, stale-minor
>
> When reading a Parquet file (produced by Spark 2.4.0 with default
> configuration) Flink's {{ParquetRowInputFormat}} fails with
> {{NumberFormatException}}.
> After debugging this it seems that Flink doesn't follow the Parquet spec on
> [encoding DECIMAL logical
> type|https://github.com/apache/parquet-format/blob/master/LogicalTypes.md#decimal]
> The Parquet schema for this field is:
> {code}
> optional fixed_len_byte_array(9) price_usd (DECIMAL(19,4));
> {code}
> If I understand the spec correctly, it says that the value should contain a
> binary representation of an unscaled decimal. Flink's
> [RowConverter|https://github.com/apache/flink/blob/release-1.10.1/flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/RowConverter.java#L202]
> however treats it as a base-10 UTF-8 string.
> What Flink essentially is doing:
> {code}
> val binary = Array[Byte](0, 0, 0, 0, 0, 11, -97, 118, -64)
> val decimal = new java.math.BigDecimal(new String(binary,
> "UTF-8").toCharArray)
> {code}
> What I think spec suggests:
> {code}
> val binary = Array[Byte](0, 0, 0, 0, 0, 11, -97, 118, -64)
> val unscaled = new java.math.BigInteger(binary)
> val decimal = new java.math.BigDecimal(unscaled)
> {code}
> Error stacktrace:
> {code}
> java.lang.NumberFormatException
> at java.math.BigDecimal.(BigDecimal.java:497)
> at java.math.BigDecimal.(BigDecimal.java:383)
> at java.math.BigDecimal.(BigDecimal.java:680)
> at
> org.apache.flink.formats.parquet.utils.RowConverter$RowPrimitiveConverter.addBinary(RowConverter.java:202)
> at
> org.apache.parquet.column.impl.ColumnReaderImpl$2$6.writeValue(ColumnReaderImpl.java:317)
> at
> org.apache.parquet.column.impl.ColumnReaderImpl.writeCurrentValueToConverter(ColumnReaderImpl.java:367)
> at
> org.apache.parquet.io.RecordReaderImplementation.read(RecordReaderImplementation.java:406)
> at
> org.apache.flink.formats.parquet.utils.ParquetRecordReader.readNextRecord(ParquetRecordReader.java:235)
> at
> org.apache.flink.formats.parquet.utils.ParquetRecordReader.reachEnd(ParquetRecordReader.java:207)
> at
> org.apache.flink.formats.parquet.ParquetInputFormat.reachedEnd(ParquetInputFormat.java:233)
> at
> org.apache.flink.streaming.api.functions.source.ContinuousFileReaderOperator$SplitReader.run(ContinuousFileReaderOperator.java:327)
> {code}
> Thanks!
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Updated] (FLINK-17638) FlinkKafkaConsumerBase restore from empty state will be set consume from earliest forced
[
https://issues.apache.org/jira/browse/FLINK-17638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-17638:
---
Labels: auto-deprioritized-major stale-minor (was:
auto-deprioritized-major)
I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help
the community manage its development. I see this issues has been marked as
Minor but is unassigned and neither itself nor its Sub-Tasks have been updated
for 180 days. I have gone ahead and marked it "stale-minor". If this ticket is
still Minor, please either assign yourself or give an update. Afterwards,
please remove the label or in 7 days the issue will be deprioritized.
> FlinkKafkaConsumerBase restore from empty state will be set consume from
> earliest forced
>
>
> Key: FLINK-17638
> URL: https://issues.apache.org/jira/browse/FLINK-17638
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka
>Affects Versions: 1.9.0, 1.9.3, 1.10.0
> Environment: Flink 1.9.0
> kafka 1.1.0
> jdk 1.8
>Reporter: chenchuangchuang
>Priority: Minor
> Labels: auto-deprioritized-major, stale-minor
>
> my work target and data is like this :
> # i need count the number of post per user create last 30 days in my system
> # the total and realtime data is in MYSQL
> # i can get increment MYSQL binlog from kafka-1.1.1 ( it just store the
> last 7 days binlog), the topic name is "binlog_post_topic"
> # so , i have to combine the MYSQL data and the binlog data
>
> i do it in this way:
> # first , i carry a snapshot of MYSQL data to kafka topic in order of
> create_time ( topic name is "init-post-topic"), and consume from kafka topic
> "init-post-topic" as flink data-stream with the SlidingEventTimeWindows
> # second, after the task do all the data in the topic "init-post-topic" , i
> create a save point for the task , call the save point save-point-a
> # third, i modify my code ,
> ## the data source is "binlog_post_topic" topic of kafka ,
> ## other operotor will not change,
> ## and the "binlog_post_topic" is setted consuming from special timestamp
> (when the snapshot of MYSQL create )
> # forth, i restart my task from save-point-a
> but i find the kafka consumer for the "binlog_post_topic" do not consume data
> from the timestamp i setted, but from the earlist, i find the log in the
> task manager
> {code:java}
> //代码占位符
> 2020-05-11 17:20:47,228 INFO
> org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase -
> Consumer subtask 0 restored state: {}.
> ...
> 2020-05-12 20:14:52,641 INFO
> org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase -
> Consumer subtask 0 will start reading 1 partitions with offsets in restored
> state: {KafkaTopicPartition{topic='binlog_post_topic',
> partition=0}=-915623761775}
> 2020-05-11 17:20:47,414 INFO
> org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase -
> Consumer subtask 0 creating fetcher with offsets
> {KafkaTopicPartition{topic='binlog_post_topic', partition=0}=-915623761775}.
> {code}
> i guess this may be caused by the FlinkKafkaConsumerBase
> then i find code like this
> in the method FlinkKafkaConsumerBase.initializeState()
> {code:java}
> //代码占位符
> if (context.isRestored() && !restoredFromOldState) {
>restoredState = new TreeMap<>(new KafkaTopicPartition.Comparator());
> {code}
> this code mean that if a task is restart from the save point ,that
> restoredState will not be null, at least be an empty TreeMap;
> and in FlinkKafkaConsumerBase.open()
> {code:java}
> //代码占位符
> if (restoredState != null) {
>for (KafkaTopicPartition partition : allPartitions) {
> if (!restoredState.containsKey(partition)) {
> restoredState.put(partition,
> KafkaTopicPartitionStateSentinel.EARLIEST_OFFSET);
> }
>}
> {code}
> in this place will init the consumer , if a task is restart from a save-point
> , restoredState at least is an empty TreeMap, then in this code , the
> consumer will be setted consume from
> KafkaTopicPartitionStateSentinel.EARLIEST_OFFSET
> i change this code like this
> {code:java}
> //代码占位符
> if (restoredState != null && !restoredState.isEmpty()) {
>
> {code}
>
> and this work well for me .
>
> 刚注意到这是一个中文jira, 哭晕
>
>
>
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Updated] (FLINK-17627) Add support for writing _SUCCESS file with StreamingFileSink
[ https://issues.apache.org/jira/browse/FLINK-17627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17627: --- Labels: auto-deprioritized-major stale-minor usability (was: auto-deprioritized-major usability) I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community manage its development. I see this issues has been marked as Minor but is unassigned and neither itself nor its Sub-Tasks have been updated for 180 days. I have gone ahead and marked it "stale-minor". If this ticket is still Minor, please either assign yourself or give an update. Afterwards, please remove the label or in 7 days the issue will be deprioritized. > Add support for writing _SUCCESS file with StreamingFileSink > > > Key: FLINK-17627 > URL: https://issues.apache.org/jira/browse/FLINK-17627 > Project: Flink > Issue Type: Improvement > Components: Connectors / FileSystem >Reporter: Robert Metzger >Priority: Minor > Labels: auto-deprioritized-major, stale-minor, usability > > (Note: This feature has been requested by multiple users: > https://lists.apache.org/list.html?u...@flink.apache.org:lte=1M:_SUCCESS) > Hadoop Map Reduce is writing a _SUCCESS file to output directories once the > result has been completely written. > Users migrating from Hadoop MR to Flink want to have a similar behavior in > Flinks StreamingFileSink. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (FLINK-17749) Remove fromTableSource method from TableEnvironment
[ https://issues.apache.org/jira/browse/FLINK-17749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17749: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community manage its development. I see this issues has been marked as Minor but is unassigned and neither itself nor its Sub-Tasks have been updated for 180 days. I have gone ahead and marked it "stale-minor". If this ticket is still Minor, please either assign yourself or give an update. Afterwards, please remove the label or in 7 days the issue will be deprioritized. > Remove fromTableSource method from TableEnvironment > > > Key: FLINK-17749 > URL: https://issues.apache.org/jira/browse/FLINK-17749 > Project: Flink > Issue Type: Improvement > Components: Table SQL / API >Reporter: Kurt Young >Priority: Minor > Labels: auto-deprioritized-major, stale-minor > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (FLINK-17650) Impossible to set Security related configs as dynamic properties
[ https://issues.apache.org/jira/browse/FLINK-17650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17650: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community manage its development. I see this issues has been marked as Minor but is unassigned and neither itself nor its Sub-Tasks have been updated for 180 days. I have gone ahead and marked it "stale-minor". If this ticket is still Minor, please either assign yourself or give an update. Afterwards, please remove the label or in 7 days the issue will be deprioritized. > Impossible to set Security related configs as dynamic properties > > > Key: FLINK-17650 > URL: https://issues.apache.org/jira/browse/FLINK-17650 > Project: Flink > Issue Type: Bug > Components: Command Line Client >Reporter: Gyula Fora >Priority: Minor > Labels: auto-deprioritized-major, stale-minor > > The CliFrontend installs the Security context based on the cli.configuration > (CliFrontend#L985)which does not take into account dynamic properties (such > as -yD or -D depending on the executor) > This makes it impossible for instance to configure kerberos by setting these > configs as dynamic props. > We should first apply all the extra configs before installing the security > context and running the command. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (FLINK-17863) flink streaming sql read hive with lots small files need to control parallelism
[ https://issues.apache.org/jira/browse/FLINK-17863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17863: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community manage its development. I see this issues has been marked as Minor but is unassigned and neither itself nor its Sub-Tasks have been updated for 180 days. I have gone ahead and marked it "stale-minor". If this ticket is still Minor, please either assign yourself or give an update. Afterwards, please remove the label or in 7 days the issue will be deprioritized. > flink streaming sql read hive with lots small files need to control > parallelism > -- > > Key: FLINK-17863 > URL: https://issues.apache.org/jira/browse/FLINK-17863 > Project: Flink > Issue Type: Improvement > Components: Connectors / Hive >Affects Versions: 1.10.1 >Reporter: richt richt >Priority: Minor > Labels: auto-deprioritized-major, stale-minor > > the table wy.cartest has 19 rows with 19 files > so when i query the table use *streaming* mode it will require 19 slots , my > cluster cannot allocate so much resource to the task. > > Caused by: org.apache.flink.runtime.JobException: Vertex Source: > HiveTableSource(carid, time, num, var) TablePath: wy.cartest, Par > titionPruned: false, PartitionNums: null -> SinkConversionToTuple2's > parallelism (19) is higher than the max parallelism (2). Plea > se lower the parallelism or increase the max parallelism. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (FLINK-17575) KafkaException: Received exception when fetching the next record from XXX-14. If needed, please seek past the record to continue consumption.
[
https://issues.apache.org/jira/browse/FLINK-17575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-17575:
---
Labels: auto-deprioritized-major stale-minor (was:
auto-deprioritized-major)
I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help
the community manage its development. I see this issues has been marked as
Minor but is unassigned and neither itself nor its Sub-Tasks have been updated
for 180 days. I have gone ahead and marked it "stale-minor". If this ticket is
still Minor, please either assign yourself or give an update. Afterwards,
please remove the label or in 7 days the issue will be deprioritized.
> KafkaException: Received exception when fetching the next record from XXX-14.
> If needed, please seek past the record to continue consumption.
> -
>
> Key: FLINK-17575
> URL: https://issues.apache.org/jira/browse/FLINK-17575
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka
>Affects Versions: 1.10.0
>Reporter: Maxim Malykhin
>Priority: Minor
> Labels: auto-deprioritized-major, stale-minor
>
> Stream don't catch exception for bad packet in kafka, exception terminate
> thread.
> {code:java}
> org.apache.kafka.common.KafkaException: Received exception when fetching the
> next record from prod_netscout_ug_s1mme-14. If needed, please seek past the
> record to continue consumption.org.apache.kafka.common.KafkaException:
> Received exception when fetching the next record from
> prod_netscout_ug_s1mme-14. If needed, please seek past the record to continue
> consumption. at
> org.apache.kafka.clients.consumer.internals.Fetcher$CompletedFetch.fetchRecords(Fetcher.java:1522)
> at
> org.apache.kafka.clients.consumer.internals.Fetcher$CompletedFetch.access$1700(Fetcher.java:1377)
> at
> org.apache.kafka.clients.consumer.internals.Fetcher.fetchRecords(Fetcher.java:677)
> at
> org.apache.kafka.clients.consumer.internals.Fetcher.fetchedRecords(Fetcher.java:632)
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.pollForFetches(KafkaConsumer.java:1290)
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1248)
> at
> org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1173)
> at
> org.apache.flink.streaming.connectors.kafka.internal.KafkaConsumerThread.run(KafkaConsumerThread.java:253)Caused
> by: org.apache.kafka.common.KafkaException: Record batch for partition
> prod_netscout_ug_s1mme-14 at offset 22405513471 is invalid, cause: Record is
> corrupt (stored crc = 995400728, computed crc = 4153305836) at
> org.apache.kafka.clients.consumer.internals.Fetcher$CompletedFetch.maybeEnsureValid(Fetcher.java:1435)
> at
> org.apache.kafka.clients.consumer.internals.Fetcher$CompletedFetch.nextFetchedRecord(Fetcher.java:1479)
> at
> org.apache.kafka.clients.consumer.internals.Fetcher$CompletedFetch.fetchRecords(Fetcher.java:1536)
> ... 7 more
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Updated] (FLINK-17900) Listener for when Files are committed in StreamingFileSink
[ https://issues.apache.org/jira/browse/FLINK-17900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17900: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community manage its development. I see this issues has been marked as Minor but is unassigned and neither itself nor its Sub-Tasks have been updated for 180 days. I have gone ahead and marked it "stale-minor". If this ticket is still Minor, please either assign yourself or give an update. Afterwards, please remove the label or in 7 days the issue will be deprioritized. > Listener for when Files are committed in StreamingFileSink > -- > > Key: FLINK-17900 > URL: https://issues.apache.org/jira/browse/FLINK-17900 > Project: Flink > Issue Type: Improvement > Components: Connectors / FileSystem >Affects Versions: 1.10.0 >Reporter: Matthew McMahon >Priority: Minor > Labels: auto-deprioritized-major, stale-minor > > I have a scenario where once a file has been committed to S3 using the > StreamingFileSink (I am using Java), that I should notify some downstream > services. > The idea is to produce a message on a Kafka topic for the files as they are > finalized. > I am currently looking into how this might be possible, and considering using > reflection and/or checking the S3 bucket before/after the checkpoint is > committed. > Still trying to find a suitable way. > However I was thinking it would be great if possible to register a listener > that can be fired when StreamingFileSink commits a file. > Does something like this exist, that I'm not aware of (new to flink) or could > it be added? -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (FLINK-17848) Allow scala datastream api to create named sources
[ https://issues.apache.org/jira/browse/FLINK-17848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17848: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community manage its development. I see this issues has been marked as Minor but is unassigned and neither itself nor its Sub-Tasks have been updated for 180 days. I have gone ahead and marked it "stale-minor". If this ticket is still Minor, please either assign yourself or give an update. Afterwards, please remove the label or in 7 days the issue will be deprioritized. > Allow scala datastream api to create named sources > -- > > Key: FLINK-17848 > URL: https://issues.apache.org/jira/browse/FLINK-17848 > Project: Flink > Issue Type: Improvement > Components: API / DataStream, API / Scala >Reporter: Zack LB >Priority: Minor > Labels: auto-deprioritized-major, stale-minor > > Currently you can only provide a custom name to a source operator from the > java API. There is no matching API on the scala API. It would be nice to > allow scala to also name sources something custom. > I'm referring to this [api specifically|#L640] > The change would be as simple as adding a default parameter to that method > which mirrors the java api's default value "Custom Source". Or if preferred > could duplicate the method with a required argument that then passes the > value to the java function. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (FLINK-17919) KafkaConsumerThread should add ratelimiter functionality as well
[
https://issues.apache.org/jira/browse/FLINK-17919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-17919:
---
Labels: auto-deprioritized-major stale-minor (was:
auto-deprioritized-major)
I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help
the community manage its development. I see this issues has been marked as
Minor but is unassigned and neither itself nor its Sub-Tasks have been updated
for 180 days. I have gone ahead and marked it "stale-minor". If this ticket is
still Minor, please either assign yourself or give an update. Afterwards,
please remove the label or in 7 days the issue will be deprioritized.
> KafkaConsumerThread should add ratelimiter functionality as well
>
>
> Key: FLINK-17919
> URL: https://issues.apache.org/jira/browse/FLINK-17919
> Project: Flink
> Issue Type: Improvement
> Components: Connectors / Kafka
>Reporter: zhangminglei
>Priority: Minor
> Labels: auto-deprioritized-major, stale-minor
>
> Currently, {{KafkaConsumerThread}} within {{flink-connector-kafka-09}} has
> the ability of rateLimiter. However, under {{flink-connector-kafka}} does not
> own it. I would suggest we can add it as well if we could.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Updated] (FLINK-21533) Kafka011ITCase#testAllDeletes fails on azure
[
https://issues.apache.org/jira/browse/FLINK-21533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-21533:
---
Labels: auto-deprioritized-major auto-deprioritized-minor test-stability
(was: auto-deprioritized-major stale-minor test-stability)
Priority: Not a Priority (was: Minor)
This issue was labeled "stale-minor" 7 days ago and has not received any
updates so it is being deprioritized. If this ticket is actually Minor, please
raise the priority and ask a committer to assign you the issue or revive the
public discussion.
> Kafka011ITCase#testAllDeletes fails on azure
>
>
> Key: FLINK-21533
> URL: https://issues.apache.org/jira/browse/FLINK-21533
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka, Tests
>Affects Versions: 1.11.3
>Reporter: Dawid Wysakowicz
>Priority: Not a Priority
> Labels: auto-deprioritized-major, auto-deprioritized-minor,
> test-stability
>
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=13867=logs=3d12d40f-c62d-5ec4-6acc-0efe94cc3e89=e4f347ab-2a29-5d7c-3685-b0fcd2b6b051
> {code}
> 2021-02-26T22:27:56.9286925Z [ERROR]
> testAllDeletes(org.apache.flink.streaming.connectors.kafka.Kafka011ITCase)
> Time elapsed: 3.228 s <<< ERROR!
> 2021-02-26T22:27:56.9287994Z
> org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
> 2021-02-26T22:27:56.9288805Z at
> org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144)
> 2021-02-26T22:27:56.9290091Z at
> org.apache.flink.runtime.minicluster.MiniCluster.executeJobBlocking(MiniCluster.java:762)
> 2021-02-26T22:27:56.9290978Z at
> org.apache.flink.streaming.util.TestStreamEnvironment.execute(TestStreamEnvironment.java:77)
> 2021-02-26T22:27:56.9291926Z at
> org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1651)
> 2021-02-26T22:27:56.9293538Z at
> org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase.runAllDeletesTest(KafkaConsumerTestBase.java:1649)
> 2021-02-26T22:27:56.9294944Z at
> org.apache.flink.streaming.connectors.kafka.Kafka011ITCase.testAllDeletes(Kafka011ITCase.java:130)
> 2021-02-26T22:27:56.9295702Z at
> sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 2021-02-26T22:27:56.9296370Z at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 2021-02-26T22:27:56.9299360Z at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2021-02-26T22:27:56.9299955Z at
> java.lang.reflect.Method.invoke(Method.java:498)
> 2021-02-26T22:27:56.9300402Z at
> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
> 2021-02-26T22:27:56.9300897Z at
> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
> 2021-02-26T22:27:56.9301387Z at
> org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
> 2021-02-26T22:27:56.9301851Z at
> org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
> 2021-02-26T22:27:56.9302471Z at
> org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:298)
> 2021-02-26T22:27:56.9325899Z at
> org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:292)
> 2021-02-26T22:27:56.9327852Z at
> java.util.concurrent.FutureTask.run(FutureTask.java:266)
> 2021-02-26T22:27:56.9328934Z at java.lang.Thread.run(Thread.java:748)
> 2021-02-26T22:27:56.9329795Z Caused by:
> org.apache.flink.runtime.JobException: Recovery is suppressed by
> NoRestartBackoffTimeStrategy
> 2021-02-26T22:27:56.9330778Z at
> org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:118)
> 2021-02-26T22:27:56.9331904Z at
> org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:80)
> 2021-02-26T22:27:56.9333126Z at
> org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:206)
> 2021-02-26T22:27:56.9334090Z at
> org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:197)
> 2021-02-26T22:27:56.9335043Z at
> org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:189)
> 2021-02-26T22:27:56.9335946Z at
> org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:639)
> 2021-02-26T22:27:56.9336834Z at
> org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:397)
> 2021-02-26T22:27:56.9337698Z at
>
[jira] [Updated] (FLINK-21565) Support more integer types in TIMESTAMPADD
[
https://issues.apache.org/jira/browse/FLINK-21565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-21565:
---
Labels: auto-deprioritized-major auto-deprioritized-minor (was:
auto-deprioritized-major stale-minor)
Priority: Not a Priority (was: Minor)
This issue was labeled "stale-minor" 7 days ago and has not received any
updates so it is being deprioritized. If this ticket is actually Minor, please
raise the priority and ask a committer to assign you the issue or revive the
public discussion.
> Support more integer types in TIMESTAMPADD
> --
>
> Key: FLINK-21565
> URL: https://issues.apache.org/jira/browse/FLINK-21565
> Project: Flink
> Issue Type: New Feature
> Components: Table SQL / API
>Affects Versions: 1.12.1
>Reporter: Nico Kruber
>Priority: Not a Priority
> Labels: auto-deprioritized-major, auto-deprioritized-minor
> Attachments: flights-21565.csv
>
>
> At the moment, {{TIMESTAMPADD}} does not seem to support {{SMALLINT}} or
> {{TINYINT}} types which should be perfectly suitable for auto-conversion (in
> contrast to BIGINT or floating numbers where I would expect the user to cast
> it appropriately).
> With the attached file, executing these lines
> {code}
> CREATE TABLE `flights` (
> `_YEAR` CHAR(4),
> `_MONTH` CHAR(2),
> `_DAY` CHAR(2),
> `_SCHEDULED_DEPARTURE` CHAR(4),
> `SCHEDULED_DEPARTURE` AS TO_TIMESTAMP(`_YEAR` || '-' || `_MONTH` || '-' ||
> `_DAY` || ' ' || SUBSTRING(`_SCHEDULED_DEPARTURE` FROM 0 FOR 2) || ':' ||
> SUBSTRING(`_SCHEDULED_DEPARTURE` FROM 3) || ':00'),
> `_DEPARTURE_TIME` CHAR(4),
> `DEPARTURE_DELAY` TINYINT,
> `DEPARTURE_TIME` AS TIMESTAMPADD(MINUTE, `DEPARTURE_DELAY`,
> TO_TIMESTAMP(`_YEAR` || '-' || `_MONTH` || '-' || `_DAY` || ' ' ||
> SUBSTRING(`_SCHEDULED_DEPARTURE` FROM 0 FOR 2) || ':' ||
> SUBSTRING(`_SCHEDULED_DEPARTURE` FROM 3) || ':00'))
> ) WITH (
> 'connector' = 'filesystem',
> 'path' = 'file:///tmp/kaggle-flight-delay/flights-21565.csv',
> 'format' = 'csv'
> );
> SELECT * FROM flights;
> {code}
> currently fail with the following exception (similarly for {{SMALLINT}}):
> {code}
> org.apache.flink.table.planner.codegen.CodeGenException: Unsupported casting
> from TINYINT to INTERVAL SECOND(3).
> at
> org.apache.flink.table.planner.codegen.calls.ScalarOperatorGens$.numericCasting(ScalarOperatorGens.scala:2352)
> ~[flink-table-blink_2.12-1.12.1.jar:1.12.1]
> at
> org.apache.flink.table.planner.codegen.calls.ScalarOperatorGens$.generateBinaryArithmeticOperator(ScalarOperatorGens.scala:93)
> ~[flink-table-blink_2.12-1.12.1.jar:1.12.1]
> at
> org.apache.flink.table.planner.codegen.ExprCodeGenerator.generateCallExpression(ExprCodeGenerator.scala:590)
> ~[flink-table-blink_2.12-1.12.1.jar:1.12.1]
> at
> org.apache.flink.table.planner.codegen.ExprCodeGenerator.visitCall(ExprCodeGenerator.scala:529)
> ~[flink-table-blink_2.12-1.12.1.jar:1.12.1]
> at
> org.apache.flink.table.planner.codegen.ExprCodeGenerator.visitCall(ExprCodeGenerator.scala:56)
> ~[flink-table-blink_2.12-1.12.1.jar:1.12.1]
> at org.apache.calcite.rex.RexCall.accept(RexCall.java:174)
> ~[flink-table_2.12-1.12.1.jar:1.12.1]
> at
> org.apache.flink.table.planner.codegen.ExprCodeGenerator.$anonfun$visitCall$2(ExprCodeGenerator.scala:526)
> ~[flink-table-blink_2.12-1.12.1.jar:1.12.1]
> at
> scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:233)
> ~[flink-dist_2.12-1.12.1.jar:1.12.1]
> at
> scala.collection.mutable.ResizableArray.foreach(ResizableArray.scala:58)
> ~[flink-dist_2.12-1.12.1.jar:1.12.1]
> at
> scala.collection.mutable.ResizableArray.foreach$(ResizableArray.scala:51)
> ~[flink-dist_2.12-1.12.1.jar:1.12.1]
> at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47)
> ~[flink-dist_2.12-1.12.1.jar:1.12.1]
> at scala.collection.TraversableLike.map(TraversableLike.scala:233)
> ~[flink-dist_2.12-1.12.1.jar:1.12.1]
> at scala.collection.TraversableLike.map$(TraversableLike.scala:226)
> ~[flink-dist_2.12-1.12.1.jar:1.12.1]
> at scala.collection.AbstractTraversable.map(Traversable.scala:104)
> ~[flink-dist_2.12-1.12.1.jar:1.12.1]
> at
> org.apache.flink.table.planner.codegen.ExprCodeGenerator.visitCall(ExprCodeGenerator.scala:517)
> ~[flink-table-blink_2.12-1.12.1.jar:1.12.1]
> at
> org.apache.flink.table.planner.codegen.ExprCodeGenerator.visitCall(ExprCodeGenerator.scala:56)
> ~[flink-table-blink_2.12-1.12.1.jar:1.12.1]
> at org.apache.calcite.rex.RexCall.accept(RexCall.java:174)
> ~[flink-table_2.12-1.12.1.jar:1.12.1]
> at
> org.apache.flink.table.planner.codegen.ExprCodeGenerator.$anonfun$visitCall$2(ExprCodeGenerator.scala:526)
>
[jira] [Updated] (FLINK-21493) Flink Command Line Interface Document can add command usage
[ https://issues.apache.org/jira/browse/FLINK-21493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21493: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major stale-minor) Priority: Not a Priority (was: Minor) This issue was labeled "stale-minor" 7 days ago and has not received any updates so it is being deprioritized. If this ticket is actually Minor, please raise the priority and ask a committer to assign you the issue or revive the public discussion. > Flink Command Line Interface Document can add command usage > --- > > Key: FLINK-21493 > URL: https://issues.apache.org/jira/browse/FLINK-21493 > Project: Flink > Issue Type: Improvement > Components: Documentation >Affects Versions: 1.12.0 >Reporter: zhisheng >Priority: Not a Priority > Labels: auto-deprioritized-major, auto-deprioritized-minor > > Flink 1.11 document has command usage > [https://ci.apache.org/projects/flink/flink-docs-release-1.11/ops/cli.html#usage] > but Flink 1.12 the usage was removed just list the cli actions > [https://ci.apache.org/projects/flink/flink-docs-release-1.12/deployment/cli.html#cli-actions|https://ci.apache.org/projects/flink/flink-docs-release-1.12/deployment/cli.html#cli-actions.] > Sometime find the actions parameter and usage information is inconvenient, > can community add the original usage document? -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Updated] (FLINK-21551) FlinkKafkaProducerITCase.testHappyPath fail
[
https://issues.apache.org/jira/browse/FLINK-21551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-21551:
---
Labels: auto-deprioritized-major auto-deprioritized-minor test-stability
(was: auto-deprioritized-major stale-minor test-stability)
Priority: Not a Priority (was: Minor)
This issue was labeled "stale-minor" 7 days ago and has not received any
updates so it is being deprioritized. If this ticket is actually Minor, please
raise the priority and ask a committer to assign you the issue or revive the
public discussion.
> FlinkKafkaProducerITCase.testHappyPath fail
> ---
>
> Key: FLINK-21551
> URL: https://issues.apache.org/jira/browse/FLINK-21551
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka
>Affects Versions: 1.11.3
>Reporter: Guowei Ma
>Priority: Not a Priority
> Labels: auto-deprioritized-major, auto-deprioritized-minor,
> test-stability
>
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=13955=logs=961f8f81-6b52-53df-09f6-7291a2e4af6a=2f99feaa-7a9b-5916-4c1c-5e61f395079e
> {code:java}
> [ERROR] Tests run: 10, Failures: 0, Errors: 1, Skipped: 0, Time elapsed:
> 47.008 s <<< FAILURE! - in
> org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase [ERROR]
> testHappyPath(org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase)
> Time elapsed: 12.865 s <<< ERROR! java.util.NoSuchElementException at
> org.apache.kafka.common.utils.AbstractIterator.next(AbstractIterator.java:52)
> at
> org.apache.flink.shaded.guava18.com.google.common.collect.Iterators.getOnlyElement(Iterators.java:302)
> at
> org.apache.flink.shaded.guava18.com.google.common.collect.Iterables.getOnlyElement(Iterables.java:289)
> at
> org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase.assertRecord(FlinkKafkaProducerITCase.java:212)
> at
> org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerITCase.testHappyPath(FlinkKafkaProducerITCase.java:91)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:498) at
> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
> at
> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
> at
> org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
> at
> org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
> at
> org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:298)
> at
> org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:292)
> at java.util.concurrent.FutureTask.run(FutureTask.java:266) at
> java.lang.Thread.run(Thread.java:748) [INFO] [INFO] Results: [INFO] [ERROR]
> Errors: [ERROR] FlinkKafkaProducerITCase.testHappyPath:91->assertRecord:212 »
> NoSuchElement
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Updated] (FLINK-21652) Elasticsearch6DynamicSinkITCase.testWritingDocumentsFromTableApi failed because of throwing SocketTimeoutException during the closing stage.
[
https://issues.apache.org/jira/browse/FLINK-21652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-21652:
---
Labels: auto-deprioritized-major auto-deprioritized-minor test-stability
(was: auto-deprioritized-major stale-minor test-stability)
Priority: Not a Priority (was: Minor)
This issue was labeled "stale-minor" 7 days ago and has not received any
updates so it is being deprioritized. If this ticket is actually Minor, please
raise the priority and ask a committer to assign you the issue or revive the
public discussion.
> Elasticsearch6DynamicSinkITCase.testWritingDocumentsFromTableApi failed
> because of throwing SocketTimeoutException during the closing stage.
>
>
> Key: FLINK-21652
> URL: https://issues.apache.org/jira/browse/FLINK-21652
> Project: Flink
> Issue Type: Bug
> Components: Connectors / ElasticSearch
>Affects Versions: 1.13.0
>Reporter: Guowei Ma
>Priority: Not a Priority
> Labels: auto-deprioritized-major, auto-deprioritized-minor,
> test-stability
>
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=14263=logs=3d12d40f-c62d-5ec4-6acc-0efe94cc3e89=5d6e4255-0ea8-5e2a-f52c-c881b7872361
> {code:java}
> 2021-03-07T23:12:11.0702985Z [ERROR]
> testWritingDocumentsFromTableApi(org.apache.flink.streaming.connectors.elasticsearch.table.Elasticsearch6DynamicSinkITCase)
> Time elapsed: 31.256 s <<< ERROR!
> 2021-03-07T23:12:11.0704247Z java.util.concurrent.ExecutionException:
> org.apache.flink.table.api.TableException: Failed to wait job finish
> 2021-03-07T23:12:11.0705203Z at
> java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
> 2021-03-07T23:12:11.0705982Z at
> java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
> 2021-03-07T23:12:11.0706791Z at
> org.apache.flink.table.api.internal.TableResultImpl.awaitInternal(TableResultImpl.java:123)
> 2021-03-07T23:12:11.0707583Z at
> org.apache.flink.table.api.internal.TableResultImpl.await(TableResultImpl.java:86)
> 2021-03-07T23:12:11.0708850Z at
> org.apache.flink.streaming.connectors.elasticsearch.table.Elasticsearch6DynamicSinkITCase.testWritingDocumentsFromTableApi(Elasticsearch6DynamicSinkITCase.java:205)
> 2021-03-07T23:12:11.0709804Z at
> sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 2021-03-07T23:12:11.0710479Z at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 2021-03-07T23:12:11.0711251Z at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2021-03-07T23:12:11.0711974Z at
> java.lang.reflect.Method.invoke(Method.java:498)
> 2021-03-07T23:12:11.0712663Z at
> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
> 2021-03-07T23:12:11.0713466Z at
> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
> 2021-03-07T23:12:11.0715464Z at
> org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
> 2021-03-07T23:12:11.0716070Z at
> org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
> 2021-03-07T23:12:11.0716576Z at
> org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
> 2021-03-07T23:12:11.0717278Z at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
> 2021-03-07T23:12:11.0717873Z at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
> 2021-03-07T23:12:11.0718540Z at
> org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
> 2021-03-07T23:12:11.0718940Z at
> org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
> 2021-03-07T23:12:11.0719362Z at
> org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
> 2021-03-07T23:12:11.0719792Z at
> org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
> 2021-03-07T23:12:11.0720207Z at
> org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
> 2021-03-07T23:12:11.0720728Z at
> org.testcontainers.containers.FailureDetectingExternalResource$1.evaluate(FailureDetectingExternalResource.java:30)
> 2021-03-07T23:12:11.0721353Z at
> org.junit.rules.RunRules.evaluate(RunRules.java:20)
> 2021-03-07T23:12:11.0721940Z at
> org.junit.runners.ParentRunner.run(ParentRunner.java:363)
> 2021-03-07T23:12:11.0753352Z at
> org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:365)
> 2021-03-07T23:12:11.0754394Z at
> org.apache.maven.surefire.junit4.JUnit4Provider.executeWithRerun(JUnit4Provider.java:273)
> 2021-03-07T23:12:11.0755260Z at
>
[jira] [Updated] (FLINK-21583) Allow comments in CSV format without having to ignore parse errors
[
https://issues.apache.org/jira/browse/FLINK-21583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-21583:
---
Labels: auto-deprioritized-major auto-deprioritized-minor (was:
auto-deprioritized-major stale-minor)
Priority: Not a Priority (was: Minor)
This issue was labeled "stale-minor" 7 days ago and has not received any
updates so it is being deprioritized. If this ticket is actually Minor, please
raise the priority and ask a committer to assign you the issue or revive the
public discussion.
> Allow comments in CSV format without having to ignore parse errors
> --
>
> Key: FLINK-21583
> URL: https://issues.apache.org/jira/browse/FLINK-21583
> Project: Flink
> Issue Type: Improvement
> Components: Formats (JSON, Avro, Parquet, ORC, SequenceFile), Table
> SQL / Ecosystem
>Affects Versions: 1.12.1
>Reporter: Nico Kruber
>Priority: Not a Priority
> Labels: auto-deprioritized-major, auto-deprioritized-minor
>
> Currently, when you pass {{'csv.allow-comments' = 'true'}} to a table
> definition, you also have to set {{'csv.ignore-parse-errors' = 'true'}} to
> actually skip the commented-out line (and the docs mention this prominently
> as well). This, however, may mask actual parsing errors that you want to be
> notified of.
> I would like to propose that {{allow-comments}} actually also skips the
> commented-out lines automatically because these shouldn't be used anyway.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Updated] (FLINK-21584) Support UNNEST in LEFT JOINs
[
https://issues.apache.org/jira/browse/FLINK-21584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-21584:
---
Labels: auto-deprioritized-major auto-deprioritized-minor (was:
auto-deprioritized-major stale-minor)
Priority: Not a Priority (was: Minor)
This issue was labeled "stale-minor" 7 days ago and has not received any
updates so it is being deprioritized. If this ticket is actually Minor, please
raise the priority and ask a committer to assign you the issue or revive the
public discussion.
> Support UNNEST in LEFT JOINs
>
>
> Key: FLINK-21584
> URL: https://issues.apache.org/jira/browse/FLINK-21584
> Project: Flink
> Issue Type: New Feature
> Components: Table SQL / API
>Affects Versions: 1.12.1
>Reporter: Nico Kruber
>Priority: Not a Priority
> Labels: auto-deprioritized-major, auto-deprioritized-minor
>
> Currently, UNNEST (for arrays and maps) is only supported in CROSS JOIN
> operations, but you may actually also want this in a LEFT JOIN fashion in
> which case you would get {{NULL}} values for the expanded fields.
> h1. Example
> {code:sql}
> CREATE TEMPORARY VIEW input ( f1, f2 )
> AS VALUES ('A', STR_TO_MAP('')), ('B', STR_TO_MAP('1, 2'));
> SELECT * FROM input LEFT JOIN UNNEST(f2);
> {code}
> This currently results in the following exception:
> {code}
> org.apache.flink.table.api.ValidationException: SQL validation failed. From
> line 1, column 26 to line 1, column 29: INNER, LEFT, RIGHT or FULL join
> requires a condition (NATURAL keyword or ON or USING clause)
> at
> org.apache.flink.table.planner.calcite.FlinkPlannerImpl.org$apache$flink$table$planner$calcite$FlinkPlannerImpl$$validate(FlinkPlannerImpl.scala:152)
> ~[flink-table-blink_2.12-1.12.1.jar:1.12.1]
> at
> org.apache.flink.table.planner.calcite.FlinkPlannerImpl.validate(FlinkPlannerImpl.scala:111)
> ~[flink-table-blink_2.12-1.12.1.jar:1.12.1]
> at
> org.apache.flink.table.planner.operations.SqlToOperationConverter.convert(SqlToOperationConverter.java:189)
> ~[flink-table-blink_2.12-1.12.1.jar:1.12.1]
> at
> org.apache.flink.table.planner.delegation.ParserImpl.parse(ParserImpl.java:77)
> ~[flink-table-blink_2.12-1.12.1.jar:1.12.1]
> at
> org.apache.flink.table.client.gateway.local.LocalExecutor$1.lambda$parse$0(LocalExecutor.java:336)
> ~[flink-sql-client_2.12-1.12.1.jar:1.12.1]
> at
> org.apache.flink.table.client.gateway.local.ExecutionContext.wrapClassLoader(ExecutionContext.java:256)
> ~[flink-sql-client_2.12-1.12.1.jar:1.12.1]
> at
> org.apache.flink.table.client.gateway.local.LocalExecutor$1.parse(LocalExecutor.java:336)
> ~[flink-sql-client_2.12-1.12.1.jar:1.12.1]
> at
> org.apache.flink.table.client.cli.SqlCommandParser.parseBySqlParser(SqlCommandParser.java:99)
> ~[flink-sql-client_2.12-1.12.1.jar:1.12.1]
> ... 6 more
> Caused by: org.apache.calcite.runtime.CalciteContextException: From line 1,
> column 26 to line 1, column 29: INNER, LEFT, RIGHT or FULL join requires a
> condition (NATURAL keyword or ON or USING clause)
> at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native
> Method) ~[?:1.8.0_282]
> at
> sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
> ~[?:1.8.0_282]
> at
> sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
> ~[?:1.8.0_282]
> at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
> ~[?:1.8.0_282]
> at
> org.apache.calcite.runtime.Resources$ExInstWithCause.ex(Resources.java:467)
> ~[flink-table_2.12-1.12.1.jar:1.12.1]
> at org.apache.calcite.sql.SqlUtil.newContextException(SqlUtil.java:883)
> ~[flink-table_2.12-1.12.1.jar:1.12.1]
> at org.apache.calcite.sql.SqlUtil.newContextException(SqlUtil.java:868)
> ~[flink-table_2.12-1.12.1.jar:1.12.1]
> at
> org.apache.calcite.sql.validate.SqlValidatorImpl.newValidationError(SqlValidatorImpl.java:5043)
> ~[flink-table_2.12-1.12.1.jar:1.12.1]
> at
> org.apache.calcite.sql.validate.SqlValidatorImpl.validateJoin(SqlValidatorImpl.java:)
> ~[flink-table_2.12-1.12.1.jar:1.12.1]
> at
> org.apache.flink.table.planner.calcite.FlinkCalciteSqlValidator.validateJoin(FlinkCalciteSqlValidator.java:100)
> ~[flink-table-blink_2.12-1.12.1.jar:1.12.1]
> at
> org.apache.calcite.sql.validate.SqlValidatorImpl.validateFrom(SqlValidatorImpl.java:3196)
> ~[flink-table_2.12-1.12.1.jar:1.12.1]
> at
> org.apache.calcite.sql.validate.SqlValidatorImpl.validateSelect(SqlValidatorImpl.java:3461)
> ~[flink-table_2.12-1.12.1.jar:1.12.1]
> at
> org.apache.calcite.sql.validate.SelectNamespace.validateImpl(SelectNamespace.java:60)
> ~[flink-table_2.12-1.12.1.jar:1.12.1]
[jira] [Updated] (FLINK-21446) KafkaProducerTestBase.testExactlyOnce Fail
[
https://issues.apache.org/jira/browse/FLINK-21446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-21446:
---
Labels: auto-deprioritized-major auto-deprioritized-minor test-stability
(was: auto-deprioritized-major stale-minor test-stability)
Priority: Not a Priority (was: Minor)
This issue was labeled "stale-minor" 7 days ago and has not received any
updates so it is being deprioritized. If this ticket is actually Minor, please
raise the priority and ask a committer to assign you the issue or revive the
public discussion.
> KafkaProducerTestBase.testExactlyOnce Fail
> --
>
> Key: FLINK-21446
> URL: https://issues.apache.org/jira/browse/FLINK-21446
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka
>Affects Versions: 1.11.3
>Reporter: Guowei Ma
>Priority: Not a Priority
> Labels: auto-deprioritized-major, auto-deprioritized-minor,
> test-stability
>
> [https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=13612=logs=d44f43ce-542c-597d-bf94-b0718c71e5e8=34f486e1-e1e4-5dd2-9c06-bfdd9b9c74a8]
>
> {code:java}
> 22:52:12,032 [ Checkpoint Timer] INFO
> org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Checkpoint 18
> of job 84164b7efcb41ca524cc7076030d1f91 expired before completing.
> 22:52:12,033 [ Checkpoint Timer] INFO
> org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Triggering
> checkpoint 19 (type=CHECKPOINT) @ 1614034332033 for job
> 84164b7efcb41ca524cc7076030d1f91. 22:52:12,036 [Source: Custom Source -> Map
> -> Sink: Unnamed (1/1)] INFO
> org.apache.flink.streaming.connectors.kafka.internal.FlinkKafkaProducer [] -
> Flushing new partitions 22:52:12,036
> [flink-akka.actor.default-dispatcher-172] INFO
> org.apache.flink.runtime.jobmaster.JobMaster [] - Trying to recover from a
> global failure. org.apache.flink.util.FlinkRuntimeException: Exceeded
> checkpoint tolerable failure threshold. at
> org.apache.flink.runtime.checkpoint.CheckpointFailureManager.handleJobLevelCheckpointException(CheckpointFailureManager.java:68)
> ~[flink-runtime_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT] at
> org.apache.flink.runtime.checkpoint.CheckpointCoordinator.abortPendingCheckpoint(CheckpointCoordinator.java:1892)
> ~[flink-runtime_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT] at
> org.apache.flink.runtime.checkpoint.CheckpointCoordinator.abortPendingCheckpoint(CheckpointCoordinator.java:1869)
> ~[flink-runtime_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT] at
> org.apache.flink.runtime.checkpoint.CheckpointCoordinator.access$600(CheckpointCoordinator.java:93)
> ~[flink-runtime_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT] at
> org.apache.flink.runtime.checkpoint.CheckpointCoordinator$CheckpointCanceller.run(CheckpointCoordinator.java:2006)
> ~[flink-runtime_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT] at
> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
> ~[?:1.8.0_275] at java.util.concurrent.FutureTask.run(FutureTask.java:266)
> ~[?:1.8.0_275] at
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
> ~[?:1.8.0_275] at
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
> ~[?:1.8.0_275] at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> ~[?:1.8.0_275] at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> ~[?:1.8.0_275] at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_275]
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Updated] (FLINK-21568) Navigating in SQL client can lead to SqlExecutionException
[
https://issues.apache.org/jira/browse/FLINK-21568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-21568:
---
Labels: auto-deprioritized-major auto-deprioritized-minor (was:
auto-deprioritized-major stale-minor)
Priority: Not a Priority (was: Minor)
This issue was labeled "stale-minor" 7 days ago and has not received any
updates so it is being deprioritized. If this ticket is actually Minor, please
raise the priority and ask a committer to assign you the issue or revive the
public discussion.
> Navigating in SQL client can lead to SqlExecutionException
> --
>
> Key: FLINK-21568
> URL: https://issues.apache.org/jira/browse/FLINK-21568
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Client
>Affects Versions: 1.12.1
>Reporter: Nico Kruber
>Priority: Not a Priority
> Labels: auto-deprioritized-major, auto-deprioritized-minor
>
> Pressing 'p' in the SQL CLI's result browser before any result is available
> will result in the following exception being thrown:
> {code}
> 2021-03-02 18:27:05,153 WARN org.apache.flink.table.client.cli.CliClient
> [] - Could not execute SQL statement.
> org.apache.flink.table.client.gateway.SqlExecutionException: Invalid page '1'.
> at
> org.apache.flink.table.client.gateway.local.result.MaterializedCollectStreamResult.retrievePage(MaterializedCollectStreamResult.java:177)
> ~[flink-sql-client_2.12-1.12.1.jar:1.12.1]
> at
> org.apache.flink.table.client.gateway.local.LocalExecutor.retrieveResultPage(LocalExecutor.java:415)
> ~[flink-sql-client_2.12-1.12.1.jar:1.12.1]
> at
> org.apache.flink.table.client.cli.CliTableResultView.updatePage(CliTableResultView.java:293)
> ~[flink-sql-client_2.12-1.12.1.jar:1.12.1]
> at
> org.apache.flink.table.client.cli.CliTableResultView.gotoPreviousPage(CliTableResultView.java:381)
> ~[flink-sql-client_2.12-1.12.1.jar:1.12.1]
> at
> org.apache.flink.table.client.cli.CliTableResultView.evaluate(CliTableResultView.java:183)
> ~[flink-sql-client_2.12-1.12.1.jar:1.12.1]
> at
> org.apache.flink.table.client.cli.CliTableResultView.evaluate(CliTableResultView.java:50)
> ~[flink-sql-client_2.12-1.12.1.jar:1.12.1]
> at org.apache.flink.table.client.cli.CliView.open(CliView.java:125)
> ~[flink-sql-client_2.12-1.12.1.jar:1.12.1]
> at
> org.apache.flink.table.client.cli.CliClient.callSelect(CliClient.java:675)
> ~[flink-sql-client_2.12-1.12.1.jar:1.12.1]
> at
> org.apache.flink.table.client.cli.CliClient.callCommand(CliClient.java:323)
> ~[flink-sql-client_2.12-1.12.1.jar:1.12.1]
> at java.util.Optional.ifPresent(Optional.java:159) [?:1.8.0_282]
> at org.apache.flink.table.client.cli.CliClient.open(CliClient.java:214)
> [flink-sql-client_2.12-1.12.1.jar:1.12.1]
> at org.apache.flink.table.client.SqlClient.openCli(SqlClient.java:144)
> [flink-sql-client_2.12-1.12.1.jar:1.12.1]
> at org.apache.flink.table.client.SqlClient.start(SqlClient.java:115)
> [flink-sql-client_2.12-1.12.1.jar:1.12.1]
> at org.apache.flink.table.client.SqlClient.main(SqlClient.java:201)
> [flink-sql-client_2.12-1.12.1.jar:1.12.1]
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[GitHub] [flink] flinkbot edited a comment on pull request #17387: [FLINK-23486][state] ChangelogUploader metrics
flinkbot edited a comment on pull request #17387: URL: https://github.com/apache/flink/pull/17387#issuecomment-930245327 ## CI report: * 440340a1c25c8678f019fdeb802623704f0963d9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26058) * 1736c549da6932a76be1268ba1f2091b825d3925 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26071) * d8834dea7c7bb6c3fb0005137ede85ee9e98518d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17387: [FLINK-23486][state] ChangelogUploader metrics
flinkbot edited a comment on pull request #17387: URL: https://github.com/apache/flink/pull/17387#issuecomment-930245327 ## CI report: * 440340a1c25c8678f019fdeb802623704f0963d9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26058) * 1736c549da6932a76be1268ba1f2091b825d3925 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26071) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17387: [FLINK-23486][state] ChangelogUploader metrics
flinkbot edited a comment on pull request #17387: URL: https://github.com/apache/flink/pull/17387#issuecomment-930245327 ## CI report: * 440340a1c25c8678f019fdeb802623704f0963d9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26058) * 1736c549da6932a76be1268ba1f2091b825d3925 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26071) * d8834dea7c7bb6c3fb0005137ede85ee9e98518d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17387: [FLINK-23486][state] ChangelogUploader metrics
flinkbot edited a comment on pull request #17387: URL: https://github.com/apache/flink/pull/17387#issuecomment-930245327 ## CI report: * 440340a1c25c8678f019fdeb802623704f0963d9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26058) * 1736c549da6932a76be1268ba1f2091b825d3925 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26071) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17387: [WIP][FLINK-23486][state] ChangelogUploader metrics
flinkbot edited a comment on pull request #17387: URL: https://github.com/apache/flink/pull/17387#issuecomment-930245327 ## CI report: * 440340a1c25c8678f019fdeb802623704f0963d9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26058) * 1736c549da6932a76be1268ba1f2091b825d3925 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26071) * d8834dea7c7bb6c3fb0005137ede85ee9e98518d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17387: [WIP][FLINK-23486][state] ChangelogUploader metrics
flinkbot edited a comment on pull request #17387: URL: https://github.com/apache/flink/pull/17387#issuecomment-930245327 ## CI report: * 440340a1c25c8678f019fdeb802623704f0963d9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26058) * 1736c549da6932a76be1268ba1f2091b825d3925 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17658: [FLINK-24684][table-planner] Add to string cast rules using the new CastRule stack
flinkbot edited a comment on pull request #17658: URL: https://github.com/apache/flink/pull/17658#issuecomment-958884763 ## CI report: * 7dfe3c64086dbe4ef1981c8e62512cb34552348b UNKNOWN * e9d39e4981e0daf3aa8678d15cbe23e44cc829ac Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26056) * 2b2ea981bbd50f98728012ec5c6d0b2aff946361 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26062) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17653: FLINK SQL checkpoint不生效
flinkbot edited a comment on pull request #17653: URL: https://github.com/apache/flink/pull/17653#issuecomment-958686553 ## CI report: * 0f14e4dd9bd38782b90a6a5633fad0d172421e86 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26037) * 237fb3a04e81602238b87ffc24423fc6f4cfe0ce Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26063) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [flink] flinkbot edited a comment on pull request #17658: [FLINK-24684][table-planner] Add to string cast rules using the new CastRule stack
flinkbot edited a comment on pull request #17658: URL: https://github.com/apache/flink/pull/17658#issuecomment-958884763 ## CI report: * 7dfe3c64086dbe4ef1981c8e62512cb34552348b UNKNOWN * cbd34f22054a70de3d91d6508b05fdd7d7ae0cc3 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26051) * e9d39e4981e0daf3aa8678d15cbe23e44cc829ac Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26056) * 2b2ea981bbd50f98728012ec5c6d0b2aff946361 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=26062) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
