[jira] [Closed] (FLINK-22968) Improve exception message when using toAppendStream[String]

["Timo Walther (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Timo Walther closed FLINK-22968.
--------------------------------
    Resolution: Won't Fix

Let's not put more effort in deprecated APIs. 

> Improve exception message when using toAppendStream[String]
> -----------------------------------------------------------
>
>                 Key: FLINK-22968
>                 URL: https://issues.apache.org/jira/browse/FLINK-22968
>             Project: Flink
>          Issue Type: Bug
>          Components: Table SQL / API
>    Affects Versions: 1.12.3, 1.13.1
>         Environment: {color:#FF0000}*Flink-1.13.1 and Flink-1.12.1*{color}
>            Reporter: DaChun
>            Assignee: Nicholas Jiang
>            Priority: Major
>         Attachments: test.scala, this_error.txt
>
>
> {code:scala}
> package com.bytedance.one
> import org.apache.flink.streaming.api.scala.{DataStream, StreamExecutionEnvironment}
> import org.apache.flink.table.api.Table
> import org.apache.flink.table.api.bridge.scala.StreamTableEnvironment
> import org.apache.flink.api.scala._
> object test {
>   def main(args: Array[String]): Unit = {
>     val env: StreamExecutionEnvironment = StreamExecutionEnvironment
>       .createLocalEnvironmentWithWebUI()
>     val stream: DataStream[String] = env.readTextFile("data/wc.txt")
>     val tableEnvironment: StreamTableEnvironment = StreamTableEnvironment.create(env)
>     val table: Table = tableEnvironment.fromDataStream(stream)
>     tableEnvironment.createTemporaryView("wc", table)
>     val res: Table = tableEnvironment.sqlQuery("select * from wc")
>     tableEnvironment.toAppendStream[String](res).print()
>     env.execute("test")
>   }
> }
> {code}
> When I run the program, the error is as follows:
> The specific error is in this_ error.txt,
> But the error prompts me to write an issue
> Caused by: org.apache.flink.api.common.InvalidProgramException: Table program cannot be compiled. This is a bug. Please file an issue.
> It's very easy to read a stream and convert it into a table mode. The generic type is string
> Then an error is reported. The code is in test. Scala and the error is in this_ error.txt
> But I try to create an entity class by myself, and then assign generics to this entity class, and then I can pass it normally,
> Or with row type, do you have to create your own entity class, not with string type?
> h3. Summary
> We should improve the exception message a bit, we can throw the given type (String) is not allowed in {{toAppendStream}}.
>  
>  
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)