Re: Example Flink SQL fromDataStream watermark code not showing *rowtime*

2022-11-27 Thread Dan Hill
I figured this out. I get this behavior because I was running the code in a minicluster test that defaulted to batch. I switched to streaming and it renders "*ROWTIME*". On Fri, Nov 25, 2022 at 11:51 PM Dan Hill wrote: > Hi. I copied the Flink code from this page. My printSchema() does not >

Example Flink SQL fromDataStream watermark code not showing *rowtime*

2022-11-25 Thread Dan Hill
Hi. I copied the Flink code from this page. My printSchema() does not contain **ROWTIME** in the output. I'm running Flink v1.14.4. https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/dev/table/data_stream_api/ public static class User {...} DataStream dataStream = env.f