flink.api.table.TableException：型がサポートされていません

Question

私はスカラでFlink Table APIを使用しようとしています。 flink.api.table.TableException: Type is not supported:<GenericType<java.lang.Object>

私のMavenの依存関係：

<dependency> 
    <groupId>org.apache.flink</groupId> 
    <artifactId>flink-scala_2.11</artifactId> 
    <version>${flink.version}</version> 
</dependency> 
<dependency> 
    <groupId>org.apache.flink</groupId> 
    <artifactId>flink-streaming-scala_2.11</artifactId> 
    <version>${flink.version}</version> 
</dependency> 
<dependency> 
    <groupId>org.apache.flink</groupId> 
    <artifactId>flink-table_2.11</artifactId> 
    <version>1.1-SNAPSHOT</version> 
</dependency> 

マイ輸入：

import org.apache.flink.streaming.api.scala._ 
import org.apache.flink.api.scala.table._ 
import org.apache.flink.api.table.{Row, Table, TableEnvironment} 

マイコード：

を時間をコンパイルしますが、qhen - 私は私のFLINKクラスタでジョブを実行中にエラーなし

// odo[(Long,String,Double,Long)] 
val inputTable = odo.toTable(tableEnv,'ts,'ty, 'vl, 'dv) 
val resultStream: Table = inputTable.where('ty === "Odometer").select('dv) 
resultStream.toDataStream[Row].print 

更新：私はそれが可能だと思います私はそのような何かをするときので、FLINKバージョン（1.0.3）についても：org.apache.flink.api.table.TableException: Aggregate on stream tables is currently not supported.

すべてのヘルプは高く評価されています

val inputTable = odo.toTable(tableEnv, 'ts, 'ty, 'vl, 'dv) 
val result = inputTable.select('dv,'vl.sum).where('dv == 111) 
result.toDataStream[Row].print() 

私は別の例外を持っています。ありがとうございました。

Answer 1

FlinkのテーブルAPIは、GenericTypeを含むフィールドを1.1-SNAPSHOTにはサポートしていません。この機能を実装するPull Requestがあります。 Flink 1.1リリースに含まれる可能性は非常に高いです。

2番目の例外について：例外は基本的には自己説明的です。これまでのストリームでは集約はできません。ただし、StreamSQLはdevelopmentです。