如何将包含时间段_ltz的表转换为pyflink 1.15.0中的dataStream？

Question

我使用pyflink 1.15.0的Kinesis连接器读取事件使用源表。 An example of the sorts of data that are in this stream is

请注意，数据流包含许多不同类型的事件，其中“详细信息”字段在不同的事件类型之间完全不同。使用PYFLINK DATASTREAM API对此连接器没有支持，因此我使用表API构建源表。该表看起来像这样：

CREATE TABLE events (
     `id` VARCHAR,
     `source` VARCHAR,
     `account` VARCHAR,
     `region` VARCHAR,
     `detail-type` VARCHAR,
     `detail` VARCHAR,
     `source` VARCHAR,
     `resources` VARCHAR,
     `time` TIMESTAMP(0) WITH LOCAL TIME ZONE,
     WATERMARK FOR `time` as `time` - INTERVAL '30' SECOND,
     PRIMARY KEY (`id`) NOT ENFORCED
) WITH (
...
)

使用：

 table_env.execute_sql(CREATE_STRING_ABOVE)

我想将此表转换为数据流，以便我可以执行一些在DataStream API中更容易执行的处理：

events_stream_table = table_env.from_path('events')

events_stream = table_env.to_data_stream(events_stream_table)

# now do some processing - let's filter by the type of event we get

codebuild_stream = events_stream.filter(
    lambda event: event['source'] == 'aws.codebuild'
)

# now do other stuff on a stream containing only events that are identical in shape
...
# maybe convert back into a Table and perform SQL on the data

当我运行此功能时，我会得到一个例外：

org.apache.flink.table.api.tableException：未支撑的转换 数据类型“时间戳（6）与时区”（转换类别： Java.Time.OffsetDateTime）要输入信息。只有数据类型 起源于类型信息完全支持反向转换。

有人报告了类似的错误在这里。当我在那里尝试建议并用本地时区域 Timestamp（3） timestamp（0）我得到不同的例外：

TypeError：Java类型信息：不支持LocalDateTime pyflink当前。

是否有一种方法可以将此表转换为数据串联（然后再次返回）？我需要在“时间”字段中使用数据作为事件的水印来源。