Re: [PR] [FLINK-34987][state] Introduce Internal State for Async State API [flink]

2024-04-17 Thread via GitHub
masteryhx closed pull request #24651: [FLINK-34987][state] Introduce Internal State for Async State API URL: https://github.com/apache/flink/pull/24651 -- 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

Re: [PR] [FLINK-34987][state] Introduce Internal State for Async State API [flink]

2024-04-17 Thread via GitHub
masteryhx commented on PR #24651: URL: https://github.com/apache/flink/pull/24651#issuecomment-2060873955 Rebased again. -- 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

Re: [PR] [FLINK-34987][state] Introduce Internal State for Async State API [flink]

2024-04-17 Thread via GitHub
masteryhx commented on PR #24651: URL: https://github.com/apache/flink/pull/24651#issuecomment-2060813581 @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

Re: [PR] [FLINK-34987][state] Introduce Internal State for Async State API [flink]

2024-04-16 Thread via GitHub
masteryhx commented on PR #24651: URL: https://github.com/apache/flink/pull/24651#issuecomment-2060251285 Rebased master. I will merge it after the CI is green. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

Re: [PR] [FLINK-34987][state] Introduce Internal State for Async State API [flink]

2024-04-15 Thread via GitHub
fredia commented on code in PR #24651: URL: https://github.com/apache/flink/pull/24651#discussion_r1565354167 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/InternalKeyedState.java: ## @@ -0,0 +1,81 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

Re: [PR] [FLINK-34987][state] Introduce Internal State for Async State API [flink]

2024-04-15 Thread via GitHub
fredia commented on code in PR #24651: URL: https://github.com/apache/flink/pull/24651#discussion_r1565352484 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/StateDescriptor.java: ## @@ -0,0 +1,166 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

Re: [PR] [FLINK-34987][state] Introduce Internal State for Async State API [flink]

2024-04-15 Thread via GitHub
masteryhx commented on code in PR #24651: URL: https://github.com/apache/flink/pull/24651#discussion_r1565315084 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/InternalKeyedState.java: ## @@ -0,0 +1,81 @@ +/* + * Licensed to the Apache Software Foundation

Re: [PR] [FLINK-34987][state] Introduce Internal State for Async State API [flink]

2024-04-15 Thread via GitHub
masteryhx commented on code in PR #24651: URL: https://github.com/apache/flink/pull/24651#discussion_r1565310323 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/StateDescriptor.java: ## @@ -0,0 +1,166 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

Re: [PR] [FLINK-34987][state] Introduce Internal State for Async State API [flink]

2024-04-15 Thread via GitHub
masteryhx commented on code in PR #24651: URL: https://github.com/apache/flink/pull/24651#discussion_r1565293565 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/StateDescriptor.java: ## @@ -0,0 +1,167 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

Re: [PR] [FLINK-34987][state] Introduce Internal State for Async State API [flink]

2024-04-14 Thread via GitHub
fredia commented on code in PR #24651: URL: https://github.com/apache/flink/pull/24651#discussion_r1565164680 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/StateDescriptor.java: ## @@ -0,0 +1,166 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

Re: [PR] [FLINK-34987][state] Introduce Internal State for Async State API [flink]

2024-04-14 Thread via GitHub
Zakelly commented on code in PR #24651: URL: https://github.com/apache/flink/pull/24651#discussion_r1565167042 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/StateDescriptor.java: ## @@ -0,0 +1,167 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

Re: [PR] [FLINK-34987][state] Introduce Internal State for Async State API [flink]

2024-04-14 Thread via GitHub
masteryhx commented on code in PR #24651: URL: https://github.com/apache/flink/pull/24651#discussion_r1565160755 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/StateDescriptor.java: ## @@ -0,0 +1,167 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

Re: [PR] [FLINK-34987][state] Introduce Internal State for Async State API [flink]

2024-04-14 Thread via GitHub
Zakelly commented on code in PR #24651: URL: https://github.com/apache/flink/pull/24651#discussion_r1565148947 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/InternalKeyedState.java: ## @@ -0,0 +1,81 @@ +/* + * Licensed to the Apache Software Foundation (ASF)