退订
HI
我简化了我python代码
只要udft方法有外部方法,都会有递归问题, 比如
agan_add_iig(),尽管我的agan_add_iig()实现很简单,flink难道不能外部import自定义方法吗??
def agan_add_iig():
return 2
@udtf(input_types=DataTypes.STRING(),
result_types=[DataTypes.STRING(), DataTypes.STRING(), DataTypes.STRING(),
DataTypes.STRING()])
def run(data_str):
try:
egator
- Closing streams for instruction 1 and outbound data
{fn/read/input:0=Byte size: 239, Element count: 4} and timers {}.
现在我在怀疑是flink在@udtf 加载装饰器过程中可能出现了问题,导致我run方法没有进去执行;因为我在run定义了log,但是在控制台没看到任何日志输出;
由于官网的docs对于这块底层加载逻辑没有太多介绍,这边请教下各位老师,应该怎么处理
我用pydev-pycharm去debug pyflink代码,发现在java_gateway.py
Hello:
请教2个问题。
1、flink 使用sql-client.sh -f xx.sql 怎么传递参数修改sql里面的文件。比如MySQL,Kafka的连接地址。
2、flink sql消费Kafka
设置group-offset,group.id之前没提交过，会直接报错。怎么设置成没提交过从earliest消费等等。
感谢大家
thanks, 设置成GBK是可以的
| |
赵兵杰
|
回复的原邮件
| 发件人 | Leo |
| 日期 | 2023年06月08日 15:16 |
| 收件人 | user-zh@flink.apache.org、Shammon FY |
| 抄送至 | |
| 主题 | Re: pyflink1.17 中文乱码 |
Hi,
这个问题我在1.16版本测试了一下， Pycharm 和 Windows命令行都测试了，结论如下：
1) Windows命令行没有任何问题，因为默认的终端窗口的字符集编码就是GBK;
2) Pycharm运行
老师们好，pyflink运行官网例子 wordcount 。把单词改成中文 乱码
----
??:
"user-zh"
Hi，all
我在linux上启动1.10的sql-client，却遇到了如下错误信息：
看了一下sql-client.sh脚本需要在FLINK_OPT_DIR路径中找到Sql-client.jar，我就手动export了一下FLINK_OPT_DIR，但还是报上面的错，与此同时，我启动1.9版本的sql-client则可以正常启动，感觉这个问题很诡异，麻烦请大家帮忙看看
10 matches
Mail list logo
