[jira] [Created] (FLINK-5749) Unset HADOOP_HOME and HADOOP_CONF_DIR from system environment when building flink

Wenlong Lyu created FLINK-5749: -- Summary: Unset HADOOP_HOME and HADOOP_CONF_DIR from system environment when building flink Key: FLINK-5749 URL: https://issues.apache.org/jira/browse/FLINK-5749 Project:

Re: FLINK-5734 : Code Generation for NormalizedKeySorter

Hi Pat, Serkan, and Gábor, This looks very nice. I'll treat this like a pre-FLIP and ask my question here. Do I understand correctly that the generated code is only dependent on the length of the sort key? So we could separate the writing and reading of keys and records and from the generated

Re: New Flink team member - Kate Eri.

Hi Kate, 1) - Broadcast: https://cwiki.apache.org/confluence/display/FLINK/FLIP-5%3A+Only+send+data+to+each+taskmanager+once+for+broadcasts - Caching: https://issues.apache.org/jira/browse/FLINK-1730 2) I have no idea about the GPU implementation. The SystemML mailing list will probably help

[jira] [Created] (FLINK-5748) Make the ExecutionGraph's FutureExecutor a ScheduledExecutionService

Stephan Ewen created FLINK-5748: --- Summary: Make the ExecutionGraph's FutureExecutor a ScheduledExecutionService Key: FLINK-5748 URL: https://issues.apache.org/jira/browse/FLINK-5748 Project: Flink

[jira] [Created] (FLINK-5746) Add acceptEither and applyToEither to Flink's Future

Till Rohrmann created FLINK-5746: Summary: Add acceptEither and applyToEither to Flink's Future Key: FLINK-5746 URL: https://issues.apache.org/jira/browse/FLINK-5746 Project: Flink Issue

FINAL REMINDER: CFP for ApacheCon closes February 11th

Dear Apache Enthusiast, This is your FINAL reminder that the Call for Papers (CFP) for ApacheCon Miami is closing this weekend - February 11th. This is your final opportunity to submit a talk for consideration at this event. This year, we are running several mini conferences in conjunction with

[jira] [Created] (FLINK-5745) Set uncaught exception handler for Netty threads

Ufuk Celebi created FLINK-5745: -- Summary: Set uncaught exception handler for Netty threads Key: FLINK-5745 URL: https://issues.apache.org/jira/browse/FLINK-5745 Project: Flink Issue Type:

[jira] [Created] (FLINK-5744) Checking remote connection in Flink-shell

Anton Solovev created FLINK-5744: Summary: Checking remote connection in Flink-shell Key: FLINK-5744 URL: https://issues.apache.org/jira/browse/FLINK-5744 Project: Flink Issue Type:

Re: flink-shell remote

Hi Anton, I was involved in writing the scala-shell, my initial idea was to just write a very small job and try to execute it remotely, and see if something comes back. I did not have time in the end to implement it. Just if you need a pointer how this could be done.. best, Nikolaas 2017-02-08

Re: flink-shell remote

Hi Anton, if you like, then you take a stab at it. Best if you first create a JIRA for that. Cheers, Till On Wed, Feb 8, 2017 at 12:27 PM, Anton Solovev wrote: > Hi > > Can we check connection to remote host before execution a program when > start flink-shell ? > > For

flink-shell remote

Hi Can we check connection to remote host before execution a program when start flink-shell ? For example, right after `bin/start-scala-shell.sh remote 35007` it checks and will not start if it wrong connects Best, Anton

Re: FLINK-5734 : Code Generation for NormalizedKeySorter

Hi Pat, Serkan and Gabor, I really like your design document and the preliminary results look really good. Impressive! I think your document can be converted into a FLIP. I was wondering whether it makes sense (or not) to generate the code on the client side? Then we would not have to introduce

Re: [ANNOUNCE] Welcome Jark Wu and Kostas Kloudas as committers

Welcome on board guys! If you want to try our your new privileges, you can add yourself here: http://flink.apache.org/community.html#people (through the apache/flink-web repo) On Wed, Feb 8, 2017 at 10:52 AM, Till Rohrmann wrote: > Congratulations Jark and Kostas :-) > >

[jira] [Created] (FLINK-5743) Mark WindowedStream.aggregate* methods as PublicEvolving

Aljoscha Krettek created FLINK-5743: --- Summary: Mark WindowedStream.aggregate* methods as PublicEvolving Key: FLINK-5743 URL: https://issues.apache.org/jira/browse/FLINK-5743 Project: Flink

[jira] [Created] (FLINK-5742) Breakpoints on documentation website

Colin Breame created FLINK-5742: --- Summary: Breakpoints on documentation website Key: FLINK-5742 URL: https://issues.apache.org/jira/browse/FLINK-5742 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5741) Add tests for window function wrappers with RichFunctions

Aljoscha Krettek created FLINK-5741: --- Summary: Add tests for window function wrappers with RichFunctions Key: FLINK-5741 URL: https://issues.apache.org/jira/browse/FLINK-5741 Project: Flink

[jira] [Created] (FLINK-5740) Make WrappingFunction an interface and move to flink-core

Aljoscha Krettek created FLINK-5740: --- Summary: Make WrappingFunction an interface and move to flink-core Key: FLINK-5740 URL: https://issues.apache.org/jira/browse/FLINK-5740 Project: Flink

Re: [ANNOUNCE] Welcome Jark Wu and Kostas Kloudas as committers

Congratulations Jark and Kostas :-) On Wed, Feb 8, 2017 at 10:49 AM, Paris Carbone wrote: > welcome aboard Kostas and Jark :) > > Paris > > > On 7 Feb 2017, at 21:16, Fabian Hueske wrote: > > > > Hi everybody, > > > > I'm very happy to announce that Jark Wu

Re: [ANNOUNCE] Welcome Jark Wu and Kostas Kloudas as committers

welcome aboard Kostas and Jark :) Paris > On 7 Feb 2017, at 21:16, Fabian Hueske wrote: > > Hi everybody, > > I'm very happy to announce that Jark Wu and Kostas Kloudas accepted the > invitation of the Flink PMC to become committers of the Apache Flink > project. > > Jark

Re: [ANNOUNCE] Welcome Jark Wu and Kostas Kloudas as committers

Congrats, Kostas and Jark! > Am 07.02.2017 um 21:16 schrieb Fabian Hueske : > > Hi everybody, > > I'm very happy to announce that Jark Wu and Kostas Kloudas accepted the > invitation of the Flink PMC to become committers of the Apache Flink > project. > > Jark and Kostas are

[jira] [Created] (FLINK-5739) NullPointerException in CliFrontend

Zhuoluo Yang created FLINK-5739: --- Summary: NullPointerException in CliFrontend Key: FLINK-5739 URL: https://issues.apache.org/jira/browse/FLINK-5739 Project: Flink Issue Type: Bug