Flink: org.apache.flink.types.Row: не удается разрешить ссылку ROW с такой подписью - PullRequest
0 голосов
/ 01 ноября 2018

Когда я использую flink и создаю объект Row, я сталкиваюсь с такой ошибкой:

package scalatest    
import org.apache.flink.api.common.typeinfo.TypeInformation
import org.apache.flink.table.api.Types
import org.apache.flink.types.Row    
object InitRowObj {
  // ok
  val row_field :TypeInformation[Row]= Types.ROW(Types.INT)
  // error: cannot resolve reference ROW with such signature
  //val row_field = Types.ROW(Array("name", "number"), Array(Types.STRING, Types.INT))
}

Почему?

...