[FLINK-22948] Scala example for toDataStream does not compile

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.13.1
• Fix Version/s: 1.14.0, 1.13.2
• Component/s: Documentation, Table SQL / API
• Assignee: Timo Walther
• Reporter: David Anderson
• Created: 09/Jun/21 14:39
• Updated: 17/Jun/21 11:21
• Resolved: 17/Jun/21 11:21

Description

The scala example at https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/table/data_stream_api/#examples-for-todatastream does not compile – User.class should be classOf[User].

It would also be better to show the table DDL as

tableEnv.executeSql(
  """
  CREATE TABLE GeneratedTable (
    name STRING,
    score INT,
    event_time TIMESTAMP_LTZ(3),
    WATERMARK FOR event_time AS event_time - INTERVAL '10' SECOND
  )
  WITH ('connector'='datagen')
  """
)