как сделать счет в Flink SQL - PullRequest
Новая
       23

как сделать счет в Flink SQL

0 голосов
/ 05 ноября 2019

Я хотел бы сделать count (0) в Flink SQL, но он выдает исключение как

org.apache.flink.client.program.ProgramInvocationException: основной метод вызвал ошибку: сбой синтаксического анализа SQL,UDT в DDL пока не поддерживается.

не знаете, что-то не так?

ожидайте, что вывод должен работать нормально 

INSERT INTO request_join
select requestId,count(0) from requests
GROUP BY TUMBLE(rowtime, INTERVAL '1' HOUR),requestId;

Схема таблицыздесь 

name: request_join
schema:
- '`requestId` VARCHAR'
- '`count` LONG'
properties:
'connector.type': 'kafka'
'connector.version': 'universal'
'connector.topic': 'request_join_test'
'connector.startup-mode': 'latest-offset'
'connector.properties.0.key': 'zookeeper.connect'
'connector.properties.0.value': '10.XXXXXXXXX'
'connector.properties.1.key': 'bootstrap.servers'
'connector.properties.1.value': '10.XXXXXXXXX'
'connector.properties.2.key': 'group.id'
'connector.properties.2.value': 'request_join_test'
'update-mode': 'append'
'format.type': 'json'
'format.json-schema': '{type: "object", properties: {requestId: { type: "string"},count:{type: 
"number"}}}'

не нашел ничего плохого, но он просто не работает, если я не считаю и удаляю счет из схемы, он будет работать хорошо, поэтому я уверен, что сам SQLхорошо.

Я проверил flink sql, там написано, что некоторые функции не поддерживаются в DDL, так что не подсчитывает поддержку flink? Из примеров видно, что он очень хорошо поддерживает SUM.

...