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
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
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
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
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
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
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
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
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
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:
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
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
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
ay 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/
Hello Ufuk,
thanks that makes very much sense :).
Best,
Niklas
On 09.09.2015 23:22, Ufuk Celebi wrote:
On 09 Sep 2015, at 19:31, Niklas Semmler wrote:
Hello Ufuk,
thanks for you amazingly quick reply.
I have seen the markFinished in Execution.java, but if I get it right, this is
simply
the receivers to be more accessible/transparent.
– Ufuk
On 09 Sep 2015, at 18:06, Niklas Semmler wrote:
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
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
notify
-DskipTests 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 Semmle
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 modul
a+exchange+between+tasks
On 09 Jul 2015, at 21:32, Niklas Semmler 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, Slot or simil
.Task#notifyFinalState()".
Let us know if you have more questions.
Greetings,
Stephan
On Mon, Jul 6, 2015 at 8:36 PM, Niklas Semmler
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 works. It
Hello Flink Community,
I am working on a network scheduler and am currently reading Flink's
code to figure out how the data exchange works. It would be great if you
could help me with some of my issues and questions.
Basically I want to extract from flink the time when a data transmission
be
22 matches
Mail list logo
