Почему DESCRIBE EXTENDED в Kafka KSQL возвращает ошибку ShowColumns не поддерживается? - PullRequest
Новая
       14

Почему DESCRIBE EXTENDED в Kafka KSQL возвращает ошибку ShowColumns не поддерживается?

0 голосов
/ 10 января 2019

У меня есть простой KTABLE в KSQL, который называется DIMAGE

Когда я запускаю следующий код 

{
"ksql": "DESCRIBE EXTENDED DIMAGE ;"
}

Я получаю следующую ошибку 

{
    "@type": "generic_error",
    "error_code": 40000,
    "message": "Statement type `io.confluent.ksql.parser.tree.ShowColumns' not supported for this resource",
    "stackTrace": []
}

Я также получаю похожее сообщение об ошибке, пытаясь описать поток. Я также получаю то же сообщение об ошибке, если удаляю атрибут EXTENDED.

1 Ответ

0 голосов
/ 17 января 2019

Вы используете неверную конечную точку REST. Если вы используете конечную точку запроса query, вы получите ошибку: 

$ curl -s -X "POST" "http://localhost:8088/query" \
       -H "Content-Type: application/vnd.ksql.v1+json; charset=utf-8" \
       -d '{
    "ksql": "DESCRIBE EXTENDED COMPUTER_T;"
  }'
{"@type":"generic_error","error_code":40000,"message":"Statement type `io.confluent.ksql.parser.tree.ShowColumns' not supported for this resource","stackTrace":[]}⏎

Если вы используете конечную точку оператора ksql, она работает нормально: 

$ curl -s -X "POST" "http://localhost:8088/ksql" \
       -H "Content-Type: application/vnd.ksql.v1+json; charset=utf-8" \
       -d '{
    "ksql": "DESCRIBE EXTENDED COMPUTER_T;"
  }'|jq '.'
[
  {
    "@type": "sourceDescription",
    "statementText": "DESCRIBE EXTENDED COMPUTER_T;",
    "sourceDescription": {
      "name": "COMPUTER_T",
      "readQueries": [
        {
          "sinks": [
            "COMP_WATCH_BY_EMP_ID_T"
          ],
          "id": "CTAS_COMP_WATCH_BY_EMP_ID_T_0",
[...]

Я зарегистрировался # 2362 , чтобы мы могли улучшить UX этого.

...