[
https://issues.apache.org/jira/browse/FLINK-22660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-22660.
--------------------------------
Resolution: Not A Problem
Hi [~tejasub], please note that {{Instant}} is mapped to {{TIMESTAMP_LTZ(9)}}
and {{LocalDateTime}} is mapped to {{TIMESTAMP(9)}}. If you update your
{{fromElements}}, your example should work. Also note that there is some known
bug in 1.13 that will be fixed in 1.13.1 that doesn't allow TIMESTAMP_LTZ with
{{SOURCE_WATERMARK}} (see FLINK-22378).
> Incorrect flink documentation example
> -------------------------------------
>
> Key: FLINK-22660
> URL: https://issues.apache.org/jira/browse/FLINK-22660
> Project: Flink
> Issue Type: Bug
> Components: Documentation, Examples
> Affects Versions: 1.13.0
> Reporter: Tejas Budukh
> Priority: Major
>
> I was trying out examples given
> [here|https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/table/data_stream_api/#examples-for-fromdatastream]
> to convert Datastream to Table and one of the example gives out error.
> My code is as follows :
> _StreamExecutionEnvironment env =
> StreamExecutionEnvironment.getExecutionEnvironment();_
> _DataStream<User> dataStream =_
> _env.fromElements(_
> _new User("Alice", 4, Instant.ofEpochMilli(1000)),_
> _new User("Bob", 6, Instant.ofEpochMilli(1001)),_
> _new User("Alice", 10, Instant.ofEpochMilli(1002)))_
>
> _.assignTimestampsAndWatermarks(WatermarkStrategy.<User>forBoundedOutOfOrderness(Duration.ofSeconds(60)));_
> _StreamTableEnvironment tableEnv =
> StreamTableEnvironment.create(env);_
> _Table table =_
> _tableEnv.fromDataStream(_
> _dataStream,_
> _Schema.newBuilder()_
> _.column("event_time", "TIMESTAMP(3)")_
> _.column("name", "STRING")_
> _.column("score", "INT")_
> _.watermark("event_time",
> "SOURCE_WATERMARK()")_
> _.build());_
> _table.printSchema();_
> _table.select($("*")).execute().print();_
> and the error I got is :
> _Caused by: org.codehaus.commons.compiler.CompileException: Line 13, Column
> 103: Cannot cast "java.time.Instant" to "java.time.LocalDateTime"_
> _at
> org.codehaus.janino.UnitCompiler.compileError(UnitCompiler.java:12211)_
> _at
> org.codehaus.janino.UnitCompiler.compileGet2(UnitCompiler.java:5051)_
> _at
> org.codehaus.janino.UnitCompiler.access$8600(UnitCompiler.java:215)_
> _at
> org.codehaus.janino.UnitCompiler$16.visitCast(UnitCompiler.java:4418)_
> _at
> org.codehaus.janino.UnitCompiler$16.visitCast(UnitCompiler.java:4396)_
> _at org.codehaus.janino.Java$Cast.accept(Java.java:4898)_
> _at
> org.codehaus.janino.UnitCompiler.compileGet(UnitCompiler.java:4396)_
> Can somebody help with this ?
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
