Re: flink流、批场景下kafka拉取速率问题:每批次拉取多少条?是动态吗还是可以设置

2021-04-21 Thread
发自我的iPhone > 在 2021年4月21日,19:58,Peihui He 写道: > > fetch.min.bytes > fetch.wait.max.ms > 还可以用着两个参数控制下的 > > 熊云昆 于2021年4月21日周三 下午7:10写道: > >> 有个这个参数max.poll.records,表示一次最多获取多少条record数据,默认是500条 >> >> >> | | >> 熊云昆 >> | >> | >> 邮箱:xiongyun...@163.com >> | >> >> 签名由 网易邮箱大师 定制 >> >>

Re: flink1.10.0 batch模式写入hive失败,找不到TableSinkFactory

2020-10-21 Thread
发自我的iPhone 在 2020年10月21日,22:39,Allen <919869...@qq.com> 写道:  您好,这样能看到吗? 发自我的iPhone -- 原始邮件 -- 发件人: hailongwang <18868816...@163.com> 发送时间: 2020年10月20日 22:24 收件人: user-zh 主题: 回复:Re:flink1.10.0

Re: 如何为每个flink任务分别设置metrics的reporter

2020-10-12 Thread
我这边是为每个流任务单独指定了一个配置文件目录 不知道可否达到你的需求 发自我的iPhone > 在 2020年10月12日,18:18,xiao cai 写道: > > Hi: > 已知的设置metrics reporter的方式是在conf/flink-conf.yaml中,如果想要为每个任务分别设置不同的metrics > reporter或者设置不同的参数,比如设置prometheus pushgateway的多个自定义的k=v,该如何设置呢? > > > Best xiao.