[ https://issues.apache.org/jira/browse/FLINK-29498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635258#comment-17635258 ]
Yun Gao commented on FLINK-29498: --------------------------------- Merged on master via d426489c9e5c634e2eec8fde6c71356700b7d4b2. > 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.3 > Reporter: Eric Xiao > Assignee: Eric Xiao > Priority: Minor > Labels: pull-request-available > > 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)