[GitHub] flink issue #2762: [FLINK-3871] Add Kafka TableSource with Avro serializatio...

2016-12-08 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2762 Hi @mushketyk, sorry for the concise description before. The problem is the following: A `TableSource` provides schema information for the Table it produces. However, the methods `TableSourc

[jira] [Commented] (FLINK-3871) Add Kafka TableSource with Avro serialization

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

[jira] [Commented] (FLINK-3849) Add FilterableTableSource interface and translation rule

2016-12-08 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15731533#comment-15731533 ] Anton Solovev commented on FLINK-3849: -- Hello, [~fhueske] Can we implement it in CsvT

[GitHub] flink issue #2810: [FLINK-3848] Add ProjectableTableSource interface and tra...

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

[jira] [Commented] (FLINK-3848) Add ProjectableTableSource interface and translation rule

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

[jira] [Commented] (FLINK-3849) Add FilterableTableSource interface and translation rule

2016-12-08 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15731549#comment-15731549 ] Fabian Hueske commented on FLINK-3849: -- Hi [~tonycox], I would like to wait for FLIN

[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 Thanks for the reviews @KurtYoung and @beyond1920. I will merge this PR later today. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Commented] (FLINK-5226) Eagerly project unused attributes

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

[GitHub] flink issue #2509: [FLINK-4280][kafka-connector] Explicit start position con...

2016-12-08 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2509 Rebased on the "flink-connectors" change. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature e

[jira] [Commented] (FLINK-4280) New Flink-specific option to set starting position of Kafka consumer without respecting external offsets in ZK / Broker

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

[GitHub] flink issue #2756: [FLINK-4997] Extending Window Function Metadata

2016-12-08 Thread VenturaDelMonte
Github user VenturaDelMonte commented on the issue: https://github.com/apache/flink/pull/2756 @manuzhang the other PR is ready since few days, you can find it here: #2946 . @aljoscha do you plan to add more tests also for AllWindowedStream? --- If your project is set up for

[jira] [Commented] (FLINK-4997) Extending Window Function Metadata

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

[GitHub] flink issue #2509: [FLINK-4280][kafka-connector] Explicit start position con...

2016-12-08 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2509 Thanks a lot! I have your Kafka pull requests on my todo list. I hope I get to it soon. I'm really sorry. --- If your project is set up for it, you can reply to this email and have your reply appea

[jira] [Commented] (FLINK-4280) New Flink-specific option to set starting position of Kafka consumer without respecting external offsets in ZK / Broker

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

[jira] [Assigned] (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 reassigned FLINK-5187: Assignee: Anton Solovev > Create analog of Row in core > > >

[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=15731686#comment-15731686 ] Jark Wu commented on FLINK-5187: Hi [~tonycox], do you have been working on this issue? I

[jira] [Created] (FLINK-5284) Make output of bucketing sink compatible with other processing framework like mapreduce

2016-12-08 Thread Wenlong Lyu (JIRA)
Wenlong Lyu created FLINK-5284: -- Summary: Make output of bucketing sink compatible with other processing framework like mapreduce Key: FLINK-5284 URL: https://issues.apache.org/jira/browse/FLINK-5284 Pro

[jira] [Commented] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

2016-12-08 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15731744#comment-15731744 ] Maximilian Michels commented on FLINK-2821: --- Thanks for testing again! I've alre

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

2016-12-08 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-5285: Summary: CancelCheckpointMarker flood when using at least once mode Key: FLINK-5285 URL: https://issues.apache.org/jira/browse/FLINK-5285 Project: Flink Issu

[GitHub] flink pull request #2962: [FLINK-5051] Backwards compatibility for serialize...

2016-12-08 Thread StefanRRichter
GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/2962 [FLINK-5051] Backwards compatibility for serializers in backens This PR sits on top of PR #2781 and introduces future backwards compatibility for state serializers and backends. We do so by

[jira] [Commented] (FLINK-5051) Backwards compatibility for serializers in backend state

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

[GitHub] flink issue #2863: [FLINK-5051] Backwards compatibility for serializers in b...

2016-12-08 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/2863 Replaced by PR #2962. --- 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 wis

[GitHub] flink pull request #2863: [FLINK-5051] Backwards compatibility for serialize...

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

[jira] [Commented] (FLINK-5051) Backwards compatibility for serializers in backend state

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

[jira] [Commented] (FLINK-5051) Backwards compatibility for serializers in backend state

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

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

[jira] [Commented] (FLINK-5051) Backwards compatibility for serializers in backend state

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

[GitHub] flink issue #2962: [FLINK-5051] Backwards compatibility for serializers in b...

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

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=15731794#comment-15731794 ] Anton Solovev commented on FLINK-5187: -- Hi [~jark], Sure > Create analog of Row in c

[GitHub] flink issue #2962: [FLINK-5051] Backwards compatibility for serializers in b...

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

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

2016-12-08 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/2963 [FLINK-5285] Abort checkpoint only once in BarrierTracker Prevent an interleaved sequence of cancellation markers for two consecutive checkpoints to trigger a flood of cancellation markers

[jira] [Assigned] (FLINK-5254) Implement Yarn HA Services

2016-12-08 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-5254: --- Assignee: Stephan Ewen > Implement Yarn HA Services > -- > >

[jira] [Commented] (FLINK-5051) Backwards compatibility for serializers in backend state

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

[jira] [Comment Edited] (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:comment-tabpanel&focusedCommentId=15731794#comment-15731794 ] Anton Solovev edited comment on FLINK-5187 at 12/8/16 10:35 AM:

[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=15731799#comment-15731799 ] ASF GitHub Bot commented on FLINK-5285: --- GitHub user tillrohrmann opened a pull requ

[jira] [Comment Edited] (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:comment-tabpanel&focusedCommentId=15731794#comment-15731794 ] Anton Solovev edited comment on FLINK-5187 at 12/8/16 10:35 AM:

[jira] [Assigned] (FLINK-2186) Rework CSV import to support very wide files

2016-12-08 Thread Anton Solovev (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Solovev reassigned FLINK-2186: Assignee: Anton Solovev > Rework CSV import to support very wide files > --

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

2016-12-08 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/2964 [backport] [FLINK-5285] Abort checkpoint only once in BarrierTracker Backport of #2963 for the release-1.1 branch. Prevent an interleaved sequence of cancellation markers for two consec

[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=15731810#comment-15731810 ] ASF GitHub Bot commented on FLINK-5285: --- GitHub user tillrohrmann opened a pull requ

[GitHub] flink issue #2829: [hotfix] prevent RecordWriter#flush() to clear the serial...

2016-12-08 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/2829 I put a bit more emphasis on that fact in the new docs. I'd say, that's enough and after reading the docs, the difference should be clear. --- If your project is set up for it, you can reply to this e

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

2016-12-08 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2953 Rebased to master to include fixed build. --- 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 e

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

[jira] [Created] (FLINK-5286) Build instability: WordCountSubclassPOJOITCase fails with IOException: Stream Closed

2016-12-08 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5286: - Summary: Build instability: WordCountSubclassPOJOITCase fails with IOException: Stream Closed Key: FLINK-5286 URL: https://issues.apache.org/jira/browse/FLINK-5286

[jira] [Commented] (FLINK-5049) Instability in QueryableStateITCase.testQueryableStateWithTaskManagerFailure

2016-12-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15731886#comment-15731886 ] Robert Metzger commented on FLINK-5049: --- Again: https://api.travis-ci.org/jobs/18200

[jira] [Commented] (FLINK-5286) Build instability: WordCountSubclassPOJOITCase fails with IOException: Stream Closed

2016-12-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15731894#comment-15731894 ] Chesnay Schepler commented on FLINK-5286: - Another occurrence in FLINK-5191. > Bu

[jira] [Commented] (FLINK-5191) ConnectedComponentsWithDeferredUpdateITCase failed

2016-12-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15731895#comment-15731895 ] Chesnay Schepler commented on FLINK-5191: - Another occurrence in FLINK-5286. > Co

[jira] [Created] (FLINK-5287) Test randomly fails with wrong result: testWithAtomic2[Execution mode = CLUSTER](org.apache.flink.api.scala.operators.JoinITCase)

2016-12-08 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5287: - Summary: Test randomly fails with wrong result: testWithAtomic2[Execution mode = CLUSTER](org.apache.flink.api.scala.operators.JoinITCase) Key: FLINK-5287 URL: https://issues.a

[jira] [Commented] (FLINK-5147) StreamingOperatorsITCase.testGroupedFoldOperation failed on Travis

2016-12-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15731899#comment-15731899 ] Robert Metzger commented on FLINK-5147: --- This seems a frequent issue ;) https://api

[jira] [Commented] (FLINK-4631) NullPointerException during stream task cleanup

2016-12-08 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15731902#comment-15731902 ] Chesnay Schepler commented on FLINK-4631: - Can we close this issue? The NullPointe

[jira] [Updated] (FLINK-5206) Flakey PythonPlanBinderTest

2016-12-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5206: -- Component/s: Python API > Flakey PythonPlanBinderTest > --- > >

[jira] [Updated] (FLINK-5206) Flakey PythonPlanBinderTest

2016-12-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5206: -- Affects Version/s: 1.2.0 > Flakey PythonPlanBinderTest > --- > >

[jira] [Commented] (FLINK-5206) Flakey PythonPlanBinderTest

2016-12-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15731901#comment-15731901 ] Robert Metzger commented on FLINK-5206: --- I got the same again: https://api.travis-c

[GitHub] flink issue #2759: [FLINK-5020] Make the GenericWriteAheadSink rescalable.

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

[jira] [Updated] (FLINK-5206) Flakey PythonPlanBinderTest

2016-12-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-5206: -- Labels: test-stability (was: ) > Flakey PythonPlanBinderTest > --- > >

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

[jira] [Commented] (FLINK-5286) Build instability: WordCountSubclassPOJOITCase fails with IOException: Stream Closed

2016-12-08 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15731933#comment-15731933 ] Stefan Richter commented on FLINK-5286: --- I think that FLINK-4910 uncovers subtle pro

[jira] [Commented] (FLINK-2980) Add CUBE/ROLLUP/GROUPING SETS operator in Table API.

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

[GitHub] flink pull request #2965: [FLINK-2980] [table] Support for SQL GROUPING SETS...

2016-12-08 Thread chermenin
GitHub user chermenin opened a pull request: https://github.com/apache/flink/pull/2965 [FLINK-2980] [table] Support for SQL GROUPING SETS clause. Support for operators GROUPING SETS / ROLLUP / CUBE was added in this PR. Also added some tests for check execution of SQL queries wit

[jira] [Assigned] (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 reassigned FLINK-5187: Assignee: Anton Solovev (was: Jark Wu) > Create analog of Row in core > --

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

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

[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

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

[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

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

[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

[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

[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

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

[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

[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

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

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

[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-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 #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,

[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

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

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

[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

[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

[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

  1   2   3   >