[jira] [Created] (FLINK-5682) Fix scala version in flink-streaming-scala

Bill Liu created FLINK-5682: --- Summary: Fix scala version in flink-streaming-scala Key: FLINK-5682 URL: https://issues.apache.org/jira/browse/FLINK-5682 Project: Flink Issue Type: Bug

Re: Stream SQL and Dynamic tables

Hi Radu, the idea is to only support operations that are bounded in space and compute time: - space: the size of state may not infinitely grow over time or with growing key domains. For these cases, the optimizer will enforce a cleanup timeout and all data which is passed that timeout will be

Re: STREAM SQL inner queries

Hi Radu, I was a bit surprised, that Calcite's parser accepted your query. Hence, I check the Calcite plan and and had look at the documentation of Calcite's SqlSingleValueAggFunction: > SINGLE_VALUE aggregate function returns the input value if there is only one value in the input; Otherwise it

Re: flink-ml test

Adding to previous, "suites" option is technically more correct for the case since wildcard is for running everything under a package (subpackages included): mvn test -Dsuites=org.apache.flink.ml.math.BreezeMathSuite This runs all tests under ml: mvn test -DwildcardSuites=org.apache.flink.ml On

[jira] [Created] (FLINK-5681) Make ReaperThread for SafetyNetCloseableRegistry a singleton

Stefan Richter created FLINK-5681: - Summary: Make ReaperThread for SafetyNetCloseableRegistry a singleton Key: FLINK-5681 URL: https://issues.apache.org/jira/browse/FLINK-5681 Project: Flink

[jira] [Created] (FLINK-5680) Document env.ssh.opts

Greg Hogan created FLINK-5680: - Summary: Document env.ssh.opts Key: FLINK-5680 URL: https://issues.apache.org/jira/browse/FLINK-5680 Project: Flink Issue Type: Improvement Components:

[jira] [Created] (FLINK-5679) Refactor *CheckpointedITCase tests to speed up

Andrew Efimov created FLINK-5679: Summary: Refactor *CheckpointedITCase tests to speed up Key: FLINK-5679 URL: https://issues.apache.org/jira/browse/FLINK-5679 Project: Flink Issue Type:

Re: [DISCUSS] (Not) tagging reviewers

> I took a quick skim on the PRs and I noticed that only a few of them are actually in mergeable shapes (i.e., properly rebased and passing CI). Although TravisCI is quite unstable, Flink executes multiple tests with different configurations so you'll want to instead look at which tests are

Re: flink-ml test

Hi, For running a specific test under flink-ml: mvn test -DwildcardSuites=org.apache.flink.ml.math.BreezeMathSuite BreezeMathSuite Cheers, Stavros On Fri, Jan 27, 2017 at 12:01 PM, Driesprong, Fokko wrote: > Hi Anton, > > I'm curious what tests fail. I run the tests by

Re: flink-ml test

typo:remove the second BreezeMathSuite.. On Fri, Jan 27, 2017 at 4:06 PM, Stavros Kontopoulos < st.kontopou...@gmail.com> wrote: > Hi, > > For running a specific test under flink-ml: > mvn test -DwildcardSuites=org.apache.flink.ml.math.BreezeMathSuite > BreezeMathSuite > > Cheers, > Stavros > >

[jira] [Created] (FLINK-5678) User-defined TableFunctions do not support all types of parameters

Timo Walther created FLINK-5678: --- Summary: User-defined TableFunctions do not support all types of parameters Key: FLINK-5678 URL: https://issues.apache.org/jira/browse/FLINK-5678 Project: Flink

[jira] [Created] (FLINK-5677) Validation layer should check whether field can be used as grouping key

Timo Walther created FLINK-5677: --- Summary: Validation layer should check whether field can be used as grouping key Key: FLINK-5677 URL: https://issues.apache.org/jira/browse/FLINK-5677 Project: Flink

[jira] [Created] (FLINK-5676) Grouping on nested fields does not work

Timo Walther created FLINK-5676: --- Summary: Grouping on nested fields does not work Key: FLINK-5676 URL: https://issues.apache.org/jira/browse/FLINK-5676 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5675) Improve QueryableStateClient API

Ufuk Celebi created FLINK-5675: -- Summary: Improve QueryableStateClient API Key: FLINK-5675 URL: https://issues.apache.org/jira/browse/FLINK-5675 Project: Flink Issue Type: Improvement

Re: [VOTE] Release Apache Flink 1.2.0 (RC2)

I think this issue that Ufuk opened is also a blocker: https://issues.apache.org/jira/browse/FLINK-5670 As I comment in the Issue, at least one bigger user of Flink has run into this problem on their cluster. On Fri, 27 Jan 2017 at 10:50 Ufuk Celebi wrote: > Thanks Gyula! > >

[jira] [Created] (FLINK-5674) Stdout not present in logs files

Timo Walther created FLINK-5674: --- Summary: Stdout not present in logs files Key: FLINK-5674 URL: https://issues.apache.org/jira/browse/FLINK-5674 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5673) NullPointerException in RemoteInputChannel.requestSubpartition

Timo Walther created FLINK-5673: --- Summary: NullPointerException in RemoteInputChannel.requestSubpartition Key: FLINK-5673 URL: https://issues.apache.org/jira/browse/FLINK-5673 Project: Flink

[jira] [Created] (FLINK-5672) Job fails with java.lang.IllegalArgumentException: port out of range:-1

Timo Walther created FLINK-5672: --- Summary: Job fails with java.lang.IllegalArgumentException: port out of range:-1 Key: FLINK-5672 URL: https://issues.apache.org/jira/browse/FLINK-5672 Project: Flink

RE: [jira] [Created] (FLINK-5656) Add processing time OVER ROWS BETWEEN UNBOUNDED PRECEDING aggregation to SQL

Ok, I just noticed that there is also the 5653 issue open, and I guess I should start working on that first. -Original Message- From: Fabian Hueske [mailto:fhue...@gmail.com] Sent: Friday, January 27, 2017 10:34 AM To: dev@flink.apache.org Subject: Re: [jira] [Created] (FLINK-5656) Add

[jira] [Created] (FLINK-5671) Test ClassLoaderITCase#testJobsWithCustomClassLoader fails

Anton Solovev created FLINK-5671: Summary: Test ClassLoaderITCase#testJobsWithCustomClassLoader fails Key: FLINK-5671 URL: https://issues.apache.org/jira/browse/FLINK-5671 Project: Flink

RE: Stream SQL and Dynamic tables

Hi, Thanks for the clarification Fabian - it is really useful. I agree that we should consolidate the module and avoid the need to further maintain 3 different "projects". It does make sense to see the current (I would call it)"Stream SQL" as a table with append semantics. However, one thing

Re: flink-ml test

Hi Anton, I'm curious what tests fail. I run the tests by using `mvn verify` in the flink-ml directory. My output is: http://pastebin.com/WmgGMb8g. I ran this against the current master. Cheers, Fokko 2017-01-27 9:21 GMT+01:00 Anton Solovev : > Yes, I had that commit, I

Re: [VOTE] Release Apache Flink 1.2.0 (RC2)

Thanks Gyula! The current state of things is: - Stefan is working on a fix for  https://issues.apache.org/jira/browse/FLINK-5663. - Till is working on https://issues.apache.org/jira/browse/FLINK-5667. As far as I can tell, these will be fixed today and we are ready to go for RC3. I resolved the

RE: STREAM SQL inner queries

Hi all, Thanks for the feedback! I agree that we should get the semantics right and after we can implement it. I think it would be quite useful. Now, regarding the remarks you made: "> SELECT STREAM amount, (SELECT id FROM inputstream1) AS field1 FROM inputstream2 you are suggesting that

Re: [jira] [Created] (FLINK-5656) Add processing time OVER ROWS BETWEEN UNBOUNDED PRECEDING aggregation to SQL

Hi Stefano, I can assign the issue to you if you want to. Just drop a comment in JIRA. Best, Fabian 2017-01-27 9:39 GMT+01:00 Stefano Bortoli : > Hi Fabian, > > In the next days I will start working on this issue. As soon as I have a > proposal I will start sharing

[jira] [Created] (FLINK-5670) Local RocksDB directories not cleaned up

Ufuk Celebi created FLINK-5670: -- Summary: Local RocksDB directories not cleaned up Key: FLINK-5670 URL: https://issues.apache.org/jira/browse/FLINK-5670 Project: Flink Issue Type: Bug

RE: [jira] [Created] (FLINK-5656) Add processing time OVER ROWS BETWEEN UNBOUNDED PRECEDING aggregation to SQL

Hi Fabian, In the next days I will start working on this issue. As soon as I have a proposal I will start sharing it for discussion. Regards, Dr. Stefano Bortoli Senior Research Engineer - Big Data and Semantic Technology Expert IT R Division -Original Message- From: Fabian Hueske

Re: [Discuss] Declare class field's type in scala class field

Hi, Till, Bruno Thank for your reply. Twitter’s scala programming suggestion is useful. I prefer the alexandru/scala-best-practices. Like this rule `2.16. Public functions SHOULD have an explicit return type`, the class field type explicitly declaring is better for developer to read. [1]

RE: flink-ml test

Yes, I had that commit, I tested master branch at that time -Original Message- From: Till Rohrmann [mailto:trohrm...@apache.org] Sent: Thursday, January 26, 2017 6:04 PM To: dev@flink.apache.org Subject: Re: flink-ml test Hi Anton, which build are you using? I've recently (Monday)