[GitHub] [flink] gaoyunhaii commented on a diff in pull request #20147: [FLINK-27524][datastream] Introduce cache API to DataStream

gaoyunhaii commented on code in PR #20147: URL: https://github.com/apache/flink/pull/20147#discussion_r935436250 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamGraphGeneratorTest.java: ## @@ -880,6 +889,125 @@ public void

[GitHub] [flink] gaoyunhaii commented on a diff in pull request #20147: [FLINK-27524][datastream] Introduce cache API to DataStream

gaoyunhaii commented on code in PR #20147: URL: https://github.com/apache/flink/pull/20147#discussion_r929639303 ## flink-clients/src/main/java/org/apache/flink/client/program/ClusterClient.java: ## @@ -184,4 +188,24 @@ CompletableFuture triggerSavepoint( */

[GitHub] [flink] gaoyunhaii commented on a diff in pull request #20147: [FLINK-27524][datastream] Introduce cache API to DataStream

gaoyunhaii commented on code in PR #20147: URL: https://github.com/apache/flink/pull/20147#discussion_r925041477 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/CacheTransformation.java: ## @@ -0,0 +1,96 @@ +/* + * Licensed to the Apache