[GitHub] [flink] flinkbot edited a comment on pull request #18653: [FLINK-25825][connector-jdbc] MySqlCatalogITCase fails on azure

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18653: URL: https://github.com/apache/flink/pull/18653#issuecomment-1032212433 ## CI report: * 1c96c6553cd12da3d699383ec26353315864871a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Comment Edited] (FLINK-25705) Translate "Metric Reporters" page of "Deployment" in to Chinese

2022-02-10 Thread Chengkai Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489940#comment-17489940 ] Chengkai Yang edited comment on FLINK-25705 at 2/11/22, 1:36 AM: -

[GitHub] [flink] flinkbot edited a comment on pull request #18653: [FLINK-25825][connector-jdbc] MySqlCatalogITCase fails on azure

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18653: URL: https://github.com/apache/flink/pull/18653#issuecomment-1032212433 ## CI report: * 1c96c6553cd12da3d699383ec26353315864871a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18653: [FLINK-25825][connector-jdbc] MySqlCatalogITCase fails on azure

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18653: URL: https://github.com/apache/flink/pull/18653#issuecomment-1032212433 ## CI report: * 1c96c6553cd12da3d699383ec26353315864871a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18653: [FLINK-25825][connector-jdbc] MySqlCatalogITCase fails on azure

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18653: URL: https://github.com/apache/flink/pull/18653#issuecomment-1032212433 ## CI report: * 1c96c6553cd12da3d699383ec26353315864871a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-25231) Update PyFlink to use the new type system

2022-02-10 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17490608#comment-17490608 ] Dian Fu commented on FLINK-25231: - [~csq] What's the status of this JIRA?  > Update PyF

[jira] [Commented] (FLINK-26060) Make Python specific exec nodes unsupported

2022-02-10 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17490607#comment-17490607 ] Dian Fu commented on FLINK-26060: - [~slinkydeveloper] Just want to figure out the conseq

[GitHub] [flink] flinkbot edited a comment on pull request #18653: [FLINK-25825][connector-jdbc] MySqlCatalogITCase fails on azure

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18653: URL: https://github.com/apache/flink/pull/18653#issuecomment-1032212433 ## CI report: * 1c96c6553cd12da3d699383ec26353315864871a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] forrestlmj commented on pull request #18713: [FLINK-25830][docs]Typo mistake in "Metric Report page" of the documentation

2022-02-10 Thread GitBox
forrestlmj commented on pull request #18713: URL: https://github.com/apache/flink/pull/18713#issuecomment-1035699822 Hi,community: This is my first pull request to Apache Flink,should I @ someone to merge this?Not sure who will review this commit, Please let me know if I am missing some

[jira] [Closed] (FLINK-26004) Introduce ForwardForConsecutiveHashPartitioner

2022-02-10 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-26004. --- Fix Version/s: 1.15.0 Resolution: Done master/release-1.15: b4d5b66df4066ab9d97e9263714c3a8bcc3063a2

[jira] [Closed] (FLINK-25996) Introduce job property isDynamicGraph to ExecutionConfig

2022-02-10 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-25996. --- Resolution: Done master/release-1.15: 90159f4c7f364f9264e0373c0b1ffa7cafa04cbc > Introduce job property isD

[jira] [Assigned] (FLINK-26004) Introduce ForwardForConsecutiveHashPartitioner

2022-02-10 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-26004: --- Assignee: Lijie Wang > Introduce ForwardForConsecutiveHashPartitioner > ---

[GitHub] [flink] flinkbot edited a comment on pull request #18714: [hotfix][table][formats][doc] Updates to debezium, canal and maxwell format

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18714: URL: https://github.com/apache/flink/pull/18714#issuecomment-1035697460 ## CI report: * 1ca214c23e580641b541c56097dcef8d212542d8 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18653: [FLINK-25825][connector-jdbc] MySqlCatalogITCase fails on azure

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18653: URL: https://github.com/apache/flink/pull/18653#issuecomment-1032212433 ## CI report: * 1c96c6553cd12da3d699383ec26353315864871a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Assigned] (FLINK-25996) Introduce job property isDynamicGraph to ExecutionConfig

2022-02-10 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-25996: --- Assignee: Lijie Wang > Introduce job property isDynamicGraph to ExecutionConfig > -

[GitHub] [flink] zhuzhurk closed pull request #18672: [FLINK-25996][runtime] Introduce job property isDynamicGraph to ExecutionConfig

2022-02-10 Thread GitBox
zhuzhurk closed pull request #18672: URL: https://github.com/apache/flink/pull/18672 -- 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-unsubs

[GitHub] [flink] zhuzhurk closed pull request #18673: [FLINK-26004][runtime] Introduce ForwardForConsecutiveHashPartitioner

2022-02-10 Thread GitBox
zhuzhurk closed pull request #18673: URL: https://github.com/apache/flink/pull/18673 -- 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-unsubs

[GitHub] [flink] flinkbot commented on pull request #18714: [hotfix][table][formats][doc] Updates to debezium, canal and maxwell format

2022-02-10 Thread GitBox
flinkbot commented on pull request #18714: URL: https://github.com/apache/flink/pull/18714#issuecomment-1035697828 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 pr

[GitHub] [flink] flinkbot commented on pull request #18714: [hotfix][table][formats][doc] Updates to debezium, canal and maxwell format

2022-02-10 Thread GitBox
flinkbot commented on pull request #18714: URL: https://github.com/apache/flink/pull/18714#issuecomment-1035697460 ## CI report: * 1ca214c23e580641b541c56097dcef8d212542d8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] RocMarshal commented on a change in pull request #18653: [FLINK-25825][connector-jdbc] MySqlCatalogITCase fails on azure

2022-02-10 Thread GitBox
RocMarshal commented on a change in pull request #18653: URL: https://github.com/apache/flink/pull/18653#discussion_r804279436 ## File path: flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/UnsignedTypeConversionITCase.java ## @@ -21,16

[GitHub] [flink] flinkbot edited a comment on pull request #18713: [FLINK-25830][docs]Typo mistake in "Metric Report page" of the documentation

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18713: URL: https://github.com/apache/flink/pull/18713#issuecomment-1035695964 ## CI report: * 286e2a81d09641461087c8da3823f0616181148b Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] zhuzhurk commented on pull request #18672: [FLINK-25996][runtime] Introduce job property isDynamicGraph to ExecutionConfig

2022-02-10 Thread GitBox
zhuzhurk commented on pull request #18672: URL: https://github.com/apache/flink/pull/18672#issuecomment-1035697155 The CI is green except for known issues. Merging. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use t

[GitHub] [flink] zhuzhurk commented on pull request #18673: [FLINK-26004][runtime] Introduce ForwardForConsecutiveHashPartitioner

2022-02-10 Thread GitBox
zhuzhurk commented on pull request #18673: URL: https://github.com/apache/flink/pull/18673#issuecomment-1035696840 The CI is green except for the e2e test which is due to known environment issue. Merging. -- This is an automated message from the Apache Git Service. To respond to the m

[GitHub] [flink] flinkbot commented on pull request #18713: [FLINK-25830][docs]Typo mistake in "Metric Report page" of the documentation

2022-02-10 Thread GitBox
flinkbot commented on pull request #18713: URL: https://github.com/apache/flink/pull/18713#issuecomment-1035696669 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 pr

[GitHub] [flink] flinkbot commented on pull request #18713: [FLINK-25830][docs]Typo mistake in "Metric Report page" of the documentation

2022-02-10 Thread GitBox
flinkbot commented on pull request #18713: URL: https://github.com/apache/flink/pull/18713#issuecomment-1035695964 ## CI report: * 286e2a81d09641461087c8da3823f0616181148b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18692: URL: https://github.com/apache/flink/pull/18692#issuecomment-1034131249 ## CI report: * e62d2306a72160805766c5ef102d617d26956e72 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * a9c278120fed2705c20d511b70f291a4bc47295f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] mans2singh opened a new pull request #18714: [hotfix][table][formats][doc] Updates to debezium, canal and maxwell format

2022-02-10 Thread GitBox
mans2singh opened a new pull request #18714: URL: https://github.com/apache/flink/pull/18714 ## What is the purpose of the change * Improvements to debezum, canal and maxwell format docs ## Brief change log * Improved format docs ## Verifying this change

[GitHub] [flink] forrestlmj opened a new pull request #18713: [FLINK-25830][docs]Typo mistake in "Metric Report page" of the documentation

2022-02-10 Thread GitBox
forrestlmj opened a new pull request #18713: URL: https://github.com/apache/flink/pull/18713 ## What is the purpose of the change Fix ypo mistake in "Metric Report page" of the documentation.There should have a space between "metrics.reporter.my_jmx_reporter.scope.variab

[jira] [Updated] (FLINK-25830) Typo mistake in "Metric Report page" of the documentation

2022-02-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25830: --- Labels: auto-unassigned pull-request-available (was: auto-unassigned) > Typo mistake in "M

[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * a9c278120fed2705c20d511b70f291a4bc47295f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * 4d9c593db3d66bd724b72624f129a6e90096157f Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18653: [FLINK-25825][connector-jdbc] MySqlCatalogITCase fails on azure

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18653: URL: https://github.com/apache/flink/pull/18653#issuecomment-1032212433 ## CI report: * 1c96c6553cd12da3d699383ec26353315864871a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18653: [FLINK-25825][connector-jdbc] MySqlCatalogITCase fails on azure

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18653: URL: https://github.com/apache/flink/pull/18653#issuecomment-1032212433 ## CI report: * 1c96c6553cd12da3d699383ec26353315864871a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] RocMarshal commented on a change in pull request #18653: [FLINK-25825][connector-jdbc] MySqlCatalogITCase fails on azure

2022-02-10 Thread GitBox
RocMarshal commented on a change in pull request #18653: URL: https://github.com/apache/flink/pull/18653#discussion_r804272180 ## File path: flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/UnsignedTypeConversionITCase.java ## @@ -21,16

[GitHub] [flink] RocMarshal commented on a change in pull request #18653: [FLINK-25825][connector-jdbc] MySqlCatalogITCase fails on azure

2022-02-10 Thread GitBox
RocMarshal commented on a change in pull request #18653: URL: https://github.com/apache/flink/pull/18653#discussion_r804271518 ## File path: flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/UnsignedTypeConversionITCase.java ## @@ -21,16

[GitHub] [flink] flinkbot edited a comment on pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18692: URL: https://github.com/apache/flink/pull/18692#issuecomment-1034131249 ## CI report: * 7df5c250c479e48d3d624af832dfd3b312dfcc1d Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18686: URL: https://github.com/apache/flink/pull/18686#issuecomment-1033839484 ## CI report: * dbad30e0c7461dd06cc7c1f21ab1774bda74e956 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * Unknown: [CANCELED](TBD) * 4d9c593db3d66bd724b72624f129a6e90096157f Azure: [PENDING

[GitHub] [flink] flinkbot edited a comment on pull request #18603: [FLINK-25610][connector/firehose] Adding table api base for kinesis firehose

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18603: URL: https://github.com/apache/flink/pull/18603#issuecomment-1027853740 ## CI report: * b6878d4a8ffc15ffadc0864dbba62e833aa199b1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18686: URL: https://github.com/apache/flink/pull/18686#issuecomment-1033839484 ## CI report: * 00da3d82453c8977bf69fc5843f1cba9c39ac5a8 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] dannycranmer commented on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration sup

2022-02-10 Thread GitBox
dannycranmer commented on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1035629718 @CrynetLogistics as per the comment, we still need to fix this to prevent it happening within the same TM, unless I am mistaken? > If two jobs are running on the sa

[GitHub] [flink] flinkbot edited a comment on pull request #18664: [FLINK-25907][runtime][security] Add pluggable delegation token manager

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18664: URL: https://github.com/apache/flink/pull/18664#issuecomment-1032585099 ## CI report: * 01046c38b403a797e9228a434d194144e6eed82b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Comment Edited] (FLINK-25289) Add DataStream sink test suite in connector testing framework

2022-02-10 Thread Yufan Sheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17490569#comment-17490569 ] Yufan Sheng edited comment on FLINK-25289 at 2/10/22, 11:03 PM: --

[GitHub] [flink] flinkbot edited a comment on pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18692: URL: https://github.com/apache/flink/pull/18692#issuecomment-1034131249 ## CI report: * b12f1c7c6f5b92363f9fe4d8c23527864a3378b3 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18689: URL: https://github.com/apache/flink/pull/18689#issuecomment-1033918208 ## CI report: * b25714f509c943f8da5caa25804e26f4b08dcd90 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18692: URL: https://github.com/apache/flink/pull/18692#issuecomment-1034131249 ## CI report: * b12f1c7c6f5b92363f9fe4d8c23527864a3378b3 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18692: URL: https://github.com/apache/flink/pull/18692#issuecomment-1034131249 ## CI report: * b12f1c7c6f5b92363f9fe4d8c23527864a3378b3 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * Unknown: [CANCELED](TBD) * 35eed39d242dc7745b7fe09f15e56ee553eb3204 Azure: [PENDING

[jira] [Commented] (FLINK-25289) Add DataStream sink test suite in connector testing framework

2022-02-10 Thread Yufan Sheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17490569#comment-17490569 ] Yufan Sheng commented on FLINK-25289: - Hi [~renqs], I have seen the DataStreamSinkEx

[GitHub] [flink] flinkbot edited a comment on pull request #18711: [FLINK-26036] Don't execute TaskExecutor.freeSlotInternal if not running

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18711: URL: https://github.com/apache/flink/pull/18711#issuecomment-1035135369 ## CI report: * eb69cc009a564d0fce6087eb0447d98c5021bc43 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18692: URL: https://github.com/apache/flink/pull/18692#issuecomment-1034131249 ## CI report: * b12f1c7c6f5b92363f9fe4d8c23527864a3378b3 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * Unknown: [CANCELED](TBD) * 35eed39d242dc7745b7fe09f15e56ee553eb3204 Azure: [PENDING

[GitHub] [flink] XComp commented on a change in pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-10 Thread GitBox
XComp commented on a change in pull request #18692: URL: https://github.com/apache/flink/pull/18692#discussion_r804199654 ## File path: flink-core/src/main/java/org/apache/flink/core/fs/FileSystem.java ## @@ -588,8 +588,10 @@ public static URI getDefaultFsUri() { *

[jira] (FLINK-26061) FileSystem.getFileStatus fails for directories

2022-02-10 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26061 ] Matthias Pohl deleted comment on FLINK-26061: --- was (Author: mapohl): This issue was discovered while investigating FLINK-26015 > FileSystem.getFileStatus fails for directories > --

[GitHub] [flink] flinkbot edited a comment on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * Unknown: [CANCELED](TBD) * 35eed39d242dc7745b7fe09f15e56ee553eb3204 Azure: [PENDING

[GitHub] [flink] flinkbot edited a comment on pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18692: URL: https://github.com/apache/flink/pull/18692#issuecomment-1034131249 ## CI report: * b12f1c7c6f5b92363f9fe4d8c23527864a3378b3 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] XComp commented on pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-10 Thread GitBox
XComp commented on pull request #18692: URL: https://github.com/apache/flink/pull/18692#issuecomment-1035608840 Thanks @zentol for your thorough. I addressed/responded to all your comments. I squashed the commits and rebased the branch. -- This is an automated message from the Apache Gi

[GitHub] [flink] flinkbot edited a comment on pull request #18702: [FLINK-24441][source] Block SourceOperator when watermarks are out of alignment

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18702: URL: https://github.com/apache/flink/pull/18702#issuecomment-1034842544 ## CI report: * 41edf88f3c2942523f9f91e4c0a26265cf2e97ec Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18692: URL: https://github.com/apache/flink/pull/18692#issuecomment-1034131249 ## CI report: * b12f1c7c6f5b92363f9fe4d8c23527864a3378b3 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] XComp commented on pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-10 Thread GitBox
XComp commented on pull request #18692: URL: https://github.com/apache/flink/pull/18692#issuecomment-1035606770 > Sadly, the JRS still doesn't work on K8s, using a minio s3 implementation: Apparently, the failure was caused by an old Docker image being used for the test which I also

[GitHub] [flink] flinkbot edited a comment on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * Unknown: [CANCELED](TBD) * 35eed39d242dc7745b7fe09f15e56ee553eb3204 Azure: [PENDING

[GitHub] [flink] flinkbot edited a comment on pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18692: URL: https://github.com/apache/flink/pull/18692#issuecomment-1034131249 ## CI report: * b12f1c7c6f5b92363f9fe4d8c23527864a3378b3 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] XComp commented on a change in pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-10 Thread GitBox
XComp commented on a change in pull request #18692: URL: https://github.com/apache/flink/pull/18692#discussion_r804187457 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/FileSystemJobResultStore.java ## @@ -155,18 +155,15 @@ public boolean h

[GitHub] [flink] flinkbot edited a comment on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * Unknown: [CANCELED](TBD) * 35eed39d242dc7745b7fe09f15e56ee553eb3204 Azure: [PENDING

[jira] [Updated] (FLINK-553) Add getGroupKey() method to group-at-time operators

2022-02-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-553: - Labels: auto-deprioritized-major auto-deprioritized-minor github-import (was: auto-deprioritize

[jira] [Updated] (FLINK-1904) Add cross() to Table API

2022-02-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-1904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-1904: -- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major sta

[jira] [Updated] (FLINK-1939) Add Parquet Documentation to Wiki

2022-02-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-1939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-1939: -- Labels: auto-deprioritized-minor auto-unassigned (was: auto-unassigned stale-minor) Prio

[jira] [Updated] (FLINK-951) Reworking of Iteration Synchronization, Accumulators and Aggregators

2022-02-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-951: - Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned refactoring (was: aut

[jira] [Updated] (FLINK-987) Extend TypeSerializers and -Comparators to work directly on Memory Segments

2022-02-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-987: - Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major stale-

[jira] [Updated] (FLINK-1493) Support for streaming jobs preserving global ordering of records

2022-02-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-1493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-1493: -- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major sta

[jira] [Updated] (FLINK-1526) Add Minimum Spanning Tree library method and example

2022-02-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-1526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-1526: -- Labels: algorithm auto-deprioritized-major auto-deprioritized-minor auto-unassigned (was: al

[jira] [Updated] (FLINK-1814) Revisit the documentation to add new operator

2022-02-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-1814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-1814: -- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major sta

[jira] [Updated] (FLINK-1689) Add documentation on streaming file sinks interaction with the batch outputformat

2022-02-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-1689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-1689: -- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major sta

[GitHub] [flink] flinkbot edited a comment on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * Unknown: [CANCELED](TBD) * 35eed39d242dc7745b7fe09f15e56ee553eb3204 Azure: [PENDING

[GitHub] [flink] XComp commented on a change in pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-10 Thread GitBox
XComp commented on a change in pull request #18692: URL: https://github.com/apache/flink/pull/18692#discussion_r804187457 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/FileSystemJobResultStore.java ## @@ -155,18 +155,15 @@ public boolean h

[GitHub] [flink] CrynetLogistics commented on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

2022-02-10 Thread GitBox
CrynetLogistics commented on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1035600321 @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] CrynetLogistics commented on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

2022-02-10 Thread GitBox
CrynetLogistics commented on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1035598885 Thank you. I have understood the issue. I have now changed my usage of Netty to the Apache synchronous http client. I have also removed the `@Ignore` flag for the integ

[GitHub] [flink] flinkbot edited a comment on pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18692: URL: https://github.com/apache/flink/pull/18692#issuecomment-1034131249 ## CI report: * b12f1c7c6f5b92363f9fe4d8c23527864a3378b3 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] XComp commented on a change in pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-10 Thread GitBox
XComp commented on a change in pull request #18692: URL: https://github.com/apache/flink/pull/18692#discussion_r804182029 ## File path: flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/util/DockerImageVersions.java ## @@ -45,4 +45,6 @@ public

[GitHub] [flink] XComp commented on a change in pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-10 Thread GitBox
XComp commented on a change in pull request #18692: URL: https://github.com/apache/flink/pull/18692#discussion_r804179821 ## File path: flink-filesystems/flink-s3-fs-presto/src/test/java/org/apache/flink/fs/s3presto/MinioTestContainer.java ## @@ -0,0 +1,146 @@ +/* + * Licensed

[GitHub] [flink] XComp commented on a change in pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-10 Thread GitBox
XComp commented on a change in pull request #18692: URL: https://github.com/apache/flink/pull/18692#discussion_r804177584 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/highavailability/AbstractHaJobRunITCase.java ## @@ -0,0 +1,133 @@ +/* + * Licensed to th

[GitHub] [flink] XComp commented on a change in pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-10 Thread GitBox
XComp commented on a change in pull request #18692: URL: https://github.com/apache/flink/pull/18692#discussion_r804176021 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/highavailability/AbstractHaJobRunITCase.java ## @@ -0,0 +1,133 @@ +/* + * Licensed to th

[GitHub] [flink] XComp commented on a change in pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-10 Thread GitBox
XComp commented on a change in pull request #18692: URL: https://github.com/apache/flink/pull/18692#discussion_r804175066 ## File path: flink-filesystems/flink-s3-fs-presto/src/test/java/org/apache/flink/fs/s3presto/MinioTestContainerTest.java ## @@ -0,0 +1,117 @@ +/* + * Lice

[GitHub] [flink] XComp commented on a change in pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-10 Thread GitBox
XComp commented on a change in pull request #18692: URL: https://github.com/apache/flink/pull/18692#discussion_r804168911 ## File path: flink-filesystems/flink-s3-fs-presto/src/test/java/org/apache/flink/fs/s3presto/MinioTestContainer.java ## @@ -0,0 +1,146 @@ +/* + * Licensed

[jira] [Updated] (FLINK-25872) Restoring from non-changelog checkpoint with changelog state-backend enabled in CLAIM mode discards state in use

2022-02-10 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-25872: -- Priority: Major (was: Blocker) > Restoring from non-changelog checkpoint with changel

[jira] [Updated] (FLINK-26079) Disallow combination of Changelog backend with CLAIM restore mode

2022-02-10 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-26079: -- Priority: Blocker (was: Major) > Disallow combination of Changelog backend with CLAIM

[jira] [Assigned] (FLINK-26079) Disallow combination of Changelog backend with CLAIM restore mode

2022-02-10 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-26079: - Assignee: Roman Khachatryan > Disallow combination of Changelog backend with CL

[jira] [Assigned] (FLINK-26063) [Changelog] Incorrect key group logged for PQ.poll and remove

2022-02-10 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-26063: - Assignee: (was: Roman Khachatryan) > [Changelog] Incorrect key group logged

[GitHub] [flink] XComp commented on a change in pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-10 Thread GitBox
XComp commented on a change in pull request #18692: URL: https://github.com/apache/flink/pull/18692#discussion_r804166962 ## File path: flink-filesystems/flink-s3-fs-presto/src/test/java/org/apache/flink/fs/s3presto/MinioTestContainer.java ## @@ -0,0 +1,146 @@ +/* + * Licensed

[jira] [Comment Edited] (FLINK-26019) [Changelog] PriorityQueue elements recovered out-of-order

2022-02-10 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489794#comment-17489794 ] Roman Khachatryan edited comment on FLINK-26019 at 2/10/22, 10:09 PM:

[GitHub] [flink] XComp commented on a change in pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-10 Thread GitBox
XComp commented on a change in pull request #18692: URL: https://github.com/apache/flink/pull/18692#discussion_r804161565 ## File path: flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/core/testutils/TestContainerExtension.java ## @@ -0,0 +1,72 @@

[jira] [Resolved] (FLINK-26062) [Changelog] Non-deterministic recovery of PriorityQueue states

2022-02-10 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan resolved FLINK-26062. --- Resolution: Fixed > [Changelog] Non-deterministic recovery of PriorityQueue states >

[jira] [Commented] (FLINK-26062) [Changelog] Non-deterministic recovery of PriorityQueue states

2022-02-10 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17490549#comment-17490549 ] Roman Khachatryan commented on FLINK-26062: --- Fix for poll() (replacement with

[GitHub] [flink] rkhachatryan commented on pull request #18694: [FLINK-26062][state/changelog] Replace poll() with remove() for PQ states

2022-02-10 Thread GitBox
rkhachatryan commented on pull request #18694: URL: https://github.com/apache/flink/pull/18694#issuecomment-1035572360 Build failures are unrelated (FLINK-26036, FLINK-24288). Build from private branch [succeeded](https://dev.azure.com/khachatryanroman/flink/_build/results?buildId=1382&v

[GitHub] [flink] rkhachatryan merged pull request #18694: [FLINK-26062][state/changelog] Replace poll() with remove() for PQ states

2022-02-10 Thread GitBox
rkhachatryan merged pull request #18694: URL: https://github.com/apache/flink/pull/18694 -- 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-un

[GitHub] [flink] flinkbot edited a comment on pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18692: URL: https://github.com/apache/flink/pull/18692#issuecomment-1034131249 ## CI report: * 395d56500dd767fbe64dcd56b6732e02ae4b3d0a Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[jira] [Commented] (FLINK-26079) Disallow combination of Changelog backend with CLAIM restore mode

2022-02-10 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17490532#comment-17490532 ] Roman Khachatryan commented on FLINK-26079: --- To implement the validation, we n

[GitHub] [flink] flinkbot edited a comment on pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18692: URL: https://github.com/apache/flink/pull/18692#issuecomment-1034131249 ## CI report: * 395d56500dd767fbe64dcd56b6732e02ae4b3d0a Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18058: [FLINK-24571][connectors/elasticsearch] Supports a system time function(now() and current_timestamp) in index pattern

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18058: URL: https://github.com/apache/flink/pull/18058#issuecomment-988949831 ## CI report: * 93c33001cf55690369281de939bd79bb3727ad9a UNKNOWN * 72a2c79d9516622a240993fe4a792a86dbfb59a2 Azure: [FAILURE](https://dev.azure.com/apache-fl

<    1   2   3   4   5   6   7   8   9   10   >