[
https://issues.apache.org/jira/browse/FLINK-18794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17177011#comment-17177011
]
JasonLee commented on FLINK-18794:
----------------------------------
Let me first briefly describe the structure of the task Data goes through in
sequence like this
Kafka source filter map map keyby window process
The first four have the same degree of parallelism so they can be chained
togather but the DAG just show the first map operator the second didn’t show
I will show u the DAG tomorrow
Thank you for your reply
JasonLee
On 08/13/2020 21:05, Chesnay Schepler (Jira) wrote:
[
https://issues.apache.org/jira/browse/FLINK-18794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17176995#comment-17176995
] Chesnay Schepler commented on FLINK-18794:
------------------------------------------ Can you outline the structure of
your job, and maybe also a screenshot of the DAG as displayed in the WebUI? >
Custom metric doesn't work in flink1.11.1 >
----------------------------------------- > > Key: FLINK-18794 > URL:
https://issues.apache.org/jira/browse/FLINK-18794 > Project: Flink > Issue
Type: Bug > Components: Runtime / Metrics > Affects Versions: 1.11.1 >
Reporter: JasonLee > Priority: Major > Fix For: 1.11.2 > > Attachments:
debug.log, info.log > > > when i use Flink 1.11.1 I've customized a flick
metric and run it in Flink on yarn cluster but I can't find the metric I just
defined on the Flink web UI and The DAG not shown the operator of custom
metric so i run the same code on the Flink 1.11.0 it can show -- This message
was sent by Atlassian Jira (v8.3.4#803005)
> Custom metric doesn't work in flink1.11.1
> -----------------------------------------
>
> Key: FLINK-18794
> URL: https://issues.apache.org/jira/browse/FLINK-18794
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Metrics
> Affects Versions: 1.11.1
> Reporter: JasonLee
> Priority: Major
> Fix For: 1.11.2
>
> Attachments: debug.log, info.log
>
>
> when i use Flink 1.11.1 I've customized a flick metric and run it in Flink
> on yarn cluster but I can't find the metric I just defined on the Flink web
> UI and The DAG not shown the operator of custom metric so i run the same
> code on the Flink 1.11.0 it can show
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
