[FLINK-17108] Exception: Cannot determine simple type name "com"

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Duplicate
• Affects Version/s: 1.10.0
• Component/s: Table SQL / Planner
• Assignee: Unassigned
• Reporter: xiemeilong
• Created: 13/Apr/20 06:44
• Updated: 16/Apr/20 06:04
• Resolved: 16/Apr/20 06:04

Description

The below code will throw exception in cluster mode , but not in local mode or when checkpoint disabled.

 

package com.test

import org.apache.flink.streaming.api.scala._
import org.apache.flink.table.api.EnvironmentSettings
import org.apache.flink.table.api.scala.{StreamTableEnvironment, _}
import org.apache.flink.types.Row

case class Test(int:Int)
object Main {
  def main(args: Array[String]) {
    val env = StreamExecutionEnvironment.getExecutionEnvironment
      .enableCheckpointing(32 * 1000)

    val settings = EnvironmentSettings.newInstance()
      .useBlinkPlanner()
      .inStreamingMode().build()
    val tableEnv = StreamTableEnvironment.create(env, settings)

    tableEnv.createTemporaryView("test", env.fromCollection(List(Test(1))))
    val deviceSchemaTable = tableEnv.from("test")
    deviceSchemaTable.toRetractStream[Row]
        .print()
  env.execute("test")
 }
}

 

 

Issue Links

• is duplicated by: FLINK-16662 Blink Planner failed to generate JobGraph for POJO DataStream converting to Table (Cannot determine simple type name)