Ksql, GROUP BY return ServerError:java.lang.NullPointerExcep

Question

我正在使用 confluent 4.1.1 ，我尝试了几个聚合命令，但总是返回带有 GROUP BY 的 NPE：

ksql> select cust_id, count(*) as sum_sub from TBL_SUBSCRIBER GROUP BY cust_id;
ServerError:java.lang.NullPointerException
ksql> 
ksql> describe extended TBL_SUBSCRIBER;
Type                 : TABLE
Key field            : SUB_ID
Timestamp field      : Not set - using <ROWTIME>
Key format           : STRING
Value format         : DELIMITED
Kafka output topic   : subscriber (partitions: 10, replication: 3)
Field               | Type                      
ROWTIME             | BIGINT           (system) 
ROWKEY              | VARCHAR(STRING)  (system) 
SUB_ID              | VARCHAR(STRING)           
CONTRACT_ID         | VARCHAR(STRING)           
CUST_ID             | VARCHAR(STRING)           
ACCOUNT_ID          | VARCHAR(STRING)           
TELECOM_SERVICE_ID  | VARCHAR(STRING)         

请帮帮我！

Answer 1

很抱歉看到您在使用 KSQL 时遇到了问题。听起来像您正在运行的旧版本中的错误。我相信您遇到的问题已在较新版本的 ksqlDB 中得到解决。 我很有信心，因为有明确的测试用例涵盖了通过 TABLE 源执行这样的组：https://github.com/confluentinc/ksql/blob/964c8ad665599123ad3635a2f806cb316e4f206e/ksqldb-functional-tests/src/test/resources/query-validation-tests/group-by.json#L184-L218

请升级并重试。