Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/711#issuecomment-105418301
Thanks @rmetzger for the review. Will merge this EOD tomorrow if no
objection.
---
If your project is set up for it, you can reply to this email and have your
reply app
Github user HilmiYildirim commented on a diff in the pull request:
https://github.com/apache/flink/pull/706#discussion_r31007499
--- Diff:
flink-staging/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseWriteStreamExample.java
---
@@ -0,0 +1,114 @@
+/*
+
Github user HilmiYildirim commented on the pull request:
https://github.com/apache/flink/pull/695#issuecomment-105415577
The problem is as follows. While I was working on the commit, the interface
SourceFunction has changed and was merged with the master. Now, it has the
methods reach
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/723
[FLINK-2053] [ml] Adds automatic preregistration of ML types
Adds automatic type registration of flink-ml types. This is done by
providing a type registration method `FlinkMLTools.registerFlinkM
[
https://issues.apache.org/jira/browse/FLINK-2053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14558559#comment-14558559
]
ASF GitHub Bot commented on FLINK-2053:
---
GitHub user tillrohrmann opened a pull requ
Github user andralungu commented on the pull request:
https://github.com/apache/flink/pull/678#issuecomment-105311774
Yes, I got the idea of difference, we agree on the functionality. What I
was trying to say is that it cannot be used in the remove* methods as it needs
to create a gra
[
https://issues.apache.org/jira/browse/FLINK-2012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14558523#comment-14558523
]
ASF GitHub Bot commented on FLINK-2012:
---
Github user andralungu commented on the pul
[
https://issues.apache.org/jira/browse/FLINK-2012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14558445#comment-14558445
]
ASF GitHub Bot commented on FLINK-2012:
---
Github user vasia commented on the pull req
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/678#issuecomment-105287317
Hey @andralungu,
first of all, you can always discuss implementation details by starting a
thread in the mailing list. This is usually done for bigger changes, so t
[
https://issues.apache.org/jira/browse/FLINK-1907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14558418#comment-14558418
]
ASF GitHub Bot commented on FLINK-1907:
---
Github user nikste commented on the pull re
Github user nikste commented on the pull request:
https://github.com/apache/flink/pull/672#issuecomment-105279617
Should work. Yes `print()` was merged independently. I'll look at it and
clean up the commits tomorrow. I too would like to see it being merged ;)
---
If your project is
[
https://issues.apache.org/jira/browse/FLINK-1941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14558417#comment-14558417
]
ASF GitHub Bot commented on FLINK-1941:
---
Github user andralungu commented on the pul
Github user andralungu commented on the pull request:
https://github.com/apache/flink/pull/722#issuecomment-105277082
+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
[
https://issues.apache.org/jira/browse/FLINK-2012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14558415#comment-14558415
]
ASF GitHub Bot commented on FLINK-2012:
---
Github user andralungu commented on the pul
Github user andralungu commented on the pull request:
https://github.com/apache/flink/pull/678#issuecomment-105277029
Hi @vasia,
I updated the addition methods to fit your suggestion. Feedback, for both
of us in the future: discuss implementation details like just add vertice
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/672#issuecomment-105276798
Whats the status of this pull request?
It seems that the changes to `print()` have been merged independently. I
would like to merge this soon (depending on the status
[
https://issues.apache.org/jira/browse/FLINK-1907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14558409#comment-14558409
]
ASF GitHub Bot commented on FLINK-1907:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14558394#comment-14558394
]
Robert Metzger commented on FLINK-2080:
---
Thank you for exploring how to run Flink wi
[
https://issues.apache.org/jira/browse/FLINK-2074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14558371#comment-14558371
]
ASF GitHub Bot commented on FLINK-2074:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/716#issuecomment-105260996
Amazing, thank you.
+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
[
https://issues.apache.org/jira/browse/FLINK-2018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14558367#comment-14558367
]
ASF GitHub Bot commented on FLINK-2018:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/720#discussion_r30986863
--- Diff:
flink-java/src/test/java/org/apache/flink/api/java/utils/ParameterToolTest.java
---
@@ -150,6 +150,12 @@ public void testMerged() {
[
https://issues.apache.org/jira/browse/FLINK-2039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14558324#comment-14558324
]
ASF GitHub Bot commented on FLINK-2039:
---
Github user ggevay commented on the pull re
Github user ggevay commented on the pull request:
https://github.com/apache/flink/pull/684#issuecomment-105249478
I coded the grouped case and did the refactoring of SumAggregator and
ComparableAggregator to use the new FieldAccessor class to access the
user-specified field. The first
[
https://issues.apache.org/jira/browse/FLINK-2088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Faye Beligianni updated FLINK-2088:
---
Description: {{name}} function of {{DataStream}} scala class has a wrong
return type: {code} D
[
https://issues.apache.org/jira/browse/FLINK-2088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Faye Beligianni updated FLINK-2088:
---
Description: {{name}} function of {{DataStream}} scala class has a wrong
return type {code} Da
Faye Beligianni created FLINK-2088:
--
Summary: change return type of name function in DataStream scala
class
Key: FLINK-2088
URL: https://issues.apache.org/jira/browse/FLINK-2088
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-2013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14558301#comment-14558301
]
Ajay Bhat commented on FLINK-2013:
--
Hi [~tvas], I could take up a few of these GLMs and w
Github user ajaybhat commented on a diff in the pull request:
https://github.com/apache/flink/pull/720#discussion_r30982636
--- Diff:
flink-java/src/test/java/org/apache/flink/api/java/utils/ParameterToolTest.java
---
@@ -150,6 +150,14 @@ public void testMerged() {
[
https://issues.apache.org/jira/browse/FLINK-2018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14558295#comment-14558295
]
ASF GitHub Bot commented on FLINK-2018:
---
Github user ajaybhat commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-2074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14558260#comment-14558260
]
ASF GitHub Bot commented on FLINK-2074:
---
Github user aljoscha commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/716#issuecomment-105233972
@rmetzger I added tests for both SlidingTimePreReducer and
SlidingTimeGroupedPreReducer to verify that they correctly flush their states
after a burst of elements.
---
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/718#issuecomment-105230094
+1 to merge.
The changes look good.
---
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 d
[
https://issues.apache.org/jira/browse/FLINK-2084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14558241#comment-14558241
]
ASF GitHub Bot commented on FLINK-2084:
---
Github user rmetzger commented on the pull
Robert Metzger created FLINK-2087:
-
Summary: Add streaming mode to YARN as well
Key: FLINK-2087
URL: https://issues.apache.org/jira/browse/FLINK-2087
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-1738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-1738.
Resolution: Duplicate
Has been implemented by FLINK-1809.
> Add mean centering transformation to ma
[
https://issues.apache.org/jira/browse/FLINK-1738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14558230#comment-14558230
]
Till Rohrmann commented on FLINK-1738:
--
Hi [~ajay bhat],
this issue has already bee
[
https://issues.apache.org/jira/browse/FLINK-1999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14558224#comment-14558224
]
Till Rohrmann commented on FLINK-1999:
--
You can do it as you like and what's easier f
[
https://issues.apache.org/jira/browse/FLINK-2084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14558202#comment-14558202
]
ASF GitHub Bot commented on FLINK-2084:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/718#discussion_r30977601
--- Diff: flink-dist/src/main/flink-bin/bin/jobmanager.sh ---
@@ -80,7 +81,7 @@ case $STARTSTOP in
rotateLogFile $out
echo "Sta
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/720#discussion_r30977489
--- Diff:
flink-java/src/test/java/org/apache/flink/api/java/utils/ParameterToolTest.java
---
@@ -150,6 +150,14 @@ public void testMerged() {
[
https://issues.apache.org/jira/browse/FLINK-2018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14558188#comment-14558188
]
ASF GitHub Bot commented on FLINK-2018:
---
Github user rmetzger commented on a diff in
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/722#issuecomment-105201007
Added comparison section and SSSP drawings for vertex-centric ^^
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as w
[
https://issues.apache.org/jira/browse/FLINK-1941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14558098#comment-14558098
]
ASF GitHub Bot commented on FLINK-1941:
---
Github user vasia commented on the pull req
[
https://issues.apache.org/jira/browse/FLINK-1963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14558088#comment-14558088
]
Fabian Hueske commented on FLINK-1963:
--
Please do so! :-)
Let me know if you need a s
[
https://issues.apache.org/jira/browse/FLINK-2082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora resolved FLINK-2082.
---
Resolution: Fixed
Implemented in:
https://github.com/apache/flink/commit/0cfa43d79faebe7000cedfc71a8f
[
https://issues.apache.org/jira/browse/FLINK-2082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-2082:
--
Priority: Minor (was: Major)
> Chained stream tasks share the same RuntimeContext
> ---
47 matches
Mail list logo
