无法在Arcadia BI工具中加载KSQL表

Question

我正在尝试使用Arcadia BI工具从KSQLDB创建流可视化。我能够建立一个连接，并从Arcadia中看到KSQLDB中的流和表。但是在尝试采样数据的同时，我得到了error.Can的帮助吗？

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":[]}' 

Answer 1

这是Arcadia和您正在运行的KSQL版本的一个问题。

有一个ksqlDB 0.6的破断变化 (随Confluent 5.4一起提供)，它改变了查询的语法。添加了拉查询，以前的“连续查询”称为“推送查询”，并使用强制EMIT CHANGES子句表示。