Вопросы по теме 'pyflink'

Получил pyflink.util.exceptions.TableException: findAndCreateTableSource не удалось. при запуске примера PyFlink
Я использую программу PyFlink (скопировано из https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/python/table_api_tutorial.html ) from pyflink.dataset import ExecutionEnvironment from pyflink.table import TableConfig, DataTypes,...
273 просмотров
schedule 26.02.2022

Получение вложенных полей из сообщения Kafka с помощью Apache Flink SQL
Я пытаюсь создать исходную таблицу с помощью Apache Flink 1.11, где я могу получить доступ к вложенным свойствам в сообщении JSON. Я могу извлекать значения из корневых свойств, но не знаю, как получить доступ к вложенным объектам. документация...
768 просмотров
schedule 07.05.2022

Что не так с моей настройкой Pyflink, что UDF Python выдают исключения py4j?
Я играю с учебником по потоку данных flink python из документации: https://ci.apache.org/projects/flink/flink-docs-master/docs/dev/python/datastream_tutorial/ Среда Моя среда находится в Windows 10. java -version дает: openjdk version...
54 просмотров
schedule 29.05.2022