[GitHub] [flink] flinkbot edited a comment on pull request #18398: [FLINK-25695][flink-table] Fix state leak in temporalRowTimeJoinOper…

flinkbot edited a comment on pull request #18398: URL: https://github.com/apache/flink/pull/18398#issuecomment-1016025272 ## CI report: * be961c279e602761b7dd727664bff6a46f78ec0d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

flinkbot edited a comment on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000 ## CI report: * 51b23df97a9e47ce6ab8f4ca321cce5c04f729bd Azure:

[GitHub] [flink] flinkbot commented on pull request #18399: [FLINK-25118][streaming] Add vertex topology index prefix in vertex name

flinkbot commented on pull request #18399: URL: https://github.com/apache/flink/pull/18399#issuecomment-1016036012 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

[GitHub] [flink] flinkbot edited a comment on pull request #17720: [FLINK-24210][serializer] Return the correct serialized length for wi…

flinkbot edited a comment on pull request #17720: URL: https://github.com/apache/flink/pull/17720#issuecomment-963141306 ## CI report: * 0c8d9c69ed2cf13ebdb1dfb6e0b44ca31ad4e706 Azure:

[jira] [Updated] (FLINK-25695) TemporalJoin cause state leak in some cases

[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-25695: -- Description: Last year, I reported the similar bug of TemporalJoin cause state leak. Detail:

[jira] [Updated] (FLINK-25695) TemporalJoin cause state leak in some cases

[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-25695: -- Description: Last year, I reported the similar bug of TemporalJoin cause state leak. Detail:

[jira] [Updated] (FLINK-25695) TemporalJoin cause state leak in some cases

[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-25695: -- Summary: TemporalJoin cause state leak in some cases (was: TemporalJoin cause state leak in some

[jira] [Updated] (FLINK-25118) Add vertex index as prefix in vertex name

[ https://issues.apache.org/jira/browse/FLINK-25118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25118: --- Labels: pull-request-available (was: ) > Add vertex index as prefix in vertex name >

[GitHub] [flink] wenlong88 opened a new pull request #18399: [FLINK-25118][streaming] Add vertex topology index prefix in vertex name

wenlong88 opened a new pull request #18399: URL: https://github.com/apache/flink/pull/18399 ## What is the purpose of the change this is part of This PR is part of

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

flinkbot edited a comment on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1015323011 ## CI report: * 0720a8c1fc29b0ce8d953de0014a30066bf866ce Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

flinkbot edited a comment on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000 ## CI report: * 51b23df97a9e47ce6ab8f4ca321cce5c04f729bd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17720: [FLINK-24210][serializer] Return the correct serialized length for wi…

flinkbot edited a comment on pull request #17720: URL: https://github.com/apache/flink/pull/17720#issuecomment-963141306 ## CI report: * 0c8d9c69ed2cf13ebdb1dfb6e0b44ca31ad4e706 Azure:

[jira] [Commented] (FLINK-25695) TemporalJoin cause state leak in some case

[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17478316#comment-17478316 ] Lyn Zhang commented on FLINK-25695: --- [~jark] Please help to check this issue > TemporalJoin cause

[GitHub] [flink] ljz2051 commented on pull request #17720: [FLINK-24210][serializer] Return the correct serialized length for wi…

ljz2051 commented on pull request #17720: URL: https://github.com/apache/flink/pull/17720#issuecomment-1016032049 @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

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

flinkbot edited a comment on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1015323011 ## CI report: * 0720a8c1fc29b0ce8d953de0014a30066bf866ce Azure:

[jira] [Updated] (FLINK-25695) TemporalJoin cause state leak in some case

[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-25695: -- Description: Last year, I reported the similar bug of TemporalJoin cause state leak. Detail:

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

flinkbot edited a comment on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000 ## CI report: * 51b23df97a9e47ce6ab8f4ca321cce5c04f729bd Azure:

[jira] [Updated] (FLINK-25695) TemporalJoin cause state leak in some case

[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-25695: -- Description: Last year, I reported the similar bug of TemporalJoin cause state leak. Detail:

[jira] [Updated] (FLINK-25695) TemporalJoin cause state leak in some case

[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lyn Zhang updated FLINK-25695: -- Description: Last year, I reported the similar bug of TemporalJoin cause state leak. Detail:

[jira] [Commented] (FLINK-25695) TemporalJoin cause state leak in some case

[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17478314#comment-17478314 ] Lyn Zhang commented on FLINK-25695: --- PR: https://github.com/apache/flink/pull/18398 > TemporalJoin

[jira] [Created] (FLINK-25695) TemporalJoin cause state leak in some case

Lyn Zhang created FLINK-25695: - Summary: TemporalJoin cause state leak in some case Key: FLINK-25695 URL: https://issues.apache.org/jira/browse/FLINK-25695 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

flinkbot edited a comment on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1015323011 ## CI report: * 0720a8c1fc29b0ce8d953de0014a30066bf866ce Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18137: [FLINK-25287][connector-testing-framework] Refactor interfaces of connector testing framework to support more scenarios

flinkbot edited a comment on pull request #18137: URL: https://github.com/apache/flink/pull/18137#issuecomment-996615034 ## CI report: * 89dbac69bd4891b3e564de634b3d942391d1840c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

flinkbot edited a comment on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000 ## CI report: * 51b23df97a9e47ce6ab8f4ca321cce5c04f729bd Azure:

[GitHub] [flink] zhuzhurk commented on a change in pull request #18126: [FLINK-25036][runtime] Add stage wise scheduling strategy

zhuzhurk commented on a change in pull request #18126: URL: https://github.com/apache/flink/pull/18126#discussion_r787294877 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/StagewiseSchedulingStrategy.java ## @@ -0,0 +1,156 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

flinkbot edited a comment on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1015323011 ## CI report: * 0720a8c1fc29b0ce8d953de0014a30066bf866ce Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18137: [FLINK-25287][connector-testing-framework] Refactor interfaces of connector testing framework to support more scenarios

flinkbot edited a comment on pull request #18137: URL: https://github.com/apache/flink/pull/18137#issuecomment-996615034 ## CI report: * 89dbac69bd4891b3e564de634b3d942391d1840c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

flinkbot edited a comment on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000 ## CI report: * 51b23df97a9e47ce6ab8f4ca321cce5c04f729bd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18398: [Quick-Commit][flink-table] Fix state leak in temporalRowTimeJoinOper…

flinkbot edited a comment on pull request #18398: URL: https://github.com/apache/flink/pull/18398#issuecomment-1016025272 ## CI report: * be961c279e602761b7dd727664bff6a46f78ec0d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

flinkbot edited a comment on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000 ## CI report: * 51b23df97a9e47ce6ab8f4ca321cce5c04f729bd Azure:

[GitHub] [flink] spoon-lz commented on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

spoon-lz commented on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-1016026449 @wangyang0918 I think the code is sorted out already -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] flinkbot commented on pull request #18398: [Quick-Commit][flink-table] Fix state leak in temporalRowTimeJoinOper…

flinkbot commented on pull request #18398: URL: https://github.com/apache/flink/pull/18398#issuecomment-1016025410 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

[GitHub] [flink] flinkbot commented on pull request #18398: [Quick-Commit][flink-table] Fix state leak in temporalRowTimeJoinOper…

flinkbot commented on pull request #18398: URL: https://github.com/apache/flink/pull/18398#issuecomment-1016025272 ## CI report: * be961c279e602761b7dd727664bff6a46f78ec0d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

flinkbot edited a comment on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000 ## CI report: * 51b23df97a9e47ce6ab8f4ca321cce5c04f729bd Azure:

[GitHub] [flink] zicat opened a new pull request #18398: [Quick-Commit][flink-table] Fix state leak in temporalRowTimeJoinOper…

zicat opened a new pull request #18398: URL: https://github.com/apache/flink/pull/18398 …ator ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

flinkbot edited a comment on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000 ## CI report: * 51b23df97a9e47ce6ab8f4ca321cce5c04f729bd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

flinkbot edited a comment on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1015323011 ## CI report: * 0720a8c1fc29b0ce8d953de0014a30066bf866ce Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

flinkbot edited a comment on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1015323011 ## CI report: * 0720a8c1fc29b0ce8d953de0014a30066bf866ce Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18365: [FLINK-22643][network] Reuse tpc connections between taskmanagers

flinkbot edited a comment on pull request #18365: URL: https://github.com/apache/flink/pull/18365#issuecomment-1013081147 ## CI report: * 51ec010668d8237bb8e02de3848126a9a7f19620 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18365: [FLINK-22643][network] Reuse tpc connections between taskmanagers

flinkbot edited a comment on pull request #18365: URL: https://github.com/apache/flink/pull/18365#issuecomment-1013081147 ## CI report: * 51ec010668d8237bb8e02de3848126a9a7f19620 Azure:

[GitHub] [flink] 1996fanrui commented on pull request #18365: [FLINK-22643][network] Reuse tpc connections between taskmanagers

1996fanrui commented on pull request #18365: URL: https://github.com/apache/flink/pull/18365#issuecomment-1016011073 > Thanks @1996fanrui , can you squash the commits before merging? done -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-25562) hive sql connector dependency conflicts

[ https://issues.apache.org/jira/browse/FLINK-25562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17478306#comment-17478306 ] luoyuxia commented on FLINK-25562: -- [~MartijnVisser] Thanks for the information, I'll fix it when i'm

[jira] [Updated] (FLINK-25676) Add set_description in Python API

[ https://issues.apache.org/jira/browse/FLINK-25676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-25676: Parent: FLINK-25070 Issue Type: Sub-task (was: Improvement) > Add set_description in Python API

[jira] [Closed] (FLINK-25676) Add set_description in Python API

[ https://issues.apache.org/jira/browse/FLINK-25676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-25676. --- Resolution: Fixed Merged to master via 1722a3060d51083874b5b8635979487de1fec31a > Add set_description in

[GitHub] [flink] dianfu closed pull request #18380: [FLINK-25676][python] Support set_description in DataStream API

dianfu closed pull request #18380: URL: https://github.com/apache/flink/pull/18380 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] dianfu commented on pull request #18380: [FLINK-25676][python] Support set_description in DataStream API

dianfu commented on pull request #18380: URL: https://github.com/apache/flink/pull/18380#issuecomment-1015993054 @HuangXingBo Thanks for the review. Will address the comments during merging the PR. -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-25683) wrong result if table transfrom to DataStream then window process in batch mode

[ https://issues.apache.org/jira/browse/FLINK-25683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17478297#comment-17478297 ] Yao Zhang commented on FLINK-25683: --- Hi [~zhangzihan] , Thank you very much for reporting this issue.

[jira] [Assigned] (FLINK-25509) FLIP-208: Add RecordEvaluator to dynamically stop source based on de-serialized records

[ https://issues.apache.org/jira/browse/FLINK-25509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned FLINK-25509: Assignee: Dong Lin > FLIP-208: Add RecordEvaluator to dynamically stop source based on >

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * fc7193f9336b272ced363c100517ad4f4f793804 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #18397: [HOTFIX][Kafka] update interface @PublicEvolving or @Internal

flinkbot edited a comment on pull request #18397: URL: https://github.com/apache/flink/pull/18397#issuecomment-1015848205 ## CI report: * dc25efa3f7f3488c227b79c99d5639037ed35655 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * fc7193f9336b272ced363c100517ad4f4f793804 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * fc7193f9336b272ced363c100517ad4f4f793804 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * fc7193f9336b272ced363c100517ad4f4f793804 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * fc7193f9336b272ced363c100517ad4f4f793804 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * fc7193f9336b272ced363c100517ad4f4f793804 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #18314: [FLINK-24228][connectors/firehose] - Unified Async Sink for Kinesis Firehose

flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * 826fd84d3f61953a127829be78708c6d54de3244 UNKNOWN * 4161e8253318ff9fadc8ca414527c92d810d0100 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * fc7193f9336b272ced363c100517ad4f4f793804 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #18397: [HOTFIX][Kafka] update interface @PublicEvolving or @Internal

flinkbot edited a comment on pull request #18397: URL: https://github.com/apache/flink/pull/18397#issuecomment-1015848205 ## CI report: * dc25efa3f7f3488c227b79c99d5639037ed35655 Azure:

[GitHub] [flink] flinkbot commented on pull request #18397: [HOTFIX][Kafka] update interface @PublicEvolving or @Internal

flinkbot commented on pull request #18397: URL: https://github.com/apache/flink/pull/18397#issuecomment-1015848712 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

[GitHub] [flink] flinkbot commented on pull request #18397: [HOTFIX][Kafka] update interface @PublicEvolving or @Internal

flinkbot commented on pull request #18397: URL: https://github.com/apache/flink/pull/18397#issuecomment-1015848205 ## CI report: * dc25efa3f7f3488c227b79c99d5639037ed35655 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] JingGe opened a new pull request #18397: [HOTFIX][Kafka] update interface @PublicEvolving or @Internal

JingGe opened a new pull request #18397: URL: https://github.com/apache/flink/pull/18397 ## What is the purpose of the change The PR added the feasible annotations to some kafka connector interfaces and fixed some code and Javadoc issues. ## Brief change log -

[GitHub] [flink] flinkbot edited a comment on pull request #18348: [FLINK-24905][connectors/kinesis] Adding support for Kinesis DataStream sink as kinesis table connector sink.

flinkbot edited a comment on pull request #18348: URL: https://github.com/apache/flink/pull/18348#issuecomment-1011977937 ## CI report: * 2ff1f4fc317826b2ed0cb006f7dbefd5a36c0c7a Azure:

[jira] [Commented] (FLINK-25661) Add Custom Fatal Exception handler in AsyncSinkWriter

[ https://issues.apache.org/jira/browse/FLINK-25661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17478201#comment-17478201 ] Nir Tsruya commented on FLINK-25661: [~dannycranmer] yes thanks > Add Custom Fatal Exception

[GitHub] [flink] flinkbot edited a comment on pull request #18348: [FLINK-24905][connectors/kinesis] Adding support for Kinesis DataStream sink as kinesis table connector sink.

flinkbot edited a comment on pull request #18348: URL: https://github.com/apache/flink/pull/18348#issuecomment-1011977937 ## CI report: * 9b26f7c03a164a4e3b2c9c28711530b36dc214dc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18314: [FLINK-24228][connectors/firehose] - Unified Async Sink for Kinesis Firehose

flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * 826fd84d3f61953a127829be78708c6d54de3244 UNKNOWN * 2173e5a6d25c78bf99f1f3c25d8e3662f22de6cf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18314: [FLINK-24228][connectors/firehose] - Unified Async Sink for Kinesis Firehose

flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * 826fd84d3f61953a127829be78708c6d54de3244 UNKNOWN * 2173e5a6d25c78bf99f1f3c25d8e3662f22de6cf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18314: [FLINK-24228][connectors/firehose] - Unified Async Sink for Kinesis Firehose

flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * 826fd84d3f61953a127829be78708c6d54de3244 UNKNOWN * 2173e5a6d25c78bf99f1f3c25d8e3662f22de6cf Azure:

[GitHub] [flink] rkhachatryan commented on a change in pull request #18224: [FLINK-25143][test] Add ITCase for periodic materialization

rkhachatryan commented on a change in pull request #18224: URL: https://github.com/apache/flink/pull/18224#discussion_r787022001 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/ChangelogPeriodicMaterializationITCase.java ## @@ -0,0 +1,734 @@ +/* +

[GitHub] [flink] flinkbot edited a comment on pull request #18314: [FLINK-24228][connectors/firehose] - Unified Async Sink for Kinesis Firehose

flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * 826fd84d3f61953a127829be78708c6d54de3244 UNKNOWN * 2173e5a6d25c78bf99f1f3c25d8e3662f22de6cf Azure:

[GitHub] [flink] rkhachatryan commented on a change in pull request #18224: [FLINK-25143][test] Add ITCase for periodic materialization

rkhachatryan commented on a change in pull request #18224: URL: https://github.com/apache/flink/pull/18224#discussion_r787048975 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/ChangelogPeriodicMaterializationITCase.java ## @@ -0,0 +1,734 @@ +/* +

[GitHub] [flink] flinkbot edited a comment on pull request #18314: [FLINK-24228][connectors/firehose] - Unified Async Sink for Kinesis Firehose

flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * 826fd84d3f61953a127829be78708c6d54de3244 UNKNOWN * 2173e5a6d25c78bf99f1f3c25d8e3662f22de6cf Azure:

[GitHub] [flink] rkhachatryan commented on a change in pull request #18224: [FLINK-25143][test] Add ITCase for periodic materialization

rkhachatryan commented on a change in pull request #18224: URL: https://github.com/apache/flink/pull/18224#discussion_r787022001 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/ChangelogPeriodicMaterializationITCase.java ## @@ -0,0 +1,734 @@ +/* +

[GitHub] [flink] rkhachatryan commented on a change in pull request #18224: [FLINK-25143][test] Add ITCase for periodic materialization

rkhachatryan commented on a change in pull request #18224: URL: https://github.com/apache/flink/pull/18224#discussion_r787017871 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/ChangelogPeriodicMaterializationITCase.java ## @@ -0,0 +1,734 @@ +/* +

[GitHub] [flink] rkhachatryan commented on a change in pull request #18224: [FLINK-25143][test] Add ITCase for periodic materialization

rkhachatryan commented on a change in pull request #18224: URL: https://github.com/apache/flink/pull/18224#discussion_r787035648 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/ChangelogPeriodicMaterializationITCase.java ## @@ -0,0 +1,734 @@ +/* +

[GitHub] [flink] flinkbot edited a comment on pull request #18314: [FLINK-24228][connectors/firehose] - Unified Async Sink for Kinesis Firehose

flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * 826fd84d3f61953a127829be78708c6d54de3244 UNKNOWN * 2173e5a6d25c78bf99f1f3c25d8e3662f22de6cf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18314: [FLINK-24228][connectors/firehose] - Unified Async Sink for Kinesis Firehose

flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * 826fd84d3f61953a127829be78708c6d54de3244 UNKNOWN * 2173e5a6d25c78bf99f1f3c25d8e3662f22de6cf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18314: [FLINK-24228][connectors/firehose] - Unified Async Sink for Kinesis Firehose

flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * 826fd84d3f61953a127829be78708c6d54de3244 UNKNOWN * 2173e5a6d25c78bf99f1f3c25d8e3662f22de6cf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18314: [FLINK-24228][connectors/firehose] - Unified Async Sink for Kinesis Firehose

flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * 826fd84d3f61953a127829be78708c6d54de3244 UNKNOWN * 2173e5a6d25c78bf99f1f3c25d8e3662f22de6cf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18314: [FLINK-24228][connectors/firehose] - Unified Async Sink for Kinesis Firehose

flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * 826fd84d3f61953a127829be78708c6d54de3244 UNKNOWN * 2173e5a6d25c78bf99f1f3c25d8e3662f22de6cf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18314: [FLINK-24228][connectors/firehose] - Unified Async Sink for Kinesis Firehose

flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * 826fd84d3f61953a127829be78708c6d54de3244 UNKNOWN * 2173e5a6d25c78bf99f1f3c25d8e3662f22de6cf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18314: [FLINK-24228][connectors/firehose] - Unified Async Sink for Kinesis Firehose

flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * 826fd84d3f61953a127829be78708c6d54de3244 UNKNOWN * 2173e5a6d25c78bf99f1f3c25d8e3662f22de6cf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18314: [FLINK-24228][connectors/firehose] - Unified Async Sink for Kinesis Firehose

flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * 826fd84d3f61953a127829be78708c6d54de3244 UNKNOWN * 2173e5a6d25c78bf99f1f3c25d8e3662f22de6cf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18354: [FLINK-25650][docs] Added "Interplay with long-running record process…

flinkbot edited a comment on pull request #18354: URL: https://github.com/apache/flink/pull/18354#issuecomment-1014449494 ## CI report: * c1441dd55ff1b42c6d9537eb55a4b96a3cf0c46e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18314: [FLINK-24228][connectors/firehose] - Unified Async Sink for Kinesis Firehose

flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * 826fd84d3f61953a127829be78708c6d54de3244 UNKNOWN * 2173e5a6d25c78bf99f1f3c25d8e3662f22de6cf Azure:

[GitHub] [flink] galenwarren commented on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

galenwarren commented on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-1015738539 Just an FYI regarding the GSON vulnerability reported [here](https://issues.apache.org/jira/browse/FLINK-25694): flink-gs-fs-hadoop uses GSON but is already using the

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

flinkbot edited a comment on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1015323011 ## CI report: * 0720a8c1fc29b0ce8d953de0014a30066bf866ce Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18348: [FLINK-24905][connectors/kinesis] Adding support for Kinesis DataStream sink as kinesis table connector sink.

flinkbot edited a comment on pull request #18348: URL: https://github.com/apache/flink/pull/18348#issuecomment-1011977937 ## CI report: * e64fc5d1a9a1ffb3e09ccc42664c8c28104a9941 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18348: [FLINK-24905][connectors/kinesis] Adding support for Kinesis DataStream sink as kinesis table connector sink.

flinkbot edited a comment on pull request #18348: URL: https://github.com/apache/flink/pull/18348#issuecomment-1011977937 ## CI report: * e64fc5d1a9a1ffb3e09ccc42664c8c28104a9941 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18348: [FLINK-24905][connectors/kinesis] Adding support for Kinesis DataStream sink as kinesis table connector sink.

flinkbot edited a comment on pull request #18348: URL: https://github.com/apache/flink/pull/18348#issuecomment-1011977937 ## CI report: * e64fc5d1a9a1ffb3e09ccc42664c8c28104a9941 Azure:

[jira] [Created] (FLINK-25694) GSON/Alluxio Vulnerability

David Perkins created FLINK-25694: - Summary: GSON/Alluxio Vulnerability Key: FLINK-25694 URL: https://issues.apache.org/jira/browse/FLINK-25694 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #18348: [FLINK-24905][connectors/kinesis] Adding support for Kinesis DataStream sink as kinesis table connector sink.

flinkbot edited a comment on pull request #18348: URL: https://github.com/apache/flink/pull/18348#issuecomment-1011977937 ## CI report: * e64fc5d1a9a1ffb3e09ccc42664c8c28104a9941 Azure:

[GitHub] [flink-docker] tweise merged pull request #98: Add 1.14.3 release

tweise merged pull request #98: URL: https://github.com/apache/flink-docker/pull/98 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] flinkbot edited a comment on pull request #18396: [hotfix][connectors] Fix: Infinite loop can arise when prepareCommit(…

flinkbot edited a comment on pull request #18396: URL: https://github.com/apache/flink/pull/18396#issuecomment-1015554715 ## CI report: * 558b1a4d2c4fb4e5a6d443b753da98603c039443 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

flinkbot edited a comment on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1015323011 ## CI report: * a5974a811e657ccabb90c1c913c00adb56f53ebe Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18348: [FLINK-24905][connectors/kinesis] Adding support for Kinesis DataStream sink as kinesis table connector sink.

flinkbot edited a comment on pull request #18348: URL: https://github.com/apache/flink/pull/18348#issuecomment-1011977937 ## CI report: * e64fc5d1a9a1ffb3e09ccc42664c8c28104a9941 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18348: [FLINK-24905][connectors/kinesis] Adding support for Kinesis DataStream sink as kinesis table connector sink.

flinkbot edited a comment on pull request #18348: URL: https://github.com/apache/flink/pull/18348#issuecomment-1011977937 ## CI report: * e64fc5d1a9a1ffb3e09ccc42664c8c28104a9941 Azure:

[jira] [Commented] (FLINK-25685) RestClusterClient gets stuck on submitting job with local user artifact

[ https://issues.apache.org/jira/browse/FLINK-25685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17478081#comment-17478081 ] Chesnay Schepler commented on FLINK-25685: -- I have seen it. I still can't reproduce the issue

[GitHub] [flink] akalash commented on a change in pull request #18341: [FLINK-25194] Implement an API for duplicating artefacts

akalash commented on a change in pull request #18341: URL: https://github.com/apache/flink/pull/18341#discussion_r787004952 ## File path: flink-core/src/main/java/org/apache/flink/core/fs/DuplicatingFileSystem.java ## @@ -0,0 +1,74 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] akalash commented on a change in pull request #18341: [FLINK-25194] Implement an API for duplicating artefacts

akalash commented on a change in pull request #18341: URL: https://github.com/apache/flink/pull/18341#discussion_r787001749 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointStreamFactory.java ## @@ -39,4 +40,31 @@ */

[GitHub] [flink] flinkbot edited a comment on pull request #18341: [FLINK-25194] Implement an API for duplicating artefacts

flinkbot edited a comment on pull request #18341: URL: https://github.com/apache/flink/pull/18341#issuecomment-1011007519 ## CI report: * 17bc21ace8d5c56af305ffe76456796e4b055ea9 Azure:

<    1   2   3   4   5   6   >