我已经从另一个聚合表创建了一个表,但是pull查询似乎不能正常工作,它只对emit changes
或in
子句(至少2个参数)正常工作我使用的是Kubernetes Confluent Helm version 7.5.1
ksql> select custid from AAAAA where custid=15555;
+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
|CUSTID |
+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
Query terminated
ksql> select custid from AAAAA where custid in (15555, 0);
+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
|CUSTID |
+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
|15555 |
Query terminated
ksql> select custid from AAAAA where custid=15555 emit changes limit 1;
+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
|CUSTID |
+----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
|15555 |
Limit Reached
Query terminated
字符串
运行聚合查询时总是生成这个警告,只是一段时间,我假设它正在等待主题创建?
[2023-10-30 10:44:04,596] WARN [Consumer clientId=_confluent-ksql-kafka-sgquery_CTAS_AAAAA_1881-9fb9d9e1-4d97-4747-9146-bd9b74f5ad2f-StreamThread-1-consumer, groupId=_confluent-ksql-kafka-sgquery_CTAS_AAAAA_1881] Error while fetching metadata with correlation id 68 : {_confluent-ksql-kafka-sgquery_CTAS_AAAAA_1881-KTABLE-FK-JOIN-SUBSCRIPTION-REGISTRATION-0000000012-topic=UNKNOWN_TOPIC_OR_PARTITION, _confluent-ksql-kafka-sgquery_CTAS_AAAAA_1881-Aggregate-GroupBy-repartition=UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient)
型
1条答案
按热度按时间2skhul331#
好了,最后是
PROTOBUF
的问题。我已经改变了所有的格式,以AVRO
和工作与整数现在罚款