Eric Xiao created FLINK-29498:
---------------------------------
Summary: 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
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.
{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)
