GitHub user markus-h opened a pull request:
https://github.com/apache/flink/pull/598
[FLINK-1885] [gelly] Added bulk execution mode to gellys vertex centric
iterations
See https://issues.apache.org/jira/browse/FLINK-1885
I essentially exchanged the delta iteration with a
Markus Holzemer created FLINK-1885:
--
Summary: Bulk mode for gelly
Key: FLINK-1885
URL: https://issues.apache.org/jira/browse/FLINK-1885
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14493713#comment-14493713
]
Jonas Traub commented on FLINK-1660:
First, sorry for not replying so far! I had a lot
[
https://issues.apache.org/jira/browse/FLINK-1861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14493772#comment-14493772
]
Maximilian Michels commented on FLINK-1861:
---
[~rmetzger] Please clear your
Github user rmetzger closed the pull request at:
https://github.com/apache/flink/pull/597
---
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-1342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14493813#comment-14493813
]
ASF GitHub Bot commented on FLINK-1342:
---
Github user rmetzger closed the pull
[
https://issues.apache.org/jira/browse/FLINK-1886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14493830#comment-14493830
]
Robert Metzger commented on FLINK-1886:
---
Hi,
please use the u...@flink.apache.org
[
https://issues.apache.org/jira/browse/FLINK-1885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14493710#comment-14493710
]
ASF GitHub Bot commented on FLINK-1885:
---
GitHub user markus-h opened a pull request:
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/587#issuecomment-92676965
I'll 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 this
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/595#discussion_r28312964
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
---
@@ -339,6 +339,12 @@ extends Actor with ActorLogMessages with
[
https://issues.apache.org/jira/browse/FLINK-1861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14493733#comment-14493733
]
Robert Metzger commented on FLINK-1861:
---
docs/latest/ and docs/stable/ are still not
[
https://issues.apache.org/jira/browse/FLINK-1829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14493737#comment-14493737
]
Robert Metzger commented on FLINK-1829:
---
Cool. I'm happy its not an issue with Flink
[
https://issues.apache.org/jira/browse/FLINK-1829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger closed FLINK-1829.
-
Resolution: Invalid
Conflicting Jackson version in the Flink POMs
Github user akshaydixi commented on the pull request:
https://github.com/apache/flink/pull/508#issuecomment-92691766
Ok. So should I delete this branch then?
---
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
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/587
---
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-1342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14493811#comment-14493811
]
ASF GitHub Bot commented on FLINK-1342:
---
Github user rmetzger commented on the pull
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/586
---
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 rmetzger commented on the pull request:
https://github.com/apache/flink/pull/597#issuecomment-92703319
I'm merging this
---
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
hagersaleh created FLINK-1886:
-
Summary: how can handles left join ,right join , FULL OUTER JOIN
in flink
Key: FLINK-1886
URL: https://issues.apache.org/jira/browse/FLINK-1886
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-1886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger closed FLINK-1886.
-
Resolution: Invalid
how can handles left join ,right join , FULL OUTER JOIN in flink
[
https://issues.apache.org/jira/browse/FLINK-1889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14494029#comment-14494029
]
Theodore Vasiloudis commented on FLINK-1889:
This issue can probably benefit
[
https://issues.apache.org/jira/browse/FLINK-1883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14493872#comment-14493872
]
ASF GitHub Bot commented on FLINK-1883:
---
Github user andralungu commented on the
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/594#issuecomment-92780564
This is a huge PR but from what I've seen you made very sensible changes.
---
If your project is set up for it, you can reply to this email and have your
reply appear on
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/595#discussion_r28319765
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
---
@@ -339,6 +339,12 @@ extends Actor with ActorLogMessages with
Theodore Vasiloudis created FLINK-1889:
--
Summary: Create optimization framework
Key: FLINK-1889
URL: https://issues.apache.org/jira/browse/FLINK-1889
Project: Flink
Issue Type: New
Maximilian Michels created FLINK-1888:
-
Summary: Download page doesn't contain Maven dependencies for
0.9.0-milestone-1
Key: FLINK-1888
URL: https://issues.apache.org/jira/browse/FLINK-1888
Github user andralungu commented on the pull request:
https://github.com/apache/flink/pull/596#issuecomment-92750207
Hi @vasia ,
I wanted to be as close to the example in the guide, to show that Spargel
code can easily be ported to Gelly, hence the name. I changed it now :)
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/202#issuecomment-92765309
Now uses TCP to exchange signals.
---
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
[
https://issues.apache.org/jira/browse/FLINK-1887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14493913#comment-14493913
]
ASF GitHub Bot commented on FLINK-1887:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/599#issuecomment-92773617
looks 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 does not have this feature
[
https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14493894#comment-14493894
]
ASF GitHub Bot commented on FLINK-377:
--
Github user zentol commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14493869#comment-14493869
]
ASF GitHub Bot commented on FLINK-1887:
---
GitHub user matadorhong opened a pull
GitHub user matadorhong opened a pull request:
https://github.com/apache/flink/pull/599
[FLINK-1887]Fix the message in runtime exception
RT,
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/matadorhong/flink
Sibao Hong created FLINK-1887:
-
Summary: Fix the message in runtime exception
Key: FLINK-1887
URL: https://issues.apache.org/jira/browse/FLINK-1887
Project: Flink
Issue Type: Improvement
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/599#issuecomment-92775321
Good 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-1887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14493921#comment-14493921
]
ASF GitHub Bot commented on FLINK-1887:
---
Github user mxm commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14493949#comment-14493949
]
Maximilian Michels commented on FLINK-1872:
---
If you want to automatically
[
https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14494112#comment-14494112
]
ASF GitHub Bot commented on FLINK-1753:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/589#issuecomment-92834090
I would like to merge this PR rather soon because I need some of the
changes from this PR for adding another KafkaITCase.
Is it okay to postpone the refactor to
[
https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14494125#comment-14494125
]
ASF GitHub Bot commented on FLINK-1753:
---
Github user gaborhermann commented on the
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/594#issuecomment-92854325
Regarding StreamRecord, is the UID still required? In my understanding we
are working towards state-snapshotting, so that would not require to have IDs
in records
[
https://issues.apache.org/jira/browse/FLINK-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14494121#comment-14494121
]
ASF GitHub Bot commented on FLINK-1789:
---
Github user aalexandrov commented on the
Github user gaborhermann commented on the pull request:
https://github.com/apache/flink/pull/589#issuecomment-92846151
Yes, of course, we can postpone the refactor.
---
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
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/594#issuecomment-92856455
By the way, all these comments I'm making. I'm just making them to keep
track of things. If we discuss them and want to implement some changes I can
also do this myself,
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/589
---
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-1871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14494347#comment-14494347
]
ASF GitHub Bot commented on FLINK-1871:
---
GitHub user andralungu opened a pull
GitHub user andralungu opened a pull request:
https://github.com/apache/flink/pull/600
[FLINK-1871][gelly] Added Spargel to Gelly migration guide
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/andralungu/flink migrationGuide
Stefan Bunk created FLINK-1890:
--
Summary: Add withReadFields or sth. similar to Scala API
Key: FLINK-1890
URL: https://issues.apache.org/jira/browse/FLINK-1890
Project: Flink
Issue Type: Wish
[
https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14494243#comment-14494243
]
ASF GitHub Bot commented on FLINK-1753:
---
Github user asfgit closed the pull request
Github user mjsax commented on a diff in the pull request:
https://github.com/apache/flink/pull/573#discussion_r28344339
--- Diff:
flink-staging/flink-streaming/flink-storm-compatibility/src/main/java/org/apache/flink/stormcompatibility/api/FlinkSubmitter.java
---
@@ -0,0 +1,258
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/589#issuecomment-92902901
I'm merging the PR 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
[
https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14494240#comment-14494240
]
ASF GitHub Bot commented on FLINK-1753:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14494246#comment-14494246
]
Robert Metzger commented on FLINK-1753:
---
Added a broker failure test in
[
https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-1753:
--
Description:
The current {{KafkaITCase}} is only doing a single test.
We need to refactor that
[
https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-1753:
--
Description:
The current {{KafkaITCase}} is only doing a single test.
We need to refactor that
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/594#issuecomment-92856051
Package org.apache.flink.streaming.runtime.streamtask could be renamed to
org.apache.flink.streaming.runtime.tasks, the streaming part is already clear
from
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/594#issuecomment-92860931
Also, there are packages streamgraph and streamoperator which could be
renamed to graph and operators, to improve consistency.
Further, there are two concepts we
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/594#issuecomment-92862631
Package api.function and its sub packages should be pluralised for
consistency.
---
If your project is set up for it, you can reply to this email and have your
reply
Github user aalexandrov commented on the pull request:
https://github.com/apache/flink/pull/593#issuecomment-92841182
:clap:
---
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-1876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14495000#comment-14495000
]
Gyula Fora commented on FLINK-1876:
---
https://github.com/apache/flink/pull/594
Refactor
[
https://issues.apache.org/jira/browse/FLINK-1655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14495001#comment-14495001
]
Gyula Fora commented on FLINK-1655:
---
https://github.com/apache/flink/pull/594
Rename
[
https://issues.apache.org/jira/browse/FLINK-1793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora resolved FLINK-1793.
---
Resolution: Fixed
Streaming File Source cannot be canceled
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/594#issuecomment-93083350
I fixed all the comments, except for the SingleOutputStreamOperator thing.
Let's leave that for later :D
---
If your project is set up for it, you can reply to this email
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/508#issuecomment-93084344
yes please
---
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-1655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14494997#comment-14494997
]
ASF GitHub Bot commented on FLINK-1655:
---
Github user gyfora commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14494075#comment-14494075
]
ASF GitHub Bot commented on FLINK-1660:
---
Github user asfgit closed the pull request
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/594#issuecomment-92817866
When merging two things to look out for: I have already pushed the key
bugfix for the StreamConfig and have have to make sure to not only close this
PR but also #508.
Github user twalthr commented on the pull request:
https://github.com/apache/flink/pull/593#issuecomment-92805121
It builds 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
[
https://issues.apache.org/jira/browse/FLINK-1888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels reassigned FLINK-1888:
-
Assignee: Maximilian Michels
Download page doesn't contain Maven dependencies
[
https://issues.apache.org/jira/browse/FLINK-1888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-1888.
-
Resolution: Fixed
Download page doesn't contain Maven dependencies for 0.9.0-milestone-1
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/590
---
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-1866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-1866.
-
Resolution: Fixed
Fix Version/s: 0.9
Fixed via 54d5662
In StreamConfig IN_STREAM_EDGES
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/594#issuecomment-92820251
By the way scrolling through the code: Big :+1: for the `streamoperator`
package and for the `StreamNode`.
---
If your project is set up for it, you can reply to this
[
https://issues.apache.org/jira/browse/FLINK-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-1660.
-
Resolution: Fixed
Assignee: Ufuk Celebi
Fixed via e5a3b95
MultiTriggerPolicyTest timeout
74 matches
Mail list logo
