其中一个表的KSQL表时间戳未按预期填充

Question

我正在构建一个类似下面的ktable，其中timestamp是底层流中的一列。但在创建之后，rowtime并没有填充时间戳列值。

CREATE TABLE MTL_PARAMETERS_TT WITH (KAFKA_TOPIC='MTL_PARAMETERS_TT', KEY_FORMAT='avro', PARTITIONS=5, REPLICAS=3, timestamp = 'CREATION_DATE', VALUE_FORMAT='avro') AS SELECT
CAST(MTL_PARAMETERS.ORGANIZATION_ID AS INTEGER) ORGANIZATION_ID,
LATEST_BY_OFFSET(MTL_PARAMETERS.ORGANIZATION_CODE) ORGANIZATION_CODE,
LATEST_BY_OFFSET(MTL_PARAMETERS.CREATION_DATE) CREATION_DATE
FROM MTL_PARAMETERS MTL_PARAMETERS
GROUP BY CAST(MTL_PARAMETERS.ORGANIZATION_ID AS INTEGER)
EMIT CHANGES;```

Answer 1

很可能是源MTL_PARAMETERS的列。CREATION_DATE不符合默认的ksqlDB时间戳格式。

要检查正确的ksqlDB时间戳格式，您可以尝试

选择FROM_UNIXTIME(行时间(

在任何流或表上。