Re: Java type erasure and object reuse

Good problem... We were thinking for a while to make the input and output type serializers available from the RuntimeContext. That way you could call "T copy = serializer.copy(inValue)". The "copy()" method on the copyable value is actually a good addition nonetheless! On Thu, Sep 17, 2015 at

[jira] [Created] (FLINK-2700) YarnSessionFIFOITCase.testJavaApi failure

Sachin Goel created FLINK-2700: -- Summary: YarnSessionFIFOITCase.testJavaApi failure Key: FLINK-2700 URL: https://issues.apache.org/jira/browse/FLINK-2700 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-2703) Remove log4j classes from fat jar / document how to use Flink with logback

Robert Metzger created FLINK-2703: - Summary: Remove log4j classes from fat jar / document how to use Flink with logback Key: FLINK-2703 URL: https://issues.apache.org/jira/browse/FLINK-2703 Project:

Re: Flink ML linear regression issue

Hi Alexey and Hanan, one of FlinkML’s feature is the flexible pipelining mechanism. It allows you to chain multiple transformers with a trailing predictor to form a data analysis pipeline. In order to support multiple input types, the actual program logic (matching for the type) is assembled at

[jira] [Created] (FLINK-2702) Add an implementation of distributed copying utility using Flink

Stephan Ewen created FLINK-2702: --- Summary: Add an implementation of distributed copying utility using Flink Key: FLINK-2702 URL: https://issues.apache.org/jira/browse/FLINK-2702 Project: Flink

[jira] [Created] (FLINK-2701) Getter for wrapped Java StreamExecutionEnvironment in the Scala Api

Stephan Ewen created FLINK-2701: --- Summary: Getter for wrapped Java StreamExecutionEnvironment in the Scala Api Key: FLINK-2701 URL: https://issues.apache.org/jira/browse/FLINK-2701 Project: Flink

[jira] [Created] (FLINK-2708) Potential null pointer dereference in JoinWithSolutionSetFirstDriver#run()

Ted Yu created FLINK-2708: - Summary: Potential null pointer dereference in JoinWithSolutionSetFirstDriver#run() Key: FLINK-2708 URL: https://issues.apache.org/jira/browse/FLINK-2708 Project: Flink

[jira] [Created] (FLINK-2709) line editing in scala shell

Matthew Farrellee created FLINK-2709: Summary: line editing in scala shell Key: FLINK-2709 URL: https://issues.apache.org/jira/browse/FLINK-2709 Project: Flink Issue Type: New Feature

Re: Flink ML linear regression issue

+1, having the convenient creation of pipelines for Java is more of a long term project, but we should make it possible to manually create pipelines in Java. On Fri, Sep 18, 2015 at 11:15 AM, Till Rohrmann wrote: > Hi Alexey and Hanan, > > one of FlinkML’s feature is

Re: Tests - Unit Tests versus Integration Tests

Hi Stephan, Thanks for nice guide! I think we can upload this to the wiki or how to contribute documentation. This guide would be helpful for newcomers. Regards, Chiwan Park > On Sep 17, 2015, at 9:33 PM, Stephan Ewen wrote: > > Hi all! > > The build time of Flink with all

RE: Flink ML linear regression issue

Thank you very much for the clarifications. -Original Message- From: Theodore Vasiloudis [mailto:theodoros.vasilou...@gmail.com] Sent: Friday, September 18, 2015 2:33 PM To: dev@flink.apache.org Cc: Hanan Meyer Subject: Re: Flink ML linear regression issue +1, having the convenient

[jira] [Created] (FLINK-2705) Yarn fails with NoSuchMethodError when log level is set to DEBUG

Till Rohrmann created FLINK-2705: Summary: Yarn fails with NoSuchMethodError when log level is set to DEBUG Key: FLINK-2705 URL: https://issues.apache.org/jira/browse/FLINK-2705 Project: Flink

[jira] [Created] (FLINK-2704) Clean up naming of State/Checkpoint Interfaces

Stephan Ewen created FLINK-2704: --- Summary: Clean up naming of State/Checkpoint Interfaces Key: FLINK-2704 URL: https://issues.apache.org/jira/browse/FLINK-2704 Project: Flink Issue Type:

[jira] [Created] (FLINK-2706) Add support for streaming RollingFileSink to truncate / append on UNIX file systems

Stephan Ewen created FLINK-2706: --- Summary: Add support for streaming RollingFileSink to truncate / append on UNIX file systems Key: FLINK-2706 URL: https://issues.apache.org/jira/browse/FLINK-2706