title: flink.api.table.TableException: Type is not supported
body: <p>I´m trying to use Flink Table API in scala. No errors in compiling time, but qhen i´m running the job in my flink cluster: <code>flink.api.table.TableException: Type is not supported:&lt;GenericType&lt;java.lang.Object&gt;</code></p>
  
  <p>My maven dependencies:</p>
  
  <pre><code>&lt;dependency&gt;
      &lt;groupId&gt;org.apache.flink&lt;/groupId&gt;
      &lt;artifactId&gt;flink-scala_2.11&lt;/artifactId&gt;
      &lt;version&gt;${flink.version}&lt;/version&gt;
  &lt;/dependency&gt;
  &lt;dependency&gt;
      &lt;groupId&gt;org.apache.flink&lt;/groupId&gt;
      &lt;artifactId&gt;flink-streaming-scala_2.11&lt;/artifactId&gt;
      &lt;version&gt;${flink.version}&lt;/version&gt;
  &lt;/dependency&gt;
  &lt;dependency&gt;
      &lt;groupId&gt;org.apache.flink&lt;/groupId&gt;
      &lt;artifactId&gt;flink-table_2.11&lt;/artifactId&gt;
      &lt;version&gt;1.1-SNAPSHOT&lt;/version&gt;
  &lt;/dependency&gt;
  </code></pre>
  
  <p>My imports:</p>
  
  <pre><code>import org.apache.flink.streaming.api.scala._
  import org.apache.flink.api.scala.table._
  import org.apache.flink.api.table.{Row, Table, TableEnvironment}
  </code></pre>
  
  <p>My code:</p>
  
  <pre><code>// 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
  </code></pre>
  
  <p><strong>Update</strong>: I think it could be about Flink version(1.0.3), because when i do something like that:</p>
  
  <pre><code>val inputTable = odo.toTable(tableEnv, 'ts, 'ty, 'vl, 'dv)
  val result = inputTable.select('dv,'vl.sum).where('dv == 111)
  result.toDataStream[Row].print()
  </code></pre>
  
  <p>I have another exception: <code>org.apache.flink.api.table.TableException: Aggregate on stream tables is currently not supported.</code></p>
  
  <p>Any help is appreciated. Thank you.</p>