[jira] [Commented] (FLINK-8580) No easy way (or issues when trying?) to handle multiple yarn sessions and choose at runtime the one to submit a ha streaming job

[ https://issues.apache.org/jira/browse/FLINK-8580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177709#comment-17177709 ] Arnaud Linz commented on FLINK-8580: Actually my cluster is a hadoop (yarn cluster), not standalone

[jira] [Commented] (FLINK-16509) FlinkKafkaConsumerBase tries to log a context that may not have been initialized and fails

[ https://issues.apache.org/jira/browse/FLINK-16509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17055651#comment-17055651 ] Arnaud Linz commented on FLINK-16509: - I was too quick to open the case. It was a side effect from a

[jira] [Closed] (FLINK-16509) FlinkKafkaConsumerBase tries to log a context that may not have been initialized and fails

[ https://issues.apache.org/jira/browse/FLINK-16509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arnaud Linz closed FLINK-16509. --- Release Note: It was a side effect. When everything goes right, we do have a context here.

[jira] [Updated] (FLINK-16509) FlinkKafkaConsumerBase tries to log a context that may not have been initialized and fails

[ https://issues.apache.org/jira/browse/FLINK-16509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arnaud Linz updated FLINK-16509: Description: New code of FlinkKafkaConsumerBase#initializeState(), logs restored state with:

[jira] [Updated] (FLINK-16509) FlinkKafkaConsumerBase tries to log a context that may not have been initialized and fails

[ https://issues.apache.org/jira/browse/FLINK-16509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arnaud Linz updated FLINK-16509: Description: New code of FlinkKafkaConsumerBase#initializeState(), logs restored state with:

[jira] [Updated] (FLINK-16509) FlinkKafkaConsumerBase tries to log a context that may not have been initialized and fails

[ https://issues.apache.org/jira/browse/FLINK-16509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arnaud Linz updated FLINK-16509: Description: New code of FlinkKafkaConsumerBase#initializeState(), logs restored state with:

[jira] [Updated] (FLINK-16509) FlinkKafkaConsumerBase tries to log a context that may not have been initialized and fails

[ https://issues.apache.org/jira/browse/FLINK-16509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arnaud Linz updated FLINK-16509: Description: New code of FlinkKafkaConsumerBase#initializeState(), logs restored state with: {{ 

[jira] [Created] (FLINK-16509) FlinkKafkaConsumerBase tries to log a context that may not have been initialized and fails

Arnaud Linz created FLINK-16509: --- Summary: FlinkKafkaConsumerBase tries to log a context that may not have been initialized and fails Key: FLINK-16509 URL: https://issues.apache.org/jira/browse/FLINK-16509

[jira] [Resolved] (FLINK-10832) StreamExecutionEnvironment.execute() does not return when all sources end

[ https://issues.apache.org/jira/browse/FLINK-10832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arnaud Linz resolved FLINK-10832. - Resolution: Won't Fix Release Note: Not a flink problem, but a JDK one, solved by

[jira] [Comment Edited] (FLINK-10832) StreamExecutionEnvironment.execute() does not return when all sources end

[ https://issues.apache.org/jira/browse/FLINK-10832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711803#comment-16711803 ] Arnaud Linz edited comment on FLINK-10832 at 12/7/18 3:37 PM: -- Okay, it

[jira] [Comment Edited] (FLINK-10832) StreamExecutionEnvironment.execute() does not return when all sources end

[ https://issues.apache.org/jira/browse/FLINK-10832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711803#comment-16711803 ] Arnaud Linz edited comment on FLINK-10832 at 12/6/18 6:22 PM: -- Okay, it

[jira] [Commented] (FLINK-10832) StreamExecutionEnvironment.execute() does not return when all sources end

[ https://issues.apache.org/jira/browse/FLINK-10832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711803#comment-16711803 ] Arnaud Linz commented on FLINK-10832: - Which jdk are you using? >

[jira] [Commented] (FLINK-10832) StreamExecutionEnvironment.execute() does not return when all sources end

[ https://issues.apache.org/jira/browse/FLINK-10832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16705012#comment-16705012 ] Arnaud Linz commented on FLINK-10832: - I've corrected my corrupted maven cache, now the run is fine.

[jira] [Commented] (FLINK-10832) StreamExecutionEnvironment.execute() does not return when all sources end

[ https://issues.apache.org/jira/browse/FLINK-10832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704554#comment-16704554 ] Arnaud Linz commented on FLINK-10832: - Okay, I've just tested with the new 1.7.0. All I did is to

[jira] [Commented] (FLINK-10832) StreamExecutionEnvironment.execute() does not return when all sources end

[ https://issues.apache.org/jira/browse/FLINK-10832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16694731#comment-16694731 ] Arnaud Linz commented on FLINK-10832: - Strange... I can reproduce it 100% of times. Have you tried

[jira] [Comment Edited] (FLINK-10832) StreamExecutionEnvironment.execute() does not return when all sources end

[ https://issues.apache.org/jira/browse/FLINK-10832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16694517#comment-16694517 ] Arnaud Linz edited comment on FLINK-10832 at 11/21/18 10:24 AM: The main

[jira] [Commented] (FLINK-10832) StreamExecutionEnvironment.execute() does not return when all sources end

[ https://issues.apache.org/jira/browse/FLINK-10832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16694517#comment-16694517 ] Arnaud Linz commented on FLINK-10832: - The main thread hangs in the MiniCluster.close() method on

[jira] [Commented] (FLINK-10832) StreamExecutionEnvironment.execute() does not return when all sources end

[ https://issues.apache.org/jira/browse/FLINK-10832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16694407#comment-16694407 ] Arnaud Linz commented on FLINK-10832: - Sorry for the long delay, I did not get the notification,

[jira] [Updated] (FLINK-10832) StreamExecutionEnvironment.execute() does not return when all sources end

[ https://issues.apache.org/jira/browse/FLINK-10832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arnaud Linz updated FLINK-10832: Attachment: (was: pom.xml) > StreamExecutionEnvironment.execute() does not return when all

[jira] [Updated] (FLINK-10832) StreamExecutionEnvironment.execute() does not return when all sources end

[ https://issues.apache.org/jira/browse/FLINK-10832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arnaud Linz updated FLINK-10832: Attachment: log.txt > StreamExecutionEnvironment.execute() does not return when all sources end >

[jira] [Updated] (FLINK-10832) StreamExecutionEnvironment.execute() does not return when all sources end

[ https://issues.apache.org/jira/browse/FLINK-10832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arnaud Linz updated FLINK-10832: Attachment: flink-10832.zip > StreamExecutionEnvironment.execute() does not return when all

[jira] [Updated] (FLINK-10832) StreamExecutionEnvironment.execute() does not return when all sources end

[ https://issues.apache.org/jira/browse/FLINK-10832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arnaud Linz updated FLINK-10832: Attachment: pom.xml > StreamExecutionEnvironment.execute() does not return when all sources end >

[jira] [Commented] (FLINK-10832) StreamExecutionEnvironment.execute() does not return when all sources end

[ https://issues.apache.org/jira/browse/FLINK-10832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16694375#comment-16694375 ] Arnaud Linz commented on FLINK-10832: - Sorry for the long reply, I did not get the post

[jira] [Issue Comment Deleted] (FLINK-10832) StreamExecutionEnvironment.execute() does not return when all sources end

[ https://issues.apache.org/jira/browse/FLINK-10832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arnaud Linz updated FLINK-10832: Comment: was deleted (was: Sorry for the long reply, I did not get the post notification. Your

[jira] [Updated] (FLINK-10832) StreamExecutionEnvironment.execute() does not return when all sources end

[ https://issues.apache.org/jira/browse/FLINK-10832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arnaud Linz updated FLINK-10832: Description: In 1.5.5, 1.6.1 and 1.6.2 (it works in 1.6.0 and 1.3.2),  This code never ends :   

[jira] [Updated] (FLINK-10832) StreamExecutionEnvironment.execute() does not return when all sources end

[ https://issues.apache.org/jira/browse/FLINK-10832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arnaud Linz updated FLINK-10832: Description: In 1.5.5, 1.6.1 and 1.6.2 (it works in 1.6.0 and 1.3.2),  This code never ends :   

[jira] [Updated] (FLINK-10832) StreamExecutionEnvironment.execute() does not return when all sources end

[ https://issues.apache.org/jira/browse/FLINK-10832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arnaud Linz updated FLINK-10832: Description: In 1.5.5, 1.6.1 and 1.6.2 (it works in 1.6.0 and 1.3.2),  This code never ends : 

[jira] [Created] (FLINK-10832) StreamExecutionEnvironment.execute() does not return when all sources end

Arnaud Linz created FLINK-10832: --- Summary: StreamExecutionEnvironment.execute() does not return when all sources end Key: FLINK-10832 URL: https://issues.apache.org/jira/browse/FLINK-10832 Project:

[jira] [Updated] (FLINK-10832) StreamExecutionEnvironment.execute() does not return when all sources end

[ https://issues.apache.org/jira/browse/FLINK-10832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arnaud Linz updated FLINK-10832: Description: In 1.5.5, 1.6.1 and 1.6.2 (it works in 1.6.0 and 1.3.2),  This code never ends :   

[jira] [Updated] (FLINK-8580) No easy way (or issues when trying?) to handle multiple yarn sessions and choose at runtime the one to submit a ha streaming job

[ https://issues.apache.org/jira/browse/FLINK-8580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arnaud Linz updated FLINK-8580: --- Description: Hello, I am using Flink 1.3.2 and I’m struggling to achieve something that should be

[jira] [Created] (FLINK-8580) No easy way (or issues when trying?) to handle multiple yarn sessions and choose at runtime the one to submit a ha streaming job

Arnaud Linz created FLINK-8580: -- Summary: No easy way (or issues when trying?) to handle multiple yarn sessions and choose at runtime the one to submit a ha streaming job Key: FLINK-8580 URL:

[jira] [Closed] (FLINK-6289) ExecutionEnvironment.readTextFile() can read gzip files & directories but not both

[ https://issues.apache.org/jira/browse/FLINK-6289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arnaud Linz closed FLINK-6289. -- Resolution: Invalid Fix Version/s: 1.1.3 Actually, it works... It seems I was to quick to report

[jira] [Created] (FLINK-6289) ExecutionEnvironment.readTextFile() can read gzip files & directories but not both

Arnaud Linz created FLINK-6289: -- Summary: ExecutionEnvironment.readTextFile() can read gzip files & directories but not both Key: FLINK-6289 URL: https://issues.apache.org/jira/browse/FLINK-6289

[jira] [Created] (FLINK-5305) Documentation of collect() should mention parameter akka.framesize

Arnaud Linz created FLINK-5305: -- Summary: Documentation of collect() should mention parameter akka.framesize Key: FLINK-5305 URL: https://issues.apache.org/jira/browse/FLINK-5305 Project: Flink

[jira] [Commented] (FLINK-4079) YARN properties file used for per-job cluster

[ https://issues.apache.org/jira/browse/FLINK-4079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15341327#comment-15341327 ] Arnaud Linz commented on FLINK-4079: Personally, I'd like to since it is a blocking problem on one of

[jira] [Commented] (FLINK-3763) RabbitMQ Source/Sink standardize connection parameters

[ https://issues.apache.org/jira/browse/FLINK-3763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15324308#comment-15324308 ] Arnaud Linz commented on FLINK-3763: No, but I do remember having lost patience on my early usage of

[jira] [Commented] (FLINK-3763) RabbitMQ Source/Sink standardize connection parameters

[ https://issues.apache.org/jira/browse/FLINK-3763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322517#comment-15322517 ] Arnaud Linz commented on FLINK-3763: This comment is probably too late, but I have a problem with :

[jira] [Commented] (FLINK-3763) RabbitMQ Source/Sink standardize connection parameters

[ https://issues.apache.org/jira/browse/FLINK-3763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15306684#comment-15306684 ] Arnaud Linz commented on FLINK-3763: IMO, this source lacks many RMQ features in order to make it

[jira] [Issue Comment Deleted] (FLINK-3763) RabbitMQ Source/Sink standardize connection parameters

[ https://issues.apache.org/jira/browse/FLINK-3763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arnaud Linz updated FLINK-3763: --- Comment: was deleted (was: IMO, this source lacks many RMQ features in order to make it usable in

[jira] [Commented] (FLINK-3763) RabbitMQ Source/Sink standardize connection parameters

[ https://issues.apache.org/jira/browse/FLINK-3763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15306678#comment-15306678 ] Arnaud Linz commented on FLINK-3763: IMO, this source lacks many RMQ features in order to make it

[jira] [Commented] (FLINK-2617) ConcurrentModificationException when using HCatRecordReader to access a hive table

[ https://issues.apache.org/jira/browse/FLINK-2617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14740440#comment-14740440 ] Arnaud Linz commented on FLINK-2617: Well, I've searched apache snapshot repository for 0.9-SNAPSHOT

[jira] [Commented] (FLINK-2617) ConcurrentModificationException when using HCatRecordReader to access a hive table

[ https://issues.apache.org/jira/browse/FLINK-2617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14740386#comment-14740386 ] Arnaud Linz commented on FLINK-2617: Hi, today (11-09) I've tested the 0.10 nightly build with

[jira] [Commented] (FLINK-2617) ConcurrentModificationException when using HCatRecordReader to access a hive table

[ https://issues.apache.org/jira/browse/FLINK-2617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14736262#comment-14736262 ] Arnaud Linz commented on FLINK-2617: hive-hcatalog-core-0.14.0.jar > ConcurrentModificationException

[jira] [Commented] (FLINK-2617) ConcurrentModificationException when using HCatRecordReader to access a hive table

[ https://issues.apache.org/jira/browse/FLINK-2617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14729289#comment-14729289 ] Arnaud Linz commented on FLINK-2617: (I think that the subject is in fact critical because it happens

[jira] [Updated] (FLINK-2617) ConcurrentModificationException when using HCatRecordReader to access a hive table

[ https://issues.apache.org/jira/browse/FLINK-2617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arnaud Linz updated FLINK-2617: --- Priority: Critical (was: Major) > ConcurrentModificationException when using HCatRecordReader to

[jira] [Created] (FLINK-2617) ConcurrentModificationException when using HCatRecordReader to access a hive table

Arnaud Linz created FLINK-2617: -- Summary: ConcurrentModificationException when using HCatRecordReader to access a hive table Key: FLINK-2617 URL: https://issues.apache.org/jira/browse/FLINK-2617

[jira] [Created] (FLINK-2589) Threads created in TimeTriggerPolicy don't end properly

Arnaud Linz created FLINK-2589: -- Summary: Threads created in TimeTriggerPolicy don't end properly Key: FLINK-2589 URL: https://issues.apache.org/jira/browse/FLINK-2589 Project: Flink Issue

[jira] [Created] (FLINK-2579) StreamExecutionEnvironment ExecutionEnvironment do not share interface but have a lot in common

Arnaud Linz created FLINK-2579: -- Summary: StreamExecutionEnvironment ExecutionEnvironment do not share interface but have a lot in common Key: FLINK-2579 URL: https://issues.apache.org/jira/browse/FLINK-2579

[jira] [Created] (FLINK-2580) HadoopDataOutputStream does not expose enough methods of org.apache.hadoop.fs.FSDataOutputStream

Arnaud Linz created FLINK-2580: -- Summary: HadoopDataOutputStream does not expose enough methods of org.apache.hadoop.fs.FSDataOutputStream Key: FLINK-2580 URL: https://issues.apache.org/jira/browse/FLINK-2580