Re:回复: flink ui 算子数据展示一直loading...

2024-01-25 Thread Xuyang
Hi, 手动curl 有问题的metric的接口,出来的数据正常吗? JM log里有发现什么异常么? -- Best! Xuyang 在 2024-01-26 11:51:53,"阿华田" 写道: >这个维度都排查了 都正常 > > >| | >阿华田 >| >| >a15733178...@163.com >| >签名由网易邮箱大师定制 > > >在2024年01月23日 21:57,Feng Jin 写道: >可以尝试着下面几种方式确认下原因: > > >1. > >打开浏览器开发者模式,看是否因为请求某个接口卡住 >2. > >查看下

回复: flink ui 算子数据展示一直loading...

2024-01-25 Thread 阿华田
这个维度都排查了 都正常 | | 阿华田 | | a15733178...@163.com | 签名由网易邮箱大师定制 在2024年01月23日 21:57,Feng Jin 写道: 可以尝试着下面几种方式确认下原因: 1. 打开浏览器开发者模式,看是否因为请求某个接口卡住 2. 查看下 JobManager 的 GC 情况,是否频繁 FullGC 3. 查看下 JobManager 的日志,是否存在某些资源文件丢失或者磁盘异常情况导致 web UI 无法访问. Best, Feng On Tue, Jan 23, 2024 at 6:16 PM 阿华田

Re: [ANNOUNCE] Apache Flink 1.18.1 released

2024-01-25 Thread Jing Ge via user
Hi folks, The bug has been fixed and PR at docker-library/official-images has been merged. The official images are available now. Best regards, Jing On Mon, Jan 22, 2024 at 11:39 AM Jing Ge wrote: > Hi folks, > > I am still working on the official images because of the issue >

Re: [ANNOUNCE] Apache Flink 1.18.1 released

2024-01-25 Thread Jing Ge
Hi folks, The bug has been fixed and PR at docker-library/official-images has been merged. The official images are available now. Best regards, Jing On Mon, Jan 22, 2024 at 11:39 AM Jing Ge wrote: > Hi folks, > > I am still working on the official images because of the issue >

RE: Elasticsearch Sink 1.17.2 error message

2024-01-25 Thread Jiabao Sun
Hi Tauseef, We cannot directly write POJO types into Elasticsearch. You can try serializing the TopologyDTO into a JSON string like Jackson before writing it. public static void main(String[] args) throws IOException { try (RestHighLevelClient client = new RestHighLevelClient(

RE: 回复:RE: how to get flink accumulated sink record count

2024-01-25 Thread Jiabao Sun
Hi Enric, Could you kindly provide more specific details where you would like to capture the metric? Additionally, if it's convenient for you, could you please share some code examples? Best, Jiabao On 2024/01/25 10:43:30 Enric Ott wrote: > Thanks,Jiabao,but what I mean is capturing the

Elasticsearch Sink 1.17.2 error message

2024-01-25 Thread Tauseef Janvekar
Hi Team, We get the below error message when we try to add an elastick sink Caused by: org.apache.flink.streaming.runtime.tasks.ExceptionInChainedOperatorException: Could not forward element to next operator at

Re: Long execution of SQL query to Kafka + Hive (q77 TPC-DS)

2024-01-25 Thread Ron liu
Hi, Can you help to explain the q77 execution plan? And find which operator takes a long time in flink UI? Best Ron Вова Фролов 于2024年1月24日周三 09:09写道: > Hello, > > I am executing a heterogeneous SQL query (part of the data is in Hive > and part in Kafka. The query utilizes TPC-DS benchmark

??????RE: how to get flink accumulated sink record count

2024-01-25 Thread Enric Ott
Thanks,Jiabao,but what I mean is capturing the metric in Flink tasks. ---- ??: "Jiabao Sun"https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/ops/metrics/ [2]