[jira] [Created] (FLINK-26710) TestLoggerResource hides log lines

Niklas Semmler created FLINK-26710: -- Summary: TestLoggerResource hides log lines Key: FLINK-26710 URL: https://issues.apache.org/jira/browse/FLINK-26710 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-26556) Refactoring MiniCluster and TestingMiniCluster

Niklas Semmler created FLINK-26556: -- Summary: Refactoring MiniCluster and TestingMiniCluster Key: FLINK-26556 URL: https://issues.apache.org/jira/browse/FLINK-26556 Project: Flink Issue

[jira] [Created] (FLINK-26522) Refactoring code for multiple component leader election

Niklas Semmler created FLINK-26522: -- Summary: Refactoring code for multiple component leader election Key: FLINK-26522 URL: https://issues.apache.org/jira/browse/FLINK-26522 Project: Flink

[jira] [Created] (FLINK-26503) Multi-network deployments may lead to hard-to-debug issues

Niklas Semmler created FLINK-26503: -- Summary: Multi-network deployments may lead to hard-to-debug issues Key: FLINK-26503 URL: https://issues.apache.org/jira/browse/FLINK-26503 Project: Flink

[jira] [Created] (FLINK-26502) Multiple component leader election has different close/stop behavior

Niklas Semmler created FLINK-26502: -- Summary: Multiple component leader election has different close/stop behavior Key: FLINK-26502 URL: https://issues.apache.org/jira/browse/FLINK-26502 Project

[jira] [Created] (FLINK-26469) Adaptive job shows error when not enough resource are available

Niklas Semmler created FLINK-26469: -- Summary: Adaptive job shows error when not enough resource are available Key: FLINK-26469 URL: https://issues.apache.org/jira/browse/FLINK-26469 Project: Flink

[jira] [Created] (FLINK-26431) Release Testing: Exception history for the adaptive scheduler

Niklas Semmler created FLINK-26431: -- Summary: Release Testing: Exception history for the adaptive scheduler Key: FLINK-26431 URL: https://issues.apache.org/jira/browse/FLINK-26431 Project: Flink

[jira] [Created] (FLINK-26400) Release Testing: Explicit shutdown signalling from TaskManager to JobManager

Niklas Semmler created FLINK-26400: -- Summary: Release Testing: Explicit shutdown signalling from TaskManager to JobManager Key: FLINK-26400 URL: https://issues.apache.org/jira/browse/FLINK-26400

[jira] [Created] (FLINK-25765) Kubernetes: flink's configmap and flink's actual config are out of sync

Niklas Semmler created FLINK-25765: -- Summary: Kubernetes: flink's configmap and flink's actual config are out of sync Key: FLINK-25765 URL: https://issues.apache.org/jira/browse/FLINK-25765 Project

[jira] [Created] (FLINK-25764) Docker sets JobManager's rpc address to same host by default

Niklas Semmler created FLINK-25764: -- Summary: Docker sets JobManager's rpc address to same host by default Key: FLINK-25764 URL: https://issues.apache.org/jira/browse/FLINK-25764 Project: Flink

[jira] [Created] (FLINK-25751) flink-table tests exit with code 137

Niklas Semmler created FLINK-25751: -- Summary: flink-table tests exit with code 137 Key: FLINK-25751 URL: https://issues.apache.org/jira/browse/FLINK-25751 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-25514) YARN session tests scan unrelated logs for bugs

Niklas Semmler created FLINK-25514: -- Summary: YARN session tests scan unrelated logs for bugs Key: FLINK-25514 URL: https://issues.apache.org/jira/browse/FLINK-25514 Project: Flink Issue

[jira] [Created] (FLINK-25277) Introduce explicit shutdown signalling between TaskManager and JobManager

Niklas Semmler created FLINK-25277: -- Summary: Introduce explicit shutdown signalling between TaskManager and JobManager Key: FLINK-25277 URL: https://issues.apache.org/jira/browse/FLINK-25277

Static deployment scheme for failure scenario

to fix the deployment scheme would be to change the scheduler, right? Did anyone attempt this so far? Best, Niklas -- Niklas Semmler PhD Student / Research Assistant TU Berlin, INET, Room MAR 4.027 Marchstr 23, 10587 Berlin Tel.: +49 (0)30 314 75739 http://inet.tu-berlin.de/~nsemmler/

Scheduling in BATCH execution mode?

Hello Flink community, what is the equivalent of the ScheduleOrUpdateConsumers message in the pipeline execution mode for the batch execution mode? When I run a WordCount in pipeline mode, the scheduling of the receiving tasks is initiated in the ResultPartition class via the function

Re: Scheduling in BATCH execution mode?

of the receivers to be more accessible/transparent. – Ufuk On 09 Sep 2015, at 18:06, Niklas Semmler <nik...@inet.tu-berlin.de> wrote: Hello Flink community, what is the equivalent of the ScheduleOrUpdateConsumers message in the pipeline execution mode for the batch execution mode? When

Updating the flink JAR with a single module

Hi there, I have a question on the setup of the development environment for flink. Is it possible to update the big JAR file (flink-dist/target/.../lib/flink-dist-0.9-SNAPSHOT.jar), which flink apparently uses for deployment, with a single module (flink-runtime)? Recompiling all of the

Re: Updating the flink JAR with a single module

pTests clean install // will fetch all required dependencies from the local Maven repository without rebuilding them. You need to have run mvn -DskipTests clean install before to have all required dependencies in the local repository. Cheers, Fabian 2015-09-04 11:46 GMT+02:00 Niklas Semmler <nse

Re: How do network transmissions in Flink work?

+between+tasks On 09 Jul 2015, at 21:32, Niklas Semmler nsemm...@inet.tu-berlin.de wrote: 1. What does the number of ResultSubpartition instances in the ResultPartition correspond to? Is one assigned to each consuming task? If so, how can I find for each ResultSubpartition the corresponding Task

Re: How do network transmissions in Flink work?

#notifyFinalState(). Let us know if you have more questions. Greetings, Stephan On Mon, Jul 6, 2015 at 8:36 PM, Niklas Semmler nik...@inet.tu-berlin.de wrote: Hello Flink Community, I am working on a network scheduler and am currently reading Flink's code to figure out how the data exchange