[GitHub] [flink] flinkbot edited a comment on pull request #18224: [FLINK-25143][test] Add ITCase for periodic materialization

flinkbot edited a comment on pull request #18224: URL: https://github.com/apache/flink/pull/18224#issuecomment-1002391830 ## CI report: * 30766aa44c0205d4510b75a9c01929de80e93572 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18739: [FLINK-26030][yarn] Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

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

[GitHub] [flink] flinkbot edited a comment on pull request #18547: [FLINK-25840][tests] add semantic test support for the connector testframe

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

[GitHub] [flink] flinkbot edited a comment on pull request #18547: [FLINK-25840][tests] add semantic test support for the connector testframe

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

[GitHub] [flink] flinkbot edited a comment on pull request #18547: [FLINK-25840][tests] add semantic test support for the connector testframe

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

[GitHub] [flink] flinkbot edited a comment on pull request #18547: [FLINK-25840][tests] add semantic test support for the connector testframe

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

[GitHub] [flink] flinkbot edited a comment on pull request #18224: [FLINK-25143][test] Add ITCase for periodic materialization

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

[GitHub] [flink] flinkbot edited a comment on pull request #18224: [FLINK-25143][test] Add ITCase for periodic materialization

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

[GitHub] [flink] flinkbot edited a comment on pull request #18224: [FLINK-25143][test] Add ITCase for periodic materialization

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

[GitHub] [flink] flinkbot edited a comment on pull request #18224: [FLINK-25143][test] Add ITCase for periodic materialization

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

[GitHub] [flink] flinkbot edited a comment on pull request #18224: [FLINK-25143][test] Add ITCase for periodic materialization

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

[GitHub] [flink] flinkbot edited a comment on pull request #18224: [FLINK-25143][test] Add ITCase for periodic materialization

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

[GitHub] [flink] flinkbot edited a comment on pull request #18224: [FLINK-25143][test] Add ITCase for periodic materialization

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

[GitHub] [flink] flinkbot edited a comment on pull request #18224: [FLINK-25143][test] Add ITCase for periodic materialization

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

[GitHub] [flink] flinkbot edited a comment on pull request #18224: [FLINK-25143][test] Add ITCase for periodic materialization

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

[GitHub] [flink] flinkbot edited a comment on pull request #18224: [FLINK-25143][test] Add ITCase for periodic materialization

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

[GitHub] [flink] flinkbot edited a comment on pull request #18224: [FLINK-25143][test] Add ITCase for periodic materialization

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

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

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

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #18224: [FLINK-25143][test] Add ITCase for periodic materialization

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

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #18224: [FLINK-25143][test] Add ITCase for periodic materialization

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

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #18224: [FLINK-25143][test] Add ITCase for periodic materialization

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

[GitHub] [flink] flinkbot edited a comment on pull request #18224: [FLINK-25143][test] Add ITCase for periodic materialization

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

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #18224: [FLINK-25143][test] Add ITCase for periodic materialization

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

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #18224: [FLINK-25143][test] Add ITCase for periodic materialization

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

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #18224: [FLINK-25143][test] Add ITCase for periodic materialization

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

[GitHub] [flink] flinkbot edited a comment on pull request #18224: [FLINK-25143][test] Add ITCase for periodic materialization

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

[GitHub] [flink] flinkbot edited a comment on pull request #18224: [FLINK-25143][test] Add ITCase for periodic materialization

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

[GitHub] [flink] bgeng777 commented on pull request #18739: [FLINK-26030][yarn] Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

bgeng777 commented on pull request #18739: URL: https://github.com/apache/flink/pull/18739#issuecomment-1037760090 This PR has not included new unit/integration tests as I find that this fix relies cluster's environment variable. Will check if we should add a e2e test in next few days. -

[GitHub] [flink] godfreyhe commented on pull request #18707: [FLINK-25995][table-planner] Make implicit assumption of SQL local hash explicit

godfreyhe commented on pull request #18707: URL: https://github.com/apache/flink/pull/18707#issuecomment-1037751201 Thanks for the review, I will merge it -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #18739: [FLINK-26030][yarn] Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

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

[GitHub] [flink] flinkbot commented on pull request #18739: [FLINK-26030][yarn] Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

flinkbot commented on pull request #18739: URL: https://github.com/apache/flink/pull/18739#issuecomment-1037748219 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 #18739: [FLINK-26030][yarn] Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

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

[jira] [Updated] (FLINK-26030) Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

[ https://issues.apache.org/jira/browse/FLINK-26030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26030: --- Labels: pull-request-available (was: ) > Set FLINK_LIB_DIR to 'lib' under working dir in YA

[GitHub] [flink] bgeng777 opened a new pull request #18739: [FLINK-26030][yarn] Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

bgeng777 opened a new pull request #18739: URL: https://github.com/apache/flink/pull/18739 ## What is the purpose of the change Fix the minor bug when locating `usrlib` with `ClusterEntrypointUtils#tryFindUserLibDirectory` as it will return a wrong usrlib if environment vari

[GitHub] [flink] flinkbot edited a comment on pull request #18547: [FLINK-25840][tests] add semantic test support for the connector testframe

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

[GitHub] [flink] flinkbot edited a comment on pull request #18547: [FLINK-25840][tests] add semantic test support for the connector testframe

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

[GitHub] [flink] flinkbot edited a comment on pull request #18547: [FLINK-25840][tests] add semantic test support for the connector testframe

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

[GitHub] [flink] flinkbot edited a comment on pull request #18547: [FLINK-25840][tests] add semantic test support for the connector testframe

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

[GitHub] [flink] flinkbot edited a comment on pull request #18547: [FLINK-25840][tests] add semantic test support for the connector testframe

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

[GitHub] [flink] flinkbot edited a comment on pull request #18547: [FLINK-25840][tests] add semantic test support for the connector testframe

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

[GitHub] [flink] flinkbot edited a comment on pull request #18547: [FLINK-25840][tests] add semantic test support for the connector testframe

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

[GitHub] [flink] flinkbot edited a comment on pull request #18547: [FLINK-25840][tests] add semantic test support for the connector testframe

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

[GitHub] [flink] ruanhang1993 commented on a change in pull request #18516: [FLINK-25288][tests] add savepoint and metric test cases in source suite of connector testframe

ruanhang1993 commented on a change in pull request #18516: URL: https://github.com/apache/flink/pull/18516#discussion_r805231978 ## File path: flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/PulsarSourceITCase.java ## @@ -40,6 +42

[GitHub] [flink] ruanhang1993 commented on a change in pull request #18516: [FLINK-25288][tests] add savepoint and metric test cases in source suite of connector testframe

ruanhang1993 commented on a change in pull request #18516: URL: https://github.com/apache/flink/pull/18516#discussion_r805231921 ## File path: flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/utils/MetricQueryer.java ## @@ -

[GitHub] [flink] ruanhang1993 commented on a change in pull request #18516: [FLINK-25288][tests] add savepoint and metric test cases in source suite of connector testframe

ruanhang1993 commented on a change in pull request #18516: URL: https://github.com/apache/flink/pull/18516#discussion_r805231905 ## File path: flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/utils/MetricQueryer.java ## @@ -

[GitHub] [flink] ruanhang1993 commented on a change in pull request #18516: [FLINK-25288][tests] add savepoint and metric test cases in source suite of connector testframe

ruanhang1993 commented on a change in pull request #18516: URL: https://github.com/apache/flink/pull/18516#discussion_r805231897 ## File path: flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/environment/MiniClusterTestEnvironment.j

[GitHub] [flink] ruanhang1993 commented on a change in pull request #18516: [FLINK-25288][tests] add savepoint and metric test cases in source suite of connector testframe

ruanhang1993 commented on a change in pull request #18516: URL: https://github.com/apache/flink/pull/18516#discussion_r805231864 ## File path: flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/environment/MiniClusterTestEnvironment.j

[GitHub] [flink] ruanhang1993 commented on a change in pull request #18516: [FLINK-25288][tests] add savepoint and metric test cases in source suite of connector testframe

ruanhang1993 commented on a change in pull request #18516: URL: https://github.com/apache/flink/pull/18516#discussion_r805231859 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/flink/FlinkContainerTestEnvironment.java ##

[GitHub] [flink] ruanhang1993 commented on a change in pull request #18516: [FLINK-25288][tests] add savepoint and metric test cases in source suite of connector testframe

ruanhang1993 commented on a change in pull request #18516: URL: https://github.com/apache/flink/pull/18516#discussion_r805231841 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/KafkaSourceExternalContext.java ## @@

[GitHub] [flink] ruanhang1993 commented on a change in pull request #18547: [FLINK-25840][tests] add semantic test support for the connector testframe

ruanhang1993 commented on a change in pull request #18547: URL: https://github.com/apache/flink/pull/18547#discussion_r805230682 ## File path: flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/utils/CollectIteratorAssertions.java ###

[GitHub] [flink] ruanhang1993 commented on a change in pull request #18547: [FLINK-25840][tests] add semantic test support for the connector testframe

ruanhang1993 commented on a change in pull request #18547: URL: https://github.com/apache/flink/pull/18547#discussion_r805230541 ## File path: flink-test-utils-parent/flink-connector-test-utils/src/test/java/org/apache/flink/connector/testframe/utils/CollectIteratorAssertTest.java ###

[GitHub] [flink] ruanhang1993 commented on a change in pull request #18547: [FLINK-25840][tests] add semantic test support for the connector testframe

ruanhang1993 commented on a change in pull request #18547: URL: https://github.com/apache/flink/pull/18547#discussion_r805230534 ## File path: flink-test-utils-parent/flink-connector-test-utils/src/test/java/org/apache/flink/connector/testframe/utils/CollectIteratorAssertTest.java ###

[GitHub] [flink] ruanhang1993 commented on a change in pull request #18547: [FLINK-25840][tests] add semantic test support for the connector testframe

ruanhang1993 commented on a change in pull request #18547: URL: https://github.com/apache/flink/pull/18547#discussion_r805230469 ## File path: flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/utils/CollectIteratorAssert.java ###

[GitHub] [flink] ruanhang1993 commented on a change in pull request #18547: [FLINK-25840][tests] add semantic test support for the connector testframe

ruanhang1993 commented on a change in pull request #18547: URL: https://github.com/apache/flink/pull/18547#discussion_r805230426 ## File path: flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/testsuites/SourceTestSuiteBase.java

[GitHub] [flink] flinkbot edited a comment on pull request #18547: [FLINK-25840][tests] add semantic test support for the connector testframe

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

[GitHub] [flink] flinkbot edited a comment on pull request #18547: [FLINK-25840][tests] add semantic test support for the connector testframe

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

[GitHub] [flink] ruanhang1993 commented on a change in pull request #18547: [FLINK-25840][tests] add semantic test support for the connector testframe

ruanhang1993 commented on a change in pull request #18547: URL: https://github.com/apache/flink/pull/18547#discussion_r805225719 ## File path: flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testframe/testsuites/SourceTestSuiteBase.java

[jira] [Updated] (FLINK-13038) CEP WITHIN don’t support interval expression

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

[jira] [Updated] (FLINK-13113) Introduce range partition in blink

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

[jira] [Updated] (FLINK-8277) Optimize code generation by using local references

[ https://issues.apache.org/jira/browse/FLINK-8277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-8277: -- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned (was: auto-deprior

[jira] [Updated] (FLINK-13251) Add bandwidth throttling for checkpoint uploading/downloading

[ https://issues.apache.org/jira/browse/FLINK-13251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13251: --- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned (was: auto-depr

[jira] [Updated] (FLINK-4860) Sort performance

[ https://issues.apache.org/jira/browse/FLINK-4860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-4860: -- Labels: auto-deprioritized-major auto-deprioritized-minor performance (was: auto-deprioritiz

[jira] [Updated] (FLINK-10381) concurrent submit job get ProgramAbortException

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

[jira] [Updated] (FLINK-15376) support "CREATE TABLE AS" in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-15376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-15376: --- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned (was: auto-depr

[jira] [Updated] (FLINK-15294) Migrate CustomCommandLine to Executor abstraction

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

[GitHub] [flink] dmvk commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

dmvk commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r805206533 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StateWithExecutionGraph.java ## @@ -148,6 +162,33 @@ public Logger get

[GitHub] [flink] dmvk commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

dmvk commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r805205858 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StateWithExecutionGraph.java ## @@ -148,6 +162,33 @@ public Logger get

[GitHub] [flink] dmvk commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

dmvk commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r805205602 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerTest.java ## @@ -969,10 +979,203 @@ public void testH

[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

flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * f54d567b9a8557f54b3ffac7dc59eb91c8e1f02e Azure: [SUCCESS](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18681: [FLINK-26032][streaming] check explicit env allowed on StreamExecutionEnvironment own.

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

[jira] [Resolved] (FLINK-25610) [FLIP-171] Kinesis Firehose implementation of Async Sink Table API

[ https://issues.apache.org/jira/browse/FLINK-25610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-25610. --- Resolution: Fixed Merged https://github.com/apache/flink/commit/5c9d0d699b31f76180308f165a7

[GitHub] [flink] flinkbot edited a comment on pull request #18681: [FLINK-26032][streaming] check explicit env allowed on StreamExecutionEnvironment own.

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

[GitHub] [flink] dannycranmer merged pull request #18603: [FLINK-25610][connector/firehose] Adding table api base for kinesis firehose

dannycranmer merged pull request #18603: URL: https://github.com/apache/flink/pull/18603 -- 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 #18681: [FLINK-26032][streaming] check explicit env allowed on StreamExecutionEnvironment own.

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

[GitHub] [flink] JingGe commented on pull request #18681: [FLINK-26032][streaming] check explicit env allowed on StreamExecutionEnvironment own.

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

[jira] [Created] (FLINK-26098) TableAPI does not forward idleness configuration from DataStream

Till Rohrmann created FLINK-26098: - Summary: TableAPI does not forward idleness configuration from DataStream Key: FLINK-26098 URL: https://issues.apache.org/jira/browse/FLINK-26098 Project: Flink

[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

flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * 128e9b4a394963cb6189259fb3bc9caa23c540f0 Azure: [FAILURE](https://dev.azure.com/apache-f

[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

flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * 128e9b4a394963cb6189259fb3bc9caa23c540f0 Azure: [FAILURE](https://dev.azure.com/apache-f

[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

flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * 128e9b4a394963cb6189259fb3bc9caa23c540f0 Azure: [FAILURE](https://dev.azure.com/apache-f

[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

flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * 128e9b4a394963cb6189259fb3bc9caa23c540f0 Azure: [FAILURE](https://dev.azure.com/apache-f

[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

flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * 128e9b4a394963cb6189259fb3bc9caa23c540f0 Azure: [FAILURE](https://dev.azure.com/apache-f

[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

flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * 128e9b4a394963cb6189259fb3bc9caa23c540f0 Azure: [FAILURE](https://dev.azure.com/apache-f

[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

flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * 128e9b4a394963cb6189259fb3bc9caa23c540f0 Azure: [FAILURE](https://dev.azure.com/apache-f

[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

flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * 128e9b4a394963cb6189259fb3bc9caa23c540f0 Azure: [FAILURE](https://dev.azure.com/apache-f

[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

flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * 128e9b4a394963cb6189259fb3bc9caa23c540f0 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

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

[GitHub] [flink-statefun-playground] tillrohrmann opened a new pull request #25: [WIP][FLINK-XXXX] Add Playground ingress/egress that allows to ingest and consume messages via curl

tillrohrmann opened a new pull request #25: URL: https://github.com/apache/flink-statefun-playground/pull/25 The PlaygroundIngress and PlaygroundIngress spin up a web server that allows to ingest and consume messages that are kept in memory via curl. -- This is an automated message fr

[GitHub] [flink] RocMarshal commented on a change in pull request #18718: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chi…

RocMarshal commented on a change in pull request #18718: URL: https://github.com/apache/flink/pull/18718#discussion_r805170553 ## File path: docs/content.zh/docs/connectors/datastream/filesystem.md ## @@ -28,39 +28,34 @@ specific language governing permissions and limitations

[GitHub] [flink] flinkbot edited a comment on pull request #18707: [FLINK-25995][table-planner] Make implicit assumption of SQL local hash explicit

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

[GitHub] [flink] RocMarshal commented on a change in pull request #18718: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chi…

RocMarshal commented on a change in pull request #18718: URL: https://github.com/apache/flink/pull/18718#discussion_r805173884 ## File path: docs/content.zh/docs/connectors/datastream/filesystem.md ## @@ -94,33 +88,29 @@ final FileSource source = {{< /tab >}} {{< /tabs >}}

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

flinkbot edited a comment on pull request #18653: URL: https://github.com/apache/flink/pull/18653#issuecomment-1032212433 ## CI report: * 1950517b6aab421fbd331d1261ab3464179a2d7d 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

flinkbot edited a comment on pull request #18653: URL: https://github.com/apache/flink/pull/18653#issuecomment-1032212433 ## CI report: * 1950517b6aab421fbd331d1261ab3464179a2d7d 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

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

[GitHub] [flink] RocMarshal commented on pull request #18480: [FLINK-25789][docs-zh] Translate the formats/hadoop page into Chinese.

RocMarshal commented on pull request #18480: URL: https://github.com/apache/flink/pull/18480#issuecomment-1037264660 @leonardBang Could you help me to merge it if there's nothing Inappropriate？ Thank you very much. -- This is an automated message from the Apache Git Service. To respond

  1   2   >