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

[ https://issues.apache.org/jira/browse/FLINK-2980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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...

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

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

[ https://issues.apache.org/jira/browse/FLINK-5286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15731933#comment-15731933 ] Stefan Richter commented on FLINK-5286: --- I think that FLINK-4910 uncovers subtle problems in those

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

[ https://issues.apache.org/jira/browse/FLINK-5020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15731904#comment-15731904 ] ASF GitHub Bot commented on FLINK-5020: --- Github user zentol commented on the issue:

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

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

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

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

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

[ 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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-5206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15731901#comment-15731901 ] Robert Metzger commented on FLINK-5206: --- I got the same again:

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

[ https://issues.apache.org/jira/browse/FLINK-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15731902#comment-15731902 ] Chesnay Schepler commented on FLINK-4631: - Can we close this issue? The NullPointerException can

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

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

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

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:

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

[ https://issues.apache.org/jira/browse/FLINK-5191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15731895#comment-15731895 ] Chesnay Schepler commented on FLINK-5191: - Another occurrence in FLINK-5286. >

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

[ https://issues.apache.org/jira/browse/FLINK-5286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15731894#comment-15731894 ] Chesnay Schepler commented on FLINK-5286: - Another occurrence in FLINK-5191. > Build instability:

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

[ https://issues.apache.org/jira/browse/FLINK-5049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15731886#comment-15731886 ] Robert Metzger commented on FLINK-5049: --- Again:

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

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-5039) Avro GenericRecord support is broken

[ https://issues.apache.org/jira/browse/FLINK-5039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15731863#comment-15731863 ] ASF GitHub Bot commented on FLINK-5039: --- Github user rmetzger commented on the issue:

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

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-5285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15731810#comment-15731810 ] ASF GitHub Bot commented on FLINK-5285: --- GitHub user tillrohrmann opened a pull request:

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

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-5187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15731794#comment-15731794 ] Anton Solovev edited comment on FLINK-5187 at 12/8/16 10:35 AM: Hi

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

[ https://issues.apache.org/jira/browse/FLINK-5187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15731794#comment-15731794 ] Anton Solovev edited comment on FLINK-5187 at 12/8/16 10:35 AM: Hi

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

[ https://issues.apache.org/jira/browse/FLINK-5285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15731799#comment-15731799 ] ASF GitHub Bot commented on FLINK-5285: --- GitHub user tillrohrmann opened a pull request:

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

[ https://issues.apache.org/jira/browse/FLINK-5051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15731796#comment-15731796 ] ASF GitHub Bot commented on FLINK-5051: --- Github user StefanRRichter commented on the issue:

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

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

[ 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-5187) Create analog of Row in core

[ https://issues.apache.org/jira/browse/FLINK-5187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15731794#comment-15731794 ] Anton Solovev commented on FLINK-5187: -- Hi [~jark], Sure > Create analog of Row in core >

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

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-5051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15731793#comment-15731793 ] ASF GitHub Bot commented on FLINK-5051: --- Github user StefanRRichter commented on the issue:

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-5051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15731788#comment-15731788 ] ASF GitHub Bot commented on FLINK-5051: --- Github user StefanRRichter closed the pull request at:

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

[ https://issues.apache.org/jira/browse/FLINK-5051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15731787#comment-15731787 ] ASF GitHub Bot commented on FLINK-5051: --- Github user StefanRRichter commented on the issue:

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

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-5051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15731784#comment-15731784 ] ASF GitHub Bot commented on FLINK-5051: --- GitHub user StefanRRichter opened a pull request:

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

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] [Created] (FLINK-5285) CancelCheckpointMarker flood when using at least once mode

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

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

[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15731744#comment-15731744 ] Maximilian Michels commented on FLINK-2821: --- Thanks for testing again! I've already fixed the

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-5187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15731686#comment-15731686 ] Jark Wu commented on FLINK-5187: Hi [~tonycox], do you have been working on this issue? If not, would you

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

[ 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-4280) New Flink-specific option to set starting position of Kafka consumer without respecting external offsets in ZK / Broker

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-4997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15731621#comment-15731621 ] ASF GitHub Bot commented on FLINK-4997: --- Github user VenturaDelMonte commented on the issue:

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

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-4280) New Flink-specific option to set starting position of Kafka consumer without respecting external offsets in ZK / Broker

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

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

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

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

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15731549#comment-15731549 ] Fabian Hueske commented on FLINK-3849: -- Hi [~tonycox], I would like to wait for FLINK-3848 to be

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

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15731533#comment-15731533 ] Anton Solovev commented on FLINK-3849: -- Hello, [~fhueske] Can we implement it in CsvTableSource? What

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

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

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

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

<    1   2   3