Не удалось загрузить таблицу K SQL в Arcadia BI Tool - PullRequest
0 голосов
/ 27 апреля 2020

Я пытаюсь создать потоковую визуализацию из KSQLDB с помощью инструмента Arcadia BI. Я могу установить sh соединение и посмотреть потоки и таблицы в KSQLDB от Arcadia. Но при попытке выборки данных я получаю сообщение об ошибке. Может ли кто-нибудь помочь?

Error running query: Error: b'{"@type":"statement_error","error_code":40001,"message":"Pull queries don\'t support LIMIT clauses. Refer to https://cnfl.io/queries for info on query types. If you intended to issue a push query, resubmit with the EMIT CHANGES clause\\n\\nQuery syntax in KSQL has changed. There are now two broad categories of queries:\\n- Pull queries: query the current state of the system, return a result, and terminate. \\n- Push queries: query the state of the system in motion and continue to output results until they meet a LIMIT condition or are terminated by the user.\\n\\n\'EMIT CHANGES\' is used to to indicate a query is a push query. To convert a pull query into a push query, which was the default behavior in older versions of KSQL, add `EMIT CHANGES` to the end of the statement before any LIMIT clause.\\n\\nFor example, the following are pull queries:\\n\\t\'SELECT * FROM X WHERE ROWKEY=Y;\' (non-windowed table)\\n\\t\'SELECT * FROM X WHERE ROWKEY=Y AND WINDOWSTART>=Z;\' (windowed table)\\n\\nThe following is a push query:\\n\\t\'SELECT * FROM X EMIT CHANGES;\'\\n\\nNote: Persistent queries, e.g. `CREATE TABLE AS ...`, have an implicit `EMIT CHANGES`, but we recommend adding `EMIT CHANGES` to these statements.","stackTrace":[],"statementText":"select * from table_name limit 10;","entities":[]}' 

1 Ответ

0 голосов
/ 27 апреля 2020

Это проблема с Arcadia и версией K SQL, которую вы используете.

Произошло критическое изменение в ksqlDB 0.6 (поставляется с Confluent Platform 5.4), которое изменило синтаксис запросов. Были добавлены запросы извлечения, а предыдущие «непрерывные запросы» известны как «pu sh запросы» и обозначены обязательным предложением EMIT CHANGES.

...