[GitHub] [flink] aihai commented on pull request #18150: [hotfix][docs] Fix incorrect dependency and markdown format
aihai commented on pull request #18150: URL: https://github.com/apache/flink/pull/18150#issuecomment-1000709419 Sorry for my wrong expression. What I mean is confusing about what to write in one commit message for the two different commits after squashed the two commits into one commit. I should commit them separately in different PR. -- 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 #17873: [FLINK-25009][CLI] Output slotSharingGroup as part of JsonGraph
flinkbot edited a comment on pull request #17873: URL: https://github.com/apache/flink/pull/17873#issuecomment-975923151 ## CI report: * e7898cfe6876c6dfd71272e8aa2b6b8593948bd7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28068) * 75cf56f6bd1755177fd6bd30e987ee6b925b093d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28572) 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 #17873: [FLINK-25009][CLI] Output slotSharingGroup as part of JsonGraph
flinkbot edited a comment on pull request #17873: URL: https://github.com/apache/flink/pull/17873#issuecomment-975923151 ## CI report: * e7898cfe6876c6dfd71272e8aa2b6b8593948bd7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28068) * 75cf56f6bd1755177fd6bd30e987ee6b925b093d 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 #18196: [FLINK-24270][checkpoint] Refactor the tests related to the VertexFinishedStateChecker
flinkbot edited a comment on pull request #18196: URL: https://github.com/apache/flink/pull/18196#issuecomment-1000619056 ## CI report: * 2af5225d59633854c7a5ed23cddf913d88c73b75 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28561) 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 #16635: [hotfix][connector-jdbc] Fix a method name typo in postgres unit test.
flinkbot edited a comment on pull request #16635: URL: https://github.com/apache/flink/pull/16635#issuecomment-888991854 ## CI report: * 0b154cc55ffdc5698f756d63367d6bf5ed2030d4 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28565) 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 #18199: [FLINK-25183] Optimize changelog normalize for the managed table upse…
flinkbot edited a comment on pull request #18199: URL: https://github.com/apache/flink/pull/18199#issuecomment-1000699581 ## CI report: * 823561319b32301e76b142cea8d514d9fe651887 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28571) 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 #18148: [FLINK-25372] Add thread dump feature for jobmanager
flinkbot edited a comment on pull request #18148: URL: https://github.com/apache/flink/pull/18148#issuecomment-997327937 ## CI report: * 89d3e84018bfad7dd3e5bf34f1864c2923b7f19e Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28560) * 1e7ac1c81e93139fe2c02f16931767eea595d622 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28563) * 92bcfd7a84d150a3d5f7d9d60ba17405368a34b1 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28568) 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 #18199: [FLINK-25183] Optimize changelog normalize for the managed table upse…
flinkbot commented on pull request #18199: URL: https://github.com/apache/flink/pull/18199#issuecomment-1000699581 ## CI report: * 823561319b32301e76b142cea8d514d9fe651887 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-25439) StreamExecCalc collect new StreamRecord to Downstream lost timestamp Attributes
[ https://issues.apache.org/jira/browse/FLINK-25439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] HunterHunter updated FLINK-25439: - Affects Version/s: 1.14.2 > StreamExecCalc collect new StreamRecord to Downstream lost timestamp > Attributes > --- > > Key: FLINK-25439 > URL: https://issues.apache.org/jira/browse/FLINK-25439 > Project: Flink > Issue Type: Bug > Components: Table SQL / Planner >Affects Versions: 1.14.2 >Reporter: HunterHunter >Priority: Major > Attachments: image-2021-12-24-10-57-01-479.png, > image-2021-12-24-10-58-25-304.png > > > When we read data from kafkasource, we can see in SourceReaderBase.pollNext > that the record has a timestamp attribute, but after StreamExecCalc the > downstream receives the streamrecord and the timestamp attribute is missing > -- This message was sent by Atlassian Jira (v8.20.1#820001)
[GitHub] [flink] flinkbot commented on pull request #18199: [FLINK-25183] Optimize changelog normalize for the managed table upse…
flinkbot commented on pull request #18199: URL: https://github.com/apache/flink/pull/18199#issuecomment-1000698593 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 823561319b32301e76b142cea8d514d9fe651887 (Fri Dec 24 07:29:26 UTC 2021) **Warnings:** * No documentation files were touched! Remember to keep the Flink docs up to date! 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 edited a comment on pull request #18145: [FLINK-25368][connectors/kafka] Substitute KafkaConsumer with AdminClient when getting offsets
flinkbot edited a comment on pull request #18145: URL: https://github.com/apache/flink/pull/18145#issuecomment-997131565 ## CI report: * 6d14f13f549a87c5982e9b23de20718bd83e13b6 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28559) 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 #18102: [FLINK-25033][runtime] Let some scheduler components updatable
flinkbot edited a comment on pull request #18102: URL: https://github.com/apache/flink/pull/18102#issuecomment-993332110 ## CI report: * 3bb15a5495d1626bded0929f766c179edfafd995 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28557) 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 #17833: [FLINK-24785][runtime] Relocate RocksDB's log under flink log directory by default
flinkbot edited a comment on pull request #17833: URL: https://github.com/apache/flink/pull/17833#issuecomment-973807642 ## CI report: * 003e60ead8f8920e66bf5235d03497298eb97d9c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28564) 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-25183) Optimize changelog normalize for the managed table upsert mode
[ https://issues.apache.org/jira/browse/FLINK-25183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25183: --- Labels: pull-request-available (was: ) > Optimize changelog normalize for the managed table upsert mode > -- > > Key: FLINK-25183 > URL: https://issues.apache.org/jira/browse/FLINK-25183 > Project: Flink > Issue Type: Sub-task >Reporter: Jingsong Lee >Assignee: Lsw_aka_laplace >Priority: Major > Labels: pull-request-available > Fix For: 1.15.0 > > > The upsert mode of managed table preserves the complete delete message and > avoids normalization for the following downstream operators: > * Upsert sink: Upsert sink only requires upsert inputs without UPDATE_BEFORE. > * Join: Join for unique inputs will store records by unique key. It can work > without UPDATE_BEFORE. -- This message was sent by Atlassian Jira (v8.20.1#820001)
[GitHub] [flink] shouweikun opened a new pull request #18199: [FLINK-25183] Optimize changelog normalize for the managed table upse…
shouweikun opened a new pull request #18199: URL: https://github.com/apache/flink/pull/18199 …rt mode ## What is the purpose of the change Optimize `ChangelogNormalize` for `ManagedTable` in upsert mode. ## Brief change log - Expose ManagedTableListener#isManagedTable. - Changes in `FlinkChangelogModeInferenceProgram` and `ChangelogNormalize` for judging and eliminating `ChangelogNormalize` if possible. ## Verifying this change This change added tests and can be verified as follows: Tests in `ChangelogModeInferenceTest` address changes mentioned above. *(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): (no) - The public API, i.e., is any changed class annotated with `@Public(Evolving)`: (no) - The serializers: (no) - The runtime per-record code paths (performance sensitive): (no ) - Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Kubernetes/Yarn, ZooKeeper: (no) - The S3 file system connector: ( no) ## Documentation - Does this pull request introduce a new feature? (no) -- 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] WTZ468071157 commented on pull request #18190: [hotfix][doc]There is a link redirection problem in the Chinese document of ‘custom_serialization’
WTZ468071157 commented on pull request #18190: URL: https://github.com/apache/flink/pull/18190#issuecomment-1000695739 Hi, @MartijnVisser There is another wrong link in the document of 'Custom_serialization'. I'm sorry to disturb you, but can you help me review it when you are free? -- 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 #18198: [FLINK-25437][python] Correct grpcio dependency version in dev-requirenment.txt
flinkbot edited a comment on pull request #18198: URL: https://github.com/apache/flink/pull/18198#issuecomment-1000693112 ## CI report: * 65e04ff7db50a23825ec148db88154545a2ab537 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28570) 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 #18196: [FLINK-24270][checkpoint] Refactor the tests related to the VertexFinishedStateChecker
flinkbot edited a comment on pull request #18196: URL: https://github.com/apache/flink/pull/18196#issuecomment-1000619056 ## CI report: * 68d4546ad8600dc12959a90aa338e3f91537db24 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28558) * 2af5225d59633854c7a5ed23cddf913d88c73b75 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28561) 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 #18183: [hotfix][doc] There is a link redirection problem in the Chinese document of Checkpointing
flinkbot edited a comment on pull request #18183: URL: https://github.com/apache/flink/pull/18183#issuecomment-999812530 ## CI report: * aca4a3202d46a1059541b1f89d082253074e2370 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28535) 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 #18198: [FLINK-25437][python] Correct grpcio dependency version in dev-requirenment.txt
flinkbot commented on pull request #18198: URL: https://github.com/apache/flink/pull/18198#issuecomment-1000693112 ## CI report: * 65e04ff7db50a23825ec148db88154545a2ab537 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 #18197: [FLINK-25437][python] Correct grpcio dependency version in dev-requirenment.txt
flinkbot edited a comment on pull request #18197: URL: https://github.com/apache/flink/pull/18197#issuecomment-1000691490 ## CI report: * 1b53f876faefbbf99353632447af0f5e5099fc58 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28569) 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 #18183: [hotfix][doc] There is a link redirection problem in the Chinese document of Checkpointing
flinkbot edited a comment on pull request #18183: URL: https://github.com/apache/flink/pull/18183#issuecomment-999812530 ## CI report: * aca4a3202d46a1059541b1f89d082253074e2370 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28535) 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 #18180: [hotfix][doc] fix typo of 'note that' and 'now that'
flinkbot edited a comment on pull request #18180: URL: https://github.com/apache/flink/pull/18180#issuecomment-999581101 ## CI report: * 79481c2adc31f175b2963651857fe9118817f50b Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28528) 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] WTZ468071157 commented on pull request #18183: [hotfix][doc] There is a link redirection problem in the Chinese document of Checkpointing
WTZ468071157 commented on pull request #18183: URL: https://github.com/apache/flink/pull/18183#issuecomment-1000692455 Is there any thing wrong with this pr? Is there anything I can do? -- 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 #18198: [FLINK-25437][python] Correct grpcio dependency version in dev-requirenment.txt
flinkbot commented on pull request #18198: URL: https://github.com/apache/flink/pull/18198#issuecomment-1000692233 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 65e04ff7db50a23825ec148db88154545a2ab537 (Fri Dec 24 07:12:53 UTC 2021) **Warnings:** * No documentation files were touched! Remember to keep the Flink docs up to date! 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] SteNicholas commented on pull request #15140: [FLINK-20628][connectors/rabbitmq2] RabbitMQ connector using new connector API
SteNicholas commented on pull request #15140: URL: https://github.com/apache/flink/pull/15140#issuecomment-1000692171 @pscls , thanks for your contribution of the new RabbitMQ connector. I left my minor comments and you should upgrade the amqp-client version for vulnerabilities. -- 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 #18197: [FLINK-25437][python] Correct grpcio dependency version in dev-requirenment.txt
flinkbot commented on pull request #18197: URL: https://github.com/apache/flink/pull/18197#issuecomment-1000691490 ## CI report: * 1b53f876faefbbf99353632447af0f5e5099fc58 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] SteNicholas commented on a change in pull request #15140: [FLINK-20628][connectors/rabbitmq2] RabbitMQ connector using new connector API
SteNicholas commented on a change in pull request #15140:
URL: https://github.com/apache/flink/pull/15140#discussion_r774904278
##
File path: flink-connectors/flink-connector-rabbitmq2/pom.xml
##
@@ -0,0 +1,84 @@
+
+
+
+http://maven.apache.org/POM/4.0.0;
+xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance;
+xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd;>
+ 4.0.0
+
+
+ org.apache.flink
+ flink-connectors
+ 1.13-SNAPSHOT
+ ..
+
+
+
flink-connector-rabbitmq2_${scala.binary.version}
+ Flink : Connectors : RabbitMQ2
+
+ jar
+
+
+
+ 5.9.0
+
+
+
+
+ org.apache.flink
+
flink-streaming-java_${scala.binary.version}
+ ${project.version}
+ provided
+
+
+
+ org.apache.flink
+ flink-connector-base
+ ${project.version}
+
+
+
+ com.rabbitmq
+ amqp-client
+ ${rabbitmq.version}
Review comment:
The 5.9.0 version of the amqp-client has the direct vulnerabilities:
CVE-2020-25649 and CVE-2020-15250. You should upgrade to 5.14.0.
--
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 #18180: [hotfix][doc] fix typo of 'note that' and 'now that'
flinkbot edited a comment on pull request #18180: URL: https://github.com/apache/flink/pull/18180#issuecomment-999581101 ## CI report: * 79481c2adc31f175b2963651857fe9118817f50b Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28528) 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 #18183: [hotfix][doc] There is a link redirection problem in the Chinese document of Checkpointing
flinkbot edited a comment on pull request #18183: URL: https://github.com/apache/flink/pull/18183#issuecomment-999812530 ## CI report: * aca4a3202d46a1059541b1f89d082253074e2370 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28535) 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 #18197: [FLINK-25437][python] Correct grpcio dependency version in dev-requirenment.txt
flinkbot commented on pull request #18197: URL: https://github.com/apache/flink/pull/18197#issuecomment-1000691284 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 1b53f876faefbbf99353632447af0f5e5099fc58 (Fri Dec 24 07:10:05 UTC 2021) **Warnings:** * No documentation files were touched! Remember to keep the Flink docs up to date! 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] MartijnVisser commented on pull request #18150: [hotfix][docs] Fix incorrect dependency and markdown format
MartijnVisser commented on pull request #18150: URL: https://github.com/apache/flink/pull/18150#issuecomment-1000690794 > Thanks very much for your patient advices. I am very sorry that I am confusing how to squash the two different commits into one commit, so I have to write the two git-logs together. As I said, They are all different, and I just committed them in a pr. One commit one PR may be better. @aihai You currently have one commit in this PR, but you can execute the following commands on this branch to update that: `git reset --soft HEAD~1` -> This reset your last commit message `git add --all` -> This adds all files that you have changed in your PR. Should be just the two files that you've changed `git commit` -> To create a commit. This is where you should provide the updated git commit message, so the one from https://github.com/apache/flink/pull/18150#issuecomment-999643942 `git push --force` -> This pushes the commit with your new commit message and overwrites the one that you currently have -- 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] HuangXingBo opened a new pull request #18198: [FLINK-25437][python] Correct grpcio dependency version in dev-requirenment.txt
HuangXingBo opened a new pull request #18198: URL: https://github.com/apache/flink/pull/18198 ## What is the purpose of the change *This pull request will correct grpcio dependency version in dev-requirenment.txt* ## Brief change log - *Correct grpcio dependency version in dev-requirenment.txt* ## Verifying this change This change added tests and can be verified as follows: - *original tests and build wheels in private Azure pipleline* ## Does this pull request potentially affect one of the following parts: - Dependencies (does it add or upgrade a dependency): (no) - The public API, i.e., is any changed class annotated with `@Public(Evolving)`: (no) - The serializers: (no) - The runtime per-record code paths (performance sensitive): (no) - Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Kubernetes/Yarn, ZooKeeper: (no) - The S3 file system connector: (no) ## Documentation - Does this pull request introduce a new feature? (no) - If yes, how is the feature documented? (not applicable) -- 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] (FLINK-25380) Introduce DynamicTableSink & DynamicTableSource for RabbitMQ
[ https://issues.apache.org/jira/browse/FLINK-25380 ] Nicholas Jiang deleted comment on FLINK-25380: was (Author: nicholasjiang): [~RocMarshal], you could firstly take the tickets of the FLINK-20628 and FLINK-21373. After these completion, you could work for this issue. > Introduce DynamicTableSink & DynamicTableSource for RabbitMQ > > > Key: FLINK-25380 > URL: https://issues.apache.org/jira/browse/FLINK-25380 > Project: Flink > Issue Type: New Feature > Components: Connectors/ RabbitMQ >Reporter: RocMarshal >Priority: Minor > > This feature should be arranged after > # FLINK-21373 > # FLINK-20628 -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Updated] (FLINK-25437) Build wheels failed
[ https://issues.apache.org/jira/browse/FLINK-25437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25437: --- Labels: pull-request-available (was: ) > Build wheels failed > --- > > Key: FLINK-25437 > URL: https://issues.apache.org/jira/browse/FLINK-25437 > Project: Flink > Issue Type: Bug > Components: API / Python >Affects Versions: 1.12.8, 1.13.6 >Reporter: Huang Xingbo >Assignee: Huang Xingbo >Priority: Blocker > Labels: pull-request-available > > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=28552=logs=33dd8067-7758-552f-a1cf-a8b8ff0e44cd=bf344275-d244-5694-d05a-7ad127794669 -- This message was sent by Atlassian Jira (v8.20.1#820001)
[GitHub] [flink] flinkbot edited a comment on pull request #18148: [FLINK-25372] Add thread dump feature for jobmanager
flinkbot edited a comment on pull request #18148: URL: https://github.com/apache/flink/pull/18148#issuecomment-997327937 ## CI report: * 40adefafcf9f1554c73d547c31eb3a4df8f2bc34 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28538) * 89d3e84018bfad7dd3e5bf34f1864c2923b7f19e Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28560) * 1e7ac1c81e93139fe2c02f16931767eea595d622 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28563) * 92bcfd7a84d150a3d5f7d9d60ba17405368a34b1 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28568) 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] HuangXingBo opened a new pull request #18197: [FLINK-25437][python] Correct grpcio dependency version in dev-requirenment.txt
HuangXingBo opened a new pull request #18197: URL: https://github.com/apache/flink/pull/18197 ## What is the purpose of the change *This pull request will correct grpcio dependency version in dev-requirenment.txt* ## Brief change log - *Correct grpcio dependency version in dev-requirenment.txt* ## Verifying this change This change added tests and can be verified as follows: - *original tests and build wheels in private Azure pipleline* ## Does this pull request potentially affect one of the following parts: - Dependencies (does it add or upgrade a dependency): (no) - The public API, i.e., is any changed class annotated with `@Public(Evolving)`: (no) - The serializers: (no) - The runtime per-record code paths (performance sensitive): (no) - Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Kubernetes/Yarn, ZooKeeper: (no) - The S3 file system connector: (no) ## Documentation - Does this pull request introduce a new feature? (no) - If yes, how is the feature documented? (not applicable) -- 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] MartijnVisser commented on pull request #18180: [hotfix][doc] fix typo of 'note that' and 'now that'
MartijnVisser commented on pull request #18180: URL: https://github.com/apache/flink/pull/18180#issuecomment-1000689614 @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
[GitHub] [flink] MartijnVisser commented on pull request #18183: [hotfix][doc] There is a link redirection problem in the Chinese document of Checkpointing
MartijnVisser commented on pull request #18183: URL: https://github.com/apache/flink/pull/18183#issuecomment-1000689457 @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
[GitHub] [flink] SteNicholas commented on a change in pull request #15140: [FLINK-20628][connectors/rabbitmq2] RabbitMQ connector using new connector API
SteNicholas commented on a change in pull request #15140:
URL: https://github.com/apache/flink/pull/15140#discussion_r774898898
##
File path: flink-connectors/flink-connector-rabbitmq2/README.md
##
@@ -0,0 +1,24 @@
+# License of the Rabbit MQ Connector
Review comment:
```suggestion
# License of the RabbitMQ Connector
```
##
File path:
flink-connectors/flink-connector-rabbitmq2/src/main/java/org/apache/flink/connector/rabbitmq2/common/RabbitMQConnectionConfig.java
##
@@ -0,0 +1,554 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ *http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.flink.connector.rabbitmq2.common;
+
+import org.apache.flink.connector.rabbitmq2.source.RabbitMQSource;
+import org.apache.flink.util.Preconditions;
+
+import com.rabbitmq.client.ConnectionFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.io.Serializable;
+import java.net.URISyntaxException;
+import java.security.KeyManagementException;
+import java.security.NoSuchAlgorithmException;
+import java.util.Optional;
+
+/**
+ * This class is copied from the previous RabbitMQ connector. Connection
Configuration for RMQ. If
+ * {@link Builder#setUri(String)} has been set then {@link
+ * RabbitMQConnectionConfig#RabbitMQConnectionConfig(String, Integer, Boolean,
Boolean, Integer,
+ * Integer, Integer, Integer, Integer)} will be used to initialize the RMQ
connection or {@link
+ * RabbitMQConnectionConfig#RabbitMQConnectionConfig(String, Integer, String,
String, String,
+ * Integer, Boolean, Boolean, Integer, Integer, Integer, Integer, Integer)}
will be used to
+ * initialize the RMQ connection.
+ */
+public class RabbitMQConnectionConfig implements Serializable {
+
+private static final long serialVersionUID = 1L;
+
+private static final Logger LOG =
LoggerFactory.getLogger(RabbitMQConnectionConfig.class);
+
+private String host;
+private Integer port;
+private String virtualHost;
+private String username;
+private String password;
+private String uri;
+
+private Integer networkRecoveryInterval;
+private Boolean automaticRecovery;
+private Boolean topologyRecovery;
+
+private Integer connectionTimeout;
+private Integer requestedChannelMax;
+private Integer requestedFrameMax;
+private Integer requestedHeartbeat;
+
+private Integer prefetchCount;
+
+/**
+ * @param host host name
+ * @param port port
+ * @param virtualHost virtual host
+ * @param username username
+ * @param password password
+ * @param networkRecoveryInterval connection recovery interval in
milliseconds
+ * @param automaticRecovery if automatic connection recovery
+ * @param topologyRecovery if topology recovery
+ * @param connectionTimeout connection timeout
+ * @param requestedChannelMax requested maximum channel number
+ * @param requestedFrameMax requested maximum frame size
+ * @param requestedHeartbeat requested heartbeat interval
+ * @throws NullPointerException if host or virtual host or username or
password is null
+ */
+private RabbitMQConnectionConfig(
+String host,
+Integer port,
+String virtualHost,
+String username,
+String password,
+Integer networkRecoveryInterval,
+Boolean automaticRecovery,
+Boolean topologyRecovery,
+Integer connectionTimeout,
+Integer requestedChannelMax,
+Integer requestedFrameMax,
+Integer requestedHeartbeat,
+Integer prefetchCount) {
+Preconditions.checkNotNull(host, "host can not be null");
+Preconditions.checkNotNull(port, "port can not be null");
+Preconditions.checkNotNull(virtualHost, "virtualHost can not be null");
+Preconditions.checkNotNull(username, "username can not be null");
+Preconditions.checkNotNull(password, "password can not be null");
+this.host = host;
Review comment:
`this.host = host` could be `this.host = requireNotNull(host)`, and
remove the `Preconditions.checkNotNull(host, "host can not be null")`.
##
File path:
[GitHub] [flink] flinkbot edited a comment on pull request #18148: [FLINK-25372] Add thread dump feature for jobmanager
flinkbot edited a comment on pull request #18148: URL: https://github.com/apache/flink/pull/18148#issuecomment-997327937 ## CI report: * 40adefafcf9f1554c73d547c31eb3a4df8f2bc34 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28538) * 89d3e84018bfad7dd3e5bf34f1864c2923b7f19e Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28560) * 1e7ac1c81e93139fe2c02f16931767eea595d622 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28563) * 92bcfd7a84d150a3d5f7d9d60ba17405368a34b1 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] [Resolved] (FLINK-25429) Avoid to close output streams twice during uploading changelogs
[
https://issues.apache.org/jira/browse/FLINK-25429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang resolved FLINK-25429.
--
Resolution: Fixed
> Avoid to close output streams twice during uploading changelogs
> ---
>
> Key: FLINK-25429
> URL: https://issues.apache.org/jira/browse/FLINK-25429
> Project: Flink
> Issue Type: Improvement
> Components: Runtime / State Backends
>Reporter: Yun Tang
>Assignee: Yun Tang
>Priority: Major
> Labels: pull-request-available
> Fix For: 1.15.0
>
>
> Current uploader implementation would close {{stream}} and {{fsStream}} one
> by one, which lead to {{fsStream}} closed twice.
> {code:java}
> try (FSDataOutputStream fsStream = fileSystem.create(path,
> NO_OVERWRITE)) {
> fsStream.write(compression ? 1 : 0);
> try (OutputStreamWithPos stream = wrap(fsStream); ) {
> final Map> tasksOffsets
> = new HashMap<>();
> for (UploadTask task : tasks) {
> tasksOffsets.put(task, format.write(stream,
> task.changeSets));
> }
> FileStateHandle handle = new FileStateHandle(path,
> stream.getPos());
> // WARN: streams have to be closed before returning the
> results
> // otherwise JM may receive invalid handles
> return new LocalResult(tasksOffsets, handle);
> }
> }
> {code}
> Not all file system supports to close same stream twice.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[GitHub] [flink] flinkbot edited a comment on pull request #18050: [FLINK-25034][runtime] Support flexible number of subpartitions in IntermediateResultPartition
flinkbot edited a comment on pull request #18050: URL: https://github.com/apache/flink/pull/18050#issuecomment-988466514 ## CI report: * e2e89c176f1e20f3583e6bdc850a0c31251cf988 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28556) 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] [Resolved] (FLINK-25094) The verify code in LatencyTrackingMapStateTest#verifyIterator is not actually executed
[
https://issues.apache.org/jira/browse/FLINK-25094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang resolved FLINK-25094.
--
Resolution: Fixed
> The verify code in LatencyTrackingMapStateTest#verifyIterator is not actually
> executed
> --
>
> Key: FLINK-25094
> URL: https://issues.apache.org/jira/browse/FLINK-25094
> Project: Flink
> Issue Type: Bug
> Components: Runtime / State Backends, Tests
>Reporter: Jinzhong Li
>Assignee: Jinzhong Li
>Priority: Minor
> Labels: pull-request-available
> Fix For: 1.15.0
>
>
> In LatencyTrackingMapStateTest,
> iterator()/entries().iterator()/keys().iterator()/values().iterator() will be
> invoke before verifyIterator method is invoked, this is,
> iterator()/... will be invode before putting the test data into
> latencyTrackingMapState. So the verify code is not actually executed since
> "iterator.hasNext()" is always false.
> {code:java}
> private void verifyIterator(
> LatencyTrackingMapState
> latencyTrackingState,
> LatencyTrackingMapState.MapStateLatencyMetrics
> latencyTrackingStateMetric,
> Iterator iterator,
> boolean removeIterator)
> throws Exception {
> ThreadLocalRandom random = ThreadLocalRandom.current();
> for (int index = 1; index <= SAMPLE_INTERVAL; index++) {
> latencyTrackingState.put((long) index, random.nextDouble());
> }
> int count = 1;
> while (iterator.hasNext()) {
> int expectedResult = count == SAMPLE_INTERVAL ? 0 : count;
> assertEquals(expectedResult,
> latencyTrackingStateMetric.getIteratorHasNextCount());
> iterator.next();
> assertEquals(expectedResult,
> latencyTrackingStateMetric.getIteratorNextCount());
> if (removeIterator) {
> iterator.remove();
> assertEquals(expectedResult,
> latencyTrackingStateMetric.getIteratorRemoveCount());
> }
> count += 1;
> }
> // as we call #hasNext on more time than #next, to avoid complex check,
> just reset hasNext
> // counter in the end.
> latencyTrackingStateMetric.resetIteratorHasNextCount();
> latencyTrackingState.clear();
> } {code}
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[jira] [Commented] (FLINK-25094) The verify code in LatencyTrackingMapStateTest#verifyIterator is not actually executed
[
https://issues.apache.org/jira/browse/FLINK-25094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464914#comment-17464914
]
Yun Tang commented on FLINK-25094:
--
Merged in master: d08a1d0f4035485283f1063d4d0fc0a8aaca
> The verify code in LatencyTrackingMapStateTest#verifyIterator is not actually
> executed
> --
>
> Key: FLINK-25094
> URL: https://issues.apache.org/jira/browse/FLINK-25094
> Project: Flink
> Issue Type: Bug
> Components: Runtime / State Backends, Tests
>Reporter: Jinzhong Li
>Assignee: Jinzhong Li
>Priority: Minor
> Labels: pull-request-available
> Fix For: 1.15.0
>
>
> In LatencyTrackingMapStateTest,
> iterator()/entries().iterator()/keys().iterator()/values().iterator() will be
> invoke before verifyIterator method is invoked, this is,
> iterator()/... will be invode before putting the test data into
> latencyTrackingMapState. So the verify code is not actually executed since
> "iterator.hasNext()" is always false.
> {code:java}
> private void verifyIterator(
> LatencyTrackingMapState
> latencyTrackingState,
> LatencyTrackingMapState.MapStateLatencyMetrics
> latencyTrackingStateMetric,
> Iterator iterator,
> boolean removeIterator)
> throws Exception {
> ThreadLocalRandom random = ThreadLocalRandom.current();
> for (int index = 1; index <= SAMPLE_INTERVAL; index++) {
> latencyTrackingState.put((long) index, random.nextDouble());
> }
> int count = 1;
> while (iterator.hasNext()) {
> int expectedResult = count == SAMPLE_INTERVAL ? 0 : count;
> assertEquals(expectedResult,
> latencyTrackingStateMetric.getIteratorHasNextCount());
> iterator.next();
> assertEquals(expectedResult,
> latencyTrackingStateMetric.getIteratorNextCount());
> if (removeIterator) {
> iterator.remove();
> assertEquals(expectedResult,
> latencyTrackingStateMetric.getIteratorRemoveCount());
> }
> count += 1;
> }
> // as we call #hasNext on more time than #next, to avoid complex check,
> just reset hasNext
> // counter in the end.
> latencyTrackingStateMetric.resetIteratorHasNextCount();
> latencyTrackingState.clear();
> } {code}
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[GitHub] [flink] Myasuka closed pull request #18111: [FLINK-25094][Test]Correct the LatencyTrackingMapStateTest#verifyIterator
Myasuka closed pull request #18111: URL: https://github.com/apache/flink/pull/18111 -- 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-25293) Option to let fail if KafkaSource keeps failing to commit offset
[
https://issues.apache.org/jira/browse/FLINK-25293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464912#comment-17464912
]
Qingsheng Ren commented on FLINK-25293:
---
[~rero] Would you mind closing this issue if you think it's not applicable
anymore?
> Option to let fail if KafkaSource keeps failing to commit offset
>
>
> Key: FLINK-25293
> URL: https://issues.apache.org/jira/browse/FLINK-25293
> Project: Flink
> Issue Type: Improvement
> Components: Connectors / Kafka
>Affects Versions: 1.14.0
> Environment: Flink 1.14.0
>Reporter: rerorero
>Priority: Major
>
> Is it possible to let KafkaSource fail if it keeps failing to commit offset?
>
> I faced an issue where KafkaSource keeps failing and never recover, while
> it's logging like these logs:
> {code:java}
> 2021-12-08 22:18:34,155 INFO
> org.apache.kafka.clients.consumer.internals.AbstractCoordinator [] -
> [Consumer clientId=dbz-cg-1, groupId=dbz-cg] Group coordinator
> b4-pkc-x.asia-northeast1.gcp.confluent.cloud:9092 (id: 2147483643 rack:
> null) is unavailable or invalid due to cause: null.isDisconnected: true.
> Rediscovery will be attempted.
> 2021-12-08 22:18:34,157 WARN
> org.apache.flink.connector.kafka.source.reader.KafkaSourceReader [] - Failed
> to commit consumer offsets for checkpoint 13 {code}
> This is happening not just once, but a couple of times a week (it happens
> when the Kafka broker performs rolling restart). It can be recovered by
> restarting the Flink Job.
> I found other people reporting the similar thing:
> [https://lists.apache.org/thread/8l4f2yb4qwysdn1cj1wjk99tfb79kgs2]. This
> could possibly be a problem with the Kafka client, and of course, the problem
> should be fixed on Kafka side if so.
> However, Flink Kafka connector doesn't provide an automatic way to save this
> situation. KafkaSource keeps retrying forever when a retriable error occurs,
> even if it is not retriable actually:
> [https://github.com/apache/flink/blob/afb29d92c4e76ec6a453459c3d8a08304efec549/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaSourceReader.java#L144-L148]
> Since it sends metrics of the number of times a commit fails, it could be
> automated by monitoring it and restarting the job, but that would mean we
> need to have a new process to be managed.
> Does it make sense to have KafkaSource have the option like, let the source
> task fail if it keeps failing to commit an offset more than X times?
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[jira] [Commented] (FLINK-25429) Avoid to close output streams twice during uploading changelogs
[
https://issues.apache.org/jira/browse/FLINK-25429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464911#comment-17464911
]
Yun Tang commented on FLINK-25429:
--
merged in master:
804eb8dda556a2bea35c69a2662f13d1dafb9255
> Avoid to close output streams twice during uploading changelogs
> ---
>
> Key: FLINK-25429
> URL: https://issues.apache.org/jira/browse/FLINK-25429
> Project: Flink
> Issue Type: Improvement
> Components: Runtime / State Backends
>Reporter: Yun Tang
>Assignee: Yun Tang
>Priority: Major
> Labels: pull-request-available
> Fix For: 1.15.0
>
>
> Current uploader implementation would close {{stream}} and {{fsStream}} one
> by one, which lead to {{fsStream}} closed twice.
> {code:java}
> try (FSDataOutputStream fsStream = fileSystem.create(path,
> NO_OVERWRITE)) {
> fsStream.write(compression ? 1 : 0);
> try (OutputStreamWithPos stream = wrap(fsStream); ) {
> final Map> tasksOffsets
> = new HashMap<>();
> for (UploadTask task : tasks) {
> tasksOffsets.put(task, format.write(stream,
> task.changeSets));
> }
> FileStateHandle handle = new FileStateHandle(path,
> stream.getPos());
> // WARN: streams have to be closed before returning the
> results
> // otherwise JM may receive invalid handles
> return new LocalResult(tasksOffsets, handle);
> }
> }
> {code}
> Not all file system supports to close same stream twice.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[GitHub] [flink] Myasuka merged pull request #18188: [FLINK-25429][state] Avoid to close output streams twice during uploading changelogs
Myasuka merged pull request #18188: URL: https://github.com/apache/flink/pull/18188 -- 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-14902) JDBCTableSource support AsyncLookupFunction
[ https://issues.apache.org/jira/browse/FLINK-14902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464908#comment-17464908 ] ranqiqiang commented on FLINK-14902: [~jark] please assign to me, I want to try it. > JDBCTableSource support AsyncLookupFunction > --- > > Key: FLINK-14902 > URL: https://issues.apache.org/jira/browse/FLINK-14902 > Project: Flink > Issue Type: Improvement > Components: Connectors / JDBC >Affects Versions: 1.9.0 >Reporter: hailong wang >Priority: Minor > Labels: auto-deprioritized-major, auto-unassigned, > pull-request-available > Time Spent: 10m > Remaining Estimate: 0h > > JDBCTableSource support AsyncLookupFunction -- This message was sent by Atlassian Jira (v8.20.1#820001)
[GitHub] [flink] flinkbot edited a comment on pull request #18014: [FLINK-24857][test][Kafka] Upgrade SourceReaderTestBase t…
flinkbot edited a comment on pull request #18014: URL: https://github.com/apache/flink/pull/18014#issuecomment-986441468 ## CI report: * 89d75be44b0c222749150970de40f095124de244 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28555) 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-25380) Introduce DynamicTableSink & DynamicTableSource for RabbitMQ
[ https://issues.apache.org/jira/browse/FLINK-25380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464907#comment-17464907 ] Nicholas Jiang commented on FLINK-25380: [~RocMarshal], you could firstly take the tickets of the FLINK-20628 and FLINK-21373. After these completion, you could work for this issue. > Introduce DynamicTableSink & DynamicTableSource for RabbitMQ > > > Key: FLINK-25380 > URL: https://issues.apache.org/jira/browse/FLINK-25380 > Project: Flink > Issue Type: New Feature > Components: Connectors/ RabbitMQ >Reporter: RocMarshal >Priority: Minor > > This feature should be arranged after > # FLINK-21373 > # FLINK-20628 -- This message was sent by Atlassian Jira (v8.20.1#820001)
[GitHub] [flink] flinkbot edited a comment on pull request #16635: [hotfix][connector-jdbc] Fix a method name typo in postgres unit test.
flinkbot edited a comment on pull request #16635: URL: https://github.com/apache/flink/pull/16635#issuecomment-888991854 ## CI report: * 2e5e6ae6b57552fe083275c36dea53b2aaeb256d Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28562) * 0b154cc55ffdc5698f756d63367d6bf5ed2030d4 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28565) 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-25437) Build wheels failed
[ https://issues.apache.org/jira/browse/FLINK-25437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-25437: - Affects Version/s: (was: 1.14.3) > Build wheels failed > --- > > Key: FLINK-25437 > URL: https://issues.apache.org/jira/browse/FLINK-25437 > Project: Flink > Issue Type: Bug > Components: API / Python >Affects Versions: 1.12.8, 1.13.6 >Reporter: Huang Xingbo >Assignee: Huang Xingbo >Priority: Blocker > > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=28552=logs=33dd8067-7758-552f-a1cf-a8b8ff0e44cd=bf344275-d244-5694-d05a-7ad127794669 -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Commented] (FLINK-25435) Can not read jobmanager/taskmanager.log in yarn-per-job mode.
[
https://issues.apache.org/jira/browse/FLINK-25435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464905#comment-17464905
]
Nicholas Jiang commented on FLINK-25435:
[~ZhangChaoming], IMO, the SET statement doesn't do extra special processing
for `execution.target`, for example, the above default configuration setting .
User could set `internal.deployment.config-dir` configuration when setting the
`execution.target`.
cc [~fsk119] [~jark]
> Can not read jobmanager/taskmanager.log in yarn-per-job mode.
> -
>
> Key: FLINK-25435
> URL: https://issues.apache.org/jira/browse/FLINK-25435
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Client
>Affects Versions: 1.14.0
>Reporter: Moses
>Priority: Major
>
> I'm using SQL Client to submit a job, and using `SET` statement to specify
> deploy mode.
> {code:sql}
> SET execution.target=yarn-per-job;
> ...
> {code}
> But I can not found log files both on master and taskmanagers.
> I found that `GenericCLI` and `FlinkYarnSessionCli` will set
> `$internal.deployment.config-dir={configurationDirectory}` in their execution
> configuration.
> Should we set this configuration in `DefaultCLI` as well?
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
[GitHub] [flink] aihai commented on pull request #18150: [hotfix][docs] Fix incorrect dependency and markdown format
aihai commented on pull request #18150: URL: https://github.com/apache/flink/pull/18150#issuecomment-1000677118 filled out the PR template -- 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 #18172: [hotfix][docs] Fix incorrect Python tableEnvironment attribute reference
flinkbot edited a comment on pull request #18172: URL: https://github.com/apache/flink/pull/18172#issuecomment-999323746 ## CI report: * aa0108e1c64dd471c09e8e0c19b2e98c0e9bf2e3 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28530) 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-25437) Build wheels failed
[ https://issues.apache.org/jira/browse/FLINK-25437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-25437: Priority: Blocker (was: Critical) > Build wheels failed > --- > > Key: FLINK-25437 > URL: https://issues.apache.org/jira/browse/FLINK-25437 > Project: Flink > Issue Type: Bug > Components: API / Python >Affects Versions: 1.12.8, 1.13.6, 1.14.3 >Reporter: Huang Xingbo >Assignee: Huang Xingbo >Priority: Blocker > > https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=28552=logs=33dd8067-7758-552f-a1cf-a8b8ff0e44cd=bf344275-d244-5694-d05a-7ad127794669 -- This message was sent by Atlassian Jira (v8.20.1#820001)
[jira] [Comment Edited] (FLINK-25439) StreamExecCalc collect new StreamRecord to Downstream lost timestamp Attributes
[ https://issues.apache.org/jira/browse/FLINK-25439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464899#comment-17464899 ] HunterHunter edited comment on FLINK-25439 at 12/24/21, 6:04 AM: - [~MartijnVisser] realese-1.14.2 was (Author: hunterhunter): realese-1.14.2 > StreamExecCalc collect new StreamRecord to Downstream lost timestamp > Attributes > --- > > Key: FLINK-25439 > URL: https://issues.apache.org/jira/browse/FLINK-25439 > Project: Flink > Issue Type: Bug > Components: Table SQL / Planner >Reporter: HunterHunter >Priority: Major > Attachments: image-2021-12-24-10-57-01-479.png, > image-2021-12-24-10-58-25-304.png > > > When we read data from kafkasource, we can see in SourceReaderBase.pollNext > that the record has a timestamp attribute, but after StreamExecCalc the > downstream receives the streamrecord and the timestamp attribute is missing > -- This message was sent by Atlassian Jira (v8.20.1#820001)
[GitHub] [flink] flinkbot edited a comment on pull request #16635: [hotfix][connector-jdbc] Fix a method name typo in postgres unit test.
flinkbot edited a comment on pull request #16635: URL: https://github.com/apache/flink/pull/16635#issuecomment-888991854 ## CI report: * 8519888d933175e0e2d370611db773f2bd173c85 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=21156) * 2e5e6ae6b57552fe083275c36dea53b2aaeb256d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28562) * 0b154cc55ffdc5698f756d63367d6bf5ed2030d4 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28565) 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] aihai commented on pull request #18150: [hotfix][docs] Fix incorrect dependency and markdown format
aihai commented on pull request #18150: URL: https://github.com/apache/flink/pull/18150#issuecomment-1000670498 Thanks very much for your patient advices. I am very sorry that I am confusing how to squash the two different commits into one commit, so I have to write the two git-logs together. As I said, They are all different, and I just committed them in a pr. One commit one PR may be better. -- 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 #16635: [hotfix][connector-jdbc] Fix a method name typo in postgres unit test.
flinkbot edited a comment on pull request #16635: URL: https://github.com/apache/flink/pull/16635#issuecomment-888991854 ## CI report: * 8519888d933175e0e2d370611db773f2bd173c85 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=21156) * 2e5e6ae6b57552fe083275c36dea53b2aaeb256d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28562) * 0b154cc55ffdc5698f756d63367d6bf5ed2030d4 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] [Commented] (FLINK-25439) StreamExecCalc collect new StreamRecord to Downstream lost timestamp Attributes
[ https://issues.apache.org/jira/browse/FLINK-25439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464899#comment-17464899 ] HunterHunter commented on FLINK-25439: -- realese-1.14.2 > StreamExecCalc collect new StreamRecord to Downstream lost timestamp > Attributes > --- > > Key: FLINK-25439 > URL: https://issues.apache.org/jira/browse/FLINK-25439 > Project: Flink > Issue Type: Bug > Components: Table SQL / Planner >Reporter: HunterHunter >Priority: Major > Attachments: image-2021-12-24-10-57-01-479.png, > image-2021-12-24-10-58-25-304.png > > > When we read data from kafkasource, we can see in SourceReaderBase.pollNext > that the record has a timestamp attribute, but after StreamExecCalc the > downstream receives the streamrecord and the timestamp attribute is missing > -- This message was sent by Atlassian Jira (v8.20.1#820001)
[GitHub] [flink] flinkbot edited a comment on pull request #16635: [hotfix][connector-jdbc] Fix a method name typo in postgres unit test.
flinkbot edited a comment on pull request #16635: URL: https://github.com/apache/flink/pull/16635#issuecomment-888991854 ## CI report: * 8519888d933175e0e2d370611db773f2bd173c85 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=21156) * 2e5e6ae6b57552fe083275c36dea53b2aaeb256d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28562) 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 #16635: [hotfix][connector-jdbc] Fix a method name typo in postgres unit test.
flinkbot edited a comment on pull request #16635: URL: https://github.com/apache/flink/pull/16635#issuecomment-888991854 ## CI report: * 8519888d933175e0e2d370611db773f2bd173c85 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=21156) * 2e5e6ae6b57552fe083275c36dea53b2aaeb256d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28562) * 0b154cc55ffdc5698f756d63367d6bf5ed2030d4 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 #17833: [FLINK-24785][runtime] Relocate RocksDB's log under flink log directory by default
flinkbot edited a comment on pull request #17833: URL: https://github.com/apache/flink/pull/17833#issuecomment-973807642 ## CI report: * 59df8a6010ef5c4d0b6472cdd735e5daf8cb6bc5 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28554) * 003e60ead8f8920e66bf5235d03497298eb97d9c Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28564) 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 #16635: [hotfix][connector-jdbc] Fix a method name typo in postgres unit test.
flinkbot edited a comment on pull request #16635: URL: https://github.com/apache/flink/pull/16635#issuecomment-888991854 ## CI report: * 8519888d933175e0e2d370611db773f2bd173c85 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=21156) * 2e5e6ae6b57552fe083275c36dea53b2aaeb256d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28562) 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 #17833: [FLINK-24785][runtime] Relocate RocksDB's log under flink log directory by default
flinkbot edited a comment on pull request #17833: URL: https://github.com/apache/flink/pull/17833#issuecomment-973807642 ## CI report: * 59df8a6010ef5c4d0b6472cdd735e5daf8cb6bc5 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28554) * 003e60ead8f8920e66bf5235d03497298eb97d9c 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 #16635: [hotfix][connector-jdbc] fix a method name typo in postgres unit test.
flinkbot edited a comment on pull request #16635: URL: https://github.com/apache/flink/pull/16635#issuecomment-888991854 ## CI report: * 8519888d933175e0e2d370611db773f2bd173c85 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=21156) * 2e5e6ae6b57552fe083275c36dea53b2aaeb256d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28562) * 0b154cc55ffdc5698f756d63367d6bf5ed2030d4 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 #16635: [hotfix][connector-jdbc] fix a method name typo in postgres unit test.
flinkbot edited a comment on pull request #16635: URL: https://github.com/apache/flink/pull/16635#issuecomment-888991854 ## CI report: * 8519888d933175e0e2d370611db773f2bd173c85 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=21156) * 2e5e6ae6b57552fe083275c36dea53b2aaeb256d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28562) 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 #18180: [hotfix][doc] fix typo of 'note that' and 'now that'
flinkbot edited a comment on pull request #18180: URL: https://github.com/apache/flink/pull/18180#issuecomment-999581101 ## CI report: * 79481c2adc31f175b2963651857fe9118817f50b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28528) 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 #16635: [hotfix][connector-jdbc] fix a method name typo in postgres unit test.
flinkbot edited a comment on pull request #16635: URL: https://github.com/apache/flink/pull/16635#issuecomment-888991854 ## CI report: * 8519888d933175e0e2d370611db773f2bd173c85 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=21156) * 2e5e6ae6b57552fe083275c36dea53b2aaeb256d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28562) * 0b154cc55ffdc5698f756d63367d6bf5ed2030d4 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 #16635: [hotfix][connector-jdbc] fix a method name typo in postgres unit test.
flinkbot edited a comment on pull request #16635: URL: https://github.com/apache/flink/pull/16635#issuecomment-888991854 ## CI report: * 8519888d933175e0e2d370611db773f2bd173c85 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=21156) * 2e5e6ae6b57552fe083275c36dea53b2aaeb256d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28562) 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 #16635: [hotfix][connector-jdbc] fix a method name typo in postgres unit test.
flinkbot edited a comment on pull request #16635: URL: https://github.com/apache/flink/pull/16635#issuecomment-888991854 ## CI report: * 8519888d933175e0e2d370611db773f2bd173c85 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=21156) * 2e5e6ae6b57552fe083275c36dea53b2aaeb256d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28562) * 0b154cc55ffdc5698f756d63367d6bf5ed2030d4 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 #16635: [hotfix][connector-jdbc] fix a method name typo in postgres unit test.
flinkbot edited a comment on pull request #16635: URL: https://github.com/apache/flink/pull/16635#issuecomment-888991854 ## CI report: * 8519888d933175e0e2d370611db773f2bd173c85 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=21156) * 2e5e6ae6b57552fe083275c36dea53b2aaeb256d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28562) 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 #18183: [hotfix][doc] There is a link redirection problem in the Chinese document of Checkpointing
flinkbot edited a comment on pull request #18183: URL: https://github.com/apache/flink/pull/18183#issuecomment-999812530 ## CI report: * aca4a3202d46a1059541b1f89d082253074e2370 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28535) 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 #18148: [FLINK-25372] Add thread dump feature for jobmanager
flinkbot edited a comment on pull request #18148: URL: https://github.com/apache/flink/pull/18148#issuecomment-997327937 ## CI report: * 40adefafcf9f1554c73d547c31eb3a4df8f2bc34 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28538) * 89d3e84018bfad7dd3e5bf34f1864c2923b7f19e Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28560) * 1e7ac1c81e93139fe2c02f16931767eea595d622 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28563) 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 #16635: [hotfix][connector-jdbc] fix a method name typo in postgres unit test.
flinkbot edited a comment on pull request #16635: URL: https://github.com/apache/flink/pull/16635#issuecomment-888991854 ## CI report: * 8519888d933175e0e2d370611db773f2bd173c85 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=21156) * 2e5e6ae6b57552fe083275c36dea53b2aaeb256d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28562) * 0b154cc55ffdc5698f756d63367d6bf5ed2030d4 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 #18148: [FLINK-25372] Add thread dump feature for jobmanager
flinkbot edited a comment on pull request #18148: URL: https://github.com/apache/flink/pull/18148#issuecomment-997327937 ## CI report: * 40adefafcf9f1554c73d547c31eb3a4df8f2bc34 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28538) * 89d3e84018bfad7dd3e5bf34f1864c2923b7f19e Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28560) * 1e7ac1c81e93139fe2c02f16931767eea595d622 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 #16635: [hotfix][connector-jdbc] fix a method name typo in postgres unit test.
flinkbot edited a comment on pull request #16635: URL: https://github.com/apache/flink/pull/16635#issuecomment-888991854 ## CI report: * 8519888d933175e0e2d370611db773f2bd173c85 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=21156) * 2e5e6ae6b57552fe083275c36dea53b2aaeb256d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28562) 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 #16635: [hotfix][connector-jdbc] fix a method name typo in postgres unit test.
flinkbot edited a comment on pull request #16635: URL: https://github.com/apache/flink/pull/16635#issuecomment-888991854 ## CI report: * 8519888d933175e0e2d370611db773f2bd173c85 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=21156) * 2e5e6ae6b57552fe083275c36dea53b2aaeb256d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28562) * 0b154cc55ffdc5698f756d63367d6bf5ed2030d4 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 #18148: [FLINK-25372] Add thread dump feature for jobmanager
flinkbot edited a comment on pull request #18148: URL: https://github.com/apache/flink/pull/18148#issuecomment-997327937 ## CI report: * 40adefafcf9f1554c73d547c31eb3a4df8f2bc34 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28538) * 89d3e84018bfad7dd3e5bf34f1864c2923b7f19e Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28560) 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 #16635: [hotfix][connector-jdbc] fix a method name typo in postgres unit test.
flinkbot edited a comment on pull request #16635: URL: https://github.com/apache/flink/pull/16635#issuecomment-888991854 ## CI report: * 8519888d933175e0e2d370611db773f2bd173c85 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=21156) * 2e5e6ae6b57552fe083275c36dea53b2aaeb256d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28562) 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] xintongsong commented on pull request #18148: [FLINK-25372] Add thread dump feature for jobmanager
xintongsong commented on pull request #18148: URL: https://github.com/apache/flink/pull/18148#issuecomment-1000657881 @X-czh As a first contribution, you did surprisingly well. Welcome to the community. -- 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] xintongsong commented on pull request #18148: [FLINK-25372] Add thread dump feature for jobmanager
xintongsong commented on pull request #18148: URL: https://github.com/apache/flink/pull/18148#issuecomment-1000657264 @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
[GitHub] [flink] flinkbot edited a comment on pull request #16635: [hotfix][connector-jdbc] fix a method name typo in postgres unit test.
flinkbot edited a comment on pull request #16635: URL: https://github.com/apache/flink/pull/16635#issuecomment-888991854 ## CI report: * 8519888d933175e0e2d370611db773f2bd173c85 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=21156) * 2e5e6ae6b57552fe083275c36dea53b2aaeb256d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28562) * 0b154cc55ffdc5698f756d63367d6bf5ed2030d4 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 #16635: [hotfix][connector-jdbc] fix a method name typo in postgres unit test.
flinkbot edited a comment on pull request #16635: URL: https://github.com/apache/flink/pull/16635#issuecomment-888991854 ## CI report: * 8519888d933175e0e2d370611db773f2bd173c85 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=21156) * 2e5e6ae6b57552fe083275c36dea53b2aaeb256d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28562) 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 #16635: [hotfix][connector-jdbc] fix a method name typo in postgres unit test.
flinkbot edited a comment on pull request #16635: URL: https://github.com/apache/flink/pull/16635#issuecomment-888991854 ## CI report: * 8519888d933175e0e2d370611db773f2bd173c85 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=21156) * 2e5e6ae6b57552fe083275c36dea53b2aaeb256d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28562) * 0b154cc55ffdc5698f756d63367d6bf5ed2030d4 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 #16635: [hotfix][connector-jdbc] fix a method name typo in postgres unit test.
flinkbot edited a comment on pull request #16635: URL: https://github.com/apache/flink/pull/16635#issuecomment-888991854 ## CI report: * 8519888d933175e0e2d370611db773f2bd173c85 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=21156) * 2e5e6ae6b57552fe083275c36dea53b2aaeb256d 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] deadwind4 edited a comment on pull request #16635: [hotfix][connector-jdbc] fix a method name typo in postgres unit test.
deadwind4 edited a comment on pull request #16635: URL: https://github.com/apache/flink/pull/16635#issuecomment-1000653736 I have updated commit message. -- 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] deadwind4 commented on pull request #16635: [hotfix][connector-jdbc] fix a method name typo in postgres unit test.
deadwind4 commented on pull request #16635: URL: https://github.com/apache/flink/pull/16635#issuecomment-1000653736 I have updated commit message -- 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 #18180: [hotfix][doc] fix typo of 'note that' and 'now that'
flinkbot edited a comment on pull request #18180: URL: https://github.com/apache/flink/pull/18180#issuecomment-999581101 ## CI report: * 79481c2adc31f175b2963651857fe9118817f50b Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28528) 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] MartijnVisser commented on pull request #16635: [hotfix][connector-jdbc] fix a method name typo in postgres unit test.
MartijnVisser commented on pull request #16635: URL: https://github.com/apache/flink/pull/16635#issuecomment-1000651894 @deadwind4 Can you also update your commit message? -- 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 #18180: [hotfix][doc] fix typo of 'note that' and 'now that'
flinkbot edited a comment on pull request #18180: URL: https://github.com/apache/flink/pull/18180#issuecomment-999581101 ## CI report: * 79481c2adc31f175b2963651857fe9118817f50b Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28528) 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] MartijnVisser commented on pull request #18180: [hotfix][doc] fix typo of 'note that' and 'now that'
MartijnVisser commented on pull request #18180: URL: https://github.com/apache/flink/pull/18180#issuecomment-1000650081 @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
[GitHub] [flink] flinkbot edited a comment on pull request #18172: [hotfix][docs] Fix incorrect Python tableEnvironment attribute reference
flinkbot edited a comment on pull request #18172: URL: https://github.com/apache/flink/pull/18172#issuecomment-999323746 ## CI report: * aa0108e1c64dd471c09e8e0c19b2e98c0e9bf2e3 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28530) 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 #18172: [hotfix][docs] Fix incorrect Python tableEnvironment attribute reference
flinkbot edited a comment on pull request #18172: URL: https://github.com/apache/flink/pull/18172#issuecomment-999323746 ## CI report: * aa0108e1c64dd471c09e8e0c19b2e98c0e9bf2e3 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28530) 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 #18183: [hotfix][doc] There is a link redirection problem in the Chinese document of Checkpointing
flinkbot edited a comment on pull request #18183: URL: https://github.com/apache/flink/pull/18183#issuecomment-999812530 ## CI report: * aca4a3202d46a1059541b1f89d082253074e2370 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28535) 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 #18183: [hotfix][doc] There is a link redirection problem in the Chinese document of Checkpointing
flinkbot edited a comment on pull request #18183: URL: https://github.com/apache/flink/pull/18183#issuecomment-999812530 ## CI report: * aca4a3202d46a1059541b1f89d082253074e2370 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=28535) 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] MartijnVisser commented on pull request #18172: [hotfix][docs] Fix incorrect Python tableEnvironment attribute reference
MartijnVisser commented on pull request #18172: URL: https://github.com/apache/flink/pull/18172#issuecomment-1000647480 @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
