Re: [PR] [FLINK-33354][runtime] Cache TaskInformation and JobInformation to avoid deserializing duplicate big objects [flink]

2023-11-06 Thread via GitHub
1996fanrui merged PR #23599: URL: https://github.com/apache/flink/pull/23599 -- 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:

Re: [PR] [FLINK-33354][runtime] Cache TaskInformation and JobInformation to avoid deserializing duplicate big objects [flink]

2023-11-06 Thread via GitHub
huwh commented on code in PR #23599: URL: https://github.com/apache/flink/pull/23599#discussion_r1384389582 ## flink-runtime/src/main/java/org/apache/flink/runtime/deployment/TaskDeploymentDescriptor.java: ## @@ -253,13 +274,19 @@ public void loadBigData(

Re: [PR] [FLINK-33354][runtime] Cache TaskInformation and JobInformation to avoid deserializing duplicate big objects [flink]

2023-11-05 Thread via GitHub
1996fanrui commented on code in PR #23599: URL: https://github.com/apache/flink/pull/23599#discussion_r1382890456 ## flink-runtime/src/main/java/org/apache/flink/runtime/deployment/TaskDeploymentDescriptor.java: ## @@ -253,13 +274,19 @@ public void loadBigData(

Re: [PR] [FLINK-33354][runtime] Cache TaskInformation and JobInformation to avoid deserializing duplicate big objects [flink]

2023-11-05 Thread via GitHub
huwh commented on code in PR #23599: URL: https://github.com/apache/flink/pull/23599#discussion_r1382863857 ## flink-runtime/src/main/java/org/apache/flink/runtime/deployment/TaskDeploymentDescriptor.java: ## @@ -253,13 +274,19 @@ public void loadBigData(

Re: [PR] [FLINK-33354][runtime] Cache TaskInformation and JobInformation to avoid deserializing duplicate big objects [flink]

2023-10-30 Thread via GitHub
1996fanrui commented on code in PR #23599: URL: https://github.com/apache/flink/pull/23599#discussion_r1376013241 ## flink-runtime/src/main/java/org/apache/flink/runtime/util/DefaultGroupCache.java: ## @@ -0,0 +1,163 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

Re: [PR] [FLINK-33354][runtime] Cache TaskInformation and JobInformation to avoid deserializing duplicate big objects [flink]

2023-10-30 Thread via GitHub
RocMarshal commented on code in PR #23599: URL: https://github.com/apache/flink/pull/23599#discussion_r1375961136 ## flink-runtime/src/main/java/org/apache/flink/runtime/util/DefaultGroupCache.java: ## @@ -0,0 +1,163 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

Re: [PR] [FLINK-33354][runtime] Cache TaskInformation and JobInformation to avoid deserializing duplicate big objects [flink]

2023-10-30 Thread via GitHub
1996fanrui commented on PR #23599: URL: https://github.com/apache/flink/pull/23599#issuecomment-1784821304 Hi @huwh , would you mind helping take a look this PR in your free time as well? This improvement is totally similar with FLINK-32386 is contributed by you, and this PR

Re: [PR] [FLINK-33354][runtime] Cache TaskInformation and JobInformation to avoid deserializing duplicate big objects [flink]

2023-10-30 Thread via GitHub
1996fanrui commented on PR #23599: URL: https://github.com/apache/flink/pull/23599#issuecomment-1784639173 Hi @pnowojski @RocMarshal , would you mind helping take a look this PR in your free time? Thanks a lot -- This is an automated message from the Apache Git Service. To respond to the

Re: [PR] [FLINK-33354][runtime] Cache TaskInformation and JobInformation to avoid deserializing duplicate big objects [flink]

2023-10-26 Thread via GitHub
flinkbot commented on PR #23599: URL: https://github.com/apache/flink/pull/23599#issuecomment-1780625586 ## CI report: * 2cd1a297d97a52d9778a430d1f9d887aff9bab63 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`