[GitHub] [flink] ericxiao251 commented on a diff in pull request #21077: [FLINK-29498] Add Scala Async Retry Strategies and ResultPredicates Helper Classes

ericxiao251 commented on code in PR #21077: URL: https://github.com/apache/flink/pull/21077#discussion_r1019305987 ## flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/async/AsyncRetryStrategies.scala: ## @@ -0,0 +1,114 @@ +/* + * Licensed to the Apache S

[GitHub] [flink] ericxiao251 commented on a diff in pull request #21077: [FLINK-29498] Add Scala Async Retry Strategies and ResultPredicates Helper Classes

ericxiao251 commented on code in PR #21077: URL: https://github.com/apache/flink/pull/21077#discussion_r1019275792 ## flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/async/AsyncRetryStrategies.scala: ## @@ -0,0 +1,114 @@ +/* + * Licensed to the Apache S

[GitHub] [flink] ericxiao251 commented on a diff in pull request #21077: [FLINK-29498] Add Scala Async Retry Strategies and ResultPredicates Helper Classes

ericxiao251 commented on code in PR #21077: URL: https://github.com/apache/flink/pull/21077#discussion_r1019260307 ## docs/content/docs/dev/datastream/operators/asyncio.md: ## @@ -140,8 +140,8 @@ DataStream> resultStream = // create an async retry strategy via utility class or