[hotfix] Fix Scala 2.12 build

5f81a36a · Aljoscha Krettek · c59e8945 · 5f81a36a
显示空白变更内容
内联并排

Showing with 1 addition and 1 deletion

flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/utils/testTableSinks.scala ...t/scala/org/apache/flink/table/utils/testTableSinks.scala +1 -1

未找到文件。
--- a/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/utils/testTableSinks.scala
+++ b/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/utils/testTableSinks.scala
@@ -70,7 +70,7 @@ final class TestingOverwritableTableSink private (

  override def getConsumedDataType: DataType = getTableSchema.toRowDataType

-  def getTableSchema: TableSchema = {
+  override def getTableSchema: TableSchema = {
    val dataTypes: Array[DataType] = fieldTypes.map(TypeConversions.fromLegacyInfoToDataType)
    TableSchema.builder().fields(fieldNames, dataTypes).build()
  }