[ https://issues.apache.org/jira/browse/FLINK-29498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618378#comment-17618378 ]
Eric Xiao commented on FLINK-29498: ----------------------------------- As discussed in the [slack thread|https://apache-flink.slack.com/archives/C03G7LJTS2G/p1663957561957419] I am eager to contribute the Scala util classes :). Should we assign the Jira ticket to me (Not sure how to do that)? > Flink Async I/O Retry Strategies Do Not Work for Scala AsyncDataStream API > -------------------------------------------------------------------------- > > Key: FLINK-29498 > URL: https://issues.apache.org/jira/browse/FLINK-29498 > Project: Flink > Issue Type: Bug > Components: API / Scala > Affects Versions: 1.15.2 > Reporter: Eric Xiao > Priority: Minor > > We are using the async I/O to make HTTP calls and one of the features we > wanted to leverage was the retries, so we pulled the newest commit: > [http://github.com/apache/flink/pull/19983] into our internal Flink fork. > When I try calling the function {{AsyncDataStream.unorderedWaitWithRetry}} > from the scala API I with a retry strategy from the java API I get an error > as {{unorderedWaitWithRetry}} expects a scala retry strategy. The problem is > that retry strategies were only implemented in java and not Scala in this PR: > [http://github.com/apache/flink/pull/19983]. > > Here is some of the code to reproduce the error: > {code:java} > import org.apache.flink.streaming.api.scala.AsyncDataStream > import org.apache.flink.streaming.util.retryable.{AsyncRetryStrategies => > JAsyncRetryStrategies} > val javaAsyncRetryStrategy = new > JAsyncRetryStrategies.FixedDelayRetryStrategyBuilder[Int](3, 100L) > .build() > val data = AsyncDataStream.unorderedWaitWithRetry( > source, > asyncOperator, > pipelineTimeoutInMs, > TimeUnit.MILLISECONDS, > javaAsyncRetryStrategy > ){code} -- This message was sent by Atlassian Jira (v8.20.10#820010)