[FLINK-22660] Incorrect flink documentation example

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Not A Problem
• Affects Version/s: 1.13.0
• Component/s: Documentation, Examples
• Assignee: Unassigned
• Reporter: Tejas Budukh
• Created: 13/May/21 20:46
• Updated: 14/May/21 13:15
• Resolved: 14/May/21 13:14

Description

I was trying out examples given here 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 ?