This is an automated email from the ASF dual-hosted git repository. snuyanzin pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit f77b82156870c28c7d6dd4e01047d4a9620eeb87 Author: Sergey Nuyanzin <[email protected]> AuthorDate: Sun Jun 7 15:00:09 2026 +0200 [hotfix][tests] Replace deprecated `JavaConversions` in `TableTestBase` --- .../planner/plan/stream/sql/ProcessTableFunctionTest.java | 10 ++++++---- .../org/apache/flink/table/planner/utils/TableTestBase.scala | 9 ++++----- 2 files changed, 10 insertions(+), 9 deletions(-) diff --git a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/stream/sql/ProcessTableFunctionTest.java b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/stream/sql/ProcessTableFunctionTest.java index 118a753556a..411b6fc2b75 100644 --- a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/stream/sql/ProcessTableFunctionTest.java +++ b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/stream/sql/ProcessTableFunctionTest.java @@ -79,7 +79,7 @@ import static org.apache.flink.table.api.Expressions.row; import static org.assertj.core.api.Assertions.assertThatThrownBy; /** Tests for the type inference and planning part of {@link ProcessTableFunction}. */ -public class ProcessTableFunctionTest extends TableTestBase { +class ProcessTableFunctionTest extends TableTestBase { private TableTestUtil util; @@ -119,9 +119,11 @@ public class ProcessTableFunctionTest extends TableTestBase { @Test void testFunctionWithMultipleTableArgs() { util.addTemporarySystemFunction("f", MultiInputFunction.class); - util.tableEnv().executeSql("CREATE VIEW v AS SELECT * FROM f(" - + "in1 => TABLE t PARTITION BY name," - + "in2 => TABLE t PARTITION BY name)"); + util.tableEnv() + .executeSql( + "CREATE VIEW v AS SELECT * FROM f(" + + "in1 => TABLE t PARTITION BY name," + + "in2 => TABLE t PARTITION BY name)"); util.verifyRelPlan("SELECT * FROM v"); } diff --git a/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/utils/TableTestBase.scala b/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/utils/TableTestBase.scala index 70ad0d426d7..6126e67a946 100644 --- a/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/utils/TableTestBase.scala +++ b/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/utils/TableTestBase.scala @@ -82,7 +82,6 @@ import org.apache.flink.util.jackson.JacksonMapperFactory import _root_.java.math.{BigDecimal => JBigDecimal} import _root_.java.util -import _root_.scala.collection.JavaConversions._ import _root_.scala.io.Source import org.apache.calcite.avatica.util.TimeUnit import org.apache.calcite.rel.RelNode @@ -1168,7 +1167,7 @@ abstract class TableTestUtilBase(test: TableTestBase, isStreamingMode: Boolean) withDuplicateChanges: Boolean): Unit = { val testStmtSet = stmtSet.asInstanceOf[StatementSetImpl[_]] - val relNodes = testStmtSet.getOperations.map(getPlanner.translateToRel) + val relNodes = testStmtSet.getOperations.asScala.map(getPlanner.translateToRel) if (relNodes.isEmpty) { throw new TableException( "No output table have been created yet. " + @@ -1523,7 +1522,7 @@ case class StreamTableTestUtil( def buildStreamProgram(firstProgramNameToRemove: String): Unit = { val program = FlinkStreamProgram.buildProgram(tableEnv.getConfig) var startRemove = false - program.getProgramNames.foreach { + program.getProgramNames.asScala.foreach { name => if (name.equals(firstProgramNameToRemove)) { startRemove = true @@ -1576,7 +1575,7 @@ case class BatchTableTestUtil( def buildBatchProgram(firstProgramNameToRemove: String): Unit = { val program = FlinkBatchProgram.buildProgram(tableEnv.getConfig) var startRemove = false - program.getProgramNames.foreach { + program.getProgramNames.asScala.foreach { name => if (name.equals(firstProgramNameToRemove)) { startRemove = true @@ -1961,7 +1960,7 @@ object TableTestUtil { } else if (file.isHidden) { Seq.empty[String] } else { - Files.readAllLines(Paths.get(file.toURI)).toSeq + Files.readAllLines(Paths.get(file.toURI)).asScala } }
