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 Git
[
https://issues.apache.org/jira/browse/FLINK-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14513657#comment-14513657
]
ASF GitHub Bot commented on FLINK-1789:
---
Github user aljoscha commented on the pull
[
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 log
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
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
[
https://issues.apache.org/jira/browse/FLINK-1930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14513703#comment-14513703
]
ASF GitHub Bot commented on FLINK-1930:
---
Github user uce commented on the pull reque
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/624#issuecomment-96555080
Thanks. I'm merging this.
(The failed Travis jobs are Travis-related I think.)
---
If your project is set up for it, you can reply to this email and have your
reply a
[
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
> --
[
https://issues.apache.org/jira/browse/FLINK-1930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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 enabl
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 ar
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 enabl
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 enabl
[
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
> --
[
https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14513707#comment-14513707
]
ASF GitHub Bot commented on FLINK-1523:
---
Github user StephanEwen commented on the pu
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 (i
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: Imp
[
https://issues.apache.org/jira/browse/FLINK-1938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14513713#comment-14513713
]
ASF GitHub Bot commented on FLINK-1938:
---
Github user StephanEwen commented on the pu
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-1682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14513714#comment-14513714
]
ASF GitHub Bot commented on FLINK-1682:
---
GitHub user fhueske opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-1615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14513718#comment-14513718
]
ASF GitHub Bot commented on FLINK-1615:
---
Github user aljoscha commented on the pull
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 proje
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 wis
[
https://issues.apache.org/jira/browse/FLINK-1924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14513732#comment-14513732
]
ASF GitHub Bot commented on FLINK-1924:
---
Github user mxm commented on the pull reque
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.
[
https://issues.apache.org/jira/browse/FLINK-1828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14513737#comment-14513737
]
ASF GitHub Bot commented on FLINK-1828:
---
Github user fhueske commented on a diff in
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 u
[
https://issues.apache.org/jira/browse/FLINK-1923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14513746#comment-14513746
]
ASF GitHub Bot commented on FLINK-1923:
---
GitHub user tillrohrmann opened a pull requ
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 t
[
https://issues.apache.org/jira/browse/FLINK-1924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14513747#comment-14513747
]
ASF GitHub Bot commented on FLINK-1924:
---
Github user aljoscha commented on the pull
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.
[
https://issues.apache.org/jira/browse/FLINK-1828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14513753#comment-14513753
]
ASF GitHub Bot commented on FLINK-1828:
---
Github user fpompermaier commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-1947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14513768#comment-14513768
]
Stephan Ewen commented on FLINK-1947:
-
You can avoid the sysout logging by using
{{Ex
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 enabl
[
https://issues.apache.org/jira/browse/FLINK-1682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14513773#comment-14513773
]
ASF GitHub Bot commented on FLINK-1682:
---
Github user StephanEwen commented on the pu
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 comma
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 to
[
https://issues.apache.org/jira/browse/FLINK-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14513849#comment-14513849
]
ASF GitHub Bot commented on FLINK-1789:
---
Github user twalthr commented on the pull r
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.
[
https://issues.apache.org/jira/browse/FLINK-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14513870#comment-14513870
]
ASF GitHub Bot commented on FLINK-1789:
---
Github user StephanEwen commented on the pu
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 no
[
https://issues.apache.org/jira/browse/FLINK-1924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14513949#comment-14513949
]
ASF GitHub Bot commented on FLINK-1924:
---
Github user mxm commented on the pull reque
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 `
[
https://issues.apache.org/jira/browse/FLINK-1933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14513953#comment-14513953
]
ASF GitHub Bot commented on FLINK-1933:
---
GitHub user chiwanpark opened a pull reques
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,
[
https://issues.apache.org/jira/browse/FLINK-1911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14513964#comment-14513964
]
ASF GitHub Bot commented on FLINK-1911:
---
GitHub user szape opened a pull request:
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-1923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14513971#comment-14513971
]
ASF GitHub Bot commented on FLINK-1923:
---
Github user StephanEwen commented on a diff
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 e
[
https://issues.apache.org/jira/browse/FLINK-1923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14513973#comment-14513973
]
ASF GitHub Bot commented on FLINK-1923:
---
Github user StephanEwen commented on the pu
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 fai
[
https://issues.apache.org/jira/browse/FLINK-1925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14513974#comment-14513974
]
ASF GitHub Bot commented on FLINK-1925:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/622#discussion_r29140570
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
---
@@ -137,7 +137,7 @@ extends Actor with ActorLogMessages
[
https://issues.apache.org/jira/browse/FLINK-1925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14513978#comment-14513978
]
ASF GitHub Bot commented on FLINK-1925:
---
Github user StephanEwen commented on a diff
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 ActorLogMessa
[
https://issues.apache.org/jira/browse/FLINK-1925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14513981#comment-14513981
]
ASF GitHub Bot commented on FLINK-1925:
---
Github user StephanEwen commented on a diff
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
[
https://issues.apache.org/jira/browse/FLINK-1925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14513993#comment-14513993
]
ASF GitHub Bot commented on FLINK-1925:
---
Github user StephanEwen commented on the pu
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-tabpanel&focusedCommentId=14514030#comment-14514030
]
ASF GitHub Bot commented on FLINK-1792:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14514045#comment-14514045
]
ASF GitHub Bot commented on FLINK-1682:
---
Github user fhueske commented on the pull r
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 t
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: Improvem
[
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
> ---
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. Fixed
[
https://issues.apache.org/jira/browse/FLINK-1922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14514068#comment-14514068
]
ASF GitHub Bot commented on FLINK-1922:
---
GitHub user tillrohrmann opened a pull requ
[
https://issues.apache.org/jira/browse/FLINK-1820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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 IOExc
[
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.
>
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[] bytes,
[
https://issues.apache.org/jira/browse/FLINK-1820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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_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
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, i
[
https://issues.apache.org/jira/browse/FLINK-1820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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-tabpanel&focusedCommentId=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, int
[
https://issues.apache.org/jira/browse/FLINK-1820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14514091#comment-14514091
]
ASF GitHub Bot commented on FLINK-1820:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14514095#comment-14514095
]
Till Rohrmann commented on FLINK-1937:
--
Hi [~chiwanpark],
the problem is that you're
[
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, I
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
[
https://issues.apache.org/jira/browse/FLINK-1820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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-tabpanel&focusedCommentId=14514102#comment-14514102
]
ASF GitHub Bot commented on FLINK-1820:
---
Github user fhueske commented on the pull r
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
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
Pr
[
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-1945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14514117#comment-14514117
]
Chesnay Schepler commented on FLINK-1945:
-
There are no print statements, all outp
[
https://issues.apache.org/jira/browse/FLINK-1820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14514122#comment-14514122
]
ASF GitHub Bot commented on FLINK-1820:
---
Github user FelixNeutatz commented on a dif
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,
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-1820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14514153#comment-14514153
]
ASF GitHub Bot commented on FLINK-1820:
---
Github user fhueske commented on a diff in
Github user FelixNeutatz commented on a diff in the pull request:
https://github.com/apache/flink/pull/566#discussion_r29148302
--- 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-1820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14514171#comment-14514171
]
ASF GitHub Bot commented on FLINK-1820:
---
Github user FelixNeutatz commented on a dif
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-tabpanel&focusedCommentId=14514215#comment-14514215
]
Stephan Ewen commented on FLINK-1950:
-
20% and 30% are both rather random magic number
GitHub user fpompermaier opened a pull request:
https://github.com/apache/flink/pull/632
Fixed missing call to configure() for Configurable HadoopOutputFormats
(Flink-1828)
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/fpomper
[
https://issues.apache.org/jira/browse/FLINK-1950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14514232#comment-14514232
]
Robert Metzger commented on FLINK-1950:
---
Spark is removing 10%, but at least 384 mb.
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/616
---
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 enabl
[
https://issues.apache.org/jira/browse/FLINK-1924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14514260#comment-14514260
]
ASF GitHub Bot commented on FLINK-1924:
---
Github user asfgit closed the pull request
Vasia Kalavri created FLINK-1951:
Summary: NullPointerException in DeltaIteration when no
ForwardedFileds
Key: FLINK-1951
URL: https://issues.apache.org/jira/browse/FLINK-1951
Project: Flink
GitHub user fpompermaier opened a pull request:
https://github.com/apache/flink/pull/633
Addde HBase OutputFormat example (Flink-1828)
Fixed on top of PR #632, shows how to write data into HBase
You can merge this pull request into a Git repository by running:
$ git pull https:
1 - 100 of 118 matches
Mail list logo
