[jira] [Commented] (FLINK-5039) Avro GenericRecord support is broken

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

[jira] [Updated] (FLINK-5300) FileStateHandle#discard & FsCheckpointStateOutputStream#close tries to delete non-empty directory

2016-12-08 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5300: - Priority: Critical (was: Minor) > FileStateHandle#discard & FsCheckpointStateOutputStream#close t

[jira] [Commented] (FLINK-3921) StringParser not specifying encoding to use

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

[GitHub] flink issue #2953: [FLINK-5039] Bump Avro version

2016-12-08 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2953 +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 and wishes so, or if

[GitHub] flink issue #2926: [FLINK-5226] [table] Use correct DataSetCostFactory and i...

2016-12-08 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2926 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 if the fea

[GitHub] flink issue #2901: [FLINK-3921] StringParser encoding

2016-12-08 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2901 Merging (+ closing PR #2060 which is included in this one) --- 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 hav

[jira] [Created] (FLINK-5300) FileStateHandle#discard & FsCheckpointStateOutputStream#close tries to delete non-empty directory

2016-12-08 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-5300: Summary: FileStateHandle#discard & FsCheckpointStateOutputStream#close tries to delete non-empty directory Key: FLINK-5300 URL: https://issues.apache.org/jira/browse/FLINK-5300

[GitHub] flink pull request #2961: [FLINK-5266] [table] eagerly project unused fields...

2016-12-08 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2961#discussion_r91561592 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/table.scala --- @@ -881,24 +883,21 @@ class GroupWindowedTable( * }}

[jira] [Commented] (FLINK-5266) Eagerly project unused fields when selecting aggregation fields

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15732811#comment-15732811 ] ASF GitHub Bot commented on FLINK-5266: --- Github user fhueske commented on a diff in

[jira] [Commented] (FLINK-5158) Handle ZooKeeperCompletedCheckpointStore exceptions in CheckpointCoordinator

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15732764#comment-15732764 ] ASF GitHub Bot commented on FLINK-5158: --- Github user tillrohrmann commented on the i

[jira] [Commented] (FLINK-5193) Recovering all jobs fails completely if a single recovery fails

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15732762#comment-15732762 ] ASF GitHub Bot commented on FLINK-5193: --- Github user tillrohrmann commented on the i

[GitHub] flink issue #2872: [FLINK-5158] [ckPtCoord] Handle exceptions from Completed...

2016-12-08 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2872 Forwarding @uce's review from the backport to this PR. Rebasing on the latest master and if Travis gives green light, then I will merge this PR. --- If your project is set up for it, y

[GitHub] flink issue #2909: [FLINK-5193] [jm] Harden job recovery in case of recovery...

2016-12-08 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2909 Forwarding @uce and @StephanEwen review from the backport to this PR. Rebasing on the latest master and if Travis gives green light, then I will merge this PR. --- If your project is s

[jira] [Commented] (FLINK-5278) Improve Task and checkpoint logging

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15732746#comment-15732746 ] ASF GitHub Bot commented on FLINK-5278: --- Github user tillrohrmann commented on the i

[GitHub] flink issue #2959: [FLINK-5278] Improve task and checkpoint related logging

2016-12-08 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2959 Travis passed locally: https://travis-ci.org/tillrohrmann/flink/builds/182247110. Failing test case is unrelated. Thanks for the review @uce for #2960. The changes are almost identical.

[jira] [Created] (FLINK-5299) DataStream support for arrays as keys

2016-12-08 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-5299: --- Summary: DataStream support for arrays as keys Key: FLINK-5299 URL: https://issues.apache.org/jira/browse/FLINK-5299 Project: Flink Issue Type: Improve

[jira] [Commented] (FLINK-5278) Improve Task and checkpoint logging

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15732731#comment-15732731 ] ASF GitHub Bot commented on FLINK-5278: --- Github user tillrohrmann closed the pull re

[jira] [Commented] (FLINK-5278) Improve Task and checkpoint logging

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15732730#comment-15732730 ] ASF GitHub Bot commented on FLINK-5278: --- Github user tillrohrmann commented on the i

[jira] [Commented] (FLINK-5298) TaskManager crashes when TM log not existant

2016-12-08 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-5298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15732728#comment-15732728 ] Mischa Krüger commented on FLINK-5298: -- This happened when the log was requested via

[GitHub] flink pull request #2960: [backport] [FLINK-5278] Improve task and checkpoin...

2016-12-08 Thread tillrohrmann
Github user tillrohrmann closed the pull request at: https://github.com/apache/flink/pull/2960 --- 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 i

[GitHub] flink issue #2960: [backport] [FLINK-5278] Improve task and checkpoint relat...

2016-12-08 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2960 Merged by @uce. --- 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,

[jira] [Updated] (FLINK-5298) TaskManager crashes when TM log not existant

2016-12-08 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-5298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mischa Krüger updated FLINK-5298: - Summary: TaskManager crashes when TM log not existant (was: Web UI crashes when TM log not exista

[jira] [Commented] (FLINK-5285) CancelCheckpointMarker flood when using at least once mode

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15732723#comment-15732723 ] ASF GitHub Bot commented on FLINK-5285: --- Github user tillrohrmann commented on a dif

[jira] [Created] (FLINK-5298) Web UI crashes when TM log not existant

2016-12-08 Thread JIRA
Mischa Krüger created FLINK-5298: Summary: Web UI crashes when TM log not existant Key: FLINK-5298 URL: https://issues.apache.org/jira/browse/FLINK-5298 Project: Flink Issue Type: Bug

[GitHub] flink pull request #2964: [backport] [FLINK-5285] Abort checkpoint only once...

2016-12-08 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2964#discussion_r91556985 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/BarrierTracker.java --- @@ -225,17 +230,19 @@ private void processCh

[jira] [Commented] (FLINK-5285) CancelCheckpointMarker flood when using at least once mode

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15732718#comment-15732718 ] ASF GitHub Bot commented on FLINK-5285: --- Github user tillrohrmann commented on the i

[GitHub] flink issue #2964: [backport] [FLINK-5285] Abort checkpoint only once in Bar...

2016-12-08 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/2964 Thanks for the review @StephanEwen. I will address your comments also from the backport and merge the PR then. --- If your project is set up for it, you can reply to this email and have your re

[jira] [Created] (FLINK-5297) Relocate Flink's Hadoop dependency and its transitive dependencies

2016-12-08 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-5297: Summary: Relocate Flink's Hadoop dependency and its transitive dependencies Key: FLINK-5297 URL: https://issues.apache.org/jira/browse/FLINK-5297 Project: Flink

[GitHub] flink pull request #2968: [FLINK-5187] [core] Create analog of Row and RowTy...

2016-12-08 Thread tonycox
Github user tonycox commented on a diff in the pull request: https://github.com/apache/flink/pull/2968#discussion_r91547877 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowComparator.java --- @@ -0,0 +1,698 @@ +/* + * Licensed to the Apach

[GitHub] flink pull request #2968: [FLINK-5187] [core] Create analog of Row and RowTy...

2016-12-08 Thread tonycox
Github user tonycox commented on a diff in the pull request: https://github.com/apache/flink/pull/2968#discussion_r91550465 --- Diff: flink-core/src/main/java/org/apache/flink/types/Row.java --- @@ -0,0 +1,118 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under

[GitHub] flink pull request #2968: [FLINK-5187] [core] Create analog of Row and RowTy...

2016-12-08 Thread tonycox
Github user tonycox commented on a diff in the pull request: https://github.com/apache/flink/pull/2968#discussion_r91551621 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowComparator.java --- @@ -0,0 +1,698 @@ +/* + * Licensed to the Apach

[GitHub] flink pull request #2968: [FLINK-5187] [core] Create analog of Row and RowTy...

2016-12-08 Thread tonycox
Github user tonycox commented on a diff in the pull request: https://github.com/apache/flink/pull/2968#discussion_r91547968 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowComparator.java --- @@ -0,0 +1,698 @@ +/* + * Licensed to the Apach

[GitHub] flink pull request #2968: [FLINK-5187] [core] Create analog of Row and RowTy...

2016-12-08 Thread tonycox
Github user tonycox commented on a diff in the pull request: https://github.com/apache/flink/pull/2968#discussion_r91546359 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/RowTypeInfo.java --- @@ -0,0 +1,176 @@ +/* + * Licensed to the Apache Software

[GitHub] flink pull request #2968: [FLINK-5187] [core] Create analog of Row and RowTy...

2016-12-08 Thread tonycox
Github user tonycox commented on a diff in the pull request: https://github.com/apache/flink/pull/2968#discussion_r91544114 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/RowTypeInfo.java --- @@ -0,0 +1,176 @@ +/* + * Licensed to the Apache Software

[GitHub] flink pull request #2968: [FLINK-5187] [core] Create analog of Row and RowTy...

2016-12-08 Thread tonycox
Github user tonycox commented on a diff in the pull request: https://github.com/apache/flink/pull/2968#discussion_r91548803 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowComparator.java --- @@ -0,0 +1,698 @@ +/* + * Licensed to the Apach

[jira] [Commented] (FLINK-5187) Create analog of Row in core

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15732680#comment-15732680 ] ASF GitHub Bot commented on FLINK-5187: --- Github user tonycox commented on a diff in

[jira] [Commented] (FLINK-5187) Create analog of Row in core

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15732686#comment-15732686 ] ASF GitHub Bot commented on FLINK-5187: --- Github user tonycox commented on a diff in

[jira] [Commented] (FLINK-5187) Create analog of Row in core

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15732685#comment-15732685 ] ASF GitHub Bot commented on FLINK-5187: --- Github user tonycox commented on a diff in

[jira] [Commented] (FLINK-5187) Create analog of Row in core

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15732681#comment-15732681 ] ASF GitHub Bot commented on FLINK-5187: --- Github user tonycox commented on a diff in

[jira] [Commented] (FLINK-5187) Create analog of Row in core

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15732684#comment-15732684 ] ASF GitHub Bot commented on FLINK-5187: --- Github user tonycox commented on a diff in

[jira] [Commented] (FLINK-5187) Create analog of Row in core

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15732682#comment-15732682 ] ASF GitHub Bot commented on FLINK-5187: --- Github user tonycox commented on a diff in

[jira] [Created] (FLINK-5296) Expose the old AlignedWindowOperators to the user through explicit commands.

2016-12-08 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5296: - Summary: Expose the old AlignedWindowOperators to the user through explicit commands. Key: FLINK-5296 URL: https://issues.apache.org/jira/browse/FLINK-5296 Project:

[jira] [Commented] (FLINK-5187) Create analog of Row in core

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15732683#comment-15732683 ] ASF GitHub Bot commented on FLINK-5187: --- Github user tonycox commented on a diff in

[jira] [Created] (FLINK-5295) Migrate the AlignedWindowOperators to the WindowOperator and make it backwards compatible.

2016-12-08 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5295: - Summary: Migrate the AlignedWindowOperators to the WindowOperator and make it backwards compatible. Key: FLINK-5295 URL: https://issues.apache.org/jira/browse/FLINK-5295

[jira] [Commented] (FLINK-5187) Create analog of Row in core

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

[GitHub] flink issue #2968: [FLINK-5187] [core] Create analog of Row and RowTypeInfo ...

2016-12-08 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/2968 Thanks for working on this @wuchong. I will review this next week. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does

[jira] [Created] (FLINK-5294) Make the WindowOperator backwards compatible.

2016-12-08 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5294: - Summary: Make the WindowOperator backwards compatible. Key: FLINK-5294 URL: https://issues.apache.org/jira/browse/FLINK-5294 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5293) Make the Kafka consumer backwards compatible.

2016-12-08 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5293: - Summary: Make the Kafka consumer backwards compatible. Key: FLINK-5293 URL: https://issues.apache.org/jira/browse/FLINK-5293 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5292) Make the remaining operators backwards compatible.

2016-12-08 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-5292: - Summary: Make the remaining operators backwards compatible. Key: FLINK-5292 URL: https://issues.apache.org/jira/browse/FLINK-5292 Project: Flink Issue Type

[GitHub] flink issue #2953: [FLINK-5039] Bump Avro version

2016-12-08 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2953 +1 to merge this for 1.2 and 1.1.4 --- 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 enabl

[jira] [Commented] (FLINK-5039) Avro GenericRecord support is broken

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

[GitHub] flink pull request #2964: [backport] [FLINK-5285] Abort checkpoint only once...

2016-12-08 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2964#discussion_r91547796 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/BarrierTracker.java --- @@ -225,17 +230,19 @@ private void processChe

[jira] [Commented] (FLINK-5285) CancelCheckpointMarker flood when using at least once mode

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

[GitHub] flink pull request #2963: [FLINK-5285] Abort checkpoint only once in Barrier...

2016-12-08 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2963#discussion_r91532008 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/BarrierBuffer.java --- @@ -422,7 +425,7 @@ private void beginNewAlignm

[jira] [Commented] (FLINK-5285) CancelCheckpointMarker flood when using at least once mode

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

[jira] [Commented] (FLINK-5289) NPE when using value state on non-keyed stream

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15732605#comment-15732605 ] ASF GitHub Bot commented on FLINK-5289: --- GitHub user StefanRRichter opened a pull re

[jira] [Commented] (FLINK-5289) NPE when using value state on non-keyed stream

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15732607#comment-15732607 ] ASF GitHub Bot commented on FLINK-5289: --- Github user StefanRRichter commented on the

[GitHub] flink issue #2969: [FLINK-5289] Meaningful exception when using value state ...

2016-12-08 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/2969 CC @twalthr --- 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, o

[GitHub] flink pull request #2969: [FLINK-5289] Meaningful exception when using value...

2016-12-08 Thread StefanRRichter
GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/2969 [FLINK-5289] Meaningful exception when using value state on non-keyed… This PR fixes [FLINK-5289] and introduces a meaningful exception when registering a keyed state on non-keyed stream.

[jira] [Commented] (FLINK-5039) Avro GenericRecord support is broken

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15732419#comment-15732419 ] ASF GitHub Bot commented on FLINK-5039: --- Github user davetorok commented on the issu

[GitHub] flink issue #2953: [FLINK-5039] Bump Avro version

2016-12-08 Thread davetorok
Github user davetorok commented on the issue: https://github.com/apache/flink/pull/2953 Thanks for this! I was going to PR yesterday but you beat me to it. Successfully running 25,825,230 Avro / GenericRecords in the past 48 hrs. --- If your project is set up for it, you can reply

[GitHub] flink pull request #2968: [FLINK-5187] [core] Create analog of Row and RowTy...

2016-12-08 Thread wuchong
GitHub user wuchong opened a pull request: https://github.com/apache/flink/pull/2968 [FLINK-5187] [core] Create analog of Row and RowTypeInfo and RowCompator in core Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list int

[jira] [Commented] (FLINK-5187) Create analog of Row in core

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15732415#comment-15732415 ] ASF GitHub Bot commented on FLINK-5187: --- GitHub user wuchong opened a pull request:

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

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15732356#comment-15732356 ] ASF GitHub Bot commented on FLINK-3551: --- Github user ch33hau commented on the issue:

[GitHub] flink issue #2761: [FLINK-3551] [examples] Sync Scala Streaming Examples

2016-12-08 Thread ch33hau
Github user ch33hau commented on the issue: https://github.com/apache/flink/pull/2761 Hi @thvasilo thank you for taking your time on this PR again. I have fixed the typos and couple of one-line-if statements, sorry for those mistakes =( . --- If your project is set up for it, yo

[jira] [Commented] (FLINK-5169) Make consumption of input channels fair

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

[GitHub] flink pull request #2967: [FLINK-5169] Fix String.format() wildcards

2016-12-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2967 --- 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 issue #2967: [FLINK-5169] Fix String.format() wildcards

2016-12-08 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/2967 Good catches! 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,

[jira] [Commented] (FLINK-5290) Ensure backwards compatibility of the hashes used to generate JobVertexIds

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

[GitHub] flink issue #2966: [FLINK-5290] Ensure backwards compatibility of the hashes...

2016-12-08 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/2966 Stephan, Aljoscha: I can take a look at this tomorrow or next week. --- 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 no

[jira] [Commented] (FLINK-5169) Make consumption of input channels fair

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

[jira] [Assigned] (FLINK-5289) NPE when using value state on non-keyed stream

2016-12-08 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-5289: - Assignee: Stefan Richter > NPE when using value state on non-keyed stream > -

[GitHub] flink issue #2966: [FLINK-5290] Ensure backwards compatibility of the hashes...

2016-12-08 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/2966 CC @aljoscha @uce @StephanEwen --- 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 enabl

[GitHub] flink pull request #2967: [FLINK-5169] Fix String.format() wildcards

2016-12-08 Thread BorisOsipov
GitHub user BorisOsipov opened a pull request: https://github.com/apache/flink/pull/2967 [FLINK-5169] Fix String.format() wildcards Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If your change

[jira] [Commented] (FLINK-5169) Make consumption of input channels fair

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15732288#comment-15732288 ] ASF GitHub Bot commented on FLINK-5169: --- GitHub user BorisOsipov opened a pull reque

[jira] [Updated] (FLINK-5066) add more efficient isEvent check to EventSerializer

2016-12-08 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-5066: --- Description: -LocalInputChannel#getNextBuffer de-serialises all incoming events on the lookout for an

[jira] [Updated] (FLINK-5066) add more efficient isEvent check to EventSerializer

2016-12-08 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-5066: --- Summary: add more efficient isEvent check to EventSerializer (was: prevent LocalInputChannel#getNextB

[jira] [Commented] (FLINK-5290) Ensure backwards compatibility of the hashes used to generate JobVertexIds

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15732273#comment-15732273 ] ASF GitHub Bot commented on FLINK-5290: --- GitHub user StefanRRichter opened a pull re

[jira] [Commented] (FLINK-5290) Ensure backwards compatibility of the hashes used to generate JobVertexIds

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15732278#comment-15732278 ] ASF GitHub Bot commented on FLINK-5290: --- Github user StefanRRichter commented on the

[GitHub] flink pull request #2966: [FLINK-5290] Ensure backwards compatibility of the...

2016-12-08 Thread StefanRRichter
GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/2966 [FLINK-5290] Ensure backwards compatibility of the hashes used to gen… The way in which hashes for JobVertexIds are generated changed between Flink 1.1 and 1.2 (parallelism was considered f

[GitHub] flink issue #2806: [FLINK-5066] Prevent LocalInputChannel#getNextBuffer from...

2016-12-08 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/2806 done, and yes, the code is now not relevant for `LocalInputChannel` anymore but for `PartitionRequestQueue` instead --- If your project is set up for it, you can reply to this email and have your repl

[jira] [Commented] (FLINK-5066) prevent LocalInputChannel#getNextBuffer from de-serialising all events when looking for EndOfPartitionEvent only

2016-12-08 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15732270#comment-15732270 ] ASF GitHub Bot commented on FLINK-5066: --- Github user NicoK commented on the issue:

[jira] [Closed] (FLINK-5291) Ensure backwards compatibility of the hashes used to generate JobVertexIds

2016-12-08 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-5291. - Resolution: Duplicate > Ensure backwards compatibility of the hashes used to generate JobVertexIds

[jira] [Created] (FLINK-5291) Ensure backwards compatibility of the hashes used to generate JobVertexIds

2016-12-08 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-5291: - Summary: Ensure backwards compatibility of the hashes used to generate JobVertexIds Key: FLINK-5291 URL: https://issues.apache.org/jira/browse/FLINK-5291 Project: F

[jira] [Created] (FLINK-5290) Ensure backwards compatibility of the hashes used to generate JobVertexIds

2016-12-08 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-5290: - Summary: Ensure backwards compatibility of the hashes used to generate JobVertexIds Key: FLINK-5290 URL: https://issues.apache.org/jira/browse/FLINK-5290 Project: F

[jira] [Updated] (FLINK-5041) Implement savepoint backwards compatibility 1.1 -> 1.2

2016-12-08 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-5041: -- Description: This issue tracks the implementation of backwards compatibility between Flink 1.1

[jira] [Created] (FLINK-5289) NPE when using value state on non-keyed stream

2016-12-08 Thread Timo Walther (JIRA)
Timo Walther created FLINK-5289: --- Summary: NPE when using value state on non-keyed stream Key: FLINK-5289 URL: https://issues.apache.org/jira/browse/FLINK-5289 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-3053) SuccessAfterNetworkBuffersFailureITCase.testSuccessfulProgramAfterFailure

2016-12-08 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15732160#comment-15732160 ] Nico Kruber commented on FLINK-3053: one more: https://api.travis-ci.org/jobs/18197645

[jira] [Created] (FLINK-5288) Flakey ConnectedComponentsITCase#testConnectedComponentsExample unit test

2016-12-08 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-5288: -- Summary: Flakey ConnectedComponentsITCase#testConnectedComponentsExample unit test Key: FLINK-5288 URL: https://issues.apache.org/jira/browse/FLINK-5288 Project: Flink

[jira] [Commented] (FLINK-4563) [metrics] scope caching not adjusted for multiple reporters

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

[jira] [Commented] (FLINK-5020) Make the GenericWriteAheadSink rescalable.

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

[jira] [Closed] (FLINK-5020) Make the GenericWriteAheadSink rescalable.

2016-12-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5020. --- Resolution: Fixed Implemented in 4eb71927bc4f0832eb08a79394ad6864a3c2e142 > Make the GenericW

[jira] [Commented] (FLINK-5164) Hadoop-compat IOFormat tests fail on Windows

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

[GitHub] flink pull request #2650: [FLINK-4563] [metrics] scope caching not adjusted ...

2016-12-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2650 --- 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 #2759: [FLINK-5020] Make the GenericWriteAheadSink rescal...

2016-12-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2759 --- 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] [Closed] (FLINK-5164) Hadoop-compat IOFormat tests fail on Windows

2016-12-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5164. --- Resolution: Fixed Fixed in fe843e1377aa08a10394bbfa67dc9d3b2a23b805 > Hadoop-compat IOFormat

[GitHub] flink pull request #2889: [FLINK-5164] Disable some Hadoop-compat tests on W...

2016-12-08 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2889 --- 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] [Closed] (FLINK-4563) [metrics] scope caching not adjusted for multiple reporters

2016-12-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-4563. --- Resolution: Fixed Fix Version/s: 1.2.0 Implemented in 86f784a3613ccd5d78197d94198a64b6f

[jira] [Commented] (FLINK-5187) Create analog of Row in core

2016-12-08 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15732044#comment-15732044 ] Jark Wu commented on FLINK-5187: Sure. I will create the PR before tomorrow. Thanks. > C

[jira] [Updated] (FLINK-5187) Create analog of Row in core

2016-12-08 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev updated FLINK-5187: - Assignee: Jark Wu (was: Anton Solovev) > Create analog of Row in core > -

<    1   2   3   >