退订

2022-04-07 文章 co_zjw
退订

Re: k8s session cluster flink1.13.6创建后提示的地址啥用。

2022-04-07 文章 yidan zhao
貌似官网对flink k8s情况有2个入口,分别为: https://nightlies.apache.org/flink/flink-docs-release-1.13/docs/deployment/resource-providers/standalone/kubernetes/#session-mode 和 https://nightlies.apache.org/flink/flink-docs-release-1.13/docs/deployment/resource-providers/native_kubernetes/。 分别对应 Resource

Re: k8s session cluster flink1.13.6创建后提示的地址啥用。

2022-04-07 文章 yidan zhao
集群是3台物理机搭建,非minikube。 不清楚是否和网卡有关,init搭建时就有网络问题,k8s要根据默认路由网卡ip决定监听的地址。 但是我感觉这个场景不应该,因为既然是clusterIp,创建后提示信息就应该提示用clusterIp吧,为啥提示的用了本机的网卡ip呢。 yidan zhao 于2022年4月8日周五 10:38写道: > > 如下是 describe svc my-first-flink-cluster-rest 的结果: > Name: my-first-flink-cluster-rest > Namespace:

Re: k8s session cluster flink1.13.6创建后提示的地址啥用。

2022-04-07 文章 yidan zhao
如下是 describe svc my-first-flink-cluster-rest 的结果: Name: my-first-flink-cluster-rest Namespace:default Labels: app=my-first-flink-cluster type=flink-native-kubernetes Annotations: Selector:

退订

2022-04-07 文章 朱福生
退订 发自我的iPhone

yarn api 提交报错

2022-04-07 文章 周涛
hi, 我在测试使用java api提交flink任务时,遇到了一些问题,需要请教: flink版本1.14.4 Hadoop版本:3.0.0-cdh6.2.1 application模式,使用命令提交正常运行,api提交失败 提交失败,yarn日志: LogType:jobmanager.err LogLastModifiedTime:Fri Apr 08 09:24:01 +0800 2022 LogLength:107

Re: k8s session cluster flink1.13.6创建后提示的地址啥用。

2022-04-07 文章 yu'an huang
理论上cluster ip是不可能在集群外访问的,你的Kubernetes环境是怎么搭建的呢?Minikube吗? 方便的话可以分享你运行这个命令的结果吗? 》kubectl describe svc my-first-flink-cluster-rest > On 7 Apr 2022, at 4:44 PM, Zhanghao Chen wrote: > > 你 kubernetes.rest-service.exposed.type 这个参数设置的是什么呢? > > Best, > Zhanghao Chen >

Re: k8s session cluster flink1.13.6创建后提示的地址啥用。

2022-04-07 文章 Zhanghao Chen
你 kubernetes.rest-service.exposed.type 这个参数设置的是什么呢? Best, Zhanghao Chen From: yidan zhao Sent: Thursday, April 7, 2022 11:41 To: user-zh Subject: k8s session cluster flink1.13.6创建后提示的地址啥用。 参考

flink sql 任务中jm Blob server 总是在凌晨报 java.io.exception :unknow opreation 71

2022-04-07 文章 su wenwen
hi,all.想问大家下,是否有遇到过这个问题,flink 1.12 的版本 在线上运行的flink sql 作业,总是在凌晨报错如下: [cid:b11b980a-9bcd-4e7d-993a-e83a9322c66c] blobserver 我理解是传输二进制jar 包,从hdfs 到 本地工作目录。但没发现其他环节出现问题,对任务数据未产生影响。。

Re: flink table store

2022-04-07 文章 Paul Lam
@tison https://nightlies.apache.org/flink/flink-table-store-docs-release-0.1/docs/try-table-store/quick-start/ Best, Paul Lam > 2022年4月7日 15:05,tison 写道: > > 我有点好奇官网看到的链接在哪,能不能来个链接捏。 >

Re: flink table store

2022-04-07 文章 tison
我有点好奇官网看到的链接在哪,能不能来个链接捏。 Best, tison. Leonard Xu 于2022年4月7日周四 14:47写道: > > 项目是开源的[1], 最近快要发布第一个版本了,可以关注下 > > Best, > Leonard > [1] https://github.com/apache/flink-table-store < > https://github.com/apache/flink-table-store> > > > > > 2022年4月7日 上午9:54,Xianxun Ye 写道: > > > > 这里有 flink table

Re: flink table store

2022-04-07 文章 Leonard Xu
项目是开源的[1], 最近快要发布第一个版本了,可以关注下 Best, Leonard [1] https://github.com/apache/flink-table-store > 2022年4月7日 上午9:54,Xianxun Ye 写道: > > 这里有 flink table store 的设计文档,你可以了解下。 >