Manu Zhang created FLINK-4863:
-
Summary: states of merging window and trigger are set to different
TimeWindows on merge
Key: FLINK-4863
URL: https://issues.apache.org/jira/browse/FLINK-4863
Project:
[
https://issues.apache.org/jira/browse/FLINK-4840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15591000#comment-15591000
]
Chesnay Schepler commented on FLINK-4840:
-
There are some things that are concerning: A histogram,
[
https://issues.apache.org/jira/browse/FLINK-4863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15591051#comment-15591051
]
ASF GitHub Bot commented on FLINK-4863:
---
GitHub user manuzhang opened a pull request:
GitHub user manuzhang opened a pull request:
https://github.com/apache/flink/pull/2666
[FLINK-4863] fix trigger context window on merge
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2636
should be fixed now
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so,
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2570#discussion_r84251996
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/HeapInternalTimerService.java
---
@@ -0,0 +1,317 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15591567#comment-15591567
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user StephanEwen commented on the issue:
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2636
I tested the change this morning, and its not working:
```
2016-10-20 11:08:28,216 WARN
org.apache.flink.runtime.metrics.MetricRegistry - Could not start
Metr
[
https://issues.apache.org/jira/browse/FLINK-4850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15591622#comment-15591622
]
Theodore Vasiloudis edited comment on FLINK-4850 at 10/20/16 11:57 AM:
[
https://issues.apache.org/jira/browse/FLINK-4850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15591622#comment-15591622
]
Theodore Vasiloudis commented on FLINK-4850:
Just to note, the PR I opened only fixes the
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15591419#comment-15591419
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user aljoscha commented on a diff in the pull
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2652
+1 go ahead
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2642
@nssalian Thanks for understanding.
We as a community together have actually gone into that mode (more
conservative and stability focused) not too long ago. So it is still a bit of a
[
https://issues.apache.org/jira/browse/FLINK-3999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15591577#comment-15591577
]
ASF GitHub Bot commented on FLINK-3999:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2448
Good to go from my side.
@rmetzger and @iampeter - since you are working on the web UI currently,
can you try and merge this?
---
If your project is set up for it, you can reply to this
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15591424#comment-15591424
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user aljoscha commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15591460#comment-15591460
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user aljoscha commented on a diff in the pull
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2570
Thanks for your comments @StefanRRichter and @kl0u. I incorporated most of
them by now.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15591462#comment-15591462
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user aljoscha commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15591587#comment-15591587
]
ASF GitHub Bot commented on FLINK-3030:
---
Github user StephanEwen commented on the issue:
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/2570#discussion_r84236439
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/HeapInternalTimerService.java
---
@@ -0,0 +1,317 @@
+/*
+ *
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2570#discussion_r84251918
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/HeapInternalTimerService.java
---
@@ -0,0 +1,317 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-4850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15591644#comment-15591644
]
Thomas FOURNIER commented on FLINK-4850:
Ok I'm creating a specific JIRA issue related to adding
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15591422#comment-15591422
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user aljoscha commented on a diff in the pull
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2570#discussion_r84251732
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/HeapInternalTimerService.java
---
@@ -0,0 +1,317 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-4850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas FOURNIER updated FLINK-4850:
---
Description:
It seems that evaluate operation is defined for Vector and not LabeledVector.
It
Fabian Hueske created FLINK-4864:
Summary: Shade Calcite dependency in flink-table
Key: FLINK-4864
URL: https://issues.apache.org/jira/browse/FLINK-4864
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15591201#comment-15591201
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user kl0u commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15591262#comment-15591262
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user kl0u commented on a diff in the pull request:
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/2570#discussion_r84236659
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/HeapInternalTimerService.java
---
@@ -0,0 +1,317 @@
+/*
+ *
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/2570#discussion_r84235862
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
---
@@ -390,4 +425,141 @@ public void close()
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15591260#comment-15591260
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user kl0u commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15591263#comment-15591263
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user kl0u commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15591264#comment-15591264
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user kl0u commented on a diff in the pull request:
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/2570#discussion_r84237685
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/DefaultProcessingTimeService.java
---
@@ -35,10 +34,10 @@
import
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15591261#comment-15591261
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user kl0u commented on a diff in the pull request:
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/2570#discussion_r84237459
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/HeapInternalTimerService.java
---
@@ -0,0 +1,317 @@
+/*
+ *
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2662
Thanks for the PR @greghogan! Having a custom exception for missing
arguments to a user program is a good approach. However, it requires the author
of the program to use the custom exception. At least,
[
https://issues.apache.org/jira/browse/FLINK-4784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15591353#comment-15591353
]
ASF GitHub Bot commented on FLINK-4784:
---
Github user zentol commented on the issue:
GitHub user sedgewickmm18 opened a pull request:
https://github.com/apache/flink/pull/2667
README.md -Description of the bluemix specifâ¦
Hi,
as per discussion with @mxm I'm proposing to include the following change
that makes use of container
[
https://issues.apache.org/jira/browse/FLINK-4784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15591287#comment-15591287
]
ASF GitHub Bot commented on FLINK-4784:
---
Github user rmetzger commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15591288#comment-15591288
]
ASF GitHub Bot commented on FLINK-4824:
---
Github user mxm commented on the issue:
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2667#discussion_r84241679
--- Diff: flink-contrib/docker-flink/docker-entrypoint.sh ---
@@ -20,11 +20,19 @@
if [ "$1" = "jobmanager" ]; then
echo "Starting Job Manager"
Github user sedgewickmm18 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2667#discussion_r84286390
--- Diff: flink-contrib/docker-flink/docker-entrypoint.sh ---
@@ -20,11 +20,19 @@
if [ "$1" = "jobmanager" ]; then
echo "Starting
Github user sedgewickmm18 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2667#discussion_r84287069
--- Diff: flink-contrib/docker-flink/docker-compose.yml ---
@@ -20,16 +20,20 @@ version: "2"
services:
jobmanager:
image: flink
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r84288567
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/RichFileInputSplit.java
---
@@ -0,0 +1,153 @@
+/*
+ *
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2628
Thanks @ggevay for reviewing. I added a commit with additional comments.
I transcribed `Quicksort` so as to remove considerations of Java
performance and inlining. It was not clear to me
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r84279968
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileReaderOperator.java
---
@@ -189,7 +186,7 @@ public
Github user sedgewickmm18 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2667#discussion_r84291047
--- Diff: flink-contrib/docker-flink/docker-compose.sh ---
@@ -0,0 +1,4 @@
+#!/bin/sh
--- End diff --
that's fine
---
If your project
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2667#discussion_r84290827
--- Diff: flink-contrib/docker-flink/docker-compose.yml ---
@@ -20,16 +20,20 @@ version: "2"
services:
jobmanager:
image: flink
+
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2667#discussion_r84242735
--- Diff: flink-contrib/docker-flink/docker-compose.sh ---
@@ -0,0 +1,4 @@
+#!/bin/sh
--- End diff --
Could we name this file
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2657
This doesn't compile currently. Do you prefer if I review the PRs
individually or review the commits in this PR?
---
If your project is set up for it, you can reply to this email and have your
reply
[
https://issues.apache.org/jira/browse/FLINK-4853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15591741#comment-15591741
]
ASF GitHub Bot commented on FLINK-4853:
---
Github user mxm commented on the issue:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2618
Thanks for updating the description. Let take a look at the changes.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does
[
https://issues.apache.org/jira/browse/FLINK-3902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15591808#comment-15591808
]
Jan Zajíc edited comment on FLINK-3902 at 10/20/16 1:24 PM:
We have same issue
[
https://issues.apache.org/jira/browse/FLINK-3722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15591881#comment-15591881
]
ASF GitHub Bot commented on FLINK-3722:
---
Github user greghogan commented on the issue:
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r84285533
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/RichFileInputSplit.java
---
@@ -0,0 +1,153 @@
+/*
+ *
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r84288480
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/RichFileInputSplit.java
---
@@ -0,0 +1,153 @@
+/*
+ *
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r84280372
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileReaderOperator.java
---
@@ -199,44 +196,39 @@ public
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r84285924
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/RichFileInputSplit.java
---
@@ -0,0 +1,153 @@
+/*
+ *
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r84288776
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/RichFileInputSplit.java
---
@@ -0,0 +1,153 @@
+/*
+ *
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r84284953
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/RichFileInputSplitTest.java
---
@@ -0,0 +1,106 @@
+/*
+ * Licensed to the Apache
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2618#discussion_r84281147
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/RichFileInputSplit.java
---
@@ -0,0 +1,153 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-4867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay reassigned FLINK-4867:
--
Assignee: Gabor Gevay
> Investigate code generation for improving sort performance
>
[
https://issues.apache.org/jira/browse/FLINK-4867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15592359#comment-15592359
]
Gabor Gevay commented on FLINK-4867:
Hm, this sounds quite interesting. Could you please share the
GitHub user tfournier314 opened a pull request:
https://github.com/apache/flink/pull/2668
Add EvaluateDataSetOperation for LabeledVector. This closes #4865
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into
[
https://issues.apache.org/jira/browse/FLINK-3722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15592186#comment-15592186
]
ASF GitHub Bot commented on FLINK-3722:
---
Github user ggevay commented on the issue:
Gabor Gevay created FLINK-4868:
--
Summary: Insertion sort could avoid the swaps
Key: FLINK-4868
URL: https://issues.apache.org/jira/browse/FLINK-4868
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-4867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15592367#comment-15592367
]
Gabor Gevay commented on FLINK-4867:
That's nice, thanks!
> Investigate code generation for improving
Greg Hogan created FLINK-4869:
-
Summary: Store record pointer after record keys
Key: FLINK-4869
URL: https://issues.apache.org/jira/browse/FLINK-4869
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15592357#comment-15592357
]
Philipp von dem Bussche commented on FLINK-2821:
Thank you for all your effort [~mxm]. I
Till Rohrmann created FLINK-4871:
Summary: Add memory calculation for TaskManagers and forward
MetricRegistry
Key: FLINK-4871
URL: https://issues.apache.org/jira/browse/FLINK-4871
Project: Flink
Gabor Gevay created FLINK-4867:
--
Summary: Investigate code generation for improving sort performance
Key: FLINK-4867
URL: https://issues.apache.org/jira/browse/FLINK-4867
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-4860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-4860:
---
Component/s: Local Runtime
> Sort performance
>
>
> Key: FLINK-4860
[
https://issues.apache.org/jira/browse/FLINK-4860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-4860:
---
Labels: performance (was: )
> Sort performance
>
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-4867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15592239#comment-15592239
]
Greg Hogan commented on FLINK-4867:
---
It will be very interesting to see the results of this project.
Chesnay Schepler created FLINK-4870:
---
Summary: ContinuousFileMonitoringFunction does not properly handle
absolut Windows paths
Key: FLINK-4870
URL: https://issues.apache.org/jira/browse/FLINK-4870
[
https://issues.apache.org/jira/browse/FLINK-4868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-4868:
---
Description:
This is about the fallback to insertion sort at the beginning of
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15592246#comment-15592246
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user StefanRRichter commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15592292#comment-15592292
]
Stefan Richter commented on FLINK-4867:
---
If you sort performance is crucial to you, I wrote some
[
https://issues.apache.org/jira/browse/FLINK-4867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15592292#comment-15592292
]
Stefan Richter edited comment on FLINK-4867 at 10/20/16 4:32 PM:
-
If sort
[
https://issues.apache.org/jira/browse/FLINK-4869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay updated FLINK-4869:
---
Labels: performance (was: )
> Store record pointer after record keys
>
[
https://issues.apache.org/jira/browse/FLINK-4857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15592452#comment-15592452
]
ASF GitHub Bot commented on FLINK-4857:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2659
Thanks for the review @mxm. Will merge this PR.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/2570
Rebased version looks good to me.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2657
Sorry @mxm. The compilation problem were introduced due to an incomplete
rebasing. Should be fixed now.
---
If your project is set up for it, you can reply to this email and have your
reply
Gyula Fora created FLINK-4873:
-
Summary: Add config option to specify "home directory" for YARN
client resource sharing
Key: FLINK-4873
URL: https://issues.apache.org/jira/browse/FLINK-4873
Project:
[
https://issues.apache.org/jira/browse/FLINK-4857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4857.
Resolution: Fixed
Fixed via 6f0faf9bb35e7cac3a38ed792cdabd6400fc4c79
> ZooKeeperUtils have a
Martin Junghanns created FLINK-4872:
---
Summary: Type erasure problem exclusively on cluster execution
Key: FLINK-4872
URL: https://issues.apache.org/jira/browse/FLINK-4872
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15592447#comment-15592447
]
ASF GitHub Bot commented on FLINK-4853:
---
Github user tillrohrmann commented on the issue:
Github user ggevay commented on the issue:
https://github.com/apache/flink/pull/2628
> I transcribed Quicksort so as to remove considerations of Java
performance and inlining. It was not clear to me that if we encapsulated the
index, page number, and page offset into an object that
[
https://issues.apache.org/jira/browse/FLINK-4871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15592437#comment-15592437
]
ASF GitHub Bot commented on FLINK-4871:
---
GitHub user tillrohrmann opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15592479#comment-15592479
]
Eryn Dahlstedt commented on FLINK-2491:
---
We have been running into this problem as well. Do you have
[
https://issues.apache.org/jira/browse/FLINK-4857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15592476#comment-15592476
]
ASF GitHub Bot commented on FLINK-4857:
---
Github user asfgit closed the pull request at:
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/2618
Thanks for the comments @mxm ! I integrated them and waiting for Travis.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project
[
https://issues.apache.org/jira/browse/FLINK-4705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15592853#comment-15592853
]
ASF GitHub Bot commented on FLINK-4705:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15592866#comment-15592866
]
Stefan Richter commented on FLINK-4867:
---
I have already pushed my code into
[
https://issues.apache.org/jira/browse/FLINK-4581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15592877#comment-15592877
]
ASF GitHub Bot commented on FLINK-4581:
---
Github user fhueske commented on the issue:
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2669
[FLINK-4871] [mini cluster] Add memory calculation for TaskManagers to
MiniCluster
This PR is based on #2651, #2655 and #2657.
If the managed memory size for the task manager has not
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2506
+1 to merge
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if
1 - 100 of 140 matches
Mail list logo
