[GitHub] [flink] flinkbot edited a comment on pull request #17562: [FLINK-16206][table-planner] Support JSON_ARRAYAGG

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

[GitHub] [flink] Airblader commented on a change in pull request #17562: [FLINK-16206][table-planner] Support JSON_ARRAYAGG

Airblader commented on a change in pull request #17562: URL: https://github.com/apache/flink/pull/17562#discussion_r737159905 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/JsonArrayAggFunction.java ## @@ -0,0

[jira] [Created] (FLINK-24664) Support merge for JSON_ARRAYAGG

Ingo Bürk created FLINK-24664: - Summary: Support merge for JSON_ARRAYAGG Key: FLINK-24664 URL: https://issues.apache.org/jira/browse/FLINK-24664 Project: Flink Issue Type: Sub-task Comp

[GitHub] [flink] flinkbot edited a comment on pull request #17562: [FLINK-16206][table-planner] Support JSON_ARRAYAGG

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

[jira] [Updated] (FLINK-24663) PyFlink failed to get the site packege path because of SyntaxError in shell command

[ https://issues.apache.org/jira/browse/FLINK-24663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackwangcs updated FLINK-24663: --- Summary: PyFlink failed to get the site packege path because of SyntaxError in shell command (was:

[jira] [Updated] (FLINK-24663) PyFlink failed to get the site packege path because of no quote in shell command

[ https://issues.apache.org/jira/browse/FLINK-24663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackwangcs updated FLINK-24663: --- Description: Flink throws an exception when it tries to install 3rd party dependencies: {code:java}

[GitHub] [flink] flinkbot edited a comment on pull request #17549: [FLINK-16205][table-planner] Support JSON_OBJECTAGG

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

[jira] [Commented] (FLINK-21068) Add new timeout options for Elasticsearch connector

[ https://issues.apache.org/jira/browse/FLINK-21068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434690#comment-17434690 ] Fabian Paul commented on FLINK-21068: - [~henriquemota] I think we can support the fe

[jira] [Updated] (FLINK-24663) PyFlink failed to get the site packege path because of no quote in shell command

[ https://issues.apache.org/jira/browse/FLINK-24663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackwangcs updated FLINK-24663: --- Description: Flink throws an exception when it tries to install 3rd party dependencies: {code:java}

[GitHub] [flink] Airblader commented on pull request #17549: [FLINK-16205][table-planner] Support JSON_OBJECTAGG

Airblader commented on pull request #17549: URL: https://github.com/apache/flink/pull/17549#issuecomment-952588166 Should work now: ``` ++ | count | ++ |{"Hello":1}

[GitHub] [flink] flinkbot edited a comment on pull request #17549: [FLINK-16205][table-planner] Support JSON_OBJECTAGG

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

[jira] [Created] (FLINK-24663) PyFlink failed to get the site packege path because of no quote in shell command

jackwangcs created FLINK-24663: -- Summary: PyFlink failed to get the site packege path because of no quote in shell command Key: FLINK-24663 URL: https://issues.apache.org/jira/browse/FLINK-24663 Project:

[GitHub] [flink] flinkbot edited a comment on pull request #17556: [FLINK-24627][tests] add some Junit5 extensions to replace the existed Junit4 rules

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

[GitHub] [flink] flinkbot edited a comment on pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

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

[jira] [Updated] (FLINK-24661) ConfigOption add isSecret method to judge sensitive options

[ https://issues.apache.org/jira/browse/FLINK-24661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-24661: - Description: Related ticket https://issues.apache.org/jira/browse/FLINK-24381 [~chesnay] Should this t

[GitHub] [flink] Airblader commented on a change in pull request #17549: [FLINK-16205][table-planner] Support JSON_OBJECTAGG

Airblader commented on a change in pull request #17549: URL: https://github.com/apache/flink/pull/17549#discussion_r737143328 ## File path: docs/data/sql_functions.yml ## @@ -766,6 +766,27 @@ json: ) ) ``` + - sql: JSON_OBJECTAGG([KEY] key VALUE value [

[GitHub] [flink] flinkbot edited a comment on pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

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

[GitHub] [flink] flinkbot edited a comment on pull request #17569: [FLINK-24648] CEIL and FLOOR should support DECADE, CENTURY, MILLENNIUM

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

[GitHub] [flink] JingsongLi commented on a change in pull request #17537: [FLINK-19722][table-planner]Pushdown Watermark to SourceProvider (new Source)

JingsongLi commented on a change in pull request #17537: URL: https://github.com/apache/flink/pull/17537#discussion_r737139591 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecTableSourceScan.java ## @@

[jira] [Updated] (FLINK-24661) ConfigOption add isSecret method to judge sensitive options

[ https://issues.apache.org/jira/browse/FLINK-24661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-24661: - Description: Related ticket https://issues.apache.org/jira/browse/FLINK-24381 [~chesnay] This ticket m

[GitHub] [flink] flinkbot edited a comment on pull request #17569: [FLINK-24648] CEIL and FLOOR should support DECADE, CENTURY, MILLENNIUM

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

[jira] [Commented] (FLINK-23914) Make connector testing framework more verbose on test failure

[ https://issues.apache.org/jira/browse/FLINK-23914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434677#comment-17434677 ] Arvid Heise commented on FLINK-23914: - Merged into master as 27ec51c56ad23217b162c4

[GitHub] [flink] AHeise commented on pull request #16940: [FLINK-23914][connector/testing-framework] Improve logging and error message in testing framework

AHeise commented on pull request #16940: URL: https://github.com/apache/flink/pull/16940#issuecomment-952569674 Thank you. Merged. Can you create a backport PR? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] AHeise merged pull request #16940: [FLINK-23914][connector/testing-framework] Improve logging and error message in testing framework

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

[GitHub] [flink] flinkbot edited a comment on pull request #14891: [FLINK-21289][deployment] FIX missing load pipeline.classpaths in app…

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

[GitHub] [flink] PChou commented on pull request #14891: [FLINK-21289][deployment] FIX missing load pipeline.classpaths in app…

PChou commented on pull request #14891: URL: https://github.com/apache/flink/pull/14891#issuecomment-952562549 `ClassPathPackagedProgramRetriever` is replaced by `DefaultPackagedProgramRetriever` on master branch, and `DefaultPackagedProgramRetriever` has been support `Configuration` as p

[GitHub] [flink] flinkbot edited a comment on pull request #14891: [FLINK-21289][deployment] FIX missing load pipeline.classpaths in app…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17463: [Hotfix] Fix typos.

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

[GitHub] [flink] xuyangzhong commented on a change in pull request #17537: [FLINK-19722][table-planner]Pushdown Watermark to SourceProvider (new Source)

xuyangzhong commented on a change in pull request #17537: URL: https://github.com/apache/flink/pull/17537#discussion_r737116940 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecTableSourceScan.java ## @

[GitHub] [flink] flinkbot edited a comment on pull request #17555: [FLINK-24381][table] Add support for setting Options sensitive

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

[GitHub] [flink] JingsongLi commented on a change in pull request #17537: [FLINK-19722][table-planner]Pushdown Watermark to SourceProvider (new Source)

JingsongLi commented on a change in pull request #17537: URL: https://github.com/apache/flink/pull/17537#discussion_r737114021 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecTableSourceScan.java ## @@

[GitHub] [flink] xuyangzhong commented on a change in pull request #17537: [FLINK-19722][table-planner]Pushdown Watermark to SourceProvider (new Source)

xuyangzhong commented on a change in pull request #17537: URL: https://github.com/apache/flink/pull/17537#discussion_r737111607 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecTableSourceScan.java ## @

[GitHub] [flink] xuyangzhong commented on a change in pull request #17537: [FLINK-19722][table-planner]Pushdown Watermark to SourceProvider (new Source)

xuyangzhong commented on a change in pull request #17537: URL: https://github.com/apache/flink/pull/17537#discussion_r737105753 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecTableSourceScan.java ## @

[GitHub] [flink] xuyangzhong commented on a change in pull request #17537: [FLINK-19722][table-planner]Pushdown Watermark to SourceProvider (new Source)

xuyangzhong commented on a change in pull request #17537: URL: https://github.com/apache/flink/pull/17537#discussion_r737105590 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecTableSourceScan.java ## @

[GitHub] [flink] tsreaper commented on a change in pull request #17570: [FLINK-24654][table] Fix NPE on RetractableTopNFunction when some records were cleared by state ttl

tsreaper commented on a change in pull request #17570: URL: https://github.com/apache/flink/pull/17570#discussion_r737100142 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/RetractableTopNFunction.java ## @@ -455,9 +464

[GitHub] [flink] tsreaper commented on a change in pull request #17570: [FLINK-24654][table] Fix NPE on RetractableTopNFunction when some records were cleared by state ttl

tsreaper commented on a change in pull request #17570: URL: https://github.com/apache/flink/pull/17570#discussion_r737099501 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/RetractableTopNFunction.java ## @@ -455,9 +464

[GitHub] [flink-ml] guoweiM commented on a change in pull request #16: [FLINK-9][iteration] Support per-round iteration

guoweiM commented on a change in pull request #16: URL: https://github.com/apache/flink-ml/pull/16#discussion_r736240831 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/PerRoundSubGraphBuilder.java ## @@ -0,0 +1,67 @@ +/* + * Licensed to the Apache So

[GitHub] [flink] flinkbot edited a comment on pull request #17516: [FLINK-23391][connector/kafka] Fix flaky Kafka source metric test by retrying notifyCheckpointComplete until success or timeout

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

[GitHub] [flink] flinkbot edited a comment on pull request #17516: [FLINK-23391][connector/kafka] Fix flaky Kafka source metric test by retrying notifyCheckpointComplete until success or timeout

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

[GitHub] [flink] flinkbot edited a comment on pull request #17516: [FLINK-23391][connector/kafka] Fix flaky Kafka source metric test by retrying notifyCheckpointComplete until success or timeout

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

[GitHub] [flink] JingsongLi commented on a change in pull request #17537: [FLINK-19722][table-planner]Pushdown Watermark to SourceProvider (new Source)

JingsongLi commented on a change in pull request #17537: URL: https://github.com/apache/flink/pull/17537#discussion_r737083797 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecTableSourceScan.java ## @@

[GitHub] [flink] JingsongLi commented on a change in pull request #17537: [FLINK-19722][table-planner]Pushdown Watermark to SourceProvider (new Source)

JingsongLi commented on a change in pull request #17537: URL: https://github.com/apache/flink/pull/17537#discussion_r737082587 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecTableSourceScan.java ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #17516: [FLINK-23391][connector/kafka] Fix flaky Kafka source metric test by retrying notifyCheckpointComplete until success or timeout

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

[GitHub] [flink] flinkbot edited a comment on pull request #17516: [FLINK-23391][connector/kafka] Fix flaky Kafka source metric test by retrying notifyCheckpointComplete until success or timeout

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

[GitHub] [flink] PatrickRen commented on pull request #16940: [FLINK-23914][connector/testing-framework] Improve logging and error message in testing framework

PatrickRen commented on pull request #16940: URL: https://github.com/apache/flink/pull/16940#issuecomment-952509350 Thanks @AHeise ! AZP run has passed. Could you help to merge the PR when you are available? -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] tsreaper commented on a change in pull request #17570: [FLINK-24654][table] Fix NPE on RetractableTopNFunction when some records were cleared by state ttl

tsreaper commented on a change in pull request #17570: URL: https://github.com/apache/flink/pull/17570#discussion_r737077180 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/RetractableTopNFunction.java ## @@ -455,9 +464

[GitHub] [flink] flinkbot edited a comment on pull request #17516: [FLINK-23391][connector/kafka] Fix flaky Kafka source metric test by retrying notifyCheckpointComplete until success or timeout

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

[GitHub] [flink] flinkbot edited a comment on pull request #17516: [FLINK-23391][connector/kafka] Fix flaky Kafka source metric test by retrying notifyCheckpointComplete until success or timeout

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

[GitHub] [flink] flinkbot edited a comment on pull request #17516: [FLINK-23391][connector/kafka] Fix flaky Kafka source metric test by retrying notifyCheckpointComplete until success or timeout

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

[GitHub] [flink] flinkbot edited a comment on pull request #17516: [FLINK-23391][connector/kafka] Fix flaky Kafka source metric test by retrying notifyCheckpointComplete until success or timeout

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

[GitHub] [flink] PatrickRen commented on pull request #17516: [FLINK-23391][connector/kafka] Fix flaky Kafka source metric test by retrying notifyCheckpointComplete until success or timeout

PatrickRen commented on pull request #17516: URL: https://github.com/apache/flink/pull/17516#issuecomment-952504483 Sorry for my late response @AHeise . I updated the commit message and rebased the latest master -- This is an automated message from the Apache Git Service. To respond to t

[GitHub] [flink] flinkbot edited a comment on pull request #17516: [FLINK-23391][connector/kafka] Fix flaky Kafka source metric test by retrying notifyCheckpointComplete until success or timeout

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

[jira] [Closed] (FLINK-24662) PyFlink sphinx check failed with "node class 'meta' is already registered, its visitors will be overridden"

[ https://issues.apache.org/jira/browse/FLINK-24662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-24662. --- Fix Version/s: 1.13.4 1.14.1 1.15.0 1.12.6 Re

[jira] [Commented] (FLINK-24662) PyFlink sphinx check failed with "node class 'meta' is already registered, its visitors will be overridden"

[ https://issues.apache.org/jira/browse/FLINK-24662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434649#comment-17434649 ] Dian Fu commented on FLINK-24662: - It should be caused by the latest release docutils [

[jira] [Commented] (FLINK-21289) Application mode ignores the pipeline.classpaths configuration

[ https://issues.apache.org/jira/browse/FLINK-21289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434648#comment-17434648 ] Zhou Parker commented on FLINK-21289: - [~wangyang0918] Since it’s been a long time i

[jira] [Closed] (FLINK-24541) ConfigurationUtils#assembleDynamicConfigsStr should consider special characters

[ https://issues.apache.org/jira/browse/FLINK-24541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-24541. Fix Version/s: (was: 1.14.1) Resolution: Fixed Fixed via: - master (1.15): 44e75ecdf9ca

[GitHub] [flink] xintongsong closed pull request #17533: [FLINK-24541][runtime] Quoting the external resource list in generati…

xintongsong closed pull request #17533: URL: https://github.com/apache/flink/pull/17533 -- 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-uns

[jira] [Created] (FLINK-24662) PyFlink sphinx check failed with "node class 'meta' is already registered, its visitors will be overridden"

Dian Fu created FLINK-24662: --- Summary: PyFlink sphinx check failed with "node class 'meta' is already registered, its visitors will be overridden" Key: FLINK-24662 URL: https://issues.apache.org/jira/browse/FLINK-24662

[GitHub] [flink] flinkbot edited a comment on pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

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

[GitHub] [flink] flinkbot edited a comment on pull request #17556: [FLINK-24627][tests] add some Junit5 extensions to replace the existed Junit4 rules

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

[jira] [Created] (FLINK-24661) ConfigOption add isSecret method to judge sensitive options

Ada Wong created FLINK-24661: Summary: ConfigOption add isSecret method to judge sensitive options Key: FLINK-24661 URL: https://issues.apache.org/jira/browse/FLINK-24661 Project: Flink Issue Ty

[GitHub] [flink] flinkbot edited a comment on pull request #17556: [FLINK-24627][tests] add some Junit5 extensions to replace the existed Junit4 rules

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

[GitHub] [flink] flinkbot edited a comment on pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

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

[jira] [Comment Edited] (FLINK-24610) Flink projection common expression elimination

[ https://issues.apache.org/jira/browse/FLINK-24610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434275#comment-17434275 ] Lyn Zhang edited comment on FLINK-24610 at 10/27/21, 2:33 AM:

[GitHub] [flink] flinkbot edited a comment on pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

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

[GitHub] [flink] ruanhang1993 commented on a change in pull request #17556: [FLINK-24627][tests] add some Junit5 extensions to replace the existed Junit4 rules

ruanhang1993 commented on a change in pull request #17556: URL: https://github.com/apache/flink/pull/17556#discussion_r737055199 ## File path: flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/core/testutils/AllCallbackWrapper.java ## @@ -0,0 +1,25

[GitHub] [flink] tsreaper commented on a change in pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

tsreaper commented on a change in pull request #17520: URL: https://github.com/apache/flink/pull/17520#discussion_r737052999 ## File path: flink-formats/flink-avro/pom.xml ## @@ -47,13 +47,11 @@ under the License. -

[GitHub] [flink] ruanhang1993 commented on a change in pull request #17556: [FLINK-24627][tests] add some Junit5 extensions to replace the existed Junit4 rules

ruanhang1993 commented on a change in pull request #17556: URL: https://github.com/apache/flink/pull/17556#discussion_r737048082 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/zookeeper/ZooKeeperExtension.java ## @@ -0,0 +1,64 @@ +package org.apache.flink.r

[GitHub] [flink] flinkbot edited a comment on pull request #17463: [Hotfix] Fix typos.

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

[GitHub] [flink] flinkbot edited a comment on pull request #17463: [Hotfix] Fix typos.

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

[GitHub] [flink] meetjunsu commented on pull request #17542: [FLINK-17782] Add array,map,row types support for parquet row writer

meetjunsu commented on pull request #17542: URL: https://github.com/apache/flink/pull/17542#issuecomment-952456458 @snuyanzin updated in latest commit -- 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 g

[jira] [Commented] (FLINK-20286) Support streaming source for filesystem SQL connector

[ https://issues.apache.org/jira/browse/FLINK-20286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434628#comment-17434628 ] Hadi commented on FLINK-20286: -- [~slinkydeveloper] can this support in Flin

[jira] [Closed] (FLINK-24641) Flink SQL FileSystem read hdfs Path, when Path's file name change, the sql will not find the file.

[ https://issues.apache.org/jira/browse/FLINK-24641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hadi closed FLINK-24641. Resolution: Duplicate > Flink SQL FileSystem read hdfs Path, when Path's file name change, the sql

[jira] [Commented] (FLINK-24641) Flink SQL FileSystem read hdfs Path, when Path's file name change, the sql will not find the file.

[ https://issues.apache.org/jira/browse/FLINK-24641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434625#comment-17434625 ] Hadi commented on FLINK-24641: -- [~MartijnVisser] thank u for ur replay. a

[jira] [Created] (FLINK-24660) Allow setting KafkaSubscriber in KafkaSourceBuilder

Mason Chen created FLINK-24660: -- Summary: Allow setting KafkaSubscriber in KafkaSourceBuilder Key: FLINK-24660 URL: https://issues.apache.org/jira/browse/FLINK-24660 Project: Flink Issue Type: I

[jira] [Updated] (FLINK-18983) Job doesn't changed to failed if close function has blocked

[ https://issues.apache.org/jira/browse/FLINK-18983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18983: --- Labels: stale-major stale-minor (was: stale-major) I am the [Flink Jira Bot|https://github.

[jira] [Updated] (FLINK-23525) Docker command fails on Azure: Exit code 137 returned from process: file name '/usr/bin/docker'

[ https://issues.apache.org/jira/browse/FLINK-23525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-23525: --- Labels: auto-deprioritized-blocker stale-critical test-stability (was: auto-deprioritized-b

[jira] [Updated] (FLINK-18574) DownloadPipelineArtifact failes occasionally

[ https://issues.apache.org/jira/browse/FLINK-18574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18574: --- Labels: auto-deprioritized-critical stale-major test-stability (was: auto-deprioritized-cri

[jira] [Updated] (FLINK-12912) Incorrect handling of task.checkpoint.alignment.max-size when one checkpoint subsumes another one

[ https://issues.apache.org/jira/browse/FLINK-12912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12912: --- Labels: stale-major stale-minor (was: stale-major) I am the [Flink Jira Bot|https://github.

[jira] [Commented] (FLINK-24580) Kinesis connect time out error is not handled as recoverable

[ https://issues.apache.org/jira/browse/FLINK-24580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434604#comment-17434604 ] John Karp commented on FLINK-24580: --- I've tested out this patch, it seems to work in m

[GitHub] [flink] rkhachatryan commented on a change in pull request #15204: [FLINK-21783] Allow extension of HeapBackend SnapshotStrategy

rkhachatryan commented on a change in pull request #15204: URL: https://github.com/apache/flink/pull/15204#discussion_r736856052 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointableKeyedStateBackend.java ## @@ -45,5 +46,6 @@ * write out

[GitHub] [flink] flinkbot edited a comment on pull request #17572: [FLINK-23647][checkpointing] Wait for CheckpointsCleaner to complete before closing cluster

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

[GitHub] [flink] flinkbot edited a comment on pull request #17463: [Hotfix] Fix typos.

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

[GitHub] [flink] flinkbot edited a comment on pull request #17573: [FLINK-24190][runtime] Forbid to split the first record in the buffer if it physically fit it.

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

[GitHub] [flink] flinkbot edited a comment on pull request #17572: [FLINK-23647][checkpointing] Wait for CheckpointsCleaner to complete before closing cluster

flinkbot edited a comment on pull request #17572: URL: https://github.com/apache/flink/pull/17572#issuecomment-952040222 ## CI report: * 5c20827f354a6f033d0ccfd71d353f9e5f6669c7 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #17472: [FLINK-24486][rest] Make async result store duration configurable

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

[GitHub] [flink] flinkbot edited a comment on pull request #17472: [FLINK-24486][rest] Make async result store duration configurable

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

[GitHub] [flink] flinkbot edited a comment on pull request #17472: [FLINK-24486][rest] Make async result store duration configurable

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

[GitHub] [flink] zentol commented on pull request #17472: [FLINK-24486][rest] Make async result store duration configurable

zentol commented on pull request #17472: URL: https://github.com/apache/flink/pull/17472#issuecomment-952185469 @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] zentol commented on a change in pull request #17556: [FLINK-24627][tests] add some Junit5 extensions to replace the existed Junit4 rules

zentol commented on a change in pull request #17556: URL: https://github.com/apache/flink/pull/17556#discussion_r735366139 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/zookeeper/ZooKeeperExtension.java ## @@ -0,0 +1,64 @@ +package org.apache.flink.runtime

[GitHub] [flink] flinkbot edited a comment on pull request #17535: [FLINK-24609][akka][build] Use same Scala properties as root pom

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

[GitHub] [flink] flinkbot edited a comment on pull request #17572: [FLINK-23647][checkpointing] Wait for CheckpointsCleaner to complete before closing cluster

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

[GitHub] [flink] flinkbot edited a comment on pull request #17572: [FLINK-23647][checkpointing] Wait for CheckpointsCleaner to complete before closing cluster

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

[GitHub] [flink] flinkbot edited a comment on pull request #17572: [FLINK-23647][checkpointing] Wait for CheckpointsCleaner to complete before closing cluster

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

[GitHub] [flink] flinkbot edited a comment on pull request #17572: [FLINK-23647][checkpointing] Wait for CheckpointsCleaner to complete before closing cluster

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

[GitHub] [flink] flinkbot edited a comment on pull request #17572: [FLINK-23647][checkpointing] Wait for CheckpointsCleaner to complete before closing cluster

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

[GitHub] [flink] flinkbot edited a comment on pull request #17571: [FLINK-23015][table-runtime-blink] Implement streaming window Deduplicate operator

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

[GitHub] [flink] flinkbot edited a comment on pull request #17572: [FLINK-23647][checkpointing] Wait for CheckpointsCleaner to complete before closing cluster

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

[GitHub] [flink] flinkbot edited a comment on pull request #17572: [FLINK-23647][checkpointing] Wait for CheckpointsCleaner to complete before closing cluster

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

[GitHub] [flink] flinkbot edited a comment on pull request #17572: [FLINK-23647][checkpointing] Wait for CheckpointsCleaner to complete before closing cluster

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

  1   2   3   4   >