[jira] [Commented] (FLINK-15431) Add numLateRecordsDropped/lateRecordsDroppedRate/watermarkLatency in CepOperator

2020-01-13 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014101#comment-17014101 ] Dawid Wysakowicz commented on FLINK-15431: -- It sounds like a good compromise fo

[jira] [Commented] (FLINK-15431) Add numLateRecordsDropped/lateRecordsDroppedRate/watermarkLatency in CepOperator

2020-01-11 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17013650#comment-17013650 ] Benchao Li commented on FLINK-15431: [~dwysakowicz] Since we are already in an agree

[jira] [Commented] (FLINK-15431) Add numLateRecordsDropped/lateRecordsDroppedRate/watermarkLatency in CepOperator

2020-01-10 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012839#comment-17012839 ] Benchao Li commented on FLINK-15431: Yes, we can calculate `watermarkLaterncy` from 

[jira] [Commented] (FLINK-15431) Add numLateRecordsDropped/lateRecordsDroppedRate/watermarkLatency in CepOperator

2020-01-10 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012814#comment-17012814 ] Dawid Wysakowicz commented on FLINK-15431: -- If I understood the {{watermarkLate

[jira] [Commented] (FLINK-15431) Add numLateRecordsDropped/lateRecordsDroppedRate/watermarkLatency in CepOperator

2020-01-10 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012799#comment-17012799 ] Benchao Li commented on FLINK-15431: [~dwysakowicz] Thanks for your comment. I agre

[jira] [Commented] (FLINK-15431) Add numLateRecordsDropped/lateRecordsDroppedRate/watermarkLatency in CepOperator

2020-01-10 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012783#comment-17012783 ] Dawid Wysakowicz commented on FLINK-15431: -- Hi [~libenchao], I think it makes