Re: [VOTE] Release Apache Flink 1.0.2 (RC3)

2016-04-19 Thread Robert Metzger
Thank you for creating another bugfix release of the 1.0 release Ufuk! +1 for releasing this proposed RC. - Checked some flink-dist jars for correctly shaded guava classes - Started Flink in local mode and ran some examples - Checked the staging repository - Checked the quickstarts for the

[jira] [Created] (FLINK-3789) Overload methods which trigger program execution to allow naming job

2016-04-19 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-3789: - Summary: Overload methods which trigger program execution to allow naming job Key: FLINK-3789 URL: https://issues.apache.org/jira/browse/FLINK-3789 Project: Flink

[jira] [Created] (FLINK-3788) Local variable values are not distributed to task runners

2016-04-19 Thread Andreas C. Osowski (JIRA)
Andreas C. Osowski created FLINK-3788: - Summary: Local variable values are not distributed to task runners Key: FLINK-3788 URL: https://issues.apache.org/jira/browse/FLINK-3788 Project: Flink

Re: Bug in Scala Shell

2016-04-19 Thread Maximilian Michels
Hi Trevor, As Nikolaas pointed out, this is a regression in the recent master. The current implementation of code in the ExecutionConfig doesn't expect multiple executions. We have a pending fix [1] which should be in soon. Cheers, Max [1] https://github.com/apache/flink/pull/1913 On Tue, Apr

Re: Flink Interpreter w/ yarn-session

2016-04-19 Thread Till Rohrmann
Hi Andrea, I think your problem should be fixed with the PRs [1,2]. I've tested it locally on my yarn cluster and it worked. [1] https://github.com/apache/flink/pull/1904 [2] https://github.com/apache/flink/pull/1914 Cheers, Till On Tue, Apr 19, 2016 at 2:16 PM, Till Rohrmann

[jira] [Created] (FLINK-3787) Yarn client does not report unfulfillable container constraints

2016-04-19 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-3787: Summary: Yarn client does not report unfulfillable container constraints Key: FLINK-3787 URL: https://issues.apache.org/jira/browse/FLINK-3787 Project: Flink

[jira] [Created] (FLINK-3786) Add BigDecimal and BigInteger as Basic types

2016-04-19 Thread Timo Walther (JIRA)
Timo Walther created FLINK-3786: --- Summary: Add BigDecimal and BigInteger as Basic types Key: FLINK-3786 URL: https://issues.apache.org/jira/browse/FLINK-3786 Project: Flink Issue Type: New

Re: Bug in Scala Shell

2016-04-19 Thread Nikolaas s
Hi Trevor, this is a bug and was introduced before the streaming shell: https://issues.apache.org/jira/browse/FLINK-3701 I suspect something changed somewhere else in the Flink code that breaks the scala shell. In the scala shell tests executing the same program twice is not done so it went

Re: GSoC Project Proposal Draft: Code Generation in Serializers

2016-04-19 Thread Fabian Hueske
Hi Gabor, you are right, a codegen serializer module would depend on flink-core and in the current design flink-core would need to know about the type infos / serializers / comparators. Decoupling implementations of type info, serializers, and comparators from flink-core and resolving the cyclic

[jira] [Created] (FLINK-3783) Support weighted random sampling with reservoir

2016-04-19 Thread GaoLun (JIRA)
GaoLun created FLINK-3783: - Summary: Support weighted random sampling with reservoir Key: FLINK-3783 URL: https://issues.apache.org/jira/browse/FLINK-3783 Project: Flink Issue Type: Improvement