KSQL持久化查询，不向KSQL表写入数据

Question

我有两个KSQL表，每个表都有相同的键。我正在对它们运行以下查询

CREATE TABLE TEMP1 AS SELECT
b.MFG_DATE,
b.rowtime as bd_rowtime,
s.rowtime as sd_rowtime,
b.EXPIRY_DATE as EXP_DATE,
b.BATCH_NO as BATCH_NO,
s.rowkey as SD_ID
FROM GR_SD4 s
INNER JOIN GR_BD4 b ON b.rowkey = s.rowkey;
PARTITION BY s.rowkey;

结果表不会填充数据，但是当我单独运行select查询时，它会填充数据。我很困惑是什么原因导致这个表没有被数据填充。

Answer 1

问题可能与查询中的PARTITION BY子句有关。由于要连接两个表，因此生成的表将有一个复合主键(rowkey, s.rowkey)。应该更新PARTITION BY子句以反映这一点，即PARTITION BY rowkey, s.w rowkey。这将确保数据被正确分区，并且可以插入到表中。