可以通过 FLINK ui 查看两个 SINK 是否 chain 在同一个 Task 内，不过可以简单认为两个 sink 是并行的
Best,
Weihua
On Tue, Jun 28, 2022 at 6:30 PM 潘明文 wrote:
> HI 您好，
>
>
> 我的就是一个源同时写入HBASE SINK,和HBASE SINK.。
>
>
>
>
>
>
>
>
>
>
>
>
>
>
> 在 2022-06-27 23:54:33，"Weihua Hu" 写道：
> >Hi，
> >图片看不到了，正常来说做个 Sink 算子之间是没有执行先后顺序保证的，是可以并行
Hi，
图片还是挂了，可以尝试用一些图床工具，贴链接到邮件里。
Best,
Weihua
On Tue, Jun 28, 2022 at 5:21 PM Howie Yang wrote:
> 刚才好像图片挂了
>
> 补充报错文字内容：
>
>
> flink\flink-rpc\flink-rpc-akka\src\main\java\org\apache\flink\runtime\rpc\akka\RobustActorSystem.java:92:56
>
> java: 无法将类 scala.Option中的方法 getOrElse应用到给定类型;
>
> 需要:
Hi,
图片看不到了，是不是在Main 方法中调用了两次 env.execute 呢？可以提供下日志
Best,
Weihua
On Tue, Jun 28, 2022 at 8:52 PM 陈卓宇 <2572805...@qq.com.invalid> wrote:
>
> flink版本：1.13.1
> 提交flink on k8s的application模式，提交完成发现webui的Running Job有两个，跟session模式非常像
> 截图在附件
>
flink??1.13.1
flink on k8s??application??webui??Running
Job??session??
??
flink??1.13.1
flink on k8s??application??webui??Running
Job??session??
??
HI 您好，
我的就是一个源同时写入HBASE SINK,和HBASE SINK.。
在 2022-06-27 23:54:33，"Weihua Hu" 写道：
>Hi，
>图片看不到了，正常来说做个 Sink 算子之间是没有执行先后顺序保证的，是可以并行的。 但是如果多个 sink 被 operator chain
>优化在一起，单个 operator chain 内部数据是并行的
>Best,
>Weihua
>
>
>On Fri, Jun 24, 2022 at 9:29 PM Lincoln Lee wrote:
>
>> Hi,
>>
刚才好像图片挂了
补充报错文字内容：
flink\flink-rpc\flink-rpc-akka\src\main\java\org\apache\flink\runtime\rpc\akka\RobustActorSystem.java:92:56
java: 无法将类 scala.Option中的方法 getOrElse应用到给定类型;
需要: scala.Function0
找到: super::unc[...]ndler
原因: 无法推断类型变量 B
(参数不匹配; scala.Function0 不是函数接口
在 接口 scal
使用IDEA根据官网最新的教程
https://nightlies.apache.org/flink/flink-docs-master/docs/flinkdev/ide_setup/
将源码下载下来编译，报以下错误
Project Structure中版本
scala-sdk-2.12.7
请问是什么原因呢？
--
EMAIL: haoyuyan...@126.com
2022年6月28日
Sorry for the incorrect blogpost link, please ignore that. There is no
blogpbost for 1.0.1 :)
Gyula
On Tue, Jun 28, 2022 at 9:43 AM Yang Wang wrote:
> Thanks Gyula for working on the first patch release for the Flink
> Kubernetes Operator project.
>
>
> Best,
> Yang
>
>
>
> Gyula Fóra 于2022年6月
Thanks Gyula for working on the first patch release for the Flink
Kubernetes Operator project.
Best,
Yang
Gyula Fóra 于2022年6月28日周二 00:22写道：
> The Apache Flink community is very happy to announce the release of Apache
> Flink Kubernetes Operator 1.0.1.
>
> The Flink Kubernetes Operator allows
10 matches
Mail list logo
