I’m having a problem using ArrayList in Scala . The code is below import org.apache.flink.core.fs._ import org.apache.flink.streaming.api._ import org.apache.flink.streaming.api.scala._ import org.apache.flink.table.api._ import org.apache.flink.table.api.scala._ import org.apache.flink.table.sinks._ import org.apache.http.HttpHost import org.slf4j.LoggerFactory
import java.util.ArrayList object Job { val httpHosts = new ArrayList[HttpHost] httpHosts.add(new HttpHost("samwise.local", 9200, "http")) ….. } Scala refuses to recognise ArrayList. The IDE InteliJ likewise flags java.util as not existing, even though it recognises ArrayList and suggest auto-insertion of the import java.utils.ArrayList statement. The compilation errors are [error] ………………/src/main/scala/org/example/Job.scala:30:13: object util is not a member of package org.apache.flink.table.api.java [error] import java.util.ArrayList [error] ^ [error] ………………/src/main/scala/org/example/Job.scala:34:23: not found: type ArrayList [error] val httpHosts = new ArrayList[HttpHost] [error] ^ [error] two errors found [error] (Compile / compileIncremental) Compilation failed Without the ArrayList reference the code compiles with no errors. The sbt build file, if it helps is, resolvers in ThisBuild ++= Seq("Apache Development Snapshot Repository" at "https://repository.apache.org/content/repositories/snapshots/", Resolver.mavenLocal) name := "Flink MultiChannel Project" version := "0.1-SNAPSHOT" organization := "org.example" scalaVersion in ThisBuild := "2.11.0" val flinkVersion = "1.8.1" val flinkDependencies = Seq( "org.apache.flink" %% "flink-scala" % flinkVersion , "org.apache.flink" %% "flink-table" % "1.7.2" , "org.apache.flink" %% "flink-connector-elasticsearch" % flinkVersion, "org.apache.flink" %% "flink-streaming-scala" % flinkVersion, "org.apache.httpcomponents" % "httpclient" % "4.5.10", "org.apache.httpcomponents" % "httpcore" % "4.4.11") // https://mvnrepository.com/artifact/org.apache.httpcomponents/httpcore lazy val root = (project in file(".")). settings( libraryDependencies ++= flinkDependencies) mainClass in assembly := Some("org.example.Job") // make run command include the provided dependencies run in Compile := Defaults.runTask(fullClasspath in Compile, mainClass in (Compile, run), runner in (Compile, run)) // exclude Scala library from assembly assemblyOption in assembly := (assemblyOption in assembly).value.copy(includeScala = false) TIA Nick