[GitHub] [flink] flinkbot commented on pull request #15100: [FLINK-21640]Job fails to be submitted in tenant scenario

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

[GitHub] [flink] flinkbot edited a comment on pull request #15049: [FLINK-21190][runtime-web] Expose exception history

flinkbot edited a comment on pull request #15049: URL: https://github.com/apache/flink/pull/15049#issuecomment-787719691 ## CI report: * 2cbffce55c35f7e163739d07f88e480870a0fc37 UNKNOWN * bd732209f8aaa9653dfeaf7be6ff8396ece70928 UNKNOWN * 6c48dd09592d47aafe0d35e742e1ac717883

[GitHub] [flink] flinkbot commented on pull request #15100: [FLINK-21640]Job fails to be submitted in tenant scenario

flinkbot commented on pull request #15100: URL: https://github.com/apache/flink/pull/15100#issuecomment-791888994 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[GitHub] [flink] cuibo01 opened a new pull request #15100: [FLINK-21640]Job fails to be submitted in tenant scenario

cuibo01 opened a new pull request #15100: URL: https://github.com/apache/flink/pull/15100 Modify the "high-availability.zookeeper.path.root" permissions. This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] cuibo01 closed pull request #15099: [FLINK-21640]Job fails to be submitted in tenant scenario

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

[GitHub] [flink] flinkbot edited a comment on pull request #15099: [FLINK-21640]Job fails to be submitted in tenant scenario

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

[GitHub] [flink] flinkbot edited a comment on pull request #15094: [FLINK-21633][coordination] Index pending task managers in TaskManage…

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

[GitHub] [flink] flinkbot edited a comment on pull request #15099: [FLINK-21640]Job fails to be submitted in tenant scenario

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

[GitHub] [flink] flinkbot edited a comment on pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

flinkbot edited a comment on pull request #14737: URL: https://github.com/apache/flink/pull/14737#issuecomment-766281483 ## CI report: * 2e05b89cd87ce4ba54de32eff3c68985f766180f UNKNOWN * a87a26aa218658f7098367cae8c7a2ed18430296 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #15099: [FLINK-21640]Job fails to be submitted in tenant scenario

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

[GitHub] [flink] flinkbot commented on pull request #15099: [FLINK-21640]Job fails to be submitted in tenant scenario

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

[GitHub] [flink] flinkbot commented on pull request #15099: [FLINK-21640]Job fails to be submitted in tenant scenario

flinkbot commented on pull request #15099: URL: https://github.com/apache/flink/pull/15099#issuecomment-791835944 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[jira] [Updated] (FLINK-21640) Job fails to be submitted in tenant scenario

[ https://issues.apache.org/jira/browse/FLINK-21640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21640: --- Labels: pull-request-available (was: ) > Job fails to be submitted in tenant scenario > ---

[GitHub] [flink] cuibo01 opened a new pull request #15099: [FLINK-21640]Job fails to be submitted in tenant scenario

cuibo01 opened a new pull request #15099: URL: https://github.com/apache/flink/pull/15099 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them on

[jira] [Created] (FLINK-21640) Job fails to be submitted in tenant scenario

Bo Cui created FLINK-21640: -- Summary: Job fails to be submitted in tenant scenario Key: FLINK-21640 URL: https://issues.apache.org/jira/browse/FLINK-21640 Project: Flink Issue Type: Bug Affects

[GitHub] [flink] flinkbot edited a comment on pull request #15094: [FLINK-21633][coordination] Index pending task managers in TaskManage…

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

[GitHub] [flink] flinkbot edited a comment on pull request #15049: [FLINK-21190][runtime-web] Expose exception history

flinkbot edited a comment on pull request #15049: URL: https://github.com/apache/flink/pull/15049#issuecomment-787719691 ## CI report: * 2cbffce55c35f7e163739d07f88e480870a0fc37 UNKNOWN * bd732209f8aaa9653dfeaf7be6ff8396ece70928 UNKNOWN * 6c48dd09592d47aafe0d35e742e1ac717883

[GitHub] [flink] flinkbot edited a comment on pull request #15094: [FLINK-21633][coordination] Index pending task managers in TaskManage…

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

[GitHub] [flink] flinkbot edited a comment on pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

flinkbot edited a comment on pull request #14737: URL: https://github.com/apache/flink/pull/14737#issuecomment-766281483 ## CI report: * 2e05b89cd87ce4ba54de32eff3c68985f766180f UNKNOWN * c77e3d4a1a7484c4f1e24b23a1099364b834cf75 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #15049: [FLINK-21190][runtime-web] Expose exception history

flinkbot edited a comment on pull request #15049: URL: https://github.com/apache/flink/pull/15049#issuecomment-787719691 ## CI report: * 2cbffce55c35f7e163739d07f88e480870a0fc37 UNKNOWN * bd732209f8aaa9653dfeaf7be6ff8396ece70928 UNKNOWN * bfbae2b9b2f95072e94ec0811c4bc085b0ba

[GitHub] [flink] flinkbot edited a comment on pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

flinkbot edited a comment on pull request #14737: URL: https://github.com/apache/flink/pull/14737#issuecomment-766281483 ## CI report: * 2e05b89cd87ce4ba54de32eff3c68985f766180f UNKNOWN * c77e3d4a1a7484c4f1e24b23a1099364b834cf75 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #15049: [FLINK-21190][runtime-web] Expose exception history

flinkbot edited a comment on pull request #15049: URL: https://github.com/apache/flink/pull/15049#issuecomment-787719691 ## CI report: * 2cbffce55c35f7e163739d07f88e480870a0fc37 UNKNOWN * bd732209f8aaa9653dfeaf7be6ff8396ece70928 UNKNOWN * bfbae2b9b2f95072e94ec0811c4bc085b0ba

[GitHub] [flink] flinkbot edited a comment on pull request #15093: [FLINK-21401] Consolidate JobGraph generation to properly instantiate streaming and batch JobGraphs

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

[GitHub] [flink] flinkbot edited a comment on pull request #15049: [FLINK-21190][runtime-web] Expose exception history

flinkbot edited a comment on pull request #15049: URL: https://github.com/apache/flink/pull/15049#issuecomment-787719691 ## CI report: * 2cbffce55c35f7e163739d07f88e480870a0fc37 UNKNOWN * bd732209f8aaa9653dfeaf7be6ff8396ece70928 UNKNOWN * bfbae2b9b2f95072e94ec0811c4bc085b0ba

[GitHub] [flink] flinkbot edited a comment on pull request #15049: [FLINK-21190][runtime-web] Expose exception history

flinkbot edited a comment on pull request #15049: URL: https://github.com/apache/flink/pull/15049#issuecomment-787719691 ## CI report: * 2cbffce55c35f7e163739d07f88e480870a0fc37 UNKNOWN * bd732209f8aaa9653dfeaf7be6ff8396ece70928 UNKNOWN * 7b7963fd75b521d7d0d34733a07d02bc72cd

[GitHub] [flink] flinkbot edited a comment on pull request #15049: [FLINK-21190][runtime-web] Expose exception history

flinkbot edited a comment on pull request #15049: URL: https://github.com/apache/flink/pull/15049#issuecomment-787719691 ## CI report: * 2cbffce55c35f7e163739d07f88e480870a0fc37 UNKNOWN * bd732209f8aaa9653dfeaf7be6ff8396ece70928 UNKNOWN * 7b7963fd75b521d7d0d34733a07d02bc72cd

[jira] [Updated] (FLINK-21639) docs still state that AsyncWaitOperator is not chainable

[ https://issues.apache.org/jira/browse/FLINK-21639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-21639: --- Description: The documentation for asyncio wasn't updated after FLINK-16219 resolved the is

[jira] [Created] (FLINK-21639) docs still state that AsyncWaitOperator is not chainable

David Anderson created FLINK-21639: -- Summary: docs still state that AsyncWaitOperator is not chainable Key: FLINK-21639 URL: https://issues.apache.org/jira/browse/FLINK-21639 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #15093: [FLINK-21401] Consolidate JobGraph generation to properly instantiate streaming and batch JobGraphs

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

[GitHub] [flink] flinkbot edited a comment on pull request #15093: [FLINK-21401] Consolidate JobGraph generation to properly instantiate streaming and batch JobGraphs

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

[GitHub] [flink] Thesharing commented on pull request #14868: [FLINK-21326][runtime] Optimize building topology when initializing ExecutionGraph

Thesharing commented on pull request #14868: URL: https://github.com/apache/flink/pull/14868#issuecomment-791609919 Thank you, @tillrohrmann and @zhuzhurk! I believe I've learnt a lot from your suggestions. I'll start to prepare the next pull request. Thank you for these enlightening revie

[GitHub] [flink] tillrohrmann closed pull request #14868: [FLINK-21326][runtime] Optimize building topology when initializing ExecutionGraph

tillrohrmann closed pull request #14868: URL: https://github.com/apache/flink/pull/14868 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] [Closed] (FLINK-21326) Optimize building topology when initializing ExecutionGraph

[ https://issues.apache.org/jira/browse/FLINK-21326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-21326. - Resolution: Fixed Fixed via 7e5b388a23fc35353fe0bf174b31f727f594cfa5 e2379c1a09c3f92c32966cceb4

[GitHub] [flink] flinkbot edited a comment on pull request #15098: [FLINK-21396][table-common] Add ResolvedCatalog(View/Table) and Catalog(View/Table).of

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

[GitHub] [flink] flinkbot edited a comment on pull request #14868: [FLINK-21326][runtime] Optimize building topology when initializing ExecutionGraph

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

[GitHub] [flink] flinkbot edited a comment on pull request #15098: [FLINK-21396][table-common] Add ResolvedCatalog(View/Table) and Catalog(View/Table).of

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

[GitHub] [flink] flinkbot edited a comment on pull request #15093: [FLINK-21401] Consolidate JobGraph generation to properly instantiate streaming and batch JobGraphs

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

[GitHub] [flink] flinkbot edited a comment on pull request #15062: [FLINK-21549][table-planner-blink] Support json serialization/deserialization for the push-down result of DynamicTableSource and Dyna

flinkbot edited a comment on pull request #15062: URL: https://github.com/apache/flink/pull/15062#issuecomment-788890431 ## CI report: * 11bc275bd72bee56af5dccb8983581890ad48ff5 UNKNOWN * 6fa6eb03777fb4061d0e1f261075ef54d37757c9 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #15049: [FLINK-21190][runtime-web] Expose exception history

flinkbot edited a comment on pull request #15049: URL: https://github.com/apache/flink/pull/15049#issuecomment-787719691 ## CI report: * 2cbffce55c35f7e163739d07f88e480870a0fc37 UNKNOWN * bd732209f8aaa9653dfeaf7be6ff8396ece70928 UNKNOWN * 7b7963fd75b521d7d0d34733a07d02bc72cd

[GitHub] [flink] tillrohrmann commented on a change in pull request #14948: [FLINK-21333][coordination] Add StopWithSavepoint state to declarative scheduler

tillrohrmann commented on a change in pull request #14948: URL: https://github.com/apache/flink/pull/14948#discussion_r588461703 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/stopwithsavepoint/StopWithSavepointOperationManager.java ## @@ -45,18 +

[GitHub] [flink] flinkbot edited a comment on pull request #15097: [FLINK-21506] [mesos] Option for mesos task user

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

[GitHub] [flink] flinkbot edited a comment on pull request #14754: [FLINK-21127][runtime][checkpoint] Stores finished status for fully finished operators in checkpoint

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

[GitHub] [flink] flinkbot edited a comment on pull request #15058: [FLINK-21419][coordination] Remove GC cleaner mechanism for unsafe memory segments

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

[jira] [Comment Edited] (FLINK-21606) TaskManager connected to invalid JobManager leading to TaskSubmissionException

[ https://issues.apache.org/jira/browse/FLINK-21606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17296145#comment-17296145 ] Till Rohrmann edited comment on FLINK-21606 at 3/5/21, 4:17 PM: --

[jira] [Commented] (FLINK-21606) TaskManager connected to invalid JobManager leading to TaskSubmissionException

[ https://issues.apache.org/jira/browse/FLINK-21606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17296145#comment-17296145 ] Till Rohrmann commented on FLINK-21606: --- I think the problem is that Flink does no

[jira] [Commented] (FLINK-21136) Reactive Mode: Adjust timeout behavior in adaptive scheduler

[ https://issues.apache.org/jira/browse/FLINK-21136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17296105#comment-17296105 ] Till Rohrmann commented on FLINK-21136: --- I like the ideas. The reactive mode needs

[GitHub] [flink] flinkbot edited a comment on pull request #15093: [FLINK-21401] Consolidate JobGraph generation to properly instantiate streaming and batch JobGraphs

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

[GitHub] [flink] flinkbot edited a comment on pull request #15049: [FLINK-21190][runtime-web] Expose exception history

flinkbot edited a comment on pull request #15049: URL: https://github.com/apache/flink/pull/15049#issuecomment-787719691 ## CI report: * 2cbffce55c35f7e163739d07f88e480870a0fc37 UNKNOWN * a4dc24e7f5ef92cf18aef9fbe5df8016189eace4 Azure: [CANCELED](https://dev.azure.com/apache-f

[jira] [Created] (FLINK-21638) Clean up argument order and semantics of all "stopWithSavepoint" calls in the codebase

Robert Metzger created FLINK-21638: -- Summary: Clean up argument order and semantics of all "stopWithSavepoint" calls in the codebase Key: FLINK-21638 URL: https://issues.apache.org/jira/browse/FLINK-21638

[GitHub] [flink] rmetzger commented on a change in pull request #14948: [FLINK-21333][coordination] Add StopWithSavepoint state to declarative scheduler

rmetzger commented on a change in pull request #14948: URL: https://github.com/apache/flink/pull/14948#discussion_r588384037 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/stopwithsavepoint/StopWithSavepointOperationManager.java ## @@ -45,18 +57,2

[jira] [Assigned] (FLINK-21606) TaskManager connected to invalid JobManager leading to TaskSubmissionException

[ https://issues.apache.org/jira/browse/FLINK-21606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-21606: - Assignee: Till Rohrmann > TaskManager connected to invalid JobManager leading to TaskSu

[jira] [Commented] (FLINK-17482) KafkaITCase.testMultipleSourcesOnePartition unstable

[ https://issues.apache.org/jira/browse/FLINK-17482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17296088#comment-17296088 ] Till Rohrmann commented on FLINK-17482: --- Another instance: https://dev.azure.com/

[jira] [Commented] (FLINK-19142) Investigate slot hijacking from preceding pipelined regions after failover

[ https://issues.apache.org/jira/browse/FLINK-19142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17296087#comment-17296087 ] Till Rohrmann commented on FLINK-19142: --- How would the system behave if we lose tw

[GitHub] [flink] flinkbot edited a comment on pull request #15098: [FLINK-21396][table-common] Add ResolvedCatalog(View/Table) and Catalog(View/Table).of

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

[GitHub] [flink] flinkbot edited a comment on pull request #15093: [FLINK-21401] Consolidate JobGraph generation to properly instantiate streaming and batch JobGraphs

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

[GitHub] [flink] flinkbot edited a comment on pull request #15087: [FLINK-21299][table] Support 'SHOW [FULL] MODULES' syntax in SqlParser, TableEnvironment and SqlCli

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

[GitHub] [flink] flinkbot edited a comment on pull request #15050: [FLINK-21531][table-planner-blink][table-api-java][hive] Introduce pluggable Parser

flinkbot edited a comment on pull request #15050: URL: https://github.com/apache/flink/pull/15050#issuecomment-787736322 ## CI report: * e096dadbeef7c6c2e6c3f79edd9b090a1374616f UNKNOWN * a34809a6a7360fc27bcf6ba7f26369f42800b307 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #15049: [FLINK-21190][runtime-web] Expose exception history

flinkbot edited a comment on pull request #15049: URL: https://github.com/apache/flink/pull/15049#issuecomment-787719691 ## CI report: * 2cbffce55c35f7e163739d07f88e480870a0fc37 UNKNOWN * a4dc24e7f5ef92cf18aef9fbe5df8016189eace4 Azure: [CANCELED](https://dev.azure.com/apache-f

[GitHub] [flink] tillrohrmann commented on a change in pull request #14948: [FLINK-21333][coordination] Add StopWithSavepoint state to declarative scheduler

tillrohrmann commented on a change in pull request #14948: URL: https://github.com/apache/flink/pull/14948#discussion_r588365069 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java ## @@ -430,14 +430,30 @@ protected void onStart() throws

[jira] [Commented] (FLINK-21588) unable to create catalogs for postgresql

[ https://issues.apache.org/jira/browse/FLINK-21588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17296073#comment-17296073 ] Matthias commented on FLINK-21588: -- This also applies to your TaskManagers? > unable t

[GitHub] [flink] tillrohrmann commented on pull request #15093: [FLINK-21401] Consolidate JobGraph generation to properly instantiate streaming and batch JobGraphs

tillrohrmann commented on pull request #15093: URL: https://github.com/apache/flink/pull/15093#issuecomment-791467318 Thanks for the review @rmetzger. I've addressed your comments. I will merge this PR once AZP gives green light. ---

[GitHub] [flink] tillrohrmann commented on a change in pull request #15093: [FLINK-21401] Consolidate JobGraph generation to properly instantiate streaming and batch JobGraphs

tillrohrmann commented on a change in pull request #15093: URL: https://github.com/apache/flink/pull/15093#discussion_r588350992 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java ## @@ -392,46 +418,47 @@ public void testNonBlocki

[GitHub] [flink] tillrohrmann commented on a change in pull request #15093: [FLINK-21401] Consolidate JobGraph generation to properly instantiate streaming and batch JobGraphs

tillrohrmann commented on a change in pull request #15093: URL: https://github.com/apache/flink/pull/15093#discussion_r588350564 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherTest.java ## @@ -991,13 +1027,11 @@ public TestingJobManager

[GitHub] [flink] tillrohrmann commented on a change in pull request #15093: [FLINK-21401] Consolidate JobGraph generation to properly instantiate streaming and batch JobGraphs

tillrohrmann commented on a change in pull request #15093: URL: https://github.com/apache/flink/pull/15093#discussion_r588347940 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/entrypoint/component/FileJobGraphRetrieverTest.java ## @@ -67,7 +68,11 @@ public

[GitHub] [flink] tillrohrmann commented on a change in pull request #15093: [FLINK-21401] Consolidate JobGraph generation to properly instantiate streaming and batch JobGraphs

tillrohrmann commented on a change in pull request #15093: URL: https://github.com/apache/flink/pull/15093#discussion_r588347385 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterTest.java ## @@ -260,100 +245,6 @@ public static void teardown

[GitHub] [flink] flinkbot edited a comment on pull request #15098: [FLINK-21396][table-common] Add ResolvedCatalog(View/Table) and Catalog(View/Table).of

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

[GitHub] [flink] flinkbot edited a comment on pull request #15095: [FLINK-13554][runtime] Add a timeout for worker registration.

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

[GitHub] [flink] flinkbot edited a comment on pull request #15094: [FLINK-21633][coordination] Index pending task managers in TaskManage…

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

[GitHub] [flink] flinkbot edited a comment on pull request #15049: [FLINK-21190][runtime-web] Expose exception history

flinkbot edited a comment on pull request #15049: URL: https://github.com/apache/flink/pull/15049#issuecomment-787719691 ## CI report: * 2cbffce55c35f7e163739d07f88e480870a0fc37 UNKNOWN * 9cc5f5153a2d91d607ae41d2d070a8779cec61f0 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] tillrohrmann commented on a change in pull request #15071: [FLINK-21135][coord] Adjust parallelism of job for reactive mode

tillrohrmann commented on a change in pull request #15071: URL: https://github.com/apache/flink/pull/15071#discussion_r588317421 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/DefaultSlotPoolServiceSchedulerFactory.java ## @@ -58,13 +58,18 @@

[GitHub] [flink] rmetzger commented on pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

rmetzger commented on pull request #14737: URL: https://github.com/apache/flink/pull/14737#issuecomment-791455142 Also note that you need to include this commit if you want to make the secrets forwarding work: https://github.com/rmetzger/flink/commit/697c40cad14f42119604b3e754c4a52ede4a5c8

[GitHub] [flink-web] HuangXingBo closed pull request #422: Add xingbo to community page

HuangXingBo closed pull request #422: URL: https://github.com/apache/flink-web/pull/422 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

[jira] [Comment Edited] (FLINK-21582) COALESCE not works when cast a variable return null

[ https://issues.apache.org/jira/browse/FLINK-21582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17295872#comment-17295872 ] jibiyr edited comment on FLINK-21582 at 3/5/21, 2:13 PM: - [~twal

[GitHub] [flink] rmetzger commented on a change in pull request #14948: [FLINK-21333][coordination] Add StopWithSavepoint state to declarative scheduler

rmetzger commented on a change in pull request #14948: URL: https://github.com/apache/flink/pull/14948#discussion_r588323345 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java ## @@ -430,14 +430,30 @@ protected void onStart() throws Job

[GitHub] [flink] flinkbot edited a comment on pull request #15062: [FLINK-21549][table-planner-blink] Support json serialization/deserialization for the push-down result of DynamicTableSource and Dyna

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

[GitHub] [flink] rkhachatryan commented on a change in pull request #13845: [FLINK-19801] Adding virtual channels for rescaling unaligned checkpoints.

rkhachatryan commented on a change in pull request #13845: URL: https://github.com/apache/flink/pull/13845#discussion_r588319634 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/VirtualChannelSelector.java ## @@ -0,0 +1,88 @@ +/* + * Licensed t

[GitHub] [flink] flinkbot edited a comment on pull request #15090: [FLINK-21428] Fixes AdaptiveSchedulerSlotSharingITCase

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

[GitHub] [flink] flinkbot edited a comment on pull request #15068: [FLINK-21523][Connectors / Hive] Bug fix: ArrayIndexOutOfBoundsException occurs while run a hive strea…

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

[GitHub] [flink] flinkbot edited a comment on pull request #14868: [FLINK-21326][runtime] Optimize building topology when initializing ExecutionGraph

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

[jira] [Comment Edited] (FLINK-21582) COALESCE not works when cast a variable return null

[ https://issues.apache.org/jira/browse/FLINK-21582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17295872#comment-17295872 ] jibiyr edited comment on FLINK-21582 at 3/5/21, 2:03 PM: - [~twal

[GitHub] [flink] rkhachatryan commented on a change in pull request #13845: [FLINK-19801] Adding virtual channels for rescaling unaligned checkpoints.

rkhachatryan commented on a change in pull request #13845: URL: https://github.com/apache/flink/pull/13845#discussion_r588317629 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/recovery/RecordFilter.java ## @@ -0,0 +1,64 @@ +/* + * Licens

[jira] [Comment Edited] (FLINK-21582) COALESCE not works when cast a variable return null

[ https://issues.apache.org/jira/browse/FLINK-21582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17295872#comment-17295872 ] jibiyr edited comment on FLINK-21582 at 3/5/21, 1:58 PM: - [~twal

[GitHub] [flink] tillrohrmann commented on a change in pull request #14948: [FLINK-21333][coordination] Add StopWithSavepoint state to declarative scheduler

tillrohrmann commented on a change in pull request #14948: URL: https://github.com/apache/flink/pull/14948#discussion_r587605723 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StopWithSavepointOperations.java ## @@ -18,15 +18,22 @@ package org

[jira] [Comment Edited] (FLINK-21432) Web UI -- Error - {"errors":["Service temporarily unavailable due to an ongoing leader election. Please refresh."]}

[ https://issues.apache.org/jira/browse/FLINK-21432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17296020#comment-17296020 ] Bhagi edited comment on FLINK-21432 at 3/5/21, 1:44 PM: Yang Wan

[GitHub] [flink] flinkbot edited a comment on pull request #15095: [FLINK-13554][runtime] Add a timeout for worker registration.

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

[GitHub] [flink] flinkbot edited a comment on pull request #15098: [FLINK-21396][table-common] Add ResolvedCatalog(View/Table) and Catalog(View/Table).of

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

[GitHub] [flink] flinkbot edited a comment on pull request #15093: [FLINK-21401] Consolidate JobGraph generation to properly instantiate streaming and batch JobGraphs

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

[GitHub] [flink] flinkbot edited a comment on pull request #15062: [FLINK-21549][table-planner-blink] Support json serialization/deserialization for the push-down result of DynamicTableSource and Dyna

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

[GitHub] [flink] flinkbot edited a comment on pull request #15019: [DRAFT][FLINK-21400] Store attempt numbers outside ExecutionGraph

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

[GitHub] [flink] flinkbot edited a comment on pull request #14868: [FLINK-21326][runtime] Optimize building topology when initializing ExecutionGraph

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

[jira] [Comment Edited] (FLINK-21432) Web UI -- Error - {"errors":["Service temporarily unavailable due to an ongoing leader election. Please refresh."]}

[ https://issues.apache.org/jira/browse/FLINK-21432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17296020#comment-17296020 ] Bhagi edited comment on FLINK-21432 at 3/5/21, 1:35 PM: Yang Wan

[jira] [Commented] (FLINK-21432) Web UI -- Error - {"errors":["Service temporarily unavailable due to an ongoing leader election. Please refresh."]}

[ https://issues.apache.org/jira/browse/FLINK-21432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17296020#comment-17296020 ] Bhagi commented on FLINK-21432: --- Yang Wang Thanks alotr for the support and giving accurat

[jira] [Updated] (FLINK-21432) Web UI -- Error - {"errors":["Service temporarily unavailable due to an ongoing leader election. Please refresh."]}

[ https://issues.apache.org/jira/browse/FLINK-21432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bhagi updated FLINK-21432: -- Attachment: image-2021-03-05-19-03-56-809.png > Web UI -- Error - {"errors":["Service temporarily unavailable

[GitHub] [flink] JackWangCS commented on pull request #14841: [FLINK-21232][YARN][Common] Introduce pluggable Hadoop delegation token providers

JackWangCS commented on pull request #14841: URL: https://github.com/apache/flink/pull/14841#issuecomment-791421666 Hi @lirui-apache, thanks for your comment. When implementing this PoC, I also want to support properties dynamically. But in some cases, the delegation tokens are obtained be

[GitHub] [flink] rmetzger commented on a change in pull request #15093: [FLINK-21401] Consolidate JobGraph generation to properly instantiate streaming and batch JobGraphs

rmetzger commented on a change in pull request #15093: URL: https://github.com/apache/flink/pull/15093#discussion_r588229663 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/entrypoint/component/FileJobGraphRetrieverTest.java ## @@ -67,7 +68,11 @@ public stat

[GitHub] [flink] flinkbot edited a comment on pull request #15097: [FLINK-21506] [mesos] Option for mesos task user

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

[GitHub] [flink] flinkbot commented on pull request #15098: [FLINK-21396][table-common] Add ResolvedCatalog(View/Table) and Catalog(View/Table).of

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

[GitHub] [flink] flinkbot edited a comment on pull request #15096: [FLINK-21396][table-common] Improve usability of new schema hierarchy

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

[GitHub] [flink] flinkbot edited a comment on pull request #15093: [FLINK-21401] Consolidate JobGraph generation to properly instantiate streaming and batch JobGraphs

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

[GitHub] [flink] flinkbot edited a comment on pull request #15075: [FLINK-21525] Move scheduler benchmarks to Flink and add unit tests

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

  1   2   3   >