[FLINK-14105] Make flink-runtime scala-free

• Type: Improvement
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 1.14.0
• Component/s: Runtime / Configuration, Runtime / Coordination
• Labels: auto-deprioritized-major

Release Note

Flink's akka dependency is now loaded with a separate classloader and no longer accessible from the outside.
Resulting from that various modules, most prominently flink-runtime, no longer have a scala suffix in their artifactId.

• Assignee: Chesnay Schepler
• Reporter: Zili Chen
• Created: 17/Sep/19 12:54
• Updated: 13/Jul/21 16:07
• Resolved: 13/Jul/21 16:07

Description

As the consensus among our community(please link dedicated thread if there is) we keep in mind that flink-runtime will be eventually scala-free. It is because of maintenance concerns, release concerns and so on.

This is an umbrella issue to track all efforts that towards a scala-free flink-runtime.

Issue Links

• blocks: FLINK-19168 Upgrade Kafka client version beyond 2.5.0
• is blocked by: FLINK-23118 Drop Mesos support

Sub-Tasks

• Use TimeUtils to parse duration configs: Resolved
• Enable TimeUtils to parse all time units labels supported by scala Duration: Resolved
• Remove unused BootstrapTools#generateTaskManagerConfiguration: Resolved
• Make TimeUtils able to parse duration string with plural form labels: Resolved
• Remove unnecessary scala Duration usages in flink-runtime: Resolved
• Port TestingUtils to Java: Closed
• Port Tasks to Java: Closed
• Remove unused ScalaUtils/TestingMessages: Closed
• Use Optional in NettyBufferPool: Closed
• Move SSLUtils#is*Enabled to SecurityOptions: Closed
• Replace AkkaUtils#get*Timeout*: Closed
• Move chill dependency to flink-scala: Closed
• Load AkkaRpcService through separate class loader: Closed
• Move FutureUtils.toJava into separate class: Closed
• Split BootstrapTools: Closed
• Move Executors#directExecutorContext to AkkaFutureUtils: Closed
• Split AkkaRpcServiceUtils: Closed
• Isolate RpcConnectionTest from runtime implementations: Closed
• Move ExecutorThreadFactory to flink-core: Closed
• Consolidate FutureUtils to flink-core: Closed
• AddressResolution should be a top-level class: Closed
• Add flink-rpc-core module: Closed
• Add flink-rpc-akka module: Closed
• Add RpcSystem abstraction: Closed
• Bump Akka to 2.6: Closed
• RestServerEndpoint references on netty 3: Closed
• Remove scala from plugin parent-first patterns: Closed