0

我正在使用 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)         

请帮我!

4

1 回答 1

0

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

请升级并重试。

于 2020-06-02T09:00:19.943 回答