[jira] [Created] (FLINK-10482) java.lang.IllegalArgumentException: Negative number of in progress checkpoints

Julio Biason created FLINK-10482: Summary: java.lang.IllegalArgumentException: Negative number of in progress checkpoints Key: FLINK-10482 URL: https://issues.apache.org/jira/browse/FLINK-10482

[jira] [Created] (FLINK-9998) FlinkKafkaConsumer produces lag -Inf when the pipeline lags

Julio Biason created FLINK-9998: --- Summary: FlinkKafkaConsumer produces lag -Inf when the pipeline lags Key: FLINK-9998 URL: https://issues.apache.org/jira/browse/FLINK-9998 Project: Flink

[jira] [Commented] (FLINK-9960) JobManager can't failover to hdfs with multiple namenodes

[ https://issues.apache.org/jira/browse/FLINK-9960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16556059#comment-16556059 ] Julio Biason commented on FLINK-9960: - Just to add: I tried to configure high-availability.storageDir

[jira] [Created] (FLINK-9960) JobManager can't failover to hdfs with multiple namenodes

Julio Biason created FLINK-9960: --- Summary: JobManager can't failover to hdfs with multiple namenodes Key: FLINK-9960 URL: https://issues.apache.org/jira/browse/FLINK-9960 Project: Flink Issue

[jira] [Commented] (FLINK-9241) Scala version of Gauge (metric) doesn't work

[ https://issues.apache.org/jira/browse/FLINK-9241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16448813#comment-16448813 ] Julio Biason commented on FLINK-9241: - Related piece of code: {{  @transient private var meanLateness

[jira] [Created] (FLINK-9241) Scala version of Gauge (metric) doesn't work

Julio Biason created FLINK-9241: --- Summary: Scala version of Gauge (metric) doesn't work Key: FLINK-9241 URL: https://issues.apache.org/jira/browse/FLINK-9241 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-9141) Calling getSideOutput() and split() on one DataStream causes NPE

[ https://issues.apache.org/jira/browse/FLINK-9141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16426937#comment-16426937 ] Julio Biason commented on FLINK-9141: - Just a note: We got a problem with split/side outputs too, but

[jira] [Created] (FLINK-9123) Scala version of ProcessFunction doesn't work

Julio Biason created FLINK-9123: --- Summary: Scala version of ProcessFunction doesn't work Key: FLINK-9123 URL: https://issues.apache.org/jira/browse/FLINK-9123 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-8284) Custom metrics not being exposed for Prometheus

[ https://issues.apache.org/jira/browse/FLINK-8284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16330397#comment-16330397 ] Julio Biason commented on FLINK-8284: - Got it. Even if that seems obvious (now), I do believe it would

[jira] [Commented] (FLINK-8284) Custom metrics not being exposed for Prometheus

[ https://issues.apache.org/jira/browse/FLINK-8284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16328953#comment-16328953 ] Julio Biason commented on FLINK-8284: - {quote}Do you see any metric for this particular operator?

[jira] [Reopened] (FLINK-8284) Custom metrics not being exposed for Prometheus

[ https://issues.apache.org/jira/browse/FLINK-8284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Julio Biason reopened FLINK-8284: - Ok, got the problem to happen again. It seems if I run in standalone mode, everything goes fine. But

[jira] [Closed] (FLINK-8284) Custom metrics not being exposed for Prometheus

[ https://issues.apache.org/jira/browse/FLINK-8284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Julio Biason closed FLINK-8284. --- Resolution: Invalid > Custom metrics not being exposed for Prometheus >

[jira] [Commented] (FLINK-8284) Custom metrics not being exposed for Prometheus

[ https://issues.apache.org/jira/browse/FLINK-8284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16318999#comment-16318999 ] Julio Biason commented on FLINK-8284: - I swear to ${deity} that it didn't work. Restarted the project

[jira] [Updated] (FLINK-8284) Custom metrics not being exposed for Prometheus

[ https://issues.apache.org/jira/browse/FLINK-8284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Julio Biason updated FLINK-8284: Description: Following the documentation, we changed our filter that removes events with missing

[jira] [Created] (FLINK-8294) Missing examples/links in Data Sink docs

Julio Biason created FLINK-8294: --- Summary: Missing examples/links in Data Sink docs Key: FLINK-8294 URL: https://issues.apache.org/jira/browse/FLINK-8294 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-8285) Iterator Data Sink doesn't mention required module

[ https://issues.apache.org/jira/browse/FLINK-8285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295507#comment-16295507 ] Julio Biason commented on FLINK-8285: - [~tzulitai] Yeah, it's not relevant, because there is no

[jira] [Commented] (FLINK-8285) Iterator Data Sink doesn't mention required module

[ https://issues.apache.org/jira/browse/FLINK-8285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295496#comment-16295496 ] Julio Biason commented on FLINK-8285: - [~tzulitai] Actually, it is relevant: It could completely

[jira] [Commented] (FLINK-8285) Iterator Data Sink doesn't mention required module

[ https://issues.apache.org/jira/browse/FLINK-8285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295479#comment-16295479 ] Julio Biason commented on FLINK-8285: - Well, I was expecting to use the DataStreamUtils.colect to

[jira] [Updated] (FLINK-8285) Iterator Data Sink doesn't mention required module

[ https://issues.apache.org/jira/browse/FLINK-8285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Julio Biason updated FLINK-8285: Description: In the docs about

[jira] [Created] (FLINK-8285) Iterator Data Sink doesn't mention required module

Julio Biason created FLINK-8285: --- Summary: Iterator Data Sink doesn't mention required module Key: FLINK-8285 URL: https://issues.apache.org/jira/browse/FLINK-8285 Project: Flink Issue Type:

[jira] [Created] (FLINK-8284) Custom metrics not being exposed for Prometheus

Julio Biason created FLINK-8284: --- Summary: Custom metrics not being exposed for Prometheus Key: FLINK-8284 URL: https://issues.apache.org/jira/browse/FLINK-8284 Project: Flink Issue Type: Bug