Ksql, GROUP BY возвращает ServerError:java.lang.NullPointerException

Question

Я использую confluent 4.1.1, я пробовал несколько агрегатных команд, но всегда возвращал NPE с GROUP BY:

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. Я уверен, потому что есть явные тестовые примеры, которые охватывают выполнение такой группы с помощью ТАБЛИЧНОГО источника: https://github.com/confluentinc/ksql/blob/964c8ad665599123ad3635a2f806cb316e4f206e/ksqldb-functional-tests/src/test/resources/query-validation-tests/group-by.json

Обновите и повторите попытку.