[jira] [Commented] (FLINK-19154) Application mode deletes HA data in case of suspended ZooKeeper connection

[ https://issues.apache.org/jira/browse/FLINK-19154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17221779#comment-17221779 ] Cristian commented on FLINK-19154: -- For the record, this does seem to fix the issue. We haven't been

[jira] [Commented] (FLINK-19154) Application mode deletes HA data in case of suspended ZooKeeper connection

[ https://issues.apache.org/jira/browse/FLINK-19154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17221652#comment-17221652 ] Cristian commented on FLINK-19154: -- When are you guys planning to release these changes? I tried using

[jira] [Commented] (FLINK-19154) Application mode deletes HA data in case of suspended ZooKeeper connection

[ https://issues.apache.org/jira/browse/FLINK-19154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17211377#comment-17211377 ] Cristian commented on FLINK-19154: -- I failed to capture the logs from the pods where this didn't

[jira] [Commented] (FLINK-19154) Application mode deletes HA data in case of suspended ZooKeeper connection

[ https://issues.apache.org/jira/browse/FLINK-19154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17204168#comment-17204168 ] Cristian commented on FLINK-19154: -- Hello guys! Good timing. This happened again yesterday. And it

[jira] [Commented] (FLINK-11127) Make metrics query service establish connection to JobManager

[ https://issues.apache.org/jira/browse/FLINK-11127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16753461#comment-16753461 ] Cristian commented on FLINK-11127: -- [~ray365] so how does the JM know how to call that service? And how

[jira] [Created] (FLINK-11408) ContinuousProcessingTimeTrigger: NPE on clear() and state is lost on merge

Cristian created FLINK-11408: Summary: ContinuousProcessingTimeTrigger: NPE on clear() and state is lost on merge Key: FLINK-11408 URL: https://issues.apache.org/jira/browse/FLINK-11408 Project: Flink

[jira] [Commented] (FLINK-7786) JarActionHandler.tokenizeArguments removes all quotes from program arguments

[ https://issues.apache.org/jira/browse/FLINK-7786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16423028#comment-16423028 ] Cristian commented on FLINK-7786: - It would be awesome if this were fixed/implemented. In our case, one

[jira] [Commented] (FLINK-4194) Implement isEndOfStream() for KinesisDeserializationSchema

[ https://issues.apache.org/jira/browse/FLINK-4194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370997#comment-16370997 ] Cristian commented on FLINK-4194: - Hi guys. This is a feature we miss. Given the fact that it's not

[jira] [Commented] (FLINK-8162) Kinesis Connector to report millisBehindLatest metric

[ https://issues.apache.org/jira/browse/FLINK-8162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295892#comment-16295892 ] Cristian commented on FLINK-8162: - I will try to test and push a PR soon. > Kinesis Connector to report

[jira] [Commented] (FLINK-8162) Kinesis Connector to report millisBehindLatest metric

[ https://issues.apache.org/jira/browse/FLINK-8162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16290737#comment-16290737 ] Cristian commented on FLINK-8162: - I'm running a fork of the kinesis connector that implements this.

[jira] [Closed] (FLINK-8164) JobManager's archiving does not work on S3

[ https://issues.apache.org/jira/browse/FLINK-8164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Cristian closed FLINK-8164. --- Resolution: Fixed Fix Version/s: 1.4.0 > JobManager's archiving does not work on S3 >

[jira] [Commented] (FLINK-8164) JobManager's archiving does not work on S3

[ https://issues.apache.org/jira/browse/FLINK-8164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16276801#comment-16276801 ] Cristian commented on FLINK-8164: - Thanks, Chesnay! If you have time... can you point me to where in the

[jira] [Commented] (FLINK-8162) Kinesis Connector to report millisBehindLatest metric

[ https://issues.apache.org/jira/browse/FLINK-8162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16273688#comment-16273688 ] Cristian commented on FLINK-8162: - Bump [~tzulitai] > Kinesis Connector to report millisBehindLatest

[jira] [Updated] (FLINK-8164) JobManager's archiving does not work on S3

[ https://issues.apache.org/jira/browse/FLINK-8164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Cristian updated FLINK-8164: Description: I'm trying to configure JobManager's archiving mechanism

[jira] [Updated] (FLINK-8164) JobManager's archiving does not work on S3

[ https://issues.apache.org/jira/browse/FLINK-8164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Cristian updated FLINK-8164: Description: I'm trying to configure JobManager's archiving mechanism

[jira] [Created] (FLINK-8164) JobManager's archiving does not work on S3

Cristian created FLINK-8164: --- Summary: JobManager's archiving does not work on S3 Key: FLINK-8164 URL: https://issues.apache.org/jira/browse/FLINK-8164 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-8162) Kinesis Connector to report millisBehindLatest metric

[ https://issues.apache.org/jira/browse/FLINK-8162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Cristian updated FLINK-8162: Description: When reading from Kinesis streams, one of the most valuable metrics is "MillisBehindLatest"

[jira] [Created] (FLINK-8162) Kinesis Connector to report millisBehindLatest metric

Cristian created FLINK-8162: --- Summary: Kinesis Connector to report millisBehindLatest metric Key: FLINK-8162 URL: https://issues.apache.org/jira/browse/FLINK-8162 Project: Flink Issue Type:

[jira] [Commented] (FLINK-6294) BucketingSink throws NPE while cancelling job

[ https://issues.apache.org/jira/browse/FLINK-6294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16261228#comment-16261228 ] Cristian commented on FLINK-6294: - This is happening to me on Flink 1.3.2. The line is different, but I

[jira] [Created] (FLINK-8124) EventTimeTrigger (and other triggers) could have less specific generic types

Cristian created FLINK-8124: --- Summary: EventTimeTrigger (and other triggers) could have less specific generic types Key: FLINK-8124 URL: https://issues.apache.org/jira/browse/FLINK-8124 Project: Flink