无法在 Arcadia BI 工具中加载 KSQL table
Not able to load KSQL table in Arcadia BI Tool
我正在尝试使用 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":[]}'
这是 Arcadia 和您 运行 的 KSQL 版本的问题。
breaking change in ksqlDB 0.6（Confluent Platform 5.4 附带）改变了查询的语法。添加了拉取查询，之前的 "continuous queries" 称为 "push queries" 并用强制性 EMIT CHANGES 子句表示。
我正在尝试使用 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":[]}'
这是 Arcadia 和您 运行 的 KSQL 版本的问题。
breaking change in ksqlDB 0.6（Confluent Platform 5.4 附带）改变了查询的语法。添加了拉取查询，之前的 "continuous queries" 称为 "push queries" 并用强制性 EMIT CHANGES 子句表示。