[jira] [Commented] (FLINK-3650) Add maxBy/minBy to Scala DataSet API

[ https://issues.apache.org/jira/browse/FLINK-3650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322334#comment-15322334 ] ramkrishna.s.vasudevan commented on FLINK-3650: --- [~till.rohrmann], [~trohrm...@apache.org]

[jira] [Commented] (FLINK-3854) Support Avro key-value rolling sink writer

[ https://issues.apache.org/jira/browse/FLINK-3854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322377#comment-15322377 ] ASF GitHub Bot commented on FLINK-3854: --- Github user asfgit closed the pull request at:

[GitHub] flink issue #1953: [FLINK-3854] Support Avro key-value rolling sink writer

Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/1953 Thank you for the contribution @IgorBerman --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature

[GitHub] flink pull request #2087: [hotfix] [streaming-java] Harden IterateTest

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2087 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0

[ https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322421#comment-15322421 ] Robert Metzger commented on FLINK-4035: --- I haven't looked into the Kafka 0.10 changes in detail. If

[jira] [Created] (FLINK-4044) Rename RabbitMQ connector to AMQP connector

Robert Metzger created FLINK-4044: - Summary: Rename RabbitMQ connector to AMQP connector Key: FLINK-4044 URL: https://issues.apache.org/jira/browse/FLINK-4044 Project: Flink Issue Type:

[jira] [Created] (FLINK-4041) Failure while asking ResourceManager for RegisterResource

Robert Metzger created FLINK-4041: - Summary: Failure while asking ResourceManager for RegisterResource Key: FLINK-4041 URL: https://issues.apache.org/jira/browse/FLINK-4041 Project: Flink

[jira] [Created] (FLINK-4042) TwitterStream example does not work

Till Rohrmann created FLINK-4042: Summary: TwitterStream example does not work Key: FLINK-4042 URL: https://issues.apache.org/jira/browse/FLINK-4042 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0

[ https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322417#comment-15322417 ] Aljoscha Krettek commented on FLINK-4035: - We'll probably need a new package for Kafka 0.10

[jira] [Comment Edited] (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=15322345#comment-15322345 ] Robert Metzger edited comment on FLINK-3763 at 6/9/16 10:52 AM: The

[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=15322345#comment-15322345 ] Robert Metzger commented on FLINK-3763: --- The Javadoc of the close() method (we are calling) states

[jira] [Commented] (FLINK-3854) Support Avro key-value rolling sink writer

[ https://issues.apache.org/jira/browse/FLINK-3854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322380#comment-15322380 ] ASF GitHub Bot commented on FLINK-3854: --- Github user rmetzger commented on the issue:

[GitHub] flink issue #2054: [FLINK-3763] RabbitMQ Source/Sink standardize connection ...

Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2054 Okay, I reviewed your pull request and I like it ;) I'll merge your pull request together with some general RMQ cleanups:

[jira] [Updated] (FLINK-4045) Test AMQP connector using Apache ActiveMQ emebdded broker

[ https://issues.apache.org/jira/browse/FLINK-4045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4045: -- Summary: Test AMQP connector using Apache ActiveMQ emebdded broker (was: Test AMQP connector

[jira] [Created] (FLINK-4045) Test AMQP connector using Apache ActiveMQ

Robert Metzger created FLINK-4045: - Summary: Test AMQP connector using Apache ActiveMQ Key: FLINK-4045 URL: https://issues.apache.org/jira/browse/FLINK-4045 Project: Flink Issue Type:

[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=15322382#comment-15322382 ] ASF GitHub Bot commented on FLINK-3763: --- Github user rmetzger commented on the issue:

[jira] [Commented] (FLINK-3977) Subclasses of InternalWindowFunction must support OutputTypeConfigurable

[ https://issues.apache.org/jira/browse/FLINK-3977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322414#comment-15322414 ] ASF GitHub Bot commented on FLINK-3977: --- Github user aljoscha commented on the issue:

[GitHub] flink issue #2086: [FLINK-3977] initialize FoldApplyWindowFunction properly

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/2086 This is not the correct way to fix the problem. I wrote an outline of the correct solution here: https://issues.apache.org/jira/browse/FLINK-3977. --- If your project is set up for it, you can

[GitHub] flink issue #2087: [hotfix] [streaming-java] Harden IterateTest

Github user uce commented on the issue: https://github.com/apache/flink/pull/2087 Travis passed, I'm going to merge this. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled

[jira] [Created] (FLINK-4043) Generalize RabbitMQ connector into AMQP connector

Robert Metzger created FLINK-4043: - Summary: Generalize RabbitMQ connector into AMQP connector Key: FLINK-4043 URL: https://issues.apache.org/jira/browse/FLINK-4043 Project: Flink Issue

[GitHub] flink pull request #1953: [FLINK-3854] Support Avro key-value rolling sink w...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1953 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Resolved] (FLINK-3854) Support Avro key-value rolling sink writer

[ https://issues.apache.org/jira/browse/FLINK-3854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3854. --- Resolution: Fixed Assignee: Igor Berman Fix Version/s: 1.1.0 Resolved in

[jira] [Commented] (FLINK-4032) Replace all usage of Guava Preconditions

[ https://issues.apache.org/jira/browse/FLINK-4032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322184#comment-15322184 ] ASF GitHub Bot commented on FLINK-4032: --- Github user zentol commented on the issue:

[GitHub] flink issue #2084: [FLINK-4032] Replace all usages Guava preconditions

Github user zentol commented on the issue: https://github.com/apache/flink/pull/2084 It is still used in FlinkKinesisProducer. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature

[jira] [Created] (FLINK-4037) Introduce ArchivedExecutionGraph without any user classes

Robert Metzger created FLINK-4037: - Summary: Introduce ArchivedExecutionGraph without any user classes Key: FLINK-4037 URL: https://issues.apache.org/jira/browse/FLINK-4037 Project: Flink

[jira] [Created] (FLINK-4040) Same env.java.opts is applied for TM , JM and ZK

Gyula Fora created FLINK-4040: - Summary: Same env.java.opts is applied for TM , JM and ZK Key: FLINK-4040 URL: https://issues.apache.org/jira/browse/FLINK-4040 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-4040) Same env.java.opts is applied for TM , JM and ZK

[ https://issues.apache.org/jira/browse/FLINK-4040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-4040: -- Component/s: Start-Stop Scripts > Same env.java.opts is applied for TM , JM and ZK >

[jira] [Commented] (FLINK-4032) Replace all usage of Guava Preconditions

[ https://issues.apache.org/jira/browse/FLINK-4032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322100#comment-15322100 ] ASF GitHub Bot commented on FLINK-4032: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #2084: [FLINK-4032] Replace all usages Guava preconditions

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2084 I think the Kinesis connector is missed out as part of this cleanup. Thanks for this! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Commented] (FLINK-4032) Replace all usage of Guava Preconditions

[ https://issues.apache.org/jira/browse/FLINK-4032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322158#comment-15322158 ] ASF GitHub Bot commented on FLINK-4032: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #1953: [FLINK-3854] Support Avro key-value rolling sink writer

Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/1953 The tests are executing very fast:  --- If your project is set up for it, you can

[jira] [Commented] (FLINK-3854) Support Avro key-value rolling sink writer

[ https://issues.apache.org/jira/browse/FLINK-3854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322194#comment-15322194 ] ASF GitHub Bot commented on FLINK-3854: --- Github user rmetzger commented on the issue:

[jira] [Created] (FLINK-4038) Impossible to set more than 1 JVM argument in env.java.opts

Gyula Fora created FLINK-4038: - Summary: Impossible to set more than 1 JVM argument in env.java.opts Key: FLINK-4038 URL: https://issues.apache.org/jira/browse/FLINK-4038 Project: Flink Issue

[GitHub] flink issue #2057: [hotfix] Fix JSONDeserializationSchema for Kafka; Paramet...

Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2057 Thanks for the review. I'll split and merge the commits --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[jira] [Created] (FLINK-4036) Potential deadlock in StreamIterationSink

Ufuk Celebi created FLINK-4036: -- Summary: Potential deadlock in StreamIterationSink Key: FLINK-4036 URL: https://issues.apache.org/jira/browse/FLINK-4036 Project: Flink Issue Type: Bug

[GitHub] flink issue #2084: [FLINK-4032] Replace all usages Guava preconditions

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2084 Oops, my mistake again ;) Thanks. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled

[jira] [Commented] (FLINK-4032) Replace all usage of Guava Preconditions

[ https://issues.apache.org/jira/browse/FLINK-4032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322198#comment-15322198 ] ASF GitHub Bot commented on FLINK-4032: --- Github user tzulitai commented on the issue:

[jira] [Created] (FLINK-4039) G1 garbage collector only set if no custom jvm arguments

Gyula Fora created FLINK-4039: - Summary: G1 garbage collector only set if no custom jvm arguments Key: FLINK-4039 URL: https://issues.apache.org/jira/browse/FLINK-4039 Project: Flink Issue Type:

[GitHub] flink issue #2084: [FLINK-4032] Replace all usages Guava preconditions

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2084 Ah right, sorry I was mistaken by the guava dependency in pom.xml. The dependency can actually be safely removed also though, must have accidentally left it there when the connector was cleaned up

[jira] [Commented] (FLINK-3854) Support Avro key-value rolling sink writer

[ https://issues.apache.org/jira/browse/FLINK-3854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322179#comment-15322179 ] ASF GitHub Bot commented on FLINK-3854: --- Github user aljoscha commented on the issue:

[GitHub] flink pull request #2087: [hotfix] [streaming-java] Harden IterateTest

GitHub user uce opened a pull request: https://github.com/apache/flink/pull/2087 [hotfix] [streaming-java] Harden IterateTest Adds retries and timeout scaling to all iteration tests, which rely on iteration timeouts. The way the tests rely on these timoeuts is prone to races. If

[GitHub] flink issue #2084: [FLINK-4032] Replace all usages Guava preconditions

Github user zentol commented on the issue: https://github.com/apache/flink/pull/2084 The Kinesis connector already uses Flink's Preconditions class. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does

[jira] [Commented] (FLINK-4032) Replace all usage of Guava Preconditions

[ https://issues.apache.org/jira/browse/FLINK-4032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322116#comment-15322116 ] ASF GitHub Bot commented on FLINK-4032: --- Github user zentol commented on the issue:

[GitHub] flink issue #1953: [FLINK-3854] Support Avro key-value rolling sink writer

Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/1953 I'm merging this change --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and

[jira] [Commented] (FLINK-3854) Support Avro key-value rolling sink writer

[ https://issues.apache.org/jira/browse/FLINK-3854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322169#comment-15322169 ] ASF GitHub Bot commented on FLINK-3854: --- Github user rmetzger commented on the issue:

[GitHub] flink pull request #2057: [hotfix] Fix JSONDeserializationSchema for Kafka; ...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2057 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-4020) Remove shard list querying from Kinesis consumer constructor

[ https://issues.apache.org/jira/browse/FLINK-4020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322207#comment-15322207 ] ASF GitHub Bot commented on FLINK-4020: --- Github user rmetzger commented on the issue:

[GitHub] flink issue #2081: [FLINK-4020][streaming-connectors] Move shard list queryi...

Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2081 I'll try to review this change soon. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature

[GitHub] flink issue #1953: [FLINK-3854] Support Avro key-value rolling sink writer

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/1953 This is introducing two new ITCases, though. I thought we want to reduce the number of those because they slow down the build. --- If your project is set up for it, you can reply to this email and

[jira] [Created] (FLINK-4046) Failing a restarting job can get stuck in JobStatus.FAILING

Till Rohrmann created FLINK-4046: Summary: Failing a restarting job can get stuck in JobStatus.FAILING Key: FLINK-4046 URL: https://issues.apache.org/jira/browse/FLINK-4046 Project: Flink

[GitHub] flink issue #1953: [FLINK-3854] Support Avro key-value rolling sink writer

Github user IgorBerman commented on the issue: https://github.com/apache/flink/pull/1953 @rmetzger @aljoscha thanks guys, sorry couldn't refactor tests, a bit of pressure at work. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[jira] [Commented] (FLINK-4034) Dependency convergence on com.101tec:zkclient and com.esotericsoftware.kryo:kryo

[ https://issues.apache.org/jira/browse/FLINK-4034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322456#comment-15322456 ] Robert Metzger commented on FLINK-4034: --- Hi, thank you for opening this issue. We rely on the

[jira] [Commented] (FLINK-3231) Handle Kinesis-side resharding in Kinesis streaming consumer

[ https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322524#comment-15322524 ] Tzu-Li (Gordon) Tai commented on FLINK-3231: Update for this: Had a talk with [~rmetzger]

[jira] [Assigned] (FLINK-3231) Handle Kinesis-side resharding in Kinesis streaming consumer

[ https://issues.apache.org/jira/browse/FLINK-3231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-3231: -- Assignee: Tzu-Li (Gordon) Tai > Handle Kinesis-side resharding in Kinesis

[jira] [Commented] (FLINK-3990) ZooKeeperLeaderElectionTest kills the JVM

[ https://issues.apache.org/jira/browse/FLINK-3990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322571#comment-15322571 ] Till Rohrmann commented on FLINK-3990: -- This log should be an instance of this issue:

[jira] [Updated] (FLINK-4034) Dependency convergence on com.101tec:zkclient and com.esotericsoftware.kryo:kryo

[ https://issues.apache.org/jira/browse/FLINK-4034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4034: -- Component/s: Build System > Dependency convergence on com.101tec:zkclient and >

[GitHub] flink pull request #2054: [FLINK-3763] RabbitMQ Source/Sink standardize conn...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2054 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (FLINK-3854) Support Avro key-value rolling sink writer

[ https://issues.apache.org/jira/browse/FLINK-3854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322574#comment-15322574 ] ASF GitHub Bot commented on FLINK-3854: --- Github user IgorBerman commented on the issue:

[jira] [Created] (FLINK-4049) Mark RichInputFormat.openInputFormat and closeInputFormat as @PublicEvolving

Robert Metzger created FLINK-4049: - Summary: Mark RichInputFormat.openInputFormat and closeInputFormat as @PublicEvolving Key: FLINK-4049 URL: https://issues.apache.org/jira/browse/FLINK-4049

[jira] [Created] (FLINK-4048) Remove Hadoop dependencies from ExecutionEnvironment

Robert Metzger created FLINK-4048: - Summary: Remove Hadoop dependencies from ExecutionEnvironment Key: FLINK-4048 URL: https://issues.apache.org/jira/browse/FLINK-4048 Project: Flink Issue

[jira] [Created] (FLINK-4050) FlinkKafkaProducer API Refactor

Elias Levy created FLINK-4050: - Summary: FlinkKafkaProducer API Refactor Key: FLINK-4050 URL: https://issues.apache.org/jira/browse/FLINK-4050 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-4051) RabbitMQ Source might not react to cancel signal

Robert Metzger created FLINK-4051: - Summary: RabbitMQ Source might not react to cancel signal Key: FLINK-4051 URL: https://issues.apache.org/jira/browse/FLINK-4051 Project: Flink Issue Type:

[jira] [Commented] (FLINK-2985) Allow different field names for unionAll() in Table API

[ https://issues.apache.org/jira/browse/FLINK-2985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322761#comment-15322761 ] ASF GitHub Bot commented on FLINK-2985: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request #2078: [FLINK-2985] Allow different field names for union...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2078#discussion_r66469727 --- Diff: flink-java/src/main/java/org/apache/flink/api/java/operators/UnionOperator.java --- @@ -43,11 +42,6 @@ public UnionOperator(DataSet

[jira] [Commented] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0

[ https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322741#comment-15322741 ] Elias Levy commented on FLINK-4035: --- AFAIK there haven't been changes to the producer API in 0.10, just

[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=15322767#comment-15322767 ] Robert Metzger commented on FLINK-3763: --- Good point. I'll open a new JIRA for the issue. > RabbitMQ

[jira] [Assigned] (FLINK-4051) RabbitMQ Source might not react to cancel signal

[ https://issues.apache.org/jira/browse/FLINK-4051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Subhankar Biswas reassigned FLINK-4051: --- Assignee: Subhankar Biswas > RabbitMQ Source might not react to cancel signal >

[GitHub] flink issue #2078: [FLINK-2985] Allow different field names for unionAll() i...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2078 Hi @gallenvara, this issue cannot be easily solved. The `TypeInfo` check in `UnionOperator` cannot be removed, because it prevents that incompatible serializers are used at runtime. However, the

[jira] [Commented] (FLINK-2985) Allow different field names for unionAll() in Table API

[ https://issues.apache.org/jira/browse/FLINK-2985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322822#comment-15322822 ] ASF GitHub Bot commented on FLINK-2985: --- Github user fhueske commented on the issue:

[GitHub] flink pull request #2078: [FLINK-2985] Allow different field names for union...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2078#discussion_r66476461 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/batch/table/UnionITCase.scala --- @@ -69,6 +69,36 @@ class UnionITCase(

[jira] [Commented] (FLINK-2985) Allow different field names for unionAll() in Table API

[ https://issues.apache.org/jira/browse/FLINK-2985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322832#comment-15322832 ] ASF GitHub Bot commented on FLINK-2985: --- Github user fhueske commented on a diff in the pull

[GitHub] flink issue #2063: [FLINK-4002] [py] Improve testing infraestructure

Github user omaralvarez commented on the issue: https://github.com/apache/flink/pull/2063 Is everything ok? Should I look into something else? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have

[jira] [Commented] (FLINK-4014) Jobs hang. Maybe NetworkBufferPool and LocalBufferPool has some problem

[ https://issues.apache.org/jira/browse/FLINK-4014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15323320#comment-15323320 ] Ufuk Celebi commented on FLINK-4014: Hey Zheng! Thanks for the stack trace. All tasks are either

[jira] [Commented] (FLINK-4014) Jobs hang. Maybe NetworkBufferPool and LocalBufferPool has some problem

[ https://issues.apache.org/jira/browse/FLINK-4014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15323319#comment-15323319 ] Ufuk Celebi commented on FLINK-4014: Hey Zheng! Thanks for the stack trace. All tasks are either

[jira] [Commented] (FLINK-2170) Add OrcTableSource

[ https://issues.apache.org/jira/browse/FLINK-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15323281#comment-15323281 ] Owen O'Malley commented on FLINK-2170: -- If no one is working on this, I'd like to work on this. >

[jira] [Updated] (FLINK-2170) Add OrcTableSource

[ https://issues.apache.org/jira/browse/FLINK-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2170: - Assignee: (was: Eric Falk) > Add OrcTableSource > -- > > Key:

[jira] [Updated] (FLINK-4014) Job blocked on read/write buffer requests

[ https://issues.apache.org/jira/browse/FLINK-4014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-4014: --- Summary: Job blocked on read/write buffer requests (was: Jobs hang. Maybe NetworkBufferPool and

[jira] [Issue Comment Deleted] (FLINK-4014) Jobs hang. Maybe NetworkBufferPool and LocalBufferPool has some problem

[ https://issues.apache.org/jira/browse/FLINK-4014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-4014: --- Comment: was deleted (was: Hey Zheng! Thanks for the stack trace. All tasks are either requesting a

[jira] [Commented] (FLINK-2170) Add OrcTableSource

[ https://issues.apache.org/jira/browse/FLINK-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15323351#comment-15323351 ] Fabian Hueske commented on FLINK-2170: -- Hi [~owen.omalley], we haven't added support for pushing

[jira] [Updated] (FLINK-2170) Add OrcTableSource

[ https://issues.apache.org/jira/browse/FLINK-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-2170: - Assignee: Owen O'Malley > Add OrcTableSource > -- > > Key:

[jira] [Commented] (FLINK-4002) [py] Improve testing infraestructure

[ https://issues.apache.org/jira/browse/FLINK-4002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15323054#comment-15323054 ] ASF GitHub Bot commented on FLINK-4002: --- Github user omaralvarez commented on the issue:

[GitHub] flink issue #2063: [FLINK-4002] [py] Improve testing infraestructure

Github user omaralvarez commented on the issue: https://github.com/apache/flink/pull/2063 Thanks! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if

[jira] [Commented] (FLINK-4051) RabbitMQ Source might not react to cancel signal

[ https://issues.apache.org/jira/browse/FLINK-4051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15323064#comment-15323064 ] Stephan Ewen commented on FLINK-4051: - Does {{nextDelivery()}} not react to thread interruptions? >

[jira] [Commented] (FLINK-4002) [py] Improve testing infraestructure

[ https://issues.apache.org/jira/browse/FLINK-4002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322943#comment-15322943 ] ASF GitHub Bot commented on FLINK-4002: --- Github user zentol commented on the issue:

[jira] [Created] (FLINK-4052) Unstable test

Stephan Ewen created FLINK-4052: --- Summary: Unstable test Key: FLINK-4052 URL: https://issues.apache.org/jira/browse/FLINK-4052 Project: Flink Issue Type: Bug Components: Tests

[jira] [Updated] (FLINK-4052) Unstable test ConnectionUtilsTest

[ https://issues.apache.org/jira/browse/FLINK-4052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-4052: Summary: Unstable test ConnectionUtilsTest (was: Unstable test) > Unstable test

[jira] [Resolved] (FLINK-4052) Unstable test ConnectionUtilsTest

[ https://issues.apache.org/jira/browse/FLINK-4052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-4052. - Resolution: Fixed Fixed via 8696e799faf18027cd9f2479b24520cdcbca8bdb - Apache Git:

[jira] [Closed] (FLINK-4052) Unstable test ConnectionUtilsTest

[ https://issues.apache.org/jira/browse/FLINK-4052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4052. --- > Unstable test ConnectionUtilsTest > - > > Key:

[GitHub] flink issue #1962: [FLINK-3857][Streaming Connectors]Add reconnect attempt t...

Github user sbcd90 commented on the issue: https://github.com/apache/flink/pull/1962 Hello @tzulitai , I think default value for int in Java is 0. The check if connection is lost or not & then retry for connection is a good suggestion. Made the change. separated the

[jira] [Commented] (FLINK-3857) Add reconnect attempt to Elasticsearch host

[ https://issues.apache.org/jira/browse/FLINK-3857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15323745#comment-15323745 ] ASF GitHub Bot commented on FLINK-3857: --- Github user sbcd90 commented on the issue:

[jira] [Resolved] (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 ] Robert Metzger resolved FLINK-3763. --- Resolution: Fixed Fix Version/s: 1.1.0 Resolved 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=15322474#comment-15322474 ] ASF GitHub Bot commented on FLINK-3763: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-3530) Kafka09ITCase.testBigRecordJob fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-3530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322482#comment-15322482 ] ASF GitHub Bot commented on FLINK-3530: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-4027) FlinkKafkaProducer09 sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322509#comment-15322509 ] Aljoscha Krettek commented on FLINK-4027: - This is the mailing list thread about this:

[GitHub] flink pull request #2088: [FLINK-3859] [table] Add BigDecimal/BigInteger sup...

GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/2088 [FLINK-3859] [table] Add BigDecimal/BigInteger support to Table API - [x] General - The pull request references the related JIRA issue ("[FLINK-XXX] Jira title text") - The pull request

[jira] [Commented] (FLINK-3859) Add BigDecimal/BigInteger support to Table API

[ https://issues.apache.org/jira/browse/FLINK-3859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322577#comment-15322577 ] ASF GitHub Bot commented on FLINK-3859: --- GitHub user twalthr opened a pull request:

[jira] [Commented] (FLINK-3990) ZooKeeperLeaderElectionTest kills the JVM

[ https://issues.apache.org/jira/browse/FLINK-3990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322591#comment-15322591 ] Till Rohrmann commented on FLINK-3990: -- But the issue that the JVM dies seems to also happens with

[GitHub] flink pull request #2080: [FLINK-3530] Fix Kafka08 instability: Avoid restar...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2080 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Resolved] (FLINK-3530) Kafka09ITCase.testBigRecordJob fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-3530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3530. --- Resolution: Fixed Fix Version/s: 1.1.0 Resolved in Flink 1.1.0

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

  1   2   >