[
https://issues.apache.org/jira/browse/FLINK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17363608#comment-17363608
]
Nicholas Jiang edited comment on FLINK-22968 at 6/16/21, 11:55 AM:
-------------------------------------------------------------------
[~jark], If the 'toAppendStream' is deprecated, there is no need to improve the
message for this method and this issue could be closed.
[~twalthr], what do you think about?
was (Author: nicholasjiang):
[~jark], If the 'toAppendStream' is deprecated, there is no need to improve the
message for this method and this issue could be closed.
[~twalthr], what do you think about?
> 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)
