[jira] [Created] (FLINK-5303) Add CUBE/ROLLUP/GROUPING SETS operator in SQL

Alexander Chermenin created FLINK-5303: -- Summary: Add CUBE/ROLLUP/GROUPING SETS operator in SQL Key: FLINK-5303 URL: https://issues.apache.org/jira/browse/FLINK-5303 Project: Flink

Re: [DISCUSS] (FLINK-2980) Add support for CUBE / ROLLUP / GROUPING SETS in Table API

Hi Fabian, thanks for your comments. I think that's good approach. I will create new issue today and change my PR after that. Regards, Alexander On Thu, Dec 8, 2016 at 11:40 PM, Fabian Hueske wrote: > Hi Alexander, > > thanks for the PR! > It might take sometime until it is

[jira] [Created] (FLINK-5302) Log failure cause at Execution

Ufuk Celebi created FLINK-5302: -- Summary: Log failure cause at Execution Key: FLINK-5302 URL: https://issues.apache.org/jira/browse/FLINK-5302 Project: Flink Issue Type: Improvement

Re: [DISCUSS] (FLINK-2980) Add support for CUBE / ROLLUP / GROUPING SETS in Table API

Hi Alexander, thanks for the PR! It might take sometime until it is reviewed. We have received quite a few PRs for the Table API lately and there is kind of a review queue at the moment. The scope of the current issue (FLINK-2980) is to support grouping sets, cube, and rollup in the Table API

[jira] [Created] (FLINK-5301) Can't upload job via Web UI when using a proxy

Mischa Krüger created FLINK-5301: Summary: Can't upload job via Web UI when using a proxy Key: FLINK-5301 URL: https://issues.apache.org/jira/browse/FLINK-5301 Project: Flink Issue Type: Bug

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

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

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

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:

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

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

Re: [DISCUSS] Schedule and Scope for Flink 1.2

We might also think about addressing: Relocate Flink's Hadoop dependency and its transitive dependencies (FLINK-5297), because a user reported that they cannot use the system due to a dependency issue. Cheers, Till On Thu, Dec 8, 2016 at 10:17 AM, Robert Metzger wrote: >

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

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

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

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

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

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] [Created] (FLINK-5294) Make the WindowOperator backwards compatible.

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:

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

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:

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

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

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

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:

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

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:

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

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

[DISCUSS] (FLINK-2980) Add support for CUBE / ROLLUP / GROUPING SETS in Table API

Hi folks! I would like to discuss next question: In PR #2965 (https://github.com/apache/flink/pull/2965) I have added support for such operators as CUBE / ROLLUP / GROUPING SETS in SQL queries. Should we do support for the same functionality in Table API? And if so, how will it look? Something

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