yeezychao commented on issue #10219: URL: https://github.com/apache/iceberg/issues/10219#issuecomment-2076423855
@pvary Thank you for your reply. I understand what you mean and I have also read the doc. However, we want to implement a function similar to this [demo](https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/dev/table/timezone/#event-time-attribute-on-timestamp) and need to use flink sql for _TUMBLE_ window aggregation. If you run window calculations by specifying the watermark field through options, I will get an exception. `org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: Window aggregate can only be defined over a time attribute column, but TIMESTAMP(3) encountered.`Because it is not defined by _WATERMARK FOR rowtime_column_name AS watermark_strategy_expression_ Therefore, I think this implementation can only be used under Flink Data StreamAPI, Table&SQL API are not supported yet. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
