[jira] [Commented] (FLINK-7637) FlinkKinesisProducer violates at-least-once guarantees

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

[GitHub] flink pull request #4871: [FLINK-7637] [kinesis] Fix at-least-once guarantee...

2017-10-23 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4871#discussion_r146467213 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java --- @@ -265,19 +25

[GitHub] flink pull request #4871: [FLINK-7637] [kinesis] Fix at-least-once guarantee...

2017-10-23 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4871#discussion_r146466958 --- Diff: flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducerTest.java --- @@ -49,61

[jira] [Commented] (FLINK-7637) FlinkKinesisProducer violates at-least-once guarantees

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

[jira] [Commented] (FLINK-7637) FlinkKinesisProducer violates at-least-once guarantees

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

[jira] [Commented] (FLINK-7637) FlinkKinesisProducer violates at-least-once guarantees

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

[GitHub] flink pull request #4871: [FLINK-7637] [kinesis] Fix at-least-once guarantee...

2017-10-23 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4871#discussion_r146466785 --- Diff: flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducerTest.java --- @@ -49,61

[jira] [Commented] (FLINK-7637) FlinkKinesisProducer violates at-least-once guarantees

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

[GitHub] flink pull request #4871: [FLINK-7637] [kinesis] Fix at-least-once guarantee...

2017-10-23 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4871#discussion_r146466759 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java --- @@ -265,19 +25

[jira] [Commented] (FLINK-7637) FlinkKinesisProducer violates at-least-once guarantees

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

[GitHub] flink pull request #4871: [FLINK-7637] [kinesis] Fix at-least-once guarantee...

2017-10-23 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4871#discussion_r146466699 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java --- @@ -265,19 +25

[GitHub] flink pull request #4871: [FLINK-7637] [kinesis] Fix at-least-once guarantee...

2017-10-23 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4871#discussion_r146466653 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java --- @@ -207,23 +21

[jira] [Assigned] (FLINK-7900) Add a Rich KeySelector

2017-10-23 Thread Hai Zhou UTC+8 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou UTC+8 reassigned FLINK-7900: - Assignee: Hai Zhou UTC+8 > Add a Rich KeySelector > -- > >

[jira] [Created] (FLINK-7907) Flink Metrics documentation missing Scala examples

2017-10-23 Thread Colin Williams (JIRA)
Colin Williams created FLINK-7907: - Summary: Flink Metrics documentation missing Scala examples Key: FLINK-7907 URL: https://issues.apache.org/jira/browse/FLINK-7907 Project: Flink Issue Type

[jira] [Commented] (FLINK-7637) FlinkKinesisProducer violates at-least-once guarantees

2017-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16216206#comment-16216206 ] ASF GitHub Bot commented on FLINK-7637: --- Github user bowenli86 commented on a diff i

[GitHub] flink pull request #4871: [FLINK-7637] [kinesis] Fix at-least-once guarantee...

2017-10-23 Thread bowenli86
Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/4871#discussion_r146440154 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java --- @@ -265,19 +2

[jira] [Commented] (FLINK-7251) Merge the flink-java8 project into flink-core

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

[jira] [Commented] (FLINK-7251) Merge the flink-java8 project into flink-core

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

[GitHub] flink pull request #4455: [FLINK-7251] Merge the flink-java8 project into co...

2017-10-23 Thread zjureel
Github user zjureel closed the pull request at: https://github.com/apache/flink/pull/4455 ---

[GitHub] flink issue #4455: [FLINK-7251] Merge the flink-java8 project into correspon...

2017-10-23 Thread zjureel
Github user zjureel commented on the issue: https://github.com/apache/flink/pull/4455 @zentol Thank you for your reply, and I agree with you that the risk will be a little high for this PR. I'd like to close this PR if there's no better solution, thanks ---

[jira] [Commented] (FLINK-7821) Replace Table.limit() by Table.fetch() and Table.offset()

2017-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16216115#comment-16216115 ] ASF GitHub Bot commented on FLINK-7821: --- Github user xccui commented on a diff in th

[jira] [Commented] (FLINK-7821) Replace Table.limit() by Table.fetch() and Table.offset()

2017-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16216111#comment-16216111 ] ASF GitHub Bot commented on FLINK-7821: --- Github user xccui commented on a diff in th

[jira] [Commented] (FLINK-7821) Replace Table.limit() by Table.fetch() and Table.offset()

2017-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16216113#comment-16216113 ] ASF GitHub Bot commented on FLINK-7821: --- Github user xccui commented on a diff in th

[jira] [Commented] (FLINK-7821) Replace Table.limit() by Table.fetch() and Table.offset()

2017-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16216116#comment-16216116 ] ASF GitHub Bot commented on FLINK-7821: --- Github user xccui commented on a diff in th

[jira] [Commented] (FLINK-7821) Replace Table.limit() by Table.fetch() and Table.offset()

2017-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16216114#comment-16216114 ] ASF GitHub Bot commented on FLINK-7821: --- Github user xccui commented on a diff in th

[jira] [Commented] (FLINK-7821) Replace Table.limit() by Table.fetch() and Table.offset()

2017-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16216112#comment-16216112 ] ASF GitHub Bot commented on FLINK-7821: --- Github user xccui commented on a diff in th

[GitHub] flink pull request #4813: [FLINK-7821] [table] Deprecate Table.limit() and r...

2017-10-23 Thread xccui
Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4813#discussion_r146426403 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala --- @@ -745,12 +748,65 @@ class Table( * * @para

[GitHub] flink pull request #4813: [FLINK-7821] [table] Deprecate Table.limit() and r...

2017-10-23 Thread xccui
Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4813#discussion_r146423134 --- Diff: docs/dev/table/tableApi.md --- @@ -1031,19 +1034,22 @@ val result = in.orderBy('a.asc); -Limit +Of

[GitHub] flink pull request #4813: [FLINK-7821] [table] Deprecate Table.limit() and r...

2017-10-23 Thread xccui
Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4813#discussion_r146423039 --- Diff: docs/dev/table/tableApi.md --- @@ -985,19 +985,22 @@ Table result = in.orderBy("a.asc"); -Limit +O

[GitHub] flink pull request #4813: [FLINK-7821] [table] Deprecate Table.limit() and r...

2017-10-23 Thread xccui
Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4813#discussion_r146423953 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala --- @@ -745,12 +748,65 @@ class Table( * * @para

[GitHub] flink pull request #4813: [FLINK-7821] [table] Deprecate Table.limit() and r...

2017-10-23 Thread xccui
Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4813#discussion_r146424180 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala --- @@ -745,12 +748,65 @@ class Table( * * @para

[GitHub] flink pull request #4813: [FLINK-7821] [table] Deprecate Table.limit() and r...

2017-10-23 Thread xccui
Github user xccui commented on a diff in the pull request: https://github.com/apache/flink/pull/4813#discussion_r146423916 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala --- @@ -745,12 +748,65 @@ class Table( * * @para

[jira] [Commented] (FLINK-7755) Null values are not correctly handled by batch inner and outer joins

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

[GitHub] flink issue #4858: [FLINK-7755] [table] Fix NULL handling in batch joins.

2017-10-23 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/4858 I'll merge the PR in the next days. ---

[jira] [Commented] (FLINK-7548) Support watermark generation for TableSource

2017-10-23 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16215805#comment-16215805 ] Fabian Hueske commented on FLINK-7548: -- Thanks for the feedback [~wheat9]. I've addr

[jira] [Commented] (FLINK-7548) Support watermark generation for TableSource

2017-10-23 Thread Haohui Mai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16215758#comment-16215758 ] Haohui Mai commented on FLINK-7548: --- Sorry for the late response. The APIs should work f

[jira] [Updated] (FLINK-7588) Document RocksDB tuning for spinning disks

2017-10-23 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-7588: -- Description: In docs/ops/state/large_state_tuning.md , it was mentioned that: bq. the default configuration is t

[jira] [Commented] (FLINK-7669) Always load Flink classes through parent ClassLoader

2017-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16215501#comment-16215501 ] ASF GitHub Bot commented on FLINK-7669: --- Github user StephanEwen commented on the is

[GitHub] flink issue #4891: [FLINK-7669] Always load Flink classes via parent ClassLo...

2017-10-23 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4891 Good fix, with minor comments. I think we want to have even more default parent-first classes, because they leak through the public API. - `org.slf4j` - `javax.annotation` -

[jira] [Commented] (FLINK-7669) Always load Flink classes through parent ClassLoader

2017-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16215496#comment-16215496 ] ASF GitHub Bot commented on FLINK-7669: --- Github user StephanEwen commented on a diff

[jira] [Commented] (FLINK-7669) Always load Flink classes through parent ClassLoader

2017-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16215499#comment-16215499 ] ASF GitHub Bot commented on FLINK-7669: --- Github user StephanEwen commented on a diff

[jira] [Commented] (FLINK-7669) Always load Flink classes through parent ClassLoader

2017-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16215498#comment-16215498 ] ASF GitHub Bot commented on FLINK-7669: --- Github user StephanEwen commented on a diff

[jira] [Commented] (FLINK-7669) Always load Flink classes through parent ClassLoader

2017-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16215497#comment-16215497 ] ASF GitHub Bot commented on FLINK-7669: --- Github user StephanEwen commented on a diff

[GitHub] flink pull request #4891: [FLINK-7669] Always load Flink classes via parent ...

2017-10-23 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/4891#discussion_r146336888 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobManagerServices.java --- @@ -116,8 +116,15 @@ public static JobManagerServic

[GitHub] flink pull request #4891: [FLINK-7669] Always load Flink classes via parent ...

2017-10-23 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/4891#discussion_r146336120 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/execution/librarycache/FlinkUserCodeClassLoaders.java --- @@ -31,24 +31,23 @@ */

[GitHub] flink pull request #4891: [FLINK-7669] Always load Flink classes via parent ...

2017-10-23 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/4891#discussion_r146336544 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobManagerServices.java --- @@ -116,8 +116,15 @@ public static JobManagerServic

[GitHub] flink pull request #4891: [FLINK-7669] Always load Flink classes via parent ...

2017-10-23 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/4891#discussion_r146338877 --- Diff: docs/monitoring/debugging_classloading.md --- @@ -57,22 +57,34 @@ YARN classloading differs between single job deployments and sessions:

[jira] [Commented] (FLINK-7669) Always load Flink classes through parent ClassLoader

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

[jira] [Commented] (FLINK-7669) Always load Flink classes through parent ClassLoader

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

[GitHub] flink pull request #4891: [FLINK-7669] Always load Flink classes via parent ...

2017-10-23 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4891#discussion_r146335716 --- Diff: docs/monitoring/debugging_classloading.md --- @@ -57,22 +57,34 @@ YARN classloading differs between single job deployments and sessions:

[GitHub] flink pull request #4891: [FLINK-7669] Always load Flink classes via parent ...

2017-10-23 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4891#discussion_r146336395 --- Diff: docs/ops/config.md --- @@ -77,6 +77,10 @@ without explicit scheme definition, such as `/user/USERNAME/in.txt`, is going to - `classloader.resol

[jira] [Commented] (FLINK-7905) HadoopS3FileSystemITCase failed on travis

2017-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16215460#comment-16215460 ] ASF GitHub Bot commented on FLINK-7905: --- GitHub user StephanEwen opened a pull reque

[GitHub] flink pull request #4892: [FLINK-7905] [build] Update encrypted Travis S3 ac...

2017-10-23 Thread StephanEwen
GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/4892 [FLINK-7905] [build] Update encrypted Travis S3 access keys This fixes the currently failing tests for S3 file systems by adding proper encrypted access credentials. The current creden

[jira] [Commented] (FLINK-7905) HadoopS3FileSystemITCase failed on travis

2017-10-23 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16215451#comment-16215451 ] Stephan Ewen commented on FLINK-7905: - I accidentally expired the AWS access keys whic

[jira] [Assigned] (FLINK-7905) HadoopS3FileSystemITCase failed on travis

2017-10-23 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-7905: --- Assignee: Stephan Ewen > HadoopS3FileSystemITCase failed on travis >

[jira] [Commented] (FLINK-7067) Cancel with savepoint does not restart checkpoint scheduler on failure

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

[GitHub] flink issue #4888: [backport] [FLINK-7067] Resume checkpointing after failed...

2017-10-23 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/4888 @aljoscha Getting the following message in two of the builds in https://travis-ci.org/apache/flink/builds/291523047: ``` ==

[jira] [Commented] (FLINK-6245) Fix late side output documentation in Window documents.

2017-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16215325#comment-16215325 ] ASF GitHub Bot commented on FLINK-6245: --- Github user bowenli86 closed the pull reque

[GitHub] flink pull request #4882: [FLINK-6245] [doc] Fix late side output documentat...

2017-10-23 Thread bowenli86
Github user bowenli86 closed the pull request at: https://github.com/apache/flink/pull/4882 ---

[jira] [Commented] (FLINK-7637) FlinkKinesisProducer violates at-least-once guarantees

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

[GitHub] flink pull request #4871: [FLINK-7637] [kinesis] Fix at-least-once guarantee...

2017-10-23 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/4871#discussion_r146302059 --- Diff: flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducerTest.java --- @@ -49,61

[jira] [Commented] (FLINK-7637) FlinkKinesisProducer violates at-least-once guarantees

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

[GitHub] flink pull request #4871: [FLINK-7637] [kinesis] Fix at-least-once guarantee...

2017-10-23 Thread aljoscha
Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/4871#discussion_r146301761 --- Diff: flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducerTest.java --- @@ -49,61

[jira] [Updated] (FLINK-7669) Always load Flink classes through parent ClassLoader

2017-10-23 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7669: Summary: Always load Flink classes through parent ClassLoader (was: ClassLoader resolution-

[jira] [Commented] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based

2017-10-23 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16215278#comment-16215278 ] ASF GitHub Bot commented on FLINK-7416: --- Github user zhijiangW commented on the issu

[GitHub] flink issue #4533: [FLINK-7416][network] Implement Netty receiver outgoing p...

2017-10-23 Thread zhijiangW
Github user zhijiangW commented on the issue: https://github.com/apache/flink/pull/4533 @pnowojski , I have submitted the modifications which include the loop issue and UTs. ---

[jira] [Closed] (FLINK-6245) Fix late side output documentation in Window documents.

2017-10-23 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-6245. --- > Fix late side output documentation in Window documents. > --

[jira] [Commented] (FLINK-6245) Fix late side output documentation in Window documents.

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

[jira] [Resolved] (FLINK-6245) Fix late side output documentation in Window documents.

2017-10-23 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek resolved FLINK-6245. - Resolution: Fixed Fixed in b2cc4515a842dea029bcf854fb5479e271192a09 > Fix late side outpu

[GitHub] flink issue #4882: [FLINK-6245] [doc] Fix late side output documentation in ...

2017-10-23 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4882 Thanks for fixing this! 😃 Could you please close the PR? ---

[jira] [Commented] (FLINK-7669) ClassLoader resolution-order setting is not used on client

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

[GitHub] flink pull request #4891: [FLINK-7669] Always load Flink classes via parent ...

2017-10-23 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/4891 [FLINK-7669] Always load Flink classes via parent ClassLoader You can merge this pull request into a Git repository by running: $ git pull https://github.com/aljoscha/flink jira-7669-classl

[jira] [Commented] (FLINK-7732) Test instability in Kafka end-to-end test (invalid Kafka offset)

2017-10-23 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16215258#comment-16215258 ] Piotr Nowojski commented on FLINK-7732: --- Yes, this definitely looks like a bug in ou

[jira] [Updated] (FLINK-7905) HadoopS3FileSystemITCase failed on travis

2017-10-23 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7905: Description: The {{HadoopS3FileSystemITCase}} is flaky on Travis because its access got den

[jira] [Updated] (FLINK-7905) HadoopS3FileSystemITCase failed on travis

2017-10-23 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7905: Labels: test-stability (was: ) > HadoopS3FileSystemITCase failed on travis > --

[jira] [Updated] (FLINK-7905) HadoopS3FileSystemITCase failed on travis

2017-10-23 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7905: Environment: https://travis-ci.org/zentol/flink/jobs/291550295 https://travis-ci.org/tillro

[jira] [Updated] (FLINK-7905) HadoopS3FileSystemITCase failed on travis

2017-10-23 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7905: Environment: https://travis-ci.org/zentol/flink/jobs/291550295 https://travis-ci.org/tillroh

[jira] [Closed] (FLINK-7906) HadoopS3FileSystemITCase flaky on Travis

2017-10-23 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7906. --- Resolution: Duplicate > HadoopS3FileSystemITCase flaky on Travis > ---

[jira] [Updated] (FLINK-7906) HadoopS3FileSystemITCase flaky on Travis

2017-10-23 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7906: - Description: The {{HadoopS3FileSystemITCase}} is flaky on Travis because its access got denied by

[jira] [Created] (FLINK-7906) HadoopS3FileSystemITCase flaky on Travis

2017-10-23 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7906: Summary: HadoopS3FileSystemITCase flaky on Travis Key: FLINK-7906 URL: https://issues.apache.org/jira/browse/FLINK-7906 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-7905) HadoopS3FileSystemITCase failed on travis

2017-10-23 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-7905: --- Summary: HadoopS3FileSystemITCase failed on travis Key: FLINK-7905 URL: https://issues.apache.org/jira/browse/FLINK-7905 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-7904) Enable Flip6 build profile on Travis

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

[GitHub] flink pull request #4890: [FLINK-7904] Enable Flip6 build profile on Travis

2017-10-23 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4890 [FLINK-7904] Enable Flip6 build profile on Travis ## What is the purpose of the change This adds a new Travis build matrix entry which runs the Flip-6 build profile. ## Does t

[jira] [Commented] (FLINK-7903) Add Flip6 build profile

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

[GitHub] flink pull request #4889: [FLINK-7903] [tests] Add flip6 build profile

2017-10-23 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4889 [FLINK-7903] [tests] Add flip6 build profile ## What is the purpose of the change The flip6 build profile only runs the Flip-6 related test cases. Moreover, all Flip-6 related test

[jira] [Created] (FLINK-7904) Enable Flip6 build profile on Travis

2017-10-23 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7904: Summary: Enable Flip6 build profile on Travis Key: FLINK-7904 URL: https://issues.apache.org/jira/browse/FLINK-7904 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-7702) Javadocs link broken

2017-10-23 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7702: Priority: Blocker (was: Critical) > Javadocs link broken > > >

[jira] [Commented] (FLINK-6584) Support multiple consecutive windows in SQL

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

[GitHub] flink issue #4199: [FLINK-6584] [table] Support multiple consecutive windows...

2017-10-23 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/4199 @fhueske @wuchong I updated the PR. ---

[jira] [Updated] (FLINK-7732) Test instability in Kafka end-to-end test (invalid Kafka offset)

2017-10-23 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7732: Fix Version/s: 1.4.0 > Test instability in Kafka end-to-end test (invalid Kafka offset) > --

[jira] [Updated] (FLINK-7732) Test instability in Kafka end-to-end test (invalid Kafka offset)

2017-10-23 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7732: Priority: Blocker (was: Critical) > Test instability in Kafka end-to-end test (invalid Kafk

[jira] [Created] (FLINK-7903) Add Flip6 build profile

2017-10-23 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7903: Summary: Add Flip6 build profile Key: FLINK-7903 URL: https://issues.apache.org/jira/browse/FLINK-7903 Project: Flink Issue Type: Improvement Compo

[jira] [Commented] (FLINK-7895) Error in the example in SideOutput usage example that show how to get late message of window

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

[GitHub] flink issue #4878: [FLINK-7895][hotfix][docs]Fix error in example in get lat...

2017-10-23 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4878 Hi @Aitozi, I'm afraid there is already an open issue with a PR for this: https://issues.apache.org/jira/browse/FLINK-6245 ---

[jira] [Closed] (FLINK-7895) Error in the example in SideOutput usage example that show how to get late message of window

2017-10-23 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7895. --- Resolution: Duplicate > Error in the example in SideOutput usage example that show how to get

[jira] [Commented] (FLINK-7669) ClassLoader resolution-order setting is not used on client

2017-10-23 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16215178#comment-16215178 ] Aljoscha Krettek commented on FLINK-7669: - Good to hear that you could reproduce t

[jira] [Commented] (FLINK-7784) Don't fail TwoPhaseCommitSinkFunction when failing to commit

2017-10-23 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16215173#comment-16215173 ] Aljoscha Krettek commented on FLINK-7784: - Not by default, but with a configuratio

[jira] [Commented] (FLINK-7873) Introduce HybridStreamStateHandle for quick recovery from checkpoint.

2017-10-23 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16215170#comment-16215170 ] Aljoscha Krettek commented on FLINK-7873: - [~srichter] could you please have a loo

[jira] [Commented] (FLINK-7881) flink can't deployed on yarn with ha

2017-10-23 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16215169#comment-16215169 ] Aljoscha Krettek commented on FLINK-7881: - What's you configuration and what's the

[jira] [Commented] (FLINK-6861) Use OperatorID in metric system

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

  1   2   >