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

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 sca

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

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

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

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 1

Re: Flink Interpreter w/ yarn-session

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 wrote: > I think

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

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

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 Feat

[jira] [Created] (FLINK-3785) Add REST resource to query information about checkpointing

Konstantin Knauf created FLINK-3785: --- Summary: Add REST resource to query information about checkpointing Key: FLINK-3785 URL: https://issues.apache.org/jira/browse/FLINK-3785 Project: Flink

Re: Adding custom monitoring to Flink

Hi Maxim, I think the corresponding JIRA issue is https://issues.apache.org/jira/browse/FLINK-456 Cheers, Till On Thu, Apr 14, 2016 at 10:50 PM, Maxim wrote: > I don't have full list of metrics, but everything that is related to > runtime performance and possible bottlenecks of the system. All

Re: Bug in Scala Shell

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 unnot

Re: GSoC Project Proposal Draft: Code Generation in Serializers

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-3784) Unexpected results using collect() in RichMapPartitionFunction

Sergio Ramírez created FLINK-3784: - Summary: Unexpected results using collect() in RichMapPartitionFunction Key: FLINK-3784 URL: https://issues.apache.org/jira/browse/FLINK-3784 Project: Flink