Re: Web UI don't show up In Flink on Yarn (Flink 1.17)

Hi, yes i have tried ip directly.and no exception exists.but i found some info > like the picture shows Is there any response to the curl? How about enabling verbose logging for curl with the command "curl -v xxx" Best, Weihua On Thu, May 25, 2023 at 8:15 PM tan yao wrote: > and this info

Kryo Serialization fails with NPE

Hi, Need some pointers in fixing an issue with Kryo Serialization failing with NPE. Based on the stack trace, kryo fails to find the registered class for the given input type. Kryo fails to find the class type *FlinkA$FlinkB$$Lambda$2568/0x7ee2fbec64b0* This is how the actual code looks like.

Seeking advice on Looking up data - FileSystem connector / Kafka topic

Hello, I have a usecase where I use flink to execute sql query on data that's flowing in from a kafka topic. The output of this query is written to another kafka topic. The query that I want to execute is supposed to do a lookup on a small csv file (from which entries can be deleted/updated

Re: Kafka Quotas & Consumer Group Client ID (Flink 1.15)

Hello Mason, I created that PR for a suggestion on how to address the issue so that it would enable us to set client id. Happy to do any modifications to get this merged for the future. On Thu, May 25, 2023 at 12:55 AM Mason Chen wrote: > Hi

Re: Web UI don't show up In Flink on Yarn (Flink 1.17)

and this info came from yarn resoucemanager 获取 Outlook for iOS 发件人: tan yao 发送时间: Thursday, May 25, 2023 8:14:45 PM 收件人: Weihua Hu 抄送: user 主题: Re: Web UI don't show up In Flink on Yarn (Flink 1.17) yes i have tried ip directly.and no

Re: Web UI don't show up In Flink on Yarn (Flink 1.17)

Hi, Are there any reported exceptions? Did you try using curl to query the rest API, such as "curl http://{ip:port}/overview; Best, Weihua On Thu, May 25, 2023 at 8:49 AM tan yao wrote: > Hi all, > I find a strange thing with flink 1.17 deployed on yarn (CDH 6.x), flink > web ui can not show

回复： flink 窗口触发计算的条件

请教一下老师，您说的【同样数据的话，水印没有推进，窗口就不会触发】是不是意思是发送相同的数据，数据本身携带的时间戳是一样的，达不到水位线触发窗口的标准呀？ 还有两个问题想请教一下各位老师： 1、事件时间窗口的闭合是取决于下一条数据所携带的时间戳嘛，只有当下一条数据携带的时间戳大于上一个窗口的endTime，窗口才会触发，如果是这个样子的话，那如果一个最后一个窗口怎么触发啊 2、我想使用stream api去打印出来窗口的起始时间以及结束时间，这个是哪一个api呀 | | 小昌同学 | | ccc0606fight...@163.com | 回复的原邮件 | 发件人