[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&focusedCommentId=17177709#comment-17177709 ] Arnaud Linz commented on FLINK-8580: Actually my cluster is a hadoop (yarn cluster),

[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&focusedCommentId=17055651#comment-17055651 ] Arnaud Linz commented on FLINK-16509: - I was too quick to open the case. It was a si

[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. Res

[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: {code

[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: {code

[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: {code

[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: {{ L

[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 upgrading

[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&focusedCommentId=16711803#comment-16711803 ] Arnaud Linz edited comment on FLINK-10832 at 12/7/18 3:37 PM:

[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&focusedCommentId=16711803#comment-16711803 ] Arnaud Linz edited comment on FLINK-10832 at 12/6/18 6:22 PM:

[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&focusedCommentId=16711803#comment-16711803 ] Arnaud Linz commented on FLINK-10832: - Which jdk are you using? > StreamExecutionEn

[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&focusedCommentId=16705012#comment-16705012 ] Arnaud Linz commented on FLINK-10832: - I've corrected my corrupted maven cache, now

[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&focusedCommentId=16704554#comment-16704554 ] Arnaud Linz commented on FLINK-10832: - Okay, I've just tested with the new 1.7.0. Al

[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&focusedCommentId=16694731#comment-16694731 ] Arnaud Linz commented on FLINK-10832: - Strange... I can reproduce it 100% of times.

[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&focusedCommentId=16694517#comment-16694517 ] Arnaud Linz edited comment on FLINK-10832 at 11/21/18 10:24 AM: --

[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&focusedCommentId=16694517#comment-16694517 ] Arnaud Linz commented on FLINK-10832: - The main thread hangs in the MiniCluster.clos

[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&focusedCommentId=16694407#comment-16694407 ] Arnaud Linz commented on FLINK-10832: - Sorry for the long delay, I did not get the n

[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 sou

[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: pom.xml > 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 source

[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&focusedCommentId=16694375#comment-16694375 ] Arnaud Linz commented on FLINK-10832: - Sorry for the long reply, I did not get the p

[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 qu

[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: Flin

[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 si

[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: https://issues.apache.or

[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 Project:

[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&focusedCommentId=15341327#comment-15341327 ] Arnaud Linz commented on FLINK-4079: Personally, I'd like to since it is a blocking pr

[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&focusedCommentId=15324308#comment-15324308 ] Arnaud Linz commented on FLINK-3763: No, but I do remember having lost patience on my

[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&focusedCommentId=15322517#comment-15322517 ] Arnaud Linz commented on FLINK-3763: This comment is probably too late, but I have a p

[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&focusedCommentId=15306684#comment-15306684 ] Arnaud Linz commented on FLINK-3763: IMO, this source lacks many RMQ features in order

[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 pro

[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&focusedCommentId=15306678#comment-15306678 ] Arnaud Linz commented on FLINK-3763: IMO, this source lacks many RMQ features in order

[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&focusedCommentId=14740440#comment-14740440 ] Arnaud Linz commented on FLINK-2617: Well, I've searched apache snapshot repository fo

[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&focusedCommentId=14740386#comment-14740386 ] Arnaud Linz commented on FLINK-2617: Hi, today (11-09) I've tested the 0.10 nightly b

[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&focusedCommentId=14736262#comment-14736262 ] Arnaud Linz commented on FLINK-2617: hive-hcatalog-core-0.14.0.jar > ConcurrentModifi

[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&focusedCommentId=14729289#comment-14729289 ] Arnaud Linz commented on FLINK-2617: (I think that the subject is in fact critical bec

[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 acce

[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 Project:

[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 Type:

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

[ https://issues.apache.org/jira/browse/FLINK-2579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14716855#comment-14716855 ] Arnaud Linz commented on FLINK-2579: I understand, it may not be such a good idea. W

[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

[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