Re: flink,50000条数据写入mysql太慢怎么办啊,除了多线程还有其他方法吗,已经是批量写入了

2019-12-06 Thread 18612537914
可以写到hive 直接sqoop导入mysql。 发自我的iPhone > 在 2019年12月7日,下午12:20,sun <1392427...@qq.com> 写道: > > hi请问: > flink5条数据写入mysql太慢怎么办啊,除了多线程还有其他方法吗,已经是批量写入了, > 每次写5条的

Re: 通过 yarn-cluster 提交多个任务,Flink 页面只显示最后一个提交的任务

2019-11-17 Thread 18612537914
我还是没有搞明白你的意思,你job里面已经是两个了。打开每一个都是对应的信息。因为你启动的是同一个class所以相当于是同一个任务只是消费数据不用。你可以换一个class ,不知道是不是我说的这个意思。 发自我的iPhone > 在 2019年11月18日,上午10:06,"lh...@126.com" 写道: > > 提交了两个job,分别在两个不同的application上,注意切换一下flink web dashboard的地址。 > > > > > lh...@126.com > > 发件人: Henry > 发送时间: 2019-11-18 08:59 >

Re: 通过 yarn-cluster 提交多个任务,Flink 页面只显示最后一个提交的任务

2019-11-17 Thread 18612537914
提交两个是两个进程,所以是两个job。我觉得没有任何问题,你点进去flink的页面肯定各是各的。 发自我的iPhone > 在 2019年11月17日,下午2:51,Henry 写道: > >  > 大家好,我想请教一个问题哈。 就是我通过 ./flink run -m yarn-cluster -yn 2 -yjm 1024 -ytm 1024 > xxx.jar 的方式提交了两个不同的任务程序,在yarn界面里也能看到两个正在运行的 app ,但是点击 对应的 ApplicationMater > 跳转到 Flink-Dashboard 页面之后,在 Running

Re: Flink DataStream Broadcast variable

2019-10-22 Thread 18612537914
你好, https://www.jianshu.com/p/c8c99f613f10?from=singlemessage=0 希望可以帮助你 > 在 2019年10月22日,下午2:04,王佩 写道: > > 请教一下, Flink DataStream中有广播变量的概念吗。 > > 比方说,我有一个全局变量ArrayList,在JobManager端更新,然后在TaskManager中共享。可以做到吗 > > 感谢!

Re: Could not forward element to next operator

2019-09-28 Thread 18612537914
我看过这个我不是这个问题,作业没有设置水印,作业可以正常运行,最近可能是运行一天多会报这个异常 发自我的 iPhone > 在 2019年9月29日,上午11:49,Wesley Peng 写道: > > Hello, > > May this article match your issue? > https://blog.csdn.net/qq_41910230/article/details/90411237 > > regards. > >> On Sun, Sep 29, 2019 at 10:33 AM allan <18612537...@163.com>