Вопросы по теме '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