Не удается подключиться к узлу CFS

Я удалил (или распаковал, не помню) аналитический узел DSE (с IP 10.14.5.50) пару месяцев назад. Когда я сейчас пытаюсь выполнить dse shark (CREATE TABLE ccc AS SELECT ...) запрос я сейчас получаю:

15/01/22 13:23:17 ERROR parse.SharkSemanticAnalyzer: org.apache.hadoop.hive.ql.parse.SemanticException: 0:0 Error creating temporary folder on: cfs://10.14.5.50/user/hive/warehouse/mykeyspace.db. Error encountered near token 'TOK_TMP_FILE'
    at org.apache.hadoop.hive.ql.parse.SemanticAnalyzer.getMetaData(SemanticAnalyzer.java:1256)
    at org.apache.hadoop.hive.ql.parse.SemanticAnalyzer.getMetaData(SemanticAnalyzer.java:1053)
    at org.apache.hadoop.hive.ql.parse.SemanticAnalyzer.analyzeInternal(SemanticAnalyzer.java:8342)
    at shark.parse.SharkSemanticAnalyzer.analyzeInternal(SharkSemanticAnalyzer.scala:105)
    at org.apache.hadoop.hive.ql.parse.BaseSemanticAnalyzer.analyze(BaseSemanticAnalyzer.java:284)
    at shark.SharkDriver.compile(SharkDriver.scala:215)
    at org.apache.hadoop.hive.ql.Driver.compile(Driver.java:342)
    at org.apache.hadoop.hive.ql.Driver.runInternal(Driver.java:977)
    at org.apache.hadoop.hive.ql.Driver.run(Driver.java:888)
    at shark.SharkCliDriver.processCmd(SharkCliDriver.scala:347)
    at org.apache.hadoop.hive.cli.CliDriver.processLine(CliDriver.java:413)
    at shark.SharkCliDriver$.main(SharkCliDriver.scala:240)
    at shark.SharkCliDriver.main(SharkCliDriver.scala)
Caused by: java.lang.RuntimeException: java.io.IOException: Error connecting to node 10.14.5.50:9160 with strategy STICKY.
    at org.apache.hadoop.hive.ql.Context.getScratchDir(Context.java:216)
    at org.apache.hadoop.hive.ql.Context.getExternalScratchDir(Context.java:270)
    at org.apache.hadoop.hive.ql.Context.getExternalTmpFileURI(Context.java:363)
    at org.apache.hadoop.hive.ql.parse.SemanticAnalyzer.getMetaData(SemanticAnalyzer.java:1253)
    ... 12 more

Я предполагаю, что вышеупомянутая ошибка происходит из-за моего пространства ключей, ссылающегося на старый узел:

shark> DESCRIBE DATABASE mykeyspace;
OK
mykeyspace      cfs://10.14.5.50/user/hive/warehouse/mykeyspace.db
Time taken: 0.997 seconds

Можно ли как-нибудь исправить этот неверный путь к базе данных?

Пробовал (но не смог) обходной путь для воссоздания базы данных: В cqlsh Я создал пространство клавиш thekeyspace и добавил таблицу thetable, Я открылась dse hive (и заметил, что DESCRIBE DATABASE thekeyspace дает мне правильный cfs дорожка). Однако я не могу удалить базу данных с помощью DROP DATABASE thekeyspace,

Дополнительная информация:

  • У меня нет внешних таблиц в моем пространстве ключей.
  • Создание SELECT по таблицам работает.
  • настройка -hiveconf cassandra.host=WORKING_NODE_IP не помогает.
  • Следующие команды возвращают правильный IP:s (т.е. не X.X.X.50):
    • dsetool listjt
    • dsetool jobtracker
    • dsetool sparkmaster
  • Я получаю ту же ошибку при выполнении запроса с помощью dse hive,
  • Нет переменная Акула ссылается на X.X.X.50 когда я выполню set; в своем REPL.
  • Я использую DSE 4.5.

1 ответ

Решение

Наткнулся на эту страницу, которая говорит, что вам нужно TRUNCATE "HiveMetaStore"."MetaStore"cqlsh) после удаления узлов улья. Это добилось цели.

Другие вопросы по тегам