Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-17108

Exception: Cannot determine simple type name "com"

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Major
    • Resolution: Duplicate
    • Affects Version/s: 1.10.0
    • Fix Version/s: None
    • Component/s: Table SQL / Planner
    • Labels:
      None

      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")
       }
      }
      

       

       

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                Unassigned
                Reporter:
                xiemeilong xiemeilong
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: