separation of JVMs for different applications

Hi all, It seems tasks of different Flink applications can end up in the same JVM (TaskManager) in standalone mode. Isn't this fragile since errors in one application could crash another ? I checked FLIP-6 but didn't

Re: Flink using Yarn on MapR

Thanks Max for a quick response. I will try it out and let you know how it goes. -Naveen > On Nov 25, 2016, at 6:05 AM, Maximilian Michels wrote: > > Fix is now in the master and everything should run smooth with MapR > Hadoop. I'd be happy if you gave it another try. > > -Max

[jira] [Created] (FLINK-5216) CheckpointCoordinator's 'minPauseBetweenCheckpoints' refers to checkpoint start rather then checkpoint completion

Stephan Ewen created FLINK-5216: --- Summary: CheckpointCoordinator's 'minPauseBetweenCheckpoints' refers to checkpoint start rather then checkpoint completion Key: FLINK-5216 URL:

[jira] [Created] (FLINK-5215) Close checkpoint streams upon cancellation

Till Rohrmann created FLINK-5215: Summary: Close checkpoint streams upon cancellation Key: FLINK-5215 URL: https://issues.apache.org/jira/browse/FLINK-5215 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5214) Clean up checkpoint files when failing checkpoint operation on TM

Till Rohrmann created FLINK-5214: Summary: Clean up checkpoint files when failing checkpoint operation on TM Key: FLINK-5214 URL: https://issues.apache.org/jira/browse/FLINK-5214 Project: Flink

[jira] [Created] (FLINK-5213) Missing @Override in Task

Ufuk Celebi created FLINK-5213: -- Summary: Missing @Override in Task Key: FLINK-5213 URL: https://issues.apache.org/jira/browse/FLINK-5213 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5212) Flakey ScalaShellITCase#testPreventRecreationBatch (out of Java heap space)

Nico Kruber created FLINK-5212: -- Summary: Flakey ScalaShellITCase#testPreventRecreationBatch (out of Java heap space) Key: FLINK-5212 URL: https://issues.apache.org/jira/browse/FLINK-5212 Project: Flink

[jira] [Created] (FLINK-5211) Include an example configuration for all reporters

Chesnay Schepler created FLINK-5211: --- Summary: Include an example configuration for all reporters Key: FLINK-5211 URL: https://issues.apache.org/jira/browse/FLINK-5211 Project: Flink Issue

[jira] [Created] (FLINK-5210) Failing performCheckpoint method causes task to fail

Till Rohrmann created FLINK-5210: Summary: Failing performCheckpoint method causes task to fail Key: FLINK-5210 URL: https://issues.apache.org/jira/browse/FLINK-5210 Project: Flink Issue

Re: JIRA task Assignment

Hi Tony, sure and done. I also gave you Contributor permissions. You can now also assign other tasks to yourself. Best, Fabian 2016-11-30 13:13 GMT+01:00 魏偉哲 : > Hi > > I would like to wok on https://issues.apache.org/jira/browse/FLINK-4611. > Can someone assign the

JIRA task Assignment

Hi I would like to wok on https://issues.apache.org/jira/browse/FLINK-4611. Can someone assign the task to me? My ID is "tonywei".

Re: Why there is no source code in flink-cep-scala_2.11-1.1.3-source.jar?

Hi! This is a very good question. It seems like there is a specific issue for this module with the Maven Scala setup. Other Scala modules have the sources attached properly. >From a quick glance a the pom, it just has the default source directory (src/main/java) implicitly specified. So two

Re: [DISCUSS] Proposed updates to Flink project site

Hi everyone, We've made progress on the new site, and here's a version you can run locally if you'd like to take a look: https://github.com/wints/flink-web-updates Should take about a minute to get it running: 1) git clone https://github.com/wints/flink-web-updates.git 2) ./build.sh -p 3)