[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

[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 *

[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

[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

[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:

[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:

[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:

[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:

[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:

[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

[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

[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

[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:

[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 *

[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:

[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:

[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 *

[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:

[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 *

[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:

[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 *

[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 *

[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 *

[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

[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:

[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:

[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

[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

[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

[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:

[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:

[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:

[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:

[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:

[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 *

[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:

[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:

[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:

[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=17296145#comment-17296145 ] Till Rohrmann edited comment on FLINK-21606 at 3/5/21, 4:17 PM: I think

[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=17296145#comment-17296145 ] Till Rohrmann commented on FLINK-21606: --- I think the problem is that Flink does not support

[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=17296105#comment-17296105 ] Till Rohrmann commented on FLINK-21136: --- I like the ideas. The reactive mode needs a slightly

[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:

[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:

[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

[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

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

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

[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=17296087#comment-17296087 ] Till Rohrmann commented on FLINK-19142: --- How would the system behave if we lose two slots (a and

[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:

[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:

[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:

[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:

[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:

[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()

[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=17296073#comment-17296073 ] Matthias commented on FLINK-21588: -- This also applies to your TaskManagers? > unable to create

[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

[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

[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

[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:

[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:

[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:

[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:

[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:

[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

[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=17295872#comment-17295872 ] jibiyr edited comment on FLINK-21582 at 3/5/21, 2:13 PM: - [~twalthr] [~jark] I

[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

[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:

[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

[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:

[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:

[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:

[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=17295872#comment-17295872 ] jibiyr edited comment on FLINK-21582 at 3/5/21, 2:03 PM: - [~twalthr] [~jark] I

[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 @@ +/* + *

[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=17295872#comment-17295872 ] jibiyr edited comment on FLINK-21582 at 3/5/21, 1:58 PM: - [~twalthr] [~jark]  

[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

[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=17296020#comment-17296020 ] Bhagi edited comment on FLINK-21432 at 3/5/21, 1:44 PM: Yang Wang Thanks alot

[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:

[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:

[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:

[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:

[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:

[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:

[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=17296020#comment-17296020 ] Bhagi edited comment on FLINK-21432 at 3/5/21, 1:35 PM: Yang Wang Thanks alot

[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=17296020#comment-17296020 ] Bhagi commented on FLINK-21432: --- Yang Wang Thanks alotr for the support and giving accurate information. I

[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

[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

[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:

[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

[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:

[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:

[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:

  1   2   3   >