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

2016-06-09 Thread ASF GitHub Bot (JIRA)
[ 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:

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

2016-06-09 Thread sbcd90
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] [Resolved] (FLINK-4052) Unstable test ConnectionUtilsTest

2016-06-09 Thread Stephan Ewen (JIRA)
[ 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

2016-06-09 Thread Stephan Ewen (JIRA)
[ 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:

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

2016-06-09 Thread Stephan Ewen (JIRA)
[ 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] [Commented] (FLINK-2170) Add OrcTableSource

2016-06-09 Thread Fabian Hueske (JIRA)
[ 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

2016-06-09 Thread Fabian Hueske (JIRA)
[ 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] [Updated] (FLINK-2170) Add OrcTableSource

2016-06-09 Thread Fabian Hueske (JIRA)
[ 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

2016-06-09 Thread Ufuk Celebi (JIRA)
[ 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

2016-06-09 Thread Ufuk Celebi (JIRA)
[ 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-4014) Jobs hang. Maybe NetworkBufferPool and LocalBufferPool has some problem

2016-06-09 Thread Ufuk Celebi (JIRA)
[ 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-4014) Jobs hang. Maybe NetworkBufferPool and LocalBufferPool has some problem

2016-06-09 Thread Ufuk Celebi (JIRA)
[ 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-2170) Add OrcTableSource

2016-06-09 Thread Owen O'Malley (JIRA)
[ 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] [Created] (FLINK-4053) Return value from Connection should be checked against null

2016-06-09 Thread Ted Yu (JIRA)
Ted Yu created FLINK-4053: - Summary: Return value from Connection should be checked against null Key: FLINK-4053 URL: https://issues.apache.org/jira/browse/FLINK-4053 Project: Flink Issue Type: Bug

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

2016-06-09 Thread Stephan Ewen (JIRA)
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] [Commented] (FLINK-4051) RabbitMQ Source might not react to cancel signal

2016-06-09 Thread Stephan Ewen (JIRA)
[ 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

2016-06-09 Thread ASF GitHub Bot (JIRA)
[ 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

2016-06-09 Thread omaralvarez
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-4002) [py] Improve testing infraestructure

2016-06-09 Thread ASF GitHub Bot (JIRA)
[ 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:

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

2016-06-09 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2063 Looks good, I'll merge it later on. --- 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-4002) [py] Improve testing infraestructure

2016-06-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322852#comment-15322852 ] ASF GitHub Bot commented on FLINK-4002: --- Github user omaralvarez commented on the issue:

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

2016-06-09 Thread omaralvarez
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-2985) Allow different field names for unionAll() in Table API

2016-06-09 Thread ASF GitHub Bot (JIRA)
[ 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 pull request #2078: [FLINK-2985] Allow different field names for union...

2016-06-09 Thread fhueske
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(

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

2016-06-09 Thread fhueske
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

2016-06-09 Thread ASF GitHub Bot (JIRA)
[ 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:

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

2016-06-09 Thread Subhankar Biswas (JIRA)
[ 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 >

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

2016-06-09 Thread Robert Metzger (JIRA)
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-3763) RabbitMQ Source/Sink standardize connection parameters

2016-06-09 Thread Robert Metzger (JIRA)
[ 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] [Commented] (FLINK-2985) Allow different field names for unionAll() in Table API

2016-06-09 Thread ASF GitHub Bot (JIRA)
[ 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...

2016-06-09 Thread fhueske
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

2016-06-09 Thread Elias Levy (JIRA)
[ 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] [Created] (FLINK-4050) FlinkKafkaProducer API Refactor

2016-06-09 Thread Elias Levy (JIRA)
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-4048) Remove Hadoop dependencies from ExecutionEnvironment

2016-06-09 Thread Robert Metzger (JIRA)
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-4049) Mark RichInputFormat.openInputFormat and closeInputFormat as @PublicEvolving

2016-06-09 Thread Robert Metzger (JIRA)
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] [Commented] (FLINK-3990) ZooKeeperLeaderElectionTest kills the JVM

2016-06-09 Thread Till Rohrmann (JIRA)
[ 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

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

2016-06-09 Thread ASF GitHub Bot (JIRA)
[ 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] [Commented] (FLINK-3859) Add BigDecimal/BigInteger support to Table API

2016-06-09 Thread ASF GitHub Bot (JIRA)
[ 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:

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

2016-06-09 Thread twalthr
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

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

2016-06-09 Thread IgorBerman
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-3990) ZooKeeperLeaderElectionTest kills the JVM

2016-06-09 Thread Till Rohrmann (JIRA)
[ 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] [Created] (FLINK-4047) Fix documentation about determinism of KeySelectors

2016-06-09 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-4047: Summary: Fix documentation about determinism of KeySelectors Key: FLINK-4047 URL: https://issues.apache.org/jira/browse/FLINK-4047 Project: Flink Issue

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

2016-06-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322562#comment-15322562 ] Robert Metzger commented on FLINK-3990: --- The linked logs contain a different failure. Maybe you

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

2016-06-09 Thread Till Rohrmann (JIRA)
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

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

2016-06-09 Thread Tzu-Li (Gordon) Tai (JIRA)
[ 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

2016-06-09 Thread Tzu-Li (Gordon) Tai (JIRA)
[ 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-3763) RabbitMQ Source/Sink standardize connection parameters

2016-06-09 Thread Arnaud Linz (JIRA)
[ 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-4027) FlinkKafkaProducer09 sink can lose messages

2016-06-09 Thread Aljoscha Krettek (JIRA)
[ 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:

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

2016-06-09 Thread ASF GitHub Bot (JIRA)
[ 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:

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

2016-06-09 Thread asfgit
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

2016-06-09 Thread Robert Metzger (JIRA)
[ 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

2016-06-09 Thread ASF GitHub Bot (JIRA)
[ 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] [Resolved] (FLINK-3763) RabbitMQ Source/Sink standardize connection parameters

2016-06-09 Thread Robert Metzger (JIRA)
[ 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

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

2016-06-09 Thread asfgit
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-4034) Dependency convergence on com.101tec:zkclient and com.esotericsoftware.kryo:kryo

2016-06-09 Thread Robert Metzger (JIRA)
[ 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] [Updated] (FLINK-4034) Dependency convergence on com.101tec:zkclient and com.esotericsoftware.kryo:kryo

2016-06-09 Thread Robert Metzger (JIRA)
[ 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 >

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

2016-06-09 Thread Robert Metzger (JIRA)
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] [Updated] (FLINK-4045) Test AMQP connector using Apache ActiveMQ emebdded broker

2016-06-09 Thread Robert Metzger (JIRA)
[ 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-4044) Rename RabbitMQ connector to AMQP connector

2016-06-09 Thread Robert Metzger (JIRA)
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-4043) Generalize RabbitMQ connector into AMQP connector

2016-06-09 Thread Robert Metzger (JIRA)
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

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

2016-06-09 Thread Robert Metzger (JIRA)
[ 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] [Commented] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0

2016-06-09 Thread Aljoscha Krettek (JIRA)
[ 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] [Commented] (FLINK-3977) Subclasses of InternalWindowFunction must support OutputTypeConfigurable

2016-06-09 Thread ASF GitHub Bot (JIRA)
[ 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

2016-06-09 Thread aljoscha
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 pull request #2087: [hotfix] [streaming-java] Harden IterateTest

2016-06-09 Thread asfgit
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

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

2016-06-09 Thread uce
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] [Commented] (FLINK-3763) RabbitMQ Source/Sink standardize connection parameters

2016-06-09 Thread ASF GitHub Bot (JIRA)
[ 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:

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

2016-06-09 Thread rmetzger
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] [Commented] (FLINK-3854) Support Avro key-value rolling sink writer

2016-06-09 Thread ASF GitHub Bot (JIRA)
[ 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 #1953: [FLINK-3854] Support Avro key-value rolling sink writer

2016-06-09 Thread rmetzger
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

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

2016-06-09 Thread ASF GitHub Bot (JIRA)
[ 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:

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

2016-06-09 Thread Robert Metzger (JIRA)
[ 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

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

2016-06-09 Thread asfgit
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] [Created] (FLINK-4042) TwitterStream example does not work

2016-06-09 Thread Till Rohrmann (JIRA)
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-3763) RabbitMQ Source/Sink standardize connection parameters

2016-06-09 Thread Robert Metzger (JIRA)
[ 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] [Comment Edited] (FLINK-3763) RabbitMQ Source/Sink standardize connection parameters

2016-06-09 Thread Robert Metzger (JIRA)
[ 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] [Created] (FLINK-4041) Failure while asking ResourceManager for RegisterResource

2016-06-09 Thread Robert Metzger (JIRA)
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] [Commented] (FLINK-3650) Add maxBy/minBy to Scala DataSet API

2016-06-09 Thread ramkrishna.s.vasudevan (JIRA)
[ 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] [Updated] (FLINK-4040) Same env.java.opts is applied for TM , JM and ZK

2016-06-09 Thread Gyula Fora (JIRA)
[ 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] [Created] (FLINK-4040) Same env.java.opts is applied for TM , JM and ZK

2016-06-09 Thread Gyula Fora (JIRA)
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] [Created] (FLINK-4039) G1 garbage collector only set if no custom jvm arguments

2016-06-09 Thread Gyula Fora (JIRA)
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 pull request #2087: [hotfix] [streaming-java] Harden IterateTest

2016-06-09 Thread uce
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

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

2016-06-09 Thread Gyula Fora (JIRA)
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

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

2016-06-09 Thread ASF GitHub Bot (JIRA)
[ 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...

2016-06-09 Thread rmetzger
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

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

2016-06-09 Thread Robert Metzger (JIRA)
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

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

2016-06-09 Thread tzulitai
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

2016-06-09 Thread ASF GitHub Bot (JIRA)
[ 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] [Commented] (FLINK-3854) Support Avro key-value rolling sink writer

2016-06-09 Thread ASF GitHub Bot (JIRA)
[ 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:

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

2016-06-09 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/1953 The tests are executing very fast: ![image](https://cloud.githubusercontent.com/assets/89049/15924303/babee52c-2e31-11e6-95da-468a0ff58ca0.png) --- If your project is set up for it, you can

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

2016-06-09 Thread asfgit
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

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

2016-06-09 Thread rmetzger
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

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

2016-06-09 Thread zentol
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] [Commented] (FLINK-4032) Replace all usage of Guava Preconditions

2016-06-09 Thread ASF GitHub Bot (JIRA)
[ 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:

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

2016-06-09 Thread ASF GitHub Bot (JIRA)
[ 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 issue #1953: [FLINK-3854] Support Avro key-value rolling sink writer

2016-06-09 Thread aljoscha
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

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

2016-06-09 Thread rmetzger
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

2016-06-09 Thread ASF GitHub Bot (JIRA)
[ 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:

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

2016-06-09 Thread ASF GitHub Bot (JIRA)
[ 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 #2084: [FLINK-4032] Replace all usages Guava preconditions

2016-06-09 Thread tzulitai
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

  1   2   >