[
https://issues.apache.org/jira/browse/FLINK-1682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14513714#comment-14513714
]
ASF GitHub Bot commented on FLINK-1682:
---
GitHub user fhueske opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14513870#comment-14513870
]
ASF GitHub Bot commented on FLINK-1789:
---
Github user StephanEwen commented on the
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/593#issuecomment-96599424
Yes, user-facing remains strings which are file paths.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well.
Till Rohrmann created FLINK-1947:
Summary: Make Avro and Tachyon test logging less verbose
Key: FLINK-1947
URL: https://issues.apache.org/jira/browse/FLINK-1947
Project: Flink
Issue Type:
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/623#issuecomment-96562609
You are definitely welcome to participate in the new web frontend
development. Have a look at the branch I sent you and see if you find your way
around the new code
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/628
[FLINK-1923] Replaces asynchronous logging with synchronous logging in
actors
Replaces asynchronous logging with synchronous logging in actors.
Additionally, all Scala implementations are now
[
https://issues.apache.org/jira/browse/FLINK-1923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14513746#comment-14513746
]
ASF GitHub Bot commented on FLINK-1923:
---
GitHub user tillrohrmann opened a pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/616#issuecomment-96573887
+1, can you merge it @mxm
---
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
[
https://issues.apache.org/jira/browse/FLINK-1682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14513773#comment-14513773
]
ASF GitHub Bot commented on FLINK-1682:
---
Github user StephanEwen commented on the
Github user twalthr commented on the pull request:
https://github.com/apache/flink/pull/593#issuecomment-96591270
It is not a problem in exposing this to the client as well, I was just
unsure if it is necessary. I will add to the client as well to be in sync.
Yes, it makes sense
[
https://issues.apache.org/jira/browse/FLINK-1947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14513768#comment-14513768
]
Stephan Ewen commented on FLINK-1947:
-
You can avoid the sysout logging by using
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/617
---
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 the feature is
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/627#issuecomment-96580250
Wow, very nice :-) Looks correct from a first glance (I did not thoroughly
check everything).
One remark: Since `print()` may become an eagerly evaluated
[
https://issues.apache.org/jira/browse/FLINK-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14513849#comment-14513849
]
ASF GitHub Bot commented on FLINK-1789:
---
Github user twalthr commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14514777#comment-14514777
]
Vasia Kalavri commented on FLINK-1941:
--
:-) you're way too fast for my current
Github user Elbehery commented on the pull request:
https://github.com/apache/flink/pull/621#issuecomment-96809741
@aljoscha I have run code format from Intellij, I think the problem should
be solved now ..
I have tried to read the travis build log, but I could not find the
[
https://issues.apache.org/jira/browse/FLINK-1615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14514915#comment-14514915
]
ASF GitHub Bot commented on FLINK-1615:
---
Github user Elbehery commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14515048#comment-14515048
]
ASF GitHub Bot commented on FLINK-1828:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-1828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14515050#comment-14515050
]
ASF GitHub Bot commented on FLINK-1828:
---
Github user fhueske commented on the pull
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/571#issuecomment-96828941
This PR was split into PR #632 and PR #633
---
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
[
https://issues.apache.org/jira/browse/FLINK-1951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-1951:
-
Priority: Critical (was: Minor)
NullPointerException in DeltaIteration when no ForwardedFileds
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/632
---
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 the feature is
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/571
---
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 the feature is
[
https://issues.apache.org/jira/browse/FLINK-1828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske resolved FLINK-1828.
--
Resolution: Fixed
Fix Version/s: 0.8.2
Fixed in
- 0.9 with
[
https://issues.apache.org/jira/browse/FLINK-1615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14513718#comment-14513718
]
ASF GitHub Bot commented on FLINK-1615:
---
Github user aljoscha commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14513703#comment-14513703
]
ASF GitHub Bot commented on FLINK-1930:
---
Github user uce commented on the pull
Till Rohrmann created FLINK-1946:
Summary: Make yarn tests logging less verbose
Key: FLINK-1946
URL: https://issues.apache.org/jira/browse/FLINK-1946
Project: Flink
Issue Type: Improvement
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/621#issuecomment-96565454
The tests are failing because you use spaces in you code for indentation.
Could you please change all indentation to tabs to satisfy the style checker?
---
If your
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/593#issuecomment-96532907
Yes, this would make things a lot cleaner. @twalthr what do you think?
---
If your project is set up for it, you can reply to this email and have your
reply appear on
[
https://issues.apache.org/jira/browse/FLINK-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14513657#comment-14513657
]
ASF GitHub Bot commented on FLINK-1789:
---
Github user aljoscha commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14513713#comment-14513713
]
ASF GitHub Bot commented on FLINK-1938:
---
Github user StephanEwen commented on the
GitHub user fhueske opened a pull request:
https://github.com/apache/flink/pull/627
[FLINK-1682] Ported optimizer unit tests from Record API to Java API
This is a step towards removing the deprecated Record API.
You can merge this pull request into a Git repository by running:
[
https://issues.apache.org/jira/browse/FLINK-1924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14513747#comment-14513747
]
ASF GitHub Bot commented on FLINK-1924:
---
Github user aljoscha commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14513732#comment-14513732
]
ASF GitHub Bot commented on FLINK-1924:
---
Github user mxm commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14513707#comment-14513707
]
ASF GitHub Bot commented on FLINK-1523:
---
Github user StephanEwen commented on the
[
https://issues.apache.org/jira/browse/FLINK-1930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-1930.
--
Resolution: Fixed
Fixed in 88638de.
NullPointerException in vertex-centric iteration
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/616#issuecomment-96570629
LGTM
---
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
[
https://issues.apache.org/jira/browse/FLINK-1923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-1923:
Assignee: Till Rohrmann
Replace asynchronous logging in JobManager with regular slf4j
Till Rohrmann created FLINK-1945:
Summary: Make python tests less verbose
Key: FLINK-1945
URL: https://issues.apache.org/jira/browse/FLINK-1945
Project: Flink
Issue Type: Improvement
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/134
---
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 the feature is
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/112
---
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 the feature is
[
https://issues.apache.org/jira/browse/FLINK-1930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14513706#comment-14513706
]
ASF GitHub Bot commented on FLINK-1930:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/624
---
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 the feature is
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/537#issuecomment-96558324
Looks good in general. A few thoughts on this:
Your prior discussion involved efficiency, and Vasia suggested to not carry
the degrees in all cases (as they
[
https://issues.apache.org/jira/browse/FLINK-1946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-1946:
--
Component/s: YARN Client
Make yarn tests logging less verbose
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/571#discussion_r29129684
--- Diff: flink-staging/flink-hbase/pom.xml ---
@@ -112,6 +112,12 @@ under the License.
/exclusion
[
https://issues.apache.org/jira/browse/FLINK-1828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14513737#comment-14513737
]
ASF GitHub Bot commented on FLINK-1828:
---
Github user fhueske commented on a diff in
Github user fpompermaier commented on a diff in the pull request:
https://github.com/apache/flink/pull/571#discussion_r29130488
--- Diff: flink-staging/flink-hbase/pom.xml ---
@@ -112,6 +112,12 @@ under the License.
/exclusion
[
https://issues.apache.org/jira/browse/FLINK-1828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14513753#comment-14513753
]
ASF GitHub Bot commented on FLINK-1828:
---
Github user fpompermaier commented on a
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/622#discussion_r29140659
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
---
@@ -795,108 +795,111 @@ extends Actor with
[
https://issues.apache.org/jira/browse/FLINK-1925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14513981#comment-14513981
]
ASF GitHub Bot commented on FLINK-1925:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-1820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14514099#comment-14514099
]
ASF GitHub Bot commented on FLINK-1820:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14514102#comment-14514102
]
ASF GitHub Bot commented on FLINK-1820:
---
Github user fhueske commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14513973#comment-14513973
]
ASF GitHub Bot commented on FLINK-1923:
---
Github user StephanEwen commented on the
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/553#issuecomment-96631425
Thank you. I'm trying to find time to review your changes soon.
---
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-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14514030#comment-14514030
]
ASF GitHub Bot commented on FLINK-1792:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-1922:
Assignee: Till Rohrmann
Failed task deployment causes NPE on input split assignment
[
https://issues.apache.org/jira/browse/FLINK-1923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14513971#comment-14513971
]
ASF GitHub Bot commented on FLINK-1923:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/628#discussion_r29140183
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ---
@@ -357,16 +356,6 @@ protected void unregisterTask() {
[
https://issues.apache.org/jira/browse/FLINK-1682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14514045#comment-14514045
]
ASF GitHub Bot commented on FLINK-1682:
---
Github user fhueske commented on the pull
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/627#issuecomment-96631688
Yes, very good point.
I replaced the `.print()` statements by `.output(new
DiscardingOutputFormat()` as suggested (not only in the ported tests but also
some more on
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/631
[FLINK-1922] Fixes NPE when TM receives a null input split
The ```TaskInputSplitProvider``` did not handle null input splits which are
wrapped into a ```NextInputSplit``` message properly.
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/566#issuecomment-96647676
Looks good. I added few minor comments inline.
Did you check if the changes should also go into the `ByteParser`?
---
If your project is set up for it, you can reply
[
https://issues.apache.org/jira/browse/FLINK-1945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-1945:
---
Assignee: Chesnay Schepler
Make python tests less verbose
[
https://issues.apache.org/jira/browse/FLINK-1820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14514122#comment-14514122
]
ASF GitHub Bot commented on FLINK-1820:
---
Github user FelixNeutatz commented on a
Github user FelixNeutatz commented on a diff in the pull request:
https://github.com/apache/flink/pull/566#discussion_r29145755
--- Diff:
flink-core/src/main/java/org/apache/flink/types/parser/IntParser.java ---
@@ -38,19 +38,28 @@ public int parseField(byte[] bytes, int startPos,
[
https://issues.apache.org/jira/browse/FLINK-1933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14513953#comment-14513953
]
ASF GitHub Bot commented on FLINK-1933:
---
GitHub user chiwanpark opened a pull
GitHub user szape opened a pull request:
https://github.com/apache/flink/pull/630
[FLINK-1911] [streaming] Streaming projection without types
Since the DataSet projection has been reworked to not require the
.types(...) call the Streaming and Batch methods were out of sync.
So,
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/622#discussion_r29140453
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java
---
@@ -345,26 +346,9 @@ public void onComplete(Throwable
[
https://issues.apache.org/jira/browse/FLINK-1922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14514068#comment-14514068
]
ASF GitHub Bot commented on FLINK-1922:
---
GitHub user tillrohrmann opened a pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/566#discussion_r29143814
--- Diff:
flink-core/src/main/java/org/apache/flink/types/parser/FloatParser.java ---
@@ -102,6 +111,10 @@ public static final float parseField(byte[] bytes,
[
https://issues.apache.org/jira/browse/FLINK-1820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14514093#comment-14514093
]
ASF GitHub Bot commented on FLINK-1820:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14514092#comment-14514092
]
ASF GitHub Bot commented on FLINK-1820:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/566#discussion_r29143800
--- Diff:
flink-core/src/main/java/org/apache/flink/types/parser/DoubleParser.java ---
@@ -42,6 +42,15 @@ public int parseField(byte[] bytes, int startPos,
[
https://issues.apache.org/jira/browse/FLINK-1820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14514091#comment-14514091
]
ASF GitHub Bot commented on FLINK-1820:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/566#discussion_r29143809
--- Diff:
flink-core/src/main/java/org/apache/flink/types/parser/FloatParser.java ---
@@ -41,6 +41,15 @@ public int parseField(byte[] bytes, int startPos, int
[
https://issues.apache.org/jira/browse/FLINK-1820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14514087#comment-14514087
]
ASF GitHub Bot commented on FLINK-1820:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/566#discussion_r29143622
--- Diff:
flink-java/src/test/java/org/apache/flink/api/java/io/CsvInputFormatTest.java
---
@@ -353,6 +354,99 @@ public void testIntegerFieldsl() throws
[
https://issues.apache.org/jira/browse/FLINK-1937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-1937:
Assignee: Till Rohrmann
Cannot create SparseVector with only one non-zero element.
[
https://issues.apache.org/jira/browse/FLINK-1937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-1937:
-
Comment: was deleted
(was: Hi [~chiwanpark],
the problem is that you're giving a tuple of (Int,
[
https://issues.apache.org/jira/browse/FLINK-1911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14513964#comment-14513964
]
ASF GitHub Bot commented on FLINK-1911:
---
GitHub user szape opened a pull request:
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/628#issuecomment-96622572
I am curious, why did you rewrite the TaskManager? I thought that one was
logging synchronously already.
---
If your project is set up for it, you can reply to this
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/566#discussion_r29143763
--- Diff:
flink-core/src/main/java/org/apache/flink/types/parser/DoubleParser.java ---
@@ -103,6 +112,10 @@ public static final double parseField(byte[]
[
https://issues.apache.org/jira/browse/FLINK-1820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14514090#comment-14514090
]
ASF GitHub Bot commented on FLINK-1820:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/566#discussion_r29144391
--- Diff:
flink-core/src/main/java/org/apache/flink/types/parser/IntParser.java ---
@@ -38,19 +38,28 @@ public int parseField(byte[] bytes, int startPos, int
Robert Metzger created FLINK-1949:
-
Summary: YARNSessionFIFOITCase sometimes fails to detect when the
detached session finishes
Key: FLINK-1949
URL: https://issues.apache.org/jira/browse/FLINK-1949
[
https://issues.apache.org/jira/browse/FLINK-1945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14514117#comment-14514117
]
Chesnay Schepler commented on FLINK-1945:
-
There are no print statements, all
GitHub user chiwanpark opened a pull request:
https://github.com/apache/flink/pull/629
[FLINK-1933] Add distance measure interface and basic implementation to
machine learning library
This PR contains following changes:
* Add `dot` method and `magnitude` method.
* Add
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/616#issuecomment-96617964
@aljoscha Alright, will merge in a bit.
---
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-1924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14513949#comment-14513949
]
ASF GitHub Bot commented on FLINK-1924:
---
Github user mxm commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14513978#comment-14513978
]
ASF GitHub Bot commented on FLINK-1925:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-1925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14513993#comment-14513993
]
ASF GitHub Bot commented on FLINK-1925:
---
Github user StephanEwen commented on the
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/622#issuecomment-96627457
Looks god modulo some comments. The most critical being the concurrent Map
one.
---
If your project is set up for it, you can reply to this email and have your
reply
Gyula Fora created FLINK-1948:
-
Summary: Add manual task slot handling for streaming jobs
Key: FLINK-1948
URL: https://issues.apache.org/jira/browse/FLINK-1948
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-1937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14514095#comment-14514095
]
Till Rohrmann commented on FLINK-1937:
--
Hi [~chiwanpark],
the problem is that you're
Robert Metzger created FLINK-1950:
-
Summary: Increase default heap cutoff ratio from 20% to 30% and
move default value to ConfigConstants
Key: FLINK-1950
URL: https://issues.apache.org/jira/browse/FLINK-1950
[
https://issues.apache.org/jira/browse/FLINK-1950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14514232#comment-14514232
]
Robert Metzger commented on FLINK-1950:
---
Spark is removing 10%, but at least 384 mb.
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/566#discussion_r29147205
--- Diff:
flink-core/src/main/java/org/apache/flink/types/parser/IntParser.java ---
@@ -38,19 +38,28 @@ public int parseField(byte[] bytes, int startPos, int
[
https://issues.apache.org/jira/browse/FLINK-1950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14514215#comment-14514215
]
Stephan Ewen commented on FLINK-1950:
-
20% and 30% are both rather random magic
[
https://issues.apache.org/jira/browse/FLINK-1820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14514171#comment-14514171
]
ASF GitHub Bot commented on FLINK-1820:
---
Github user FelixNeutatz commented on a
1 - 100 of 114 matches
Mail list logo
