Re: Flink HA on AWS: Network related issue

Hi Deepak, could you check the logs whether the JobManager has been quarantined and thus, cannot be connected to anymore? The logs should at least contain a hint why the TaskManager lost the connection initially. Cheers, Till On Thu, Sep 8, 2016 at 7:08 PM, Deepak Jha wrote: > Hi, > I've setup

[jira] [Created] (FLINK-4602) Move RocksDB backed to proper package

Aljoscha Krettek created FLINK-4602: --- Summary: Move RocksDB backed to proper package Key: FLINK-4602 URL: https://issues.apache.org/jira/browse/FLINK-4602 Project: Flink Issue Type: Sub-tas

[jira] [Created] (FLINK-4603) KeyedStateBackend cannot restore user code classes

Till Rohrmann created FLINK-4603: Summary: KeyedStateBackend cannot restore user code classes Key: FLINK-4603 URL: https://issues.apache.org/jira/browse/FLINK-4603 Project: Flink Issue Type:

Contribution

Hi devs, i contributed to Stratosphere as I was studying computer science at the FU Berlin. Currently i am working as data engineer and i am very interested in contributing to your project. Do someone have an idea for getting started in contributing to Flink like a certain jira task? Best Rega

[jira] [Created] (FLINK-4604) Add support for standard deviation/variance

Timo Walther created FLINK-4604: --- Summary: Add support for standard deviation/variance Key: FLINK-4604 URL: https://issues.apache.org/jira/browse/FLINK-4604 Project: Flink Issue Type: New Featu

Re: Contribution

Hi Hasan, Welcome! There is the "starter" label on some Jiras, which means that the issue is good for getting started. Best, Gábor 2016-09-09 13:46 GMT+02:00 Hasan Gürcan : > Hi devs, > > i contributed to Stratosphere as I was studying computer science at the FU > Berlin. Currently i am work

Re: Contribution

Welcome back Hasan :-) What are you interested in (e.g. libraries, backend, frontend)? Cheers, Till On Fri, Sep 9, 2016 at 2:02 PM, Gábor Gévay wrote: > Hi Hasan, > > Welcome! > There is the "starter" label on some Jiras, which means that the issue > is good for getting started. > > Best, > Gá

Re: Contribution

Hi, Thanks Gábor i will search for some tasks with this label. @Till: Thanks too :). Tendencially to backend. Best Regards Hasan > Am 09.09.2016 um 14:17 schrieb Till Rohrmann : > > Welcome back Hasan :-) > > What are you interested in (e.g. libraries, backend, frontend)? > > Cheers, > Till >

Contribution

Hi devs, i contributed to Stratosphere as I was studying computer science at the FU Berlin. Currently i am working as data engineer and i am very interested in contributing to your project. Do someone have an idea for getting started in contributing to Flink like a certain jira task? Best Rega

Re: Flink HA on AWS: Network related issue

Hi Till, I'm getting following message in Jobmanager log 2016-09-09 07:46:55,093 PDT [WARN] ip-10-8-11-249 [flink-akka.actor.default-dispatcher-985] akka.remote.RemoteWatcher - *Detected unreachable: [akka.tcp://flink@10.8.4.57:6121 ]* 2016-09-09 07:46:55,094 PDT [INF

[jira] [Created] (FLINK-4605) Add an expression that returns the return type of an expression

Timo Walther created FLINK-4605: --- Summary: Add an expression that returns the return type of an expression Key: FLINK-4605 URL: https://issues.apache.org/jira/browse/FLINK-4605 Project: Flink

Implementing FLIP-2 and FLIP-4

Thank you for offering your support, I'm excited to dig in! I have some work to do getting up to speed on the windowing internals. And I still need to get my bearing on the Evictor changes, I plan to read through the list archive and documents today. Vishnu, are your changes already publicly viewa

[jira] [Created] (FLINK-4606) Integrate the new ResourceManager with the existing FlinkResourceManager

zhangjing created FLINK-4606: Summary: Integrate the new ResourceManager with the existing FlinkResourceManager Key: FLINK-4606 URL: https://issues.apache.org/jira/browse/FLINK-4606 Project: Flink

[jira] [Created] (FLINK-4607) Close FileInputStream in ParameterTool and other

Alexander Pivovarov created FLINK-4607: -- Summary: Close FileInputStream in ParameterTool and other Key: FLINK-4607 URL: https://issues.apache.org/jira/browse/FLINK-4607 Project: Flink Is

[jira] [Created] (FLINK-4608) Use short-circuit AND in Max/Min AggregationFunction

Alexander Pivovarov created FLINK-4608: -- Summary: Use short-circuit AND in Max/Min AggregationFunction Key: FLINK-4608 URL: https://issues.apache.org/jira/browse/FLINK-4608 Project: Flink

[jira] [Created] (FLINK-4609) Remove redundant check for null in CrossOperator

Alexander Pivovarov created FLINK-4609: -- Summary: Remove redundant check for null in CrossOperator Key: FLINK-4609 URL: https://issues.apache.org/jira/browse/FLINK-4609 Project: Flink Is

[jira] [Created] (FLINK-4610) Replace keySet/getValue with entrySet in UdfAnalyzerUtils

Alexander Pivovarov created FLINK-4610: -- Summary: Replace keySet/getValue with entrySet in UdfAnalyzerUtils Key: FLINK-4610 URL: https://issues.apache.org/jira/browse/FLINK-4610 Project: Flink