[jira] [Created] (FLINK-11419) StreamingFileSink fails to recover after taskmanager failure

2019-01-23 Thread Edward Rojas (JIRA)
Edward Rojas created FLINK-11419: Summary: StreamingFileSink fails to recover after taskmanager failure Key: FLINK-11419 URL: https://issues.apache.org/jira/browse/FLINK-11419 Project: Flink

[jira] [Created] (FLINK-11337) Incorrect watermark in StreaminFileSink BucketAssigner.Context when used in connected stream

2019-01-15 Thread Edward Rojas (JIRA)
Edward Rojas created FLINK-11337: Summary: Incorrect watermark in StreaminFileSink BucketAssigner.Context when used in connected stream Key: FLINK-11337 URL: https://issues.apache.org/jira/browse/FLINK-11337

[jira] [Created] (FLINK-11318) [Regression] StreamingFileSink can overwrite existing files

2019-01-14 Thread Edward Rojas (JIRA)
Edward Rojas created FLINK-11318: Summary: [Regression] StreamingFileSink can overwrite existing files Key: FLINK-11318 URL: https://issues.apache.org/jira/browse/FLINK-11318 Project: Flink

[jira] [Created] (FLINK-11087) Broadcast state migration Incompatibility from 1.5.3 to 1.7.0

2018-12-06 Thread Edward Rojas (JIRA)
Edward Rojas created FLINK-11087: Summary: Broadcast state migration Incompatibility from 1.5.3 to 1.7.0 Key: FLINK-11087 URL: https://issues.apache.org/jira/browse/FLINK-11087 Project: Flink

Re: Flink 1.5 - Job fails to execute in multiple taskmanagers (parallelism > 1)

2018-05-25 Thread Edward Rojas
I just tested the workaround and it works. Thank you -- Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/

Re: Flink 1.5 - Job fails to execute in multiple taskmanagers (parallelism > 1)

2018-05-24 Thread Edward Rojas
This may help to target the issue: If I let global ssl enabled, but I set taskmanager.data.ssl.enabled: false, it works again. -- Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/

Re: Flink 1.5 - Job fails to execute in multiple taskmanagers (parallelism > 1)

2018-05-24 Thread Edward Rojas
Regarding heap, the only configurations I do explicitly are /`jobmanager.heap.mb`/, /`taskmanager.heap.mb`/ and /`taskmanager.memory.preallocate: false`/. All other settings for memory have their default value. I just tested and it fails only when SSL is enabled. -- Sent from: http://apache-fli

Flink 1.5 - Job fails to execute in multiple taskmanagers (parallelism > 1)

2018-05-24 Thread Edward Rojas
Hi all, I was testing Flink 1.5 rc5 and I found this issue. I'm running a cluster in HA mode with one jobmanager, several taskmanagers, each one with two task slots and default parallelism set to 2. I'm running two jobs, one simple one with a kafka consumer, a filter and a sink. The other a littl

[jira] [Created] (FLINK-9261) Regression - Flink CLI and Web UI not working when SSL is enabled

2018-04-26 Thread Edward Rojas (JIRA)
Edward Rojas created FLINK-9261: --- Summary: Regression - Flink CLI and Web UI not working when SSL is enabled Key: FLINK-9261 URL: https://issues.apache.org/jira/browse/FLINK-9261 Project: Flink

[jira] [Created] (FLINK-9255) Regression - Flink CLI -m,--jobmanager option not working

2018-04-25 Thread Edward Rojas (JIRA)
Edward Rojas created FLINK-9255: --- Summary: Regression - Flink CLI -m,--jobmanager option not working Key: FLINK-9255 URL: https://issues.apache.org/jira/browse/FLINK-9255 Project: Flink Issue

[jira] [Created] (FLINK-9103) SSL verification on TaskManager when parallelism > 1

2018-03-28 Thread Edward Rojas (JIRA)
Edward Rojas created FLINK-9103: --- Summary: SSL verification on TaskManager when parallelism > 1 Key: FLINK-9103 URL: https://issues.apache.org/jira/browse/FLINK-9103 Project: Flink Issue T