[GitHub] flink issue #3891: [FLINK-6575] Disable tests on Windows that use HDFS

2017-06-29 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3891 One question: I'm curious how the scan for tests that use HDFS was done? --- 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 proje

[GitHub] flink issue #3891: [FLINK-6575] Disable tests on Windows that use HDFS

2017-06-29 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3891 This looks good! +1, merging ... --- 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 an

[jira] [Comment Edited] (FLINK-7047) Reorganize build profiles

2017-06-29 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069605#comment-16069605 ] Kostas Kloudas edited comment on FLINK-7047 at 6/30/17 6:54 AM:

[jira] [Commented] (FLINK-7047) Reorganize build profiles

2017-06-29 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069605#comment-16069605 ] Kostas Kloudas commented on FLINK-7047: --- I like this change. It is a more systematic

[GitHub] flink pull request #4167: Test PR, please ignore

2017-06-29 Thread zentol
Github user zentol closed the pull request at: https://github.com/apache/flink/pull/4167 --- 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 enab

[jira] [Commented] (FLINK-7047) Reorganize build profiles

2017-06-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069603#comment-16069603 ] Chesnay Schepler commented on FLINK-7047: - We can also think about adding more pro

[GitHub] flink pull request #3855: [FLINK-6496] Port SSl config parameters to ConfigO...

2017-06-29 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3855#discussion_r124972967 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/blob/BlobClientSslTest.java --- @@ -35,6 +35,7 @@ import org.apache.flink.configuration

[jira] [Commented] (FLINK-7047) Reorganize build profiles

2017-06-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069601#comment-16069601 ] Chesnay Schepler commented on FLINK-7047: - We can also do that now, but i wanted t

[jira] [Commented] (FLINK-6496) Migrate SSL configuration options

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069591#comment-16069591 ] ASF GitHub Bot commented on FLINK-6496: --- Github user tzulitai commented on a diff in

[jira] [Commented] (FLINK-6496) Migrate SSL configuration options

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069596#comment-16069596 ] ASF GitHub Bot commented on FLINK-6496: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-6496) Migrate SSL configuration options

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069594#comment-16069594 ] ASF GitHub Bot commented on FLINK-6496: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #3855: [FLINK-6496] Port SSl config parameters to ConfigO...

2017-06-29 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3855#discussion_r124973801 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/blob/BlobClientSslTest.java --- @@ -35,6 +35,7 @@ import org.apache.flink.configuration.C

[GitHub] flink pull request #3855: [FLINK-6496] Port SSl config parameters to ConfigO...

2017-06-29 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3855#discussion_r124973760 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/blob/BlobClientSslTest.java --- @@ -35,6 +35,7 @@ import org.apache.flink.configuration.C

[jira] [Commented] (FLINK-6502) Add support ElasticsearchSink for DataSet

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069579#comment-16069579 ] ASF GitHub Bot commented on FLINK-6502: --- Github user tzulitai commented on the issue

[jira] [Commented] (FLINK-7047) Reorganize build profiles

2017-06-29 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069580#comment-16069580 ] Aljoscha Krettek commented on FLINK-7047: - To me that sounds very good! We might b

[GitHub] flink issue #3869: [FLINK-6502] Add support ElasticsearchSink for DataSet

2017-06-29 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3869 @397090770 I'm afraid I will need to reject this PR as of its current state. The main issue is that we can't just move those public user-facing classes. We either have to deprecate them and

[jira] [Updated] (FLINK-7047) Reorganize build profiles

2017-06-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7047: Description: With the current build times once again hitting the timeout it is time to revi

[jira] [Commented] (FLINK-7045) Reduce element count of UdfStreamOperatorCheckpointingITCase

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069563#comment-16069563 ] ASF GitHub Bot commented on FLINK-7045: --- GitHub user zhangminglei opened a pull requ

[GitHub] flink pull request #4230: [FLINK-7045] [checkpoints] Reduce element count of...

2017-06-29 Thread zhangminglei
GitHub user zhangminglei opened a pull request: https://github.com/apache/flink/pull/4230 [FLINK-7045] [checkpoints] Reduce element count of UdfStreamOperatorC… With NUM_INPUT equals to 2,500,000. It costs 33s,556ms on my computer. But and I can get 10s, 915ms as I reduce the elem

[jira] [Commented] (FLINK-7047) Reorganize build profiles

2017-06-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069562#comment-16069562 ] Chesnay Schepler commented on FLINK-7047: - here's an exxample build https://travis

[jira] [Commented] (FLINK-7045) Reduce element count of UdfStreamOperatorCheckpointingITCase

2017-06-29 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069558#comment-16069558 ] mingleizhang commented on FLINK-7045: - With NUM_INPUT equals 2,500,000. It costs *33s,

[jira] [Commented] (FLINK-6496) Migrate SSL configuration options

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069552#comment-16069552 ] ASF GitHub Bot commented on FLINK-6496: --- Github user tzulitai commented on a diff in

[jira] [Commented] (FLINK-6496) Migrate SSL configuration options

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069554#comment-16069554 ] ASF GitHub Bot commented on FLINK-6496: --- Github user tzulitai commented on a diff in

[jira] [Commented] (FLINK-6496) Migrate SSL configuration options

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069553#comment-16069553 ] ASF GitHub Bot commented on FLINK-6496: --- Github user tzulitai commented on a diff in

[GitHub] flink pull request #3855: [FLINK-6496] Port SSl config parameters to ConfigO...

2017-06-29 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3855#discussion_r124970162 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/blob/BlobClientSslTest.java --- @@ -35,6 +35,7 @@ import org.apache.flink.configuration

[GitHub] flink pull request #3855: [FLINK-6496] Port SSl config parameters to ConfigO...

2017-06-29 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3855#discussion_r124969948 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/akka/AkkaUtils.scala --- @@ -26,7 +26,7 @@ import akka.actor._ import akka.pattern.{ask

[GitHub] flink pull request #3855: [FLINK-6496] Port SSl config parameters to ConfigO...

2017-06-29 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3855#discussion_r124970218 --- Diff: flink-runtime/src/test/scala/org/apache/flink/runtime/akka/AkkaSslITCase.scala --- @@ -20,8 +20,8 @@ package org.apache.flink.runtime.akka

[jira] [Commented] (FLINK-6789) Remove duplicated test utility reducer in optimizer

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069543#comment-16069543 ] ASF GitHub Bot commented on FLINK-6789: --- Github user tzulitai commented on the issue

[jira] [Updated] (FLINK-7047) Reorganize build profiles

2017-06-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7047: Description: With the current build times once again hitting the timeout it is time to revi

[GitHub] flink issue #4216: [FLINK-6789] [optimizer] Remove duplicated test utility r...

2017-06-29 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4216 LGTM, merging ... --- 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

[GitHub] flink issue #4229: [FLINK-7038] [docs] Correct misused term to KeyedStream

2017-06-29 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/4229 Exactly, Could we create another jira or just do a hotfix for ```WindowedDataStream``` under ```FLINK-7038``` ? --- If your project is set up for it, you can reply to this email and have your r

[jira] [Commented] (FLINK-7038) Several misused "KeyedDataStream" term in docs and Javadocs

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069538#comment-16069538 ] ASF GitHub Bot commented on FLINK-7038: --- Github user zhangminglei commented on the i

[GitHub] flink pull request #4228: Flink-7035 Automatically identify AWS Region, simp...

2017-06-29 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4228#discussion_r124967289 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisConfigUtil.java --- @@ -171,7 +1

[GitHub] flink pull request #4228: Flink-7035 Automatically identify AWS Region, simp...

2017-06-29 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4228#discussion_r124967667 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisConfigUtil.java --- @@ -171,7 +1

[GitHub] flink issue #4229: [FLINK-7038] [docs] Correct misused term to KeyedStream

2017-06-29 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4229 Yes. That's why the `KeyedDataStream` is a misused term. The actual class is called `KeyedStream`. --- If your project is set up for it, you can reply to this email and have your reply appear on Gi

[jira] [Commented] (FLINK-7038) Several misused "KeyedDataStream" term in docs and Javadocs

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069533#comment-16069533 ] ASF GitHub Bot commented on FLINK-7038: --- Github user tzulitai commented on the issue

[jira] [Commented] (FLINK-7038) Several misused "KeyedDataStream" term in docs and Javadocs

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069531#comment-16069531 ] ASF GitHub Bot commented on FLINK-7038: --- Github user zhangminglei commented on the i

[GitHub] flink issue #4229: [FLINK-7038] [docs] Correct misused term to KeyedStream

2017-06-29 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/4229 Okay. I really found many ```KeyedDataStream``` terms existing in flink project under master branch. But there is not a class called it. So, it is very strange. Also the same stuff refers to ```

[jira] [Commented] (FLINK-6352) FlinkKafkaConsumer should support to use timestamp to set up start offset

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069507#comment-16069507 ] ASF GitHub Bot commented on FLINK-6352: --- Github user tzulitai commented on a diff in

[jira] [Commented] (FLINK-6352) FlinkKafkaConsumer should support to use timestamp to set up start offset

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069510#comment-16069510 ] ASF GitHub Bot commented on FLINK-6352: --- Github user tzulitai commented on a diff in

[jira] [Commented] (FLINK-6352) FlinkKafkaConsumer should support to use timestamp to set up start offset

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069512#comment-16069512 ] ASF GitHub Bot commented on FLINK-6352: --- Github user tzulitai commented on a diff in

[jira] [Commented] (FLINK-6352) FlinkKafkaConsumer should support to use timestamp to set up start offset

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069509#comment-16069509 ] ASF GitHub Bot commented on FLINK-6352: --- Github user tzulitai commented on a diff in

[jira] [Commented] (FLINK-6352) FlinkKafkaConsumer should support to use timestamp to set up start offset

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069511#comment-16069511 ] ASF GitHub Bot commented on FLINK-6352: --- Github user tzulitai commented on a diff in

[jira] [Commented] (FLINK-6352) FlinkKafkaConsumer should support to use timestamp to set up start offset

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069508#comment-16069508 ] ASF GitHub Bot commented on FLINK-6352: --- Github user tzulitai commented on a diff in

[jira] [Commented] (FLINK-6352) FlinkKafkaConsumer should support to use timestamp to set up start offset

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069514#comment-16069514 ] ASF GitHub Bot commented on FLINK-6352: --- Github user tzulitai commented on a diff in

[jira] [Commented] (FLINK-6352) FlinkKafkaConsumer should support to use timestamp to set up start offset

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069513#comment-16069513 ] ASF GitHub Bot commented on FLINK-6352: --- Github user tzulitai commented on a diff in

[GitHub] flink pull request #3915: [FLINK-6352] Support to use timestamp to set the i...

2017-06-29 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3915#discussion_r124964821 --- Diff: flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer010.java --- @@ -128,6 +1

[GitHub] flink pull request #3915: [FLINK-6352] Support to use timestamp to set the i...

2017-06-29 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3915#discussion_r124964762 --- Diff: flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer010.java --- @@ -128,6 +1

[GitHub] flink pull request #3915: [FLINK-6352] Support to use timestamp to set the i...

2017-06-29 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3915#discussion_r124966020 --- Diff: flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer010.java --- @@ -128,6 +1

[GitHub] flink pull request #3915: [FLINK-6352] Support to use timestamp to set the i...

2017-06-29 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3915#discussion_r124965318 --- Diff: flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer010.java --- @@ -128,6 +1

[GitHub] flink pull request #3915: [FLINK-6352] Support to use timestamp to set the i...

2017-06-29 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3915#discussion_r124964448 --- Diff: flink-connectors/flink-connector-kafka-0.10/pom.xml --- @@ -37,7 +37,7 @@ under the License. - 0.10.0.1 +

[GitHub] flink pull request #3915: [FLINK-6352] Support to use timestamp to set the i...

2017-06-29 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3915#discussion_r124964813 --- Diff: flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer010.java --- @@ -128,6 +1

[GitHub] flink pull request #3915: [FLINK-6352] Support to use timestamp to set the i...

2017-06-29 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3915#discussion_r124966340 --- Diff: flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java --- @@ -697,13

[GitHub] flink pull request #3915: [FLINK-6352] Support to use timestamp to set the i...

2017-06-29 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3915#discussion_r124965642 --- Diff: flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer010.java --- @@ -128,6 +1

[jira] [Commented] (FLINK-6352) FlinkKafkaConsumer should support to use timestamp to set up start offset

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069483#comment-16069483 ] ASF GitHub Bot commented on FLINK-6352: --- Github user tzulitai commented on the issue

[GitHub] flink issue #3915: [FLINK-6352] Support to use timestamp to set the initial ...

2017-06-29 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3915 @zjureel there seems to be a failure in the Kafka tests caused by this PR, could you have a look? >Tests run: 1, Failures: 1, Errors: 0, Skipped: 0, Time elapsed: 2.875 sec <<< FAILURE! - in or

[jira] [Commented] (FLINK-6996) FlinkKafkaProducer010 doesn't guarantee at-least-once semantic

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069471#comment-16069471 ] ASF GitHub Bot commented on FLINK-6996: --- Github user tzulitai commented on the issue

[GitHub] flink issue #4206: [FLINK-6996] FlinkKafkaProducer010 doesn't guarantee at-l...

2017-06-29 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4206 @pnowojski related test `Kafka010ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink` is failing in Travis. It seems like the fetched records from Kafka is empty? ```

[jira] [Commented] (FLINK-7038) Several misused "KeyedDataStream" term in docs and Javadocs

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069469#comment-16069469 ] ASF GitHub Bot commented on FLINK-7038: --- Github user tzulitai commented on the issue

[GitHub] flink issue #4229: [FLINK-7038] [docs] Correct misused term to KeyedStream

2017-06-29 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4229 @zhangminglei thanks for picking this up. The last time I checked, there's much more misused "KeyedDataStream" terms, both in Javadocs and the documentation. Could you please include fixes f

[jira] [Commented] (FLINK-7011) Instable Kafka testStartFromKafkaCommitOffsets failures on Travis

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069446#comment-16069446 ] ASF GitHub Bot commented on FLINK-7011: --- Github user tzulitai commented on a diff in

[GitHub] flink pull request #4190: [FLINK-7011] [kafka] Harden Kafka testStartFromKaf...

2017-06-29 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4190#discussion_r124961658 --- Diff: flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaConsumerTestBase.java --- @@ -279,49 +

[jira] [Commented] (FLINK-7011) Instable Kafka testStartFromKafkaCommitOffsets failures on Travis

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069444#comment-16069444 ] ASF GitHub Bot commented on FLINK-7011: --- Github user tzulitai commented on the issue

[GitHub] flink issue #4190: [FLINK-7011] [kafka] Harden Kafka testStartFromKafkaCommi...

2017-06-29 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4190 @zentol the time limit is set on each individual version-specific `KafkaConsumerXXITCase` --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as w

[jira] [Commented] (FLINK-4022) Partition discovery / regex topic subscription for the Kafka consumer

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069437#comment-16069437 ] ASF GitHub Bot commented on FLINK-4022: --- Github user tzulitai commented on the issue

[jira] [Commented] (FLINK-6867) Elasticsearch 1.x ITCase still instable due to embedded node instability

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069436#comment-16069436 ] ASF GitHub Bot commented on FLINK-6867: --- Github user tzulitai commented on the issue

[GitHub] flink issue #3746: [FLINK-4022] [kafka] Partition and topic discovery for Fl...

2017-06-29 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3746 Travis passed, merging ... --- 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 wish

[GitHub] flink issue #4191: [FLINK-6867] [elasticsearch] Fix instable Elasticsearch 1...

2017-06-29 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4191 Merging once Travis gives green. --- 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 an

[jira] [Commented] (FLINK-6991) Inaccessible link under Gelly document

2017-06-29 Thread njzhuyuqi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069391#comment-16069391 ] njzhuyuqi commented on FLINK-6991: -- Ok, thanks Greg Hogan for telling me your opinion. I

[jira] [Commented] (FLINK-7036) Type cast in ExpressionReducer's reduce broke CodeGen's compile stage

2017-06-29 Thread Aegeaner (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069385#comment-16069385 ] Aegeaner commented on FLINK-7036: - Hi [~jark] I have just created a skeleton but you can t

[jira] [Assigned] (FLINK-7045) Reduce element count of UdfStreamOperatorCheckpointingITCase

2017-06-29 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang reassigned FLINK-7045: --- Assignee: mingleizhang > Reduce element count of UdfStreamOperatorCheckpointingITCase > -

[jira] [Commented] (FLINK-7036) Type cast in ExpressionReducer's reduce broke CodeGen's compile stage

2017-06-29 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069318#comment-16069318 ] Jark Wu commented on FLINK-7036: [~Aegeaner] Can you link your working in process STR_TO_D

[jira] [Assigned] (FLINK-7038) Several misused "KeyedDataStream" term in docs and Javadocs

2017-06-29 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang reassigned FLINK-7038: --- Assignee: mingleizhang > Several misused "KeyedDataStream" term in docs and Javadocs > --

[jira] [Commented] (FLINK-7038) Several misused "KeyedDataStream" term in docs and Javadocs

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069283#comment-16069283 ] ASF GitHub Bot commented on FLINK-7038: --- GitHub user zhangminglei opened a pull requ

[GitHub] flink pull request #4229: [FLINK-7038] [docs] Correct misused term to KeyedS...

2017-06-29 Thread zhangminglei
GitHub user zhangminglei opened a pull request: https://github.com/apache/flink/pull/4229 [FLINK-7038] [docs] Correct misused term to KeyedStream Correct misused term to KeyedStream. You can merge this pull request into a Git repository by running: $ git pull https://github.com

[jira] [Commented] (FLINK-7038) Several misused "KeyedDataStream" term in docs and Javadocs

2017-06-29 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069257#comment-16069257 ] mingleizhang commented on FLINK-7038: - Hello, Gordon. I will look into this today. >

[GitHub] flink issue #4210: [FLINK-7024][table]Add supported for selecting window pro...

2017-06-29 Thread sunjincheng121
Github user sunjincheng121 commented on the issue: https://github.com/apache/flink/pull/4210 @wuchong Thanks for your review. I had update the PR. --- 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 h

[jira] [Commented] (FLINK-7035) Flink Kinesis connector forces hard coding the AWS Region

2017-06-29 Thread Matt Pouttu-clarke (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069162#comment-16069162 ] Matt Pouttu-clarke commented on FLINK-7035: --- Please see the following pull reque

[GitHub] flink pull request #4228: Flink-7035 Automatically identify AWS Region, simp...

2017-06-29 Thread mpouttuclarke
GitHub user mpouttuclarke opened a pull request: https://github.com/apache/flink/pull/4228 Flink-7035 Automatically identify AWS Region, simplified constructors, added test properties support You can merge this pull request into a Git repository by running: $ git pull https:/

[jira] [Closed] (FLINK-7025) Using NullByteKeySelector for Unbounded ProcTime NonPartitioned Over

2017-06-29 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-7025. Resolution: Fixed Fix Version/s: 1.3.2 1.4.0 Fixed for 1.3.2 with db7f0ffd

[jira] [Updated] (FLINK-7049) TestingApplicationMaster keeps running after integration tests finish

2017-06-29 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-7049: -- Attachment: testingApplicationMaster.stack Stack trace for TestingApplicationMaster > TestingApplicationMaster

[jira] [Created] (FLINK-7049) TestingApplicationMaster keeps running after integration tests finish

2017-06-29 Thread Ted Yu (JIRA)
Ted Yu created FLINK-7049: - Summary: TestingApplicationMaster keeps running after integration tests finish Key: FLINK-7049 URL: https://issues.apache.org/jira/browse/FLINK-7049 Project: Flink Issue

[jira] [Closed] (FLINK-3551) Sync Scala and Java Streaming Examples

2017-06-29 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-3551. Resolution: Implemented Fix Version/s: 1.4.0 Implemented with 1cf162079c990e0504d736df768b0a8

[jira] [Commented] (FLINK-3551) Sync Scala and Java Streaming Examples

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069059#comment-16069059 ] ASF GitHub Bot commented on FLINK-3551: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-7025) Using NullByteKeySelector for Unbounded ProcTime NonPartitioned Over

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069060#comment-16069060 ] ASF GitHub Bot commented on FLINK-7025: --- Github user asfgit closed the pull request

[GitHub] flink pull request #2761: [FLINK-3551] [examples] Sync Scala Streaming Examp...

2017-06-29 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2761 --- 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 enab

[GitHub] flink pull request #4212: [FLINK-7025][table]Using NullByteKeySelector for U...

2017-06-29 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4212 --- 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 enab

[jira] [Commented] (FLINK-7048) Define javadoc skipping in travis watchdog script

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16068986#comment-16068986 ] ASF GitHub Bot commented on FLINK-7048: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #4227: [FLINK-7048] [travis] Define javadoc skipping in t...

2017-06-29 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/4227 [FLINK-7048] [travis] Define javadoc skipping in travis watchdog script You can merge this pull request into a Git repository by running: $ git pull https://github.com/zentol/flink 7048 Altern

[jira] [Updated] (FLINK-7048) Define javadoc skipping in travis watchdog script

2017-06-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7048: Priority: Trivial (was: Major) > Define javadoc skipping in travis watchdog script > --

[jira] [Updated] (FLINK-7046) Hide logging about downloaded artifacts on travis

2017-06-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7046: Priority: Trivial (was: Major) > Hide logging about downloaded artifacts on travis > --

[jira] [Created] (FLINK-7048) Define javadoc skipping in travis watchdog script

2017-06-29 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-7048: --- Summary: Define javadoc skipping in travis watchdog script Key: FLINK-7048 URL: https://issues.apache.org/jira/browse/FLINK-7048 Project: Flink Issue T

[jira] [Updated] (FLINK-7047) Reorganize build profiles

2017-06-29 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7047: Description: With the current build times once again hitting the timeout it is time to revi

[jira] [Created] (FLINK-7047) Reorganize build profiles

2017-06-29 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-7047: --- Summary: Reorganize build profiles Key: FLINK-7047 URL: https://issues.apache.org/jira/browse/FLINK-7047 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-7046) Hide logging about downloaded artifacts on travis

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16068968#comment-16068968 ] ASF GitHub Bot commented on FLINK-7046: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #4226: [FLINK-7046] [travis] Hide download logging messag...

2017-06-29 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/4226 [FLINK-7046] [travis] Hide download logging messages You can merge this pull request into a Git repository by running: $ git pull https://github.com/zentol/flink 7046 Alternatively you can rev

[jira] [Created] (FLINK-7046) Hide logging about downloaded artifacts on travis

2017-06-29 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-7046: --- Summary: Hide logging about downloaded artifacts on travis Key: FLINK-7046 URL: https://issues.apache.org/jira/browse/FLINK-7046 Project: Flink Issue T

[jira] [Commented] (FLINK-6880) Activate checkstyle for runtime/iterative

2017-06-29 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16068925#comment-16068925 ] ASF GitHub Bot commented on FLINK-6880: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #4098: [FLINK-6880] [runtime] Activate checkstyle for run...

2017-06-29 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4098#discussion_r124902455 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/iterative/io/SolutionSetFastUpdateOutputCollector.java --- @@ -18,17 +18,17 @@ pack

[jira] [Resolved] (FLINK-7008) Update NFA state only when the NFA changes.

2017-06-29 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz resolved FLINK-7008. - Resolution: Fixed > Update NFA state only when the NFA changes. >

  1   2   3   >