Re: Re: 来自潘明文的邮件
可以通过 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 算子之间是没有执行先后顺序保证的，是可以并行的。 但是如果多个 sink 被 operator chain > >优化在一起，单个 operator chain 内部数据是并行的 > >Best, > >Weihua > > > > > >On Fri, Jun 24, 2022 at 9:29 PM Lincoln Lee > wrote: > > > >> Hi, > >>邮件中直接贴图片无法正常看到,可以发下文本 > >> > >> Best, > >> Lincoln Lee > >> > >> > >> 潘明文 于2022年6月24日周五 16:36写道： > >> > >> > 你好，下面2个SINK 能够并发同时处理吗？还是要窜行，等第一个SINK 好了，才能第二个SINK. > >> > > >> > > >> >
Re: IDEA尝试编译最新flink源码报错
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应用到给定类型; > > 需要: scala.Function0 > > 找到: super::unc[...]ndler > > 原因: 无法推断类型变量 B > > (参数不匹配; scala.Function0 不是函数接口 > > 在 接口 scala.Function0 中找到多个非覆盖抽象方法) > > > > > > -- > EMAIL: haoyuyan...@126.com > 2022年6月28日 > > > 在 2022-06-28 17:07:04，"Howie Yang" 写道： > > 使用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日 > >
Re: flink on k8s的application模式
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 on k8s??application????
flink??1.13.1 flink on k8s??application??webui??Running Job??session?? ??
flink on k8s??application????
flink??1.13.1 flink on k8s??application??webui??Running Job??session?? ??
Re:Re: 来自潘明文的邮件
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, >>邮件中直接贴图片无法正常看到,可以发下文本 >> >> Best, >> Lincoln Lee >> >> >> 潘明文 于2022年6月24日周五 16:36写道： >> >> > 你好，下面2个SINK 能够并发同时处理吗？还是要窜行，等第一个SINK 好了，才能第二个SINK. >> > >> > >>
Re:IDEA尝试编译最新flink源码报错
刚才好像图片挂了 补充报错文字内容： 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 不是函数接口 在 接口 scala.Function0 中找到多个非覆盖抽象方法) -- EMAIL: haoyuyan...@126.com 2022年6月28日 在 2022-06-28 17:07:04，"Howie Yang" 写道： 使用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日
IDEA尝试编译最新flink源码报错
使用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日
Re: [ANNOUNCE] Apache Flink Kubernetes Operator 1.0.1 released
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月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 users to manage their Apache Flink >> applications and their lifecycle through native k8s tooling like kubectl. >> < >> https://flink.apache.org/news/2022/04/03/release-kubernetes-operator-0.1.0.html >> > >> >> The release is available for download at: >> https://flink.apache.org/downloads.html >> >> Official Docker image for Flink Kubernetes Operator applications can be >> found at: >> https://hub.docker.com/r/apache/flink-kubernetes-operator >> >> The full release notes are available in Jira: >> >> https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522=12351812 >> >> We would like to thank all contributors of the Apache Flink community who >> made this release possible! >> >> Regards, >> Gyula Fora >> >
Re: [ANNOUNCE] Apache Flink Kubernetes Operator 1.0.1 released
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 users to manage their Apache Flink > applications and their lifecycle through native k8s tooling like kubectl. > < > https://flink.apache.org/news/2022/04/03/release-kubernetes-operator-0.1.0.html > > > > The release is available for download at: > https://flink.apache.org/downloads.html > > Official Docker image for Flink Kubernetes Operator applications can be > found at: > https://hub.docker.com/r/apache/flink-kubernetes-operator > > The full release notes are available in Jira: > > https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522=12351812 > > We would like to thank all contributors of the Apache Flink community who > made this release possible! > > Regards, > Gyula Fora >
