pyflink??????????mysql????????

pyflink??kafka??mysql??udf??mysql1

Re: How to use

Hi To subscribe to the user mail list, you need to send a mail to user-zh-subscr...@flink.apache.org, you can get more info here[1] 可以发送邮件到 user-zh-subscr...@flink.apache.org 订阅 user-zh 邮件列表 https://flink.apache.org/community.html#mailing-lists Best, Congxian fangzhou ding

How to use

How to receive email from here

?????? ????pyflink??udf??????????python3.5??????

3.6??anaconda?? ---- ??: "user-zh"

?????? ????pyflink??udf??????????python3.5??????

pip list?? apache-beam 2.19.0 ?? ---- ??: "user-zh"

Re: 回复: flink 自定义udf注册后不能使用

Hi, 当前可以理解Flink注册UDF有三种类型： - TEMPORARY SYSTEM FUNCTION - TEMPORARY CATALOG FUNCTION - CATALOG FUNCTION 加上内置的SYSTEM FUNCTION 可以认为一共有四种，他们的解析顺序为： 1. TEMPORARY SYSTEM FUNCTION 2. SYSTEM FUNCTION 3. TEMPORARY CATALOG FUNCTION 4. CATALOG FUNCTION 所以你观察到TEMPORARY SYSTEM FUNCTION会覆盖内置函数，但是TEMPORARY

flink table转datastream失败

hi、我这面正在将flinktable转换为datastream，现在抛出如下异常，貌似是个bug。。。 table.printSchema(); streamTableEnv.toRetractStream(table, Types.ROW(TypeConversions.fromDataTypeToLegacyInfo(table.getSchema().getFieldDataTypes(.print(); root |-- register_id: BIGINT |-- asi_uid: BIGINT |-- person_uuid: BIGINT |--

??????flink sql count distinct??????????

---- ??: "user-zh"

Re: 请问pyflink的udf是否必须是python3.5谢谢！

Hi, pyflink 1.11支持的python版本是3.5, 3.6，3.7。这个报错看起来像是你的环境里面的apache-beam的版本太低导致的。你可以看下beam的版本是不是2.19 Best, Xingbo 大森林 于2020年10月17日周六 下午5:54写道： > > 您好！ > 请问目前的apache-flink是否必须在python3.5以下才能完全兼容？ > > 完整代码是: > > https://enjoyment.cool/2020/02/27/Three-Min-Series-How-to-create-UDF-in-PyFlink-1-10/ >

Re: pyflink sql中select,where都带udf，其中一个udf失效

这个问题是一个bug， 我创建了一个JIRA：https://issues.apache.org/jira/browse/FLINK-19675 出现的条件：在一个Calc里同时有Python UDF、Where条件、复合列访问。 在没有修复之前， 可以这样work around一下： tmp_table = st_env.from_path("source")\ .select("kubernetes.get('container').get('name') as

??????flink sql count distinct??????????

??user_id | | ?? | | ??xiongyun...@163.com | ?? ??2020??10??17?? 16:24??867127831 ?? ??flink sqldaugroupbycount distinct

Re: 关于内存大小设置以及预测

可以使用jvm自带命令jstat或通过 ManagementFactory类 监控TaskManager所在主机的堆/元空间内存、GC收集等一些信息 Kyle Zhang 于2020年10月16日周五 下午5:34写道： > Hi all， > 最近也是遇到比较常见的内存溢出的错误OutOfMemoryError: Java heap space，JM:1g > TM:2g，简单粗暴的设置成2g、4g就可以运行了， > INFO [] - Loading configuration property: > cluster.termination-message-path,

Re: Re:Re: Flink 1.10.1 checkpoint失败问题

FYI 分享一个可能相关的文章[1] [1] https://cloud.tencent.com/developer/news/564780 Best, Congxian Storm☀️ 于2020年10月15日周四 上午10:42写道： > 非常感谢。 > 后续我关注下这个问题，有结论反馈给大家，供参考。 > > > > -- > Sent from: http://apache-flink.147419.n8.nabble.com/

Re:hive streaning 问题请教

Hi McClone: You should register a hive catalog first. Hive factory is only work for catalog. You can refer to HiveTableSinkITCase#testStreamingWrite (HiveTableSinkITCase.java). Hope this can help you! Best, Hailong Wang At 2020-10-16 20:31:55, "McClone" wrote: >StreamExecutionEnvironment env =