[
https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933009#comment-16933009
]
Zijie Lu edited comment on FLINK-14099 at 9/19/19 2:44 AM:
-----------------------------------------------------------
I have tried what you mentioned, but it seems that the timestamp field also
needs to be standard SQL timestamp and the following exception is throwed.
[~jark]
{quote}Exception in thread "main" org.apache.flink.table.api.TableException:
findAndCreateTableSource failed.Exception in thread "main"
org.apache.flink.table.api.TableException: findAndCreateTableSource failed. at
org.apache.flink.table.factories.TableFactoryUtil.findAndCreateTableSource(TableFactoryUtil.java:67)
at
org.apache.flink.table.factories.TableFactoryUtil.findAndCreateTableSource(TableFactoryUtil.java:54)
at
org.apache.flink.table.descriptors.ConnectTableDescriptor.registerTableSource(ConnectTableDescriptor.java:69)
at sql.job.ms.ClickStats.main(ClickStats.java:73)Caused by:
org.apache.flink.table.api.ValidationException: Rowtime attribute 'timestamp'
is not of type SQL_TIMESTAMP. at
org.apache.flink.streaming.connectors.kafka.KafkaTableSourceBase.validateRowtimeAttributeDescriptors(KafkaTableSourceBase.java:313)
at
org.apache.flink.streaming.connectors.kafka.KafkaTableSourceBase.<init>(KafkaTableSourceBase.java:118)
at
org.apache.flink.streaming.connectors.kafka.KafkaTableSource.<init>(KafkaTableSource.java:66)
at
org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactory.createKafkaTableSource(KafkaTableSourceSinkFactory.java:66)
at
org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactoryBase.createStreamTableSource(KafkaTableSourceSinkFactoryBase.java:147)
at
org.apache.flink.table.factories.StreamTableSourceFactory.createTableSource(StreamTableSourceFactory.java:49)
at
org.apache.flink.table.factories.TableFactoryUtil.findAndCreateTableSource(TableFactoryUtil.java:65)
... 3 more
{quote}
was (Author: alfredlu):
I have tried what you mentioned, but it seems that the timestamp field also
needs to be standard SQL timestamp and the following exception is throwed.
{quote}Exception in thread "main" org.apache.flink.table.api.TableException:
findAndCreateTableSource failed.Exception in thread "main"
org.apache.flink.table.api.TableException: findAndCreateTableSource failed. at
org.apache.flink.table.factories.TableFactoryUtil.findAndCreateTableSource(TableFactoryUtil.java:67)
at
org.apache.flink.table.factories.TableFactoryUtil.findAndCreateTableSource(TableFactoryUtil.java:54)
at
org.apache.flink.table.descriptors.ConnectTableDescriptor.registerTableSource(ConnectTableDescriptor.java:69)
at sql.job.ms.ClickStats.main(ClickStats.java:73)Caused by:
org.apache.flink.table.api.ValidationException: Rowtime attribute 'timestamp'
is not of type SQL_TIMESTAMP. at
org.apache.flink.streaming.connectors.kafka.KafkaTableSourceBase.validateRowtimeAttributeDescriptors(KafkaTableSourceBase.java:313)
at
org.apache.flink.streaming.connectors.kafka.KafkaTableSourceBase.<init>(KafkaTableSourceBase.java:118)
at
org.apache.flink.streaming.connectors.kafka.KafkaTableSource.<init>(KafkaTableSource.java:66)
at
org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactory.createKafkaTableSource(KafkaTableSourceSinkFactory.java:66)
at
org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactoryBase.createStreamTableSource(KafkaTableSourceSinkFactoryBase.java:147)
at
org.apache.flink.table.factories.StreamTableSourceFactory.createTableSource(StreamTableSourceFactory.java:49)
at
org.apache.flink.table.factories.TableFactoryUtil.findAndCreateTableSource(TableFactoryUtil.java:65)
... 3 more
{quote}
> SQL supports timestamp in Long
> ------------------------------
>
> Key: FLINK-14099
> URL: https://issues.apache.org/jira/browse/FLINK-14099
> Project: Flink
> Issue Type: New Feature
> Reporter: Zijie Lu
> Priority: Major
>
> The rowtime only supports sql timestamp but not long. Can the rowtime field
> supports long?
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
