答复: 退订

2021-07-30 文章 zhao liang
如果需要取消订阅 user-zh@flink.apache.org 邮件组,是发送任意内容的邮件到 user-zh-unsubscr...@flink.apache.org 发件人: 谢振爵 日期: 星期五, 2021年7月30日 15:11 收件人: user-zh 主题: 退订 退订

答复: 退订

2021-07-30 文章 zhao liang
如果需要取消订阅 user-zh@flink.apache.org 邮件组,是发送任意内容的邮件到 user-zh-unsubscr...@flink.apache.org 发件人: 赵珠峰 日期: 星期五, 2021年7月30日 15:15 收件人: user-zh@flink.apache.org 主题: 退订 退订 本邮件载有秘密信息,请您恪守保密义务。未经许可不得披露、使用或允许他人使用。谢谢合作。 This email contains confidential information. Recipient is obliged to keep the informa

flink 1.13.1 ????hive??????like????????????

2021-07-30 文章 Asahi Lee
hihive??sql??like ?? org.apache.flink.table.planner.codegen.CodeGenException: Unsupported call: like(VARCHAR(255), STRING NOT NULL)  org.apache.flink.table.planner.codegen.CodeGenException: Unsupported call: like(STRING, STRING NOT NULL)  If

Re: Over窗口聚合性能调优问题

2021-07-30 文章 Tianwang Li
(小的)tumbling window + (大的)over window 这样会不会好一些。 Wanghui (HiCampus) 于2021年7月30日周五 下午3:17写道: > Hi all: >我在测试Over窗口时,当窗口是5秒~15s级别时,处理速度能够达到2000/s。 > 但是当我把窗口调整为10分钟以上时,处理速度从2000开始急速下降,几分钟后下降至230/s。 > 请问下: >Over窗口的性能该如何优化,因为我后续会将窗口调整为24小时,按照目前的情况来看,性能会下降很快。 >我的测试节点配置:8C + 16G

flink 1.13.1 TM内存超用严重问题

2021-07-30 文章 Tianwang Li
问题: flink 计算任务配置的TM内存是 6G,但是,TM进程占用的内存实际达到了 8G。 是什么超用那么多内存? flink rocksdb内存超用那么多吗? 还是我的配置有什么问题 ? 内存使用: > top - 19:05:36 up 304 days, 9:12, 0 users, load average: 7.24, 5.99, > 5.25 > Tasks: 5 total, 1 running, 4 sleeping, 0 stopped, 0 zombie > %Cpu(s): 5.8 us, 0.9 sy, 0.0 ni, 92

场景题:Flink SQL 不支持 INSERT INTO… ON DUPLICATE KEY UPDATE ?

2021-07-30 文章 Ye Chen
现有table CREATE TABLE t ( abigint, bbigint, cbigint, PRIMARY KEY (a) NOT ENFORCED ) WITH ( ... ); 我们的场景只想根据主键a更新部分字段b,其余的字段保持不变,例如 mysql 支持 insert into t(a,b,c) select '1','2','3' on duplicate key update b='4'; 主键重复的时候只更新字段b,字段c的值不变 我在官方文档中没找到这个用法,sql-client也测试了一

Re: Flink Yarn Session模式,多任务不同Kerberos认证问题

2021-07-30 文章 Ada Luna
这个不知道未来怎么规划 Paul Lam 于2021年7月30日周五 下午2:51写道: > > 现在是不能共享的。Flink JobManager 的 principal 在启动时就确定了。 > > Best, > Paul Lam > > > 2021年7月30日 14:46,Ada Luna 写道: > > > > 在Flink Yarn Session中每次提交Job都更换principal。因为要做权限隔离,每个用户有自己的principal。 > > > > 现在 Flink Session模式是不是无法满足多个principal共享一个Flink Session集群,只能

flink on yarn报错

2021-07-30 文章 wangjingen
有没有大佬帮忙看看这个问题 The RMClient's and YarnResourceManagers internal state about the number of pending container requests for resource has diverged .Number client's pending container requests 1 !=Number RM's pending container requests 0;

Re: 退订

2021-07-30 文章 刘建刚
Send anything to user-zh-unsubscr...@flink.apache.org hihl 于2021年7月27日周二 下午5:50写道: > 退订

Over窗口聚合性能调优问题

2021-07-30 文章 Wanghui (HiCampus)
Hi all: 我在测试Over窗口时,当窗口是5秒~15s级别时,处理速度能够达到2000/s。 但是当我把窗口调整为10分钟以上时,处理速度从2000开始急速下降,几分钟后下降至230/s。 请问下: Over窗口的性能该如何优化,因为我后续会将窗口调整为24小时,按照目前的情况来看,性能会下降很快。 我的测试节点配置:8C + 16G Flink配置: taskmanager process memory: 8G Best regards WangHui

退订

2021-07-30 文章 赵珠峰
退订 本邮件载有秘密信息,请您恪守保密义务。未经许可不得披露、使用或允许他人使用。谢谢合作。 This email contains confidential information. Recipient is obliged to keep the information confidential. Any unauthorized disclosure, use, or distribution of the information in this email is strictly prohibited. Thank you.

退订

2021-07-30 文章 谢振爵
退订

?????? flink 1.13.1 ????hive??????????hive sql????????

2021-07-30 文章 Asahi Lee
CREATE TABLE `cosldatacenter.ods_emp_maindata_iadc_paramvalue`(   `paramvalue_id` string COMMENT '',    `platform_id` string COMMENT '',    `equipment_id` string COMMENT '',    `param_id` string COMMENT '',    `param_value` string COMMENT '',    `remark` string COMMENT '',    `create_time` string C