= table_env.from_pandas(df,col) .filter("candidate_first_namecandidate_source_id")\ .order_by("candidate_id").to_pandas() 我的错误是Py
浏览 102提问于2020-07-16得票数 0
回答已采纳
1回答
在最简单的例子中，我试着做这件事。输入包含输出存在。为了在我的应用程序中使用docker下载pyflink版本的1.10，我使用了以下代码片段： image: pyflink/playgrounds:1.10.0ExecutionEnvironment
from pyflink.table import TableConfig, DataTypes, BatchT
浏览 21提问于2021-07-20得票数 0
我运行在PyFlink程序下面(从复制)from pyflink.table import TableConfigecho -e "flink\npyflink\nflink" > /tmp/inputRun python WordCount.pyRun cat /tmp/out并查找预期输出
然后，我更改了我的PyFlink</e
浏览 2提问于2021-03-15得票数 2
回答已采纳
我尝试使用外部JAR在Pyflink中注册一个Scala UDF，如下所示，但得到下面的错误。Scala UDF： package com.dummy
class dummyTransform_37/lib/python3.7/site-packages/pyflink/lib/ Python： from pyflink.dataset import
浏览 20提问于2020-10-27得票数 1
回答已采纳
Apache Flink的Python SDK (PyFlink)数据流API支持像窗口这样的操作符吗？到目前为止，我所见过的使用PyFlink进行窗口操作的所有示例都使用了Table API。Datastream API确实支持这些操作符，但看起来还不能通过PyFlink使用这些操作符？ 谢谢!
浏览 25提问于2021-03-21得票数 0
回答已采纳
我正在尝试运行一个PyFlink作业，它从源Kafka主题获取数据，并将其放入hdfs中。有一个奇怪的与SQL相关的错误不断出现。这来自Apache (PyFlink) Table中的SQL语句：sql_statement_sink = """
CREATE TABLE avro_sink (ms_log_consumer/venv/lib/
浏览 6提问于2021-11-21得票数 0
可用于SQL函数中。我在这里看了flink的医生：并在终端上尝试此操作pyExecutable /Users/jonathanfigueroa/opt/anaconda3/bin/python --pyFiles /Users
浏览 1提问于2020-07-09得票数 0
我试图在编写pyflink作业时读取一个已建立的csv文件。from pyflink.dataset import ExecutionEnvironmentfrom pyflink.
浏览 22提问于2021-03-11得票数 0
2回答
我正试图在PyFlink中的一个窗口上进行一些聚合。from pyflink.common import Rowfrom pyflink.table.window import Tum
浏览 15提问于2021-06-17得票数 1
Apache Flink 1.11.0 Python表API目录: postgresql 通过Table API抛出UUID数据类型unsupportedOperatorException，从包含UUID数据类型列的postgresql Catalog表中读取和写入数据。如何处理pyFlink中的UUID数据类型？
浏览 26提问于2020-10-18得票数 0
我试图连接到windows上带有pyflink的postgresql，并使用以下代码：table_env = TableEnvironment.create(env_settings)
table_env.execute_sql(""
浏览 16提问于2022-01-26得票数 1
使用Flink 1.13.1和以Hive表为源和接收器的pyFlink和用户定义的表聚合函数(UDTAGG)，我遇到了一个错误： Table sink 'myhive.mydb.flink_tmp_model' doesn't supportconsuming update
浏览 1提问于2021-08-05得票数 1
我是PyFlink的新手，正在努力学习。我使用pyflink和jupyter笔记本并执行一些基本操作。因此，当我执行某些操作时，它会返回内存中的一个表位置，如"<pyflink.table.table.Table at 0x1eeffd773a0>。要查看数据，我需要调用to_pandas()方法。是否可以在不调用to_pandas()的情况下查看数据。Pyflink中
浏览 5提问于2022-01-30得票数 0
回答已采纳
我想使用Flink从输入文件中读取，执行一些聚合，并将结果写入输出文件。作业处于批处理模式。/projects/flink/flink-docs-release-1.12/dev/python/table_api_tutorial.html
> cat /tmp/output/part-305680d0-e680-420f-ab17-3e558c
浏览 37提问于2021-03-15得票数 1
回答已采纳
我正在使用PyFlink，我想对用Python编写的UDF进行单元测试。要测试以下简单的udf：from pyflink.table import DataTypes
from pyflink.table.udf import/usr/local/anaconda3/envs/pyflink-quickstart/lib
浏览 4提问于2021-03-23得票数 2
回答已采纳
我使用的是pyflink和Flink 11.2，我将我的表定义如下： def _create_sink_table(st_env): table = table.where("d.e = 'fail'") 到目前为止，我尝试的所有操作都导致了错误，这是其中之一： ➜
浏览 13提问于2020-11-28得票数 0
_2.12-1.11.0.jar:/opt/flink/lib/log4j-1.2-api-2.12.1.jar-2.12.1.jar:
/opt/flink/lib/flink-dist_2.12-1.11.0.jar::: 从日志中，您可以看到一些默认库已加载到系统中，但我希望添加一些jars，如flink-jd
浏览 121提问于2020-10-11得票数 1
我想在windows上使用flink的python api处理数据。但是当我使用该命令向本地集群提交作业时，它抛出了NullPointerException。bin/flink run -py D:\workspace\python-test\flink-test.py flink-test.py： from pyflink.dataset import ExecutionEnvironmentfrom pyflink.table import TableConfig, DataTypes, B
浏览 23提问于2019-12-19得票数 0
/pyflink/table/table.py", line 1108, in execute_insertpyflink.util.exceptions.TableE
浏览 48提问于2022-01-14得票数 0
回答已采纳
from pyflink.datastream.time_characteristic import TimeCharacteristic DataTypes, CsvTableSink,from pyflink.table.descriptors/pyflink/table&#
浏览 12提问于2021-11-12得票数 0
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
