Я пытаюсь загрузить транзакционную таблицу куста в фрейм данных PySpark, но получаю сообщение об ошибке:
py4j.protocol.Py4JJavaError: Произошла ошибка при вызове o086.showString.
Вызвано: java.util.concurrent.ExecutionException: java.lang.NumberFormatException: для входной строки: «0289756_0000»
Использование SparkSession.builder и попытка загрузки в фрейм данных.
Есть ли способ загрузить транзакционную таблицу в фрейм данных?
Версия Spark: 2.1.0.2.6.0.3-8
Версия Python: 2.7.5
Я попробовал загрузить таблицу с помощью SparkSession.builder( ).
Я ожидал, что он вернет объект DataFrame.
Подробнее здесь: https://stackoverflow.com/questions/791 ... ing-spark2
Невозможно загрузить транзакционную таблицу Hive в фрейм данных с помощью Spark2. ⇐ Python
-
- Похожие темы
- Ответы
- Просмотры
- Последнее сообщение
-
-
Невозможно загрузить транзакционную таблицу Hive в фрейм данных с помощью Spark2.
Anonymous » » в форуме Python - 0 Ответы
- 8 Просмотры
-
Последнее сообщение Anonymous
-
-
-
Преобразование строки в массив [Int] в столбце Hive с помощью Spark или Hive
Anonymous » » в форуме Python - 0 Ответы
- 61 Просмотры
-
Последнее сообщение Anonymous
-
-
-
Как установить неактивное соединение Hive jdbc из Java-кода с помощью hive jdbc
Anonymous » » в форуме JAVA - 0 Ответы
- 24 Просмотры
-
Последнее сообщение Anonymous
-
-
-
Как установить Idle Hive JDBC Connection Out из кода Java с помощью Hive JDBC
Anonymous » » в форуме JAVA - 0 Ответы
- 4 Просмотры
-
Последнее сообщение Anonymous
-