[jira] [Created] (FLINK-4252) Table program cannot be compiled

Renkai Ge created FLINK-4252: Summary: Table program cannot be compiled Key: FLINK-4252 URL: https://issues.apache.org/jira/browse/FLINK-4252 Project: Flink Issue Type: Bug Components:

Re: Broadcast data sent increases with # slots per TM

Hi everybody, I found an issue with my first approach therefore I couldn't run the experiments yet. In the design document I summarized my ideas and work of the last weeks on this issue. You can find the design document here: https://docs.google.com/document/d/1odYIvmQt4feonQF9q-btBnGvrzzN3lX0Os6

[jira] [Created] (FLINK-4251) Add possiblity for the RMQ Streaming Sink to customize the queue

Philipp Grulich created FLINK-4251: -- Summary: Add possiblity for the RMQ Streaming Sink to customize the queue Key: FLINK-4251 URL: https://issues.apache.org/jira/browse/FLINK-4251 Project: Flink

[jira] [Created] (FLINK-4250) Cannot select column from CsvTableSource

Till Rohrmann created FLINK-4250: Summary: Cannot select column from CsvTableSource Key: FLINK-4250 URL: https://issues.apache.org/jira/browse/FLINK-4250 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-4248) CsvTableSource does not support reading SqlTimeTypeInfo types

Till Rohrmann created FLINK-4248: Summary: CsvTableSource does not support reading SqlTimeTypeInfo types Key: FLINK-4248 URL: https://issues.apache.org/jira/browse/FLINK-4248 Project: Flink

[jira] [Created] (FLINK-4249) CsvTableSource does not support reading SqlTimeTypeInfo types

Till Rohrmann created FLINK-4249: Summary: CsvTableSource does not support reading SqlTimeTypeInfo types Key: FLINK-4249 URL: https://issues.apache.org/jira/browse/FLINK-4249 Project: Flink

[jira] [Created] (FLINK-4247) CsvTableSource.getDataSet() expects Java ExecutionEnvironment

Till Rohrmann created FLINK-4247: Summary: CsvTableSource.getDataSet() expects Java ExecutionEnvironment Key: FLINK-4247 URL: https://issues.apache.org/jira/browse/FLINK-4247 Project: Flink

[jira] [Created] (FLINK-4246) Allow Specifying Multiple Metrics Reporters

Aljoscha Krettek created FLINK-4246: --- Summary: Allow Specifying Multiple Metrics Reporters Key: FLINK-4246 URL: https://issues.apache.org/jira/browse/FLINK-4246 Project: Flink Issue Type: I

Re: Flink 1.1.0 Preview RC0

https://github.com/apache/flink/pull/2257 should almost be mergable. There is only an issue with one test which only occurs on Travis. But I think I found the culprit. Currently, testing it on Travis again. On Thu, Jul 21, 2016 at 3:53 PM, Flavio Pompermaier wrote: > Maybe someone could complete

[jira] [Created] (FLINK-4245) Metric naming improvements

Stephan Ewen created FLINK-4245: --- Summary: Metric naming improvements Key: FLINK-4245 URL: https://issues.apache.org/jira/browse/FLINK-4245 Project: Flink Issue Type: Improvement Re

[jira] [Created] (FLINK-4244) Field names for union operator do not have to be equal

Till Rohrmann created FLINK-4244: Summary: Field names for union operator do not have to be equal Key: FLINK-4244 URL: https://issues.apache.org/jira/browse/FLINK-4244 Project: Flink Issue Ty

[jira] [Created] (FLINK-4243) Change "Scope" to "Namespace" for Metrics

Stephan Ewen created FLINK-4243: --- Summary: Change "Scope" to "Namespace" for Metrics Key: FLINK-4243 URL: https://issues.apache.org/jira/browse/FLINK-4243 Project: Flink Issue Type: Improvement

Re: Flink 1.1.0 Preview RC0

Maybe someone could complete FLINK-3901 - Added CsvRowInputFormat ? This would be very useful to us.. Best, Flavio On Thu, Jul 21, 2016 at 3:31 PM, Aljoscha Krettek wrote: > Sounds good! > > This one I just merged: https://github.com/apache/flink/pull/2273 (Only > allow/require query > for Tupl

[jira] [Created] (FLINK-4242) Improve validation exception messages

Till Rohrmann created FLINK-4242: Summary: Improve validation exception messages Key: FLINK-4242 URL: https://issues.apache.org/jira/browse/FLINK-4242 Project: Flink Issue Type: Improvement

Re: Flink 1.1.0 Preview RC0

I think Aljoscha is having a look. > On Jul 21, 2016, at 3:39 PM, Kostas Kloudas > wrote: > > There is an open PR now for https://issues.apache.org/jira/browse/FLINK-4207 > > > Kostas > >> On Jul 21, 2016, at 3:38 PM, Stephan Ewen >

Re: Flink 1.1.0 Preview RC0

There is an open PR now for https://issues.apache.org/jira/browse/FLINK-4207 Kostas > On Jul 21, 2016, at 3:38 PM, Stephan Ewen wrote: > > Looking into - https://github.com/apache/flink/pull/2226: Move Metrics API > to separate module > > On

Re: Flink 1.1.0 Preview RC0

Looking into - https://github.com/apache/flink/pull/2226: Move Metrics API to separate module On Thu, Jul 21, 2016 at 3:31 PM, Aljoscha Krettek wrote: > Sounds good! > > This one I just merged: https://github.com/apache/flink/pull/2273 (Only > allow/require query > for Tuple Stream in CassandraS

Re: Flink 1.1.0 Preview RC0

Sounds good! This one I just merged: https://github.com/apache/flink/pull/2273 (Only allow/require query for Tuple Stream in CassandraSink) For https://issues.apache.org/jira/browse/FLINK-4239 (Set Default Allowed Lateness to Zero and Make Triggers Non-Purging) I just opened a PR: https://github.

[jira] [Created] (FLINK-4241) Cryptic expression parser exceptions

Till Rohrmann created FLINK-4241: Summary: Cryptic expression parser exceptions Key: FLINK-4241 URL: https://issues.apache.org/jira/browse/FLINK-4241 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-4240) Cannot use expressions in Scala Table API's groupBy method

Till Rohrmann created FLINK-4240: Summary: Cannot use expressions in Scala Table API's groupBy method Key: FLINK-4240 URL: https://issues.apache.org/jira/browse/FLINK-4240 Project: Flink Issu

Re: Flink 1.1.0 Preview RC0

Hey all, although there was no feedback for this preview RC, most of the issues mentioned in the release are either resolved or open PRs. Once the following PRs have been merged, I would like to create RC1 and the release-1.1 branch. Feedback to this list is highly appreciated. Open PRs (awaiting

Re: [DISCUSS] Enhance Window Evictor in Flink

Thanks Aljoscha. On Thu, Jul 21, 2016 at 4:46 AM, Aljoscha Krettek wrote: > Hi, > this, in fact, seems to be a bug. There should be something like > windowState.clear(); > for (IN element: projectedContents) { >windowState.add(element); > } > > after passing the elements to the window functi

Re: QueryableState, unable to register KvStateRegistryListener

Hi Ufuk, Thanks for the reply. Yes I am running in local mode (and hope it can be used in local mode) Thanks, Vishnu On Thu, Jul 21, 2016 at 4:29 AM, Ufuk Celebi wrote: > Hey Vishnu, > > thanks for trying out the PR. :-) Would be great to move future > questions to the PR. > > How are you star

Implementing multi-field "sum" function [FLINK-4029]

Hi, I would like to implement a multi-field "sum" function[1], but I am not sure what would be the best way to approach it. Should I add a new method to the DataStream class or would it be better to add it to a specialized stream? Should it be based on existing operators/streams, or should I imple

Re: [DISCUSS] Enhance Window Evictor in Flink

Hi, this, in fact, seems to be a bug. There should be something like windowState.clear(); for (IN element: projectedContents) { windowState.add(element); } after passing the elements to the window function. This is very inefficient but the only way I see of doing it right now. Cheers, Aljosch

Re: QueryableState, unable to register KvStateRegistryListener

Hey Vishnu, thanks for trying out the PR. :-) Would be great to move future questions to the PR. How are you starting your cluster? My guess is that you are running the cluster in local mode, which is not starting up the network components. Is that the case? – Ufuk On Thu, Jul 21, 2016 at 1:56

Re: [DISCUSS] Allowed Lateness in Flink

I'm proposing to get this small change into 1.1: https://issues.apache.org/jira/browse/FLINK-4239 This will make our lives easier with the future proposed changes. What do you think? On Tue, 19 Jul 2016 at 11:41 Aljoscha Krettek wrote: > Hi, > these new features should make it into the 1.2 relea

[jira] [Created] (FLINK-4239) Set Default Allowed Lateness to Zero and Make Triggers Non-Purging

Aljoscha Krettek created FLINK-4239: --- Summary: Set Default Allowed Lateness to Zero and Make Triggers Non-Purging Key: FLINK-4239 URL: https://issues.apache.org/jira/browse/FLINK-4239 Project: Flink