Похоже, улей replace columns
не работает со искрой 2.2.1, а также с 2.3.1.
alterSchemaSql : alter table myschema.mytable replace columns (a int,b int,d int)
Exception in thread "main" org.apache.spark.sql.catalyst.parser.ParseException:
Operation not allowed: alter table replace columns(line 2, pos 6)
Похоже, это было исправлено для версии ADD COLUMNS
2.2 и выше. Это также работает для меня, но replace columns
все еще не работает.
Операция не разрешена: изменить таблицу добавить столбцы (строка 1, позиция 0)
В следующих документах говорится, что он должен поддерживаться. Не уверен, почему это терпит неудачу для меня. https://spark.apache.org/docs/2.2.0/sql-programming-guide.html#supported-hive-features