可以写到hive 直接sqoop导入mysql。
发自我的iPhone
> 在 2019年12月7日,下午12:20,sun <1392427...@qq.com> 写道:
>
> hi请问:
> flink5条数据写入mysql太慢怎么办啊,除了多线程还有其他方法吗,已经是批量写入了,
> 每次写5条的
我还是没有搞明白你的意思,你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
>
提交两个是两个进程,所以是两个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
你好,
https://www.jianshu.com/p/c8c99f613f10?from=singlemessage=0
希望可以帮助你
> 在 2019年10月22日,下午2:04,王佩 写道:
>
> 请教一下, Flink DataStream中有广播变量的概念吗。
>
> 比方说,我有一个全局变量ArrayList,在JobManager端更新,然后在TaskManager中共享。可以做到吗
>
> 感谢!
我看过这个我不是这个问题,作业没有设置水印,作业可以正常运行,最近可能是运行一天多会报这个异常
发自我的 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>