[GitHub] [flink] gyfora commented on pull request #17582: [FLINK-24674][kubernetes] Create corresponding resouces for task manager Pods

gyfora commented on pull request #17582: URL: https://github.com/apache/flink/pull/17582#issuecomment-964865674 Just one question so I understand the exact problem @viirya : Does this issue only happen if you are using a custom taskmanager pod template in which you define the hadoop

[GitHub] [flink] flinkbot edited a comment on pull request #17741: [BP-1.13][FLINK-23696][connectors/rabbitmq] Fix RMQSourceTest.testRedeliveredSessionIDsAck

flinkbot edited a comment on pull request #17741: URL: https://github.com/apache/flink/pull/17741#issuecomment-964618004 ## CI report: * 15a1ede8913257d8f919b8c1e89192c154ef7720 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-24621) JobManager fails to recover 1.13.1 checkpoint due to InflightDataRescalingDescriptor

[ https://issues.apache.org/jira/browse/FLINK-24621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17441558#comment-17441558 ] Dawid Wysakowicz commented on FLINK-24621: -- I am decreasing priority, because a

[jira] [Updated] (FLINK-24621) JobManager fails to recover 1.13.1 checkpoint due to InflightDataRescalingDescriptor

[ https://issues.apache.org/jira/browse/FLINK-24621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-24621: - Priority: Major (was: Blocker) > JobManager fails to recover 1.13.1 checkpoint due to

[GitHub] [flink] flinkbot edited a comment on pull request #17708: [FLINK-23696][connectors/rabbitmq] Fix RMQSourceTest.testRedeliveredSessionIDsAck

flinkbot edited a comment on pull request #17708: URL: https://github.com/apache/flink/pull/17708#issuecomment-962715413 ## CI report: * c3683b982d7aebe2bbdd8cf8c0800fed0c180b61 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Comment Edited] (FLINK-24621) JobManager fails to recover 1.13.1 checkpoint due to InflightDataRescalingDescriptor

[ https://issues.apache.org/jira/browse/FLINK-24621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17441558#comment-17441558 ] Dawid Wysakowicz edited comment on FLINK-24621 at 11/10/21, 7:46 AM: -

[GitHub] [flink] flinkbot edited a comment on pull request #17741: [BP-1.13][FLINK-23696][connectors/rabbitmq] Fix RMQSourceTest.testRedeliveredSessionIDsAck

flinkbot edited a comment on pull request #17741: URL: https://github.com/apache/flink/pull/17741#issuecomment-964618004 ## CI report: * 15a1ede8913257d8f919b8c1e89192c154ef7720 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17708: [FLINK-23696][connectors/rabbitmq] Fix RMQSourceTest.testRedeliveredSessionIDsAck

flinkbot edited a comment on pull request #17708: URL: https://github.com/apache/flink/pull/17708#issuecomment-962715413 ## CI report: * c3683b982d7aebe2bbdd8cf8c0800fed0c180b61 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] fapaul commented on pull request #17741: [BP-1.13][FLINK-23696][connectors/rabbitmq] Fix RMQSourceTest.testRedeliveredSessionIDsAck

fapaul commented on pull request #17741: URL: https://github.com/apache/flink/pull/17741#issuecomment-964861470 @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 c

[GitHub] [flink] fapaul commented on pull request #17708: [FLINK-23696][connectors/rabbitmq] Fix RMQSourceTest.testRedeliveredSessionIDsAck

fapaul commented on pull request #17708: URL: https://github.com/apache/flink/pull/17708#issuecomment-964860454 @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 c

[jira] [Commented] (FLINK-24800) BufferTimeoutITCase.testDisablingBufferTimeout failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-24800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17441553#comment-17441553 ] Fabian Paul commented on FLINK-24800: - https://dev.azure.com/apache-flink/apache-fli

[GitHub] [flink] fapaul commented on pull request #17731: [FLINK-24834][connectors / filesystem] Add typed builders to DefaultRollingPolicy

fapaul commented on pull request #17731: URL: https://github.com/apache/flink/pull/17731#issuecomment-964857374 Hmm, I checked my local sha and we are looking at the same commit :) Can you check `ContinuousFileReaderOperatorITCase#testChainedOperatorsAreNotPrematurelyClosed`? --

[jira] [Commented] (FLINK-24729) Support IterationBody with mixed per-round and all-round operators

[ https://issues.apache.org/jira/browse/FLINK-24729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17441543#comment-17441543 ] Yun Gao commented on FLINK-24729: - Fix on master via a0331de0b797068f885e6e691a73fff4487

[jira] [Assigned] (FLINK-24674) Create corresponding resouces for task manager Pods

[ https://issues.apache.org/jira/browse/FLINK-24674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-24674: -- Assignee: L. C. Hsieh > Create corresponding resouces for task manager Pods > ---

[jira] [Closed] (FLINK-24729) Support IterationBody with mixed per-round and all-round operators

[ https://issues.apache.org/jira/browse/FLINK-24729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-24729. --- Resolution: Fixed > Support IterationBody with mixed per-round and all-round operators > ---

[GitHub] [flink-ml] gaoyunhaii closed pull request #23: [FLINK-24729][iteration] Support iteration with mixed operator life-cycle

gaoyunhaii closed pull request #23: URL: https://github.com/apache/flink-ml/pull/23 -- 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-unsubsc

[jira] [Commented] (FLINK-24851) KafkaSourceBuilder: auto.offset.reset is ignored

[ https://issues.apache.org/jira/browse/FLINK-24851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17441542#comment-17441542 ] liwei li commented on FLINK-24851: -- Can you give me the ticket and let me have a try?

[GitHub] [flink] JingsongLi commented on a change in pull request #17666: [FLINK-21327][table-planner-blink] Support window TVF in batch mode

JingsongLi commented on a change in pull request #17666: URL: https://github.com/apache/flink/pull/17666#discussion_r746306840 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchPhysicalWindowTableFunction.scala #

[GitHub] [flink] flinkbot edited a comment on pull request #17698: [FLINK-24689][runtime-web] Add log's last modify time in log list view

flinkbot edited a comment on pull request #17698: URL: https://github.com/apache/flink/pull/17698#issuecomment-961944542 ## CI report: * 0b4b16b4fa5826314209258cbe6c9322b6482afa Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink-ml] guoweiM commented on a change in pull request #23: [FLINK-24729][iteration] Support iteration with mixed operator life-cycle

guoweiM commented on a change in pull request #23: URL: https://github.com/apache/flink-ml/pull/23#discussion_r746302918 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/IterationBody.java ## @@ -44,7 +51,7 @@ * streams returned by the IterationBody.

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #23: [FLINK-24729][iteration] Support iteration with mixed operator life-cycle

gaoyunhaii commented on a change in pull request #23: URL: https://github.com/apache/flink-ml/pull/23#discussion_r746302382 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/IterationBody.java ## @@ -44,7 +51,7 @@ * streams returned by the IterationBo

[GitHub] [flink] JingsongLi merged pull request #17673: [FLINK-24001][table-runtime] Window table-valued function operator support proctime window

JingsongLi merged pull request #17673: URL: https://github.com/apache/flink/pull/17673 -- 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-unsu

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #23: [FLINK-24729][iteration] Support iteration with mixed operator life-cycle

gaoyunhaii commented on a change in pull request #23: URL: https://github.com/apache/flink-ml/pull/23#discussion_r746302145 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/IterationBody.java ## @@ -44,7 +51,7 @@ * streams returned by the IterationBo

[jira] [Closed] (FLINK-24501) Unexpected behavior of cumulate window aggregate for late event after recover from sp/cp

[ https://issues.apache.org/jira/browse/FLINK-24501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-24501. Fix Version/s: 1.15.0 Resolution: Fixed master: cba6b2c89a0ecd8858c1849a9b06350db48fb450 >

[GitHub] [flink] JingsongLi merged pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-tvf aggregat

JingsongLi merged pull request #17509: URL: https://github.com/apache/flink/pull/17509 -- 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-unsu

[GitHub] [flink] flinkbot edited a comment on pull request #17592: [hotfixs][flink-yarn] Fix typo in YarnConfigOptions.java

flinkbot edited a comment on pull request #17592: URL: https://github.com/apache/flink/pull/17592#issuecomment-953735692 ## CI report: * 08e16c79ffcf4046a8948652faba7e268d61036f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17733: [FLINK-24835][table-planner] Fix bug in `RelTimeIndicatorConverter` when materialize time attribute fields of regular join's inputs

flinkbot edited a comment on pull request #17733: URL: https://github.com/apache/flink/pull/17733#issuecomment-963997692 ## CI report: * 4cb7640a1d8ec87af337ea967af06cb3add1cb01 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17673: [FLINK-24001][table-runtime] Window table-valued function operator support proctime window

flinkbot edited a comment on pull request #17673: URL: https://github.com/apache/flink/pull/17673#issuecomment-960580326 ## CI report: * 1570fa21dcbce0f6c4152cf9d740f5d551008729 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink-ml] guoweiM commented on a change in pull request #23: [FLINK-24729][iteration] Support iteration with mixed operator life-cycle

guoweiM commented on a change in pull request #23: URL: https://github.com/apache/flink-ml/pull/23#discussion_r746295904 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/IterationBody.java ## @@ -44,7 +51,7 @@ * streams returned by the IterationBody.

[GitHub] [flink] flinkbot edited a comment on pull request #17742: [BP-1.14][FLINK-24733][connector/pulsar] Data loss in pulsar source when using shared mode

flinkbot edited a comment on pull request #17742: URL: https://github.com/apache/flink/pull/17742#issuecomment-964839558 ## CI report: * cdd8dceadd7e64914a304f735086bab40a270b2a Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #17742: [BP-1.14][FLINK-24733][connector/pulsar] Data loss in pulsar source when using shared mode

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

[GitHub] [flink] flinkbot commented on pull request #17742: [BP-1.14][FLINK-24733][connector/pulsar] Data loss in pulsar source when using shared mode

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

[GitHub] [flink] syhily opened a new pull request #17742: [BP-1.14][FLINK-24733][connector/pulsar] Data loss in pulsar source when using shared mode

syhily opened a new pull request #17742: URL: https://github.com/apache/flink/pull/17742 This is a backport of #17643 (fixing FLINK-24733) to release-1.14. The fix is exactly the same as in #17643. Please see #17643 for a detailed description. -- This is an automated message from

[jira] [Assigned] (FLINK-24668) Pulsar consumption data repeated output

[ https://issues.apache.org/jira/browse/FLINK-24668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-24668: -- Assignee: Yufan Sheng > Pulsar consumption data repeated output > ---

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-t

flinkbot edited a comment on pull request #17509: URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594 ## CI report: * a010eb5ec6d5f36100d2a9a10ef57df393fdb32f Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #29: [FLINK-24838] Add BaseAlgoImpl class to support link() and linkFrom()

zhipeng93 commented on a change in pull request #29: URL: https://github.com/apache/flink-ml/pull/29#discussion_r746280421 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/operator/BaseAlgoImpl.java ## @@ -0,0 +1,98 @@ +/* + * Licensed to the Apache Software Founda

[GitHub] [flink] flinkbot edited a comment on pull request #17741: [BP-1.13][FLINK-23696][connectors/rabbitmq] Fix RMQSourceTest.testRedeliveredSessionIDsAck

flinkbot edited a comment on pull request #17741: URL: https://github.com/apache/flink/pull/17741#issuecomment-964618004 ## CI report: * 15a1ede8913257d8f919b8c1e89192c154ef7720 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17740: [BP-1.14][FLINK-23696][connectors/rabbitmq] Fix RMQSourceTest.testRedeliveredSessionIDsAck

flinkbot edited a comment on pull request #17740: URL: https://github.com/apache/flink/pull/17740#issuecomment-964612266 ## CI report: * aad4ecf474e16e0cdb95579269fcfa9c1e17d668 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #29: [FLINK-24838] Add BaseAlgoImpl class to support link() and linkFrom()

zhipeng93 commented on a change in pull request #29: URL: https://github.com/apache/flink-ml/pull/29#discussion_r746279810 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/operator/batch/BatchOperator.java ## @@ -0,0 +1,109 @@ +/* + * Licensed to the Apache Softwar

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #29: [FLINK-24838] Add BaseAlgoImpl class to support link() and linkFrom()

zhipeng93 commented on a change in pull request #29: URL: https://github.com/apache/flink-ml/pull/29#discussion_r746280421 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/operator/BaseAlgoImpl.java ## @@ -0,0 +1,98 @@ +/* + * Licensed to the Apache Software Founda

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #29: [FLINK-24838] Add BaseAlgoImpl class to support link() and linkFrom()

zhipeng93 commented on a change in pull request #29: URL: https://github.com/apache/flink-ml/pull/29#discussion_r746279810 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/operator/batch/BatchOperator.java ## @@ -0,0 +1,109 @@ +/* + * Licensed to the Apache Softwar

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #29: [FLINK-24838] Add BaseAlgoImpl class to support link() and linkFrom()

zhipeng93 commented on a change in pull request #29: URL: https://github.com/apache/flink-ml/pull/29#discussion_r746279810 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/operator/batch/BatchOperator.java ## @@ -0,0 +1,109 @@ +/* + * Licensed to the Apache Softwar

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #29: [FLINK-24838] Add BaseAlgoImpl class to support link() and linkFrom()

zhipeng93 commented on a change in pull request #29: URL: https://github.com/apache/flink-ml/pull/29#discussion_r746279810 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/operator/batch/BatchOperator.java ## @@ -0,0 +1,109 @@ +/* + * Licensed to the Apache Softwar

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #29: [FLINK-24838] Add BaseAlgoImpl class to support link() and linkFrom()

zhipeng93 commented on a change in pull request #29: URL: https://github.com/apache/flink-ml/pull/29#discussion_r746279810 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/operator/batch/BatchOperator.java ## @@ -0,0 +1,109 @@ +/* + * Licensed to the Apache Softwar

[GitHub] [flink] flinkbot edited a comment on pull request #17643: [FLINK-24733][connector/pulsar] Data loss in pulsar source when using shared mode

flinkbot edited a comment on pull request #17643: URL: https://github.com/apache/flink/pull/17643#issuecomment-957416596 ## CI report: * 2c6da59c41a17a14cf2ca5ee9931d716dd038f6a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17643: [FLINK-24733][connector/pulsar] Data loss in pulsar source when using shared mode

flinkbot edited a comment on pull request #17643: URL: https://github.com/apache/flink/pull/17643#issuecomment-957416596 ## CI report: * 2c6da59c41a17a14cf2ca5ee9931d716dd038f6a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] syhily commented on pull request #17643: [FLINK-24733][connector/pulsar] Data loss in pulsar source when using shared mode

syhily commented on pull request #17643: URL: https://github.com/apache/flink/pull/17643#issuecomment-964822135 @AHeise I think this PR is ready. Can you perform the final review? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitH

[jira] [Comment Edited] (FLINK-23848) PulsarSourceITCase is failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-23848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17441511#comment-17441511 ] Yufan Sheng edited comment on FLINK-23848 at 11/10/21, 6:01 AM: --

[jira] [Updated] (FLINK-24838) Add BaseAlgoImpl class to support link() and linkFrom() (FlinkML)

[ https://issues.apache.org/jira/browse/FLINK-24838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24838: --- Labels: pull-request-available (was: ) > Add BaseAlgoImpl class to support link() and linkF

[GitHub] [flink-ml] lindong28 commented on a change in pull request #29: [FLINK-24838] Add BaseAlgoImpl class to support link() and linkFrom()

lindong28 commented on a change in pull request #29: URL: https://github.com/apache/flink-ml/pull/29#discussion_r746269333 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/operator/batch/BatchOperator.java ## @@ -0,0 +1,109 @@ +/* + * Licensed to the Apache Softwar

[jira] [Commented] (FLINK-24449) PulsarSourceITCase>SourceTestSuiteBase.testTaskManagerFailure fails with record mismatch

[ https://issues.apache.org/jira/browse/FLINK-24449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17441513#comment-17441513 ] Yufan Sheng commented on FLINK-24449: - Hi [~dwysakowicz], this issue is the same as

[GitHub] [flink] flinkbot edited a comment on pull request #17708: [FLINK-23696][connectors/rabbitmq] Fix RMQSourceTest.testRedeliveredSessionIDsAck

flinkbot edited a comment on pull request #17708: URL: https://github.com/apache/flink/pull/17708#issuecomment-962715413 ## CI report: * c3683b982d7aebe2bbdd8cf8c0800fed0c180b61 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-23848) PulsarSourceITCase is failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-23848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17441511#comment-17441511 ] Yufan Sheng commented on FLINK-23848: - [~gaoyunhaii] I think this is a new issue cau

[GitHub] [flink] RocMarshal edited a comment on pull request #17548: [FLINK-24383][streaming] Remove the deprecated SlidingTimeWindows, TumblingTimeWindows, BaseAlignedWindowAssigner.

RocMarshal edited a comment on pull request #17548: URL: https://github.com/apache/flink/pull/17548#issuecomment-950549753 Hi, @wuchong @xintongsong @lirui-apache @klion26 Could you help me to check this pr ?Thank you. -- This is an automated message from the Apache Git Service. T

[GitHub] [flink] JasonLeeCoding commented on pull request #17690: [FLINK-24490][docs] The sample code is wrong in Apache Kafka Connector page

JasonLeeCoding commented on pull request #17690: URL: https://github.com/apache/flink/pull/17690#issuecomment-964785060 @wuchong There are some errors in the Python module that cause CI fails -- This is an automated message from the Apache Git Service. To respond to the message, please lo

[GitHub] [flink] flinkbot edited a comment on pull request #17714: [FLINK-24818][API/State Processor]Correct the ttlConfig comment in StateDescriptor

flinkbot edited a comment on pull request #17714: URL: https://github.com/apache/flink/pull/17714#issuecomment-962984732 ## CI report: * Unknown: [CANCELED](TBD) * 4306f05de41e33a2d9a3f301ae3adfbf2739410f Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620

[GitHub] [flink] flinkbot edited a comment on pull request #17714: [FLINK-24818][API/State Processor]Correct the ttlConfig comment in StateDescriptor

flinkbot edited a comment on pull request #17714: URL: https://github.com/apache/flink/pull/17714#issuecomment-962984732 ## CI report: * Unknown: [CANCELED](TBD) * 4306f05de41e33a2d9a3f301ae3adfbf2739410f UNKNOWN Bot commands The @flinkbot bot supports the fol

[GitHub] [flink] datayjz commented on pull request #17714: [FLINK-24818][API/State Processor]Correct the ttlConfig comment in StateDescriptor

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

[GitHub] [flink] flinkbot edited a comment on pull request #17687: [FLINK-24227][connectors] Improved AsyncSink base by adding a builder…

flinkbot edited a comment on pull request #17687: URL: https://github.com/apache/flink/pull/17687#issuecomment-961206353 ## CI report: * cbe908acb91f17e4f485d27ec1a04bcf3eb68c86 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-21565) Support more integer types in TIMESTAMPADD

[ https://issues.apache.org/jira/browse/FLINK-21565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17441496#comment-17441496 ] Shen Zhu commented on FLINK-21565: -- Hi Nico, I'm interested in working on this ticket,

[jira] [Commented] (FLINK-24722) Fix the issues with supporting keyed stream

[ https://issues.apache.org/jira/browse/FLINK-24722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17441491#comment-17441491 ] Yun Gao commented on FLINK-24722: - Fix on master via 9c44eef25970338fe32dcf77ce45efac74c

[jira] [Closed] (FLINK-24722) Fix the issues with supporting keyed stream

[ https://issues.apache.org/jira/browse/FLINK-24722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-24722. --- Resolution: Fixed > Fix the issues with supporting keyed stream > --

[GitHub] [flink-ml] gaoyunhaii closed pull request #22: [FLINK-24722][iteration] Fixes the issues on supporting keyed stream

gaoyunhaii closed pull request #22: URL: https://github.com/apache/flink-ml/pull/22 -- 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-unsubsc

[jira] [Comment Edited] (FLINK-23035) Add explicit method to StateChangelogWriter to write metadata

[ https://issues.apache.org/jira/browse/FLINK-23035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17440985#comment-17440985 ] Xinbin Huang edited comment on FLINK-23035 at 11/10/21, 3:29 AM: -

[GitHub] [flink] FiveAgo commented on pull request #17592: [hotfixs][flink-yarn] Fix typo in YarnConfigOptions.java

FiveAgo commented on pull request #17592: URL: https://github.com/apache/flink/pull/17592#issuecomment-964748646 @MartijnVisser Hi,MartijnVisser. Thank you for your patience. I update the name of the commit as you said. I think it is ok now. -- This is an automated message from the Apa

[GitHub] [flink] flinkbot edited a comment on pull request #17592: [hotfixs][flink-yarn] Fix typo in YarnConfigOptions.java

flinkbot edited a comment on pull request #17592: URL: https://github.com/apache/flink/pull/17592#issuecomment-953735692 ## CI report: * 7da6ae9821118028e7a34caf8cdc28bf91f8e473 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17592: [hotfixs][flink-yarn] Fix typo in YarnConfigOptions.java

flinkbot edited a comment on pull request #17592: URL: https://github.com/apache/flink/pull/17592#issuecomment-953735692 ## CI report: * 7da6ae9821118028e7a34caf8cdc28bf91f8e473 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17733: [FLINK-24835][table-planner] Fix bug in `RelTimeIndicatorConverter` when materialize time attribute fields of regular join's inputs

flinkbot edited a comment on pull request #17733: URL: https://github.com/apache/flink/pull/17733#issuecomment-963997692 ## CI report: * 5bc3b14c5475ef1ea9e0604f4ff3de865ef980b7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17690: [FLINK-24490][docs] The sample code is wrong in Apache Kafka Connector page

flinkbot edited a comment on pull request #17690: URL: https://github.com/apache/flink/pull/17690#issuecomment-961660965 ## CI report: * adaacc288130da0e5ab487b1c669a3a730095eb5 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17733: [FLINK-24835][table-planner] Fix bug in `RelTimeIndicatorConverter` when materialize time attribute fields of regular join's inputs

flinkbot edited a comment on pull request #17733: URL: https://github.com/apache/flink/pull/17733#issuecomment-963997692 ## CI report: * 5bc3b14c5475ef1ea9e0604f4ff3de865ef980b7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] datayjz commented on pull request #17714: [FLINK-24818][API/State Processor]Correct the ttlConfig comment in StateDescriptor

datayjz commented on pull request #17714: URL: https://github.com/apache/flink/pull/17714#issuecomment-964735113 hi, @Myasuka could you review it for me. thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] flinkbot edited a comment on pull request #17698: [FLINK-24689][runtime-web] Add log's last modify time in log list view

flinkbot edited a comment on pull request #17698: URL: https://github.com/apache/flink/pull/17698#issuecomment-961944542 ## CI report: * fa92589384c20aaec7c77534531044a82758541f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17698: [FLINK-24689][runtime-web] Add log's last modify time in log list view

flinkbot edited a comment on pull request #17698: URL: https://github.com/apache/flink/pull/17698#issuecomment-961944542 ## CI report: * fa92589384c20aaec7c77534531044a82758541f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17690: [FLINK-24490][docs] The sample code is wrong in Apache Kafka Connector page

flinkbot edited a comment on pull request #17690: URL: https://github.com/apache/flink/pull/17690#issuecomment-961660965 ## CI report: * adaacc288130da0e5ab487b1c669a3a730095eb5 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17690: [FLINK-24490][docs] The sample code is wrong in Apache Kafka Connector page

flinkbot edited a comment on pull request #17690: URL: https://github.com/apache/flink/pull/17690#issuecomment-961660965 ## CI report: * adaacc288130da0e5ab487b1c669a3a730095eb5 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] JasonLeeCoding commented on pull request #17690: [FLINK-24490][docs] The sample code is wrong in Apache Kafka Connector page

JasonLeeCoding commented on pull request #17690: URL: https://github.com/apache/flink/pull/17690#issuecomment-964725950 @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 sp

[GitHub] [flink] flinkbot edited a comment on pull request #17673: [FLINK-24001][table-runtime] Window table-valued function operator support proctime window

flinkbot edited a comment on pull request #17673: URL: https://github.com/apache/flink/pull/17673#issuecomment-960580326 ## CI report: * 2383968f5682b5d74103f1c06abb0852911af2ff Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17673: [FLINK-24001][table-runtime] Window table-valued function operator support proctime window

flinkbot edited a comment on pull request #17673: URL: https://github.com/apache/flink/pull/17673#issuecomment-960580326 ## CI report: * 2383968f5682b5d74103f1c06abb0852911af2ff Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-t

flinkbot edited a comment on pull request #17509: URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594 ## CI report: * c683b88035514ec2decda77911bb5447f9932a21 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-22631) Metrics are incorrect when task finished

[ https://issues.apache.org/jira/browse/FLINK-22631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Li updated FLINK-22631: --- Priority: Major (was: Minor) > Metrics are incorrect when task finished >

[GitHub] [flink] beyond1920 commented on pull request #17673: [FLINK-24001][table-runtime] Window table-valued function operator support proctime window

beyond1920 commented on pull request #17673: URL: https://github.com/apache/flink/pull/17673#issuecomment-964721430 @JingsongLi Yes, the second pr for individual window table-valued function support is [pull#17684](https://github.com/apache/flink/pull/17684). Please have a look at the seco

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-t

flinkbot edited a comment on pull request #17509: URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594 ## CI report: * c683b88035514ec2decda77911bb5447f9932a21 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Closed] (FLINK-24654) NPE on RetractableTopNFunction when some records were cleared by state ttl

[ https://issues.apache.org/jira/browse/FLINK-24654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-24654. Fix Version/s: 1.14.1 Resolution: Fixed > NPE on RetractableTopNFunction when some records

[jira] [Comment Edited] (FLINK-24654) NPE on RetractableTopNFunction when some records were cleared by state ttl

[ https://issues.apache.org/jira/browse/FLINK-24654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17435226#comment-17435226 ] Jingsong Lee edited comment on FLINK-24654 at 11/10/21, 2:09 AM: -

[jira] [Reopened] (FLINK-24654) NPE on RetractableTopNFunction when some records were cleared by state ttl

[ https://issues.apache.org/jira/browse/FLINK-24654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reopened FLINK-24654: -- > NPE on RetractableTopNFunction when some records were cleared by state ttl > --

[jira] [Closed] (FLINK-24704) Exception occurs when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

[ https://issues.apache.org/jira/browse/FLINK-24704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-24704. Resolution: Fixed master: 33aaabebc63f7a44fb64930f5daf8006ce030752 release-1.14: d31cfb9b1b206270

[GitHub] [flink] JingsongLi merged pull request #17689: [FLINK-24704][table] Fix exception when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

JingsongLi merged pull request #17689: URL: https://github.com/apache/flink/pull/17689 -- 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-unsu

[GitHub] [flink] JingsongLi commented on a change in pull request #17673: [FLINK-24001][table-runtime] Window table-valued function operator support proctime window

JingsongLi commented on a change in pull request #17673: URL: https://github.com/apache/flink/pull/17673#discussion_r746187390 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/window/WindowWTFWithRowSemanticsOperator.java ##

[GitHub] [flink] JingsongLi commented on a change in pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for w

JingsongLi commented on a change in pull request #17509: URL: https://github.com/apache/flink/pull/17509#discussion_r746186312 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/window/processors/RowTimeWindowRankProcessor.java ##

[jira] [Commented] (FLINK-24852) Cleanup of Orphaned Incremental State Artifacts

[ https://issues.apache.org/jira/browse/FLINK-24852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17441423#comment-17441423 ] Stephan Ewen commented on FLINK-24852: -- /cc [~yunta] and [~roman] > Cleanup of Orp

[jira] [Commented] (FLINK-24611) Prevent JM from discarding state on checkpoint abortion

[ https://issues.apache.org/jira/browse/FLINK-24611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17441422#comment-17441422 ] Stephan Ewen commented on FLINK-24611: -- I created FLINK-24852 as a follow-up for th

[GitHub] [flink] cmick commented on pull request #17708: [FLINK-23696][connectors/rabbitmq] Fix RMQSourceTest.testRedeliveredSessionIDsAck

cmick commented on pull request #17708: URL: https://github.com/apache/flink/pull/17708#issuecomment-964622552 @fapaul Thanks for the review. Sure, backports added in #17740 and #17741 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Created] (FLINK-24852) Cleanup of Orphaned Incremental State Artifacts

Stephan Ewen created FLINK-24852: Summary: Cleanup of Orphaned Incremental State Artifacts Key: FLINK-24852 URL: https://issues.apache.org/jira/browse/FLINK-24852 Project: Flink Issue Type: I

[GitHub] [flink] flinkbot edited a comment on pull request #17741: [BP-1.13][FLINK-23696][connectors/rabbitmq] Fix RMQSourceTest.testRedeliveredSessionIDsAck

flinkbot edited a comment on pull request #17741: URL: https://github.com/apache/flink/pull/17741#issuecomment-964618004 ## CI report: * 15a1ede8913257d8f919b8c1e89192c154ef7720 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #17741: [BP-1.13][FLINK-23696][connectors/rabbitmq] Fix RMQSourceTest.testRedeliveredSessionIDsAck

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

[GitHub] [flink] flinkbot commented on pull request #17741: [BP-1.13][FLINK-23696][connectors/rabbitmq] Fix RMQSourceTest.testRedeliveredSessionIDsAck

flinkbot commented on pull request #17741: URL: https://github.com/apache/flink/pull/17741#issuecomment-964618004 ## CI report: * 15a1ede8913257d8f919b8c1e89192c154ef7720 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] cmick opened a new pull request #17741: [BP-1.13][FLINK-23696][connectors/rabbitmq] Fix RMQSourceTest.testRedeliveredSessionIDsAck

cmick opened a new pull request #17741: URL: https://github.com/apache/flink/pull/17741 This is a backport of #17708 (fixing FLINK-23696) to release-1.13. The fix is exactly the same as in #17708. Please see #17708 for a detailed description. -- This is an automated message from t

[GitHub] [flink] flinkbot edited a comment on pull request #17740: [BP-1.14][FLINK-23696][connectors/rabbitmq] Fix RMQSourceTest.testRedeliveredSessionIDsAck

flinkbot edited a comment on pull request #17740: URL: https://github.com/apache/flink/pull/17740#issuecomment-964612266 ## CI report: * aad4ecf474e16e0cdb95579269fcfa9c1e17d668 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #17740: [BP-1.14][FLINK-23696][connectors/rabbitmq] Fix RMQSourceTest.testRedeliveredSessionIDsAck

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

[GitHub] [flink] flinkbot commented on pull request #17740: [BP-1.14][FLINK-23696][connectors/rabbitmq] Fix RMQSourceTest.testRedeliveredSessionIDsAck

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

  1   2   3   4   5   >