Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/553#discussion_r29662593
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
---
@@ -1894,6 +1895,52 @@ object TaskManager {
[
https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14528354#comment-14528354
]
ASF GitHub Bot commented on FLINK-1792:
---
Github user tillrohrmann commented on the
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/553#discussion_r29662751
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
---
@@ -1894,6 +1895,52 @@ object TaskManager {
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/537#issuecomment-99070508
Hey @andralungu ,
I'm not sure what @StephanEwen had in mind when suggesting to subclass
Vertex, but the current implementation forces the user to cast the `Vertex`
[
https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14528386#comment-14528386
]
ASF GitHub Bot commented on FLINK-1523:
---
Github user vasia commented on the pull
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/643#issuecomment-99073001
Sorry, my bad, I confused the layers.
These interfaces do not sufficiently describe things for incremental
checkpointing. We may have to introduce additional
[
https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14528343#comment-14528343
]
ASF GitHub Bot commented on FLINK-1792:
---
Github user tillrohrmann commented on a
[
https://issues.apache.org/jira/browse/FLINK-1807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14528405#comment-14528405
]
ASF GitHub Bot commented on FLINK-1807:
---
Github user tillrohrmann commented on a
[
https://issues.apache.org/jira/browse/FLINK-1807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14528410#comment-14528410
]
ASF GitHub Bot commented on FLINK-1807:
---
Github user tillrohrmann commented on a
[
https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14528491#comment-14528491
]
Aljoscha Krettek commented on FLINK-1962:
-
If would be against reimplementing
GitHub user jkirsch opened a pull request:
https://github.com/apache/flink/pull/652
[FLINK-1974] JobExecutionResult NetRuntime - document result type
- Added documentation to indicate that the return type is in milliseconds
- Added an elapsedNetRuntime method which accepts a
[
https://issues.apache.org/jira/browse/FLINK-1974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14528685#comment-14528685
]
ASF GitHub Bot commented on FLINK-1974:
---
GitHub user jkirsch opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-1976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14528832#comment-14528832
]
Vasia Kalavri commented on FLINK-1976:
--
Big +1! Check also the classes in the
Andra Lungu created FLINK-1975:
--
Summary: Graph getUndirected improvement
Key: FLINK-1975
URL: https://issues.apache.org/jira/browse/FLINK-1975
Project: Flink
Issue Type: Improvement
Github user bhatsachin commented on a diff in the pull request:
https://github.com/apache/flink/pull/553#discussion_r29682706
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
---
@@ -1894,6 +1895,52 @@ object TaskManager {
[
https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14528703#comment-14528703
]
ASF GitHub Bot commented on FLINK-1792:
---
Github user bhatsachin commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14528340#comment-14528340
]
ASF GitHub Bot commented on FLINK-1792:
---
Github user tillrohrmann commented on a
Github user thvasilo commented on the pull request:
https://github.com/apache/flink/pull/613#issuecomment-99064842
BTW some of the builds are still failing due to excessive logging. Any
ideas for a fix?
---
If your project is set up for it, you can reply to this email and have your
[
https://issues.apache.org/jira/browse/FLINK-1871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri resolved FLINK-1871.
--
Resolution: Implemented
Fix Version/s: 0.9
Add a Spargel to Gelly migration guide
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/635#issuecomment-99169722
Yap, that's what I had in mind! Only the class names are a bit too long.
Maybe VertexCentricConfiguration and GSAConfiguration? Or something similar?
---
If your project
[
https://issues.apache.org/jira/browse/FLINK-1942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14529002#comment-14529002
]
ASF GitHub Bot commented on FLINK-1942:
---
Github user vasia commented on the pull
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/553#discussion_r29648339
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
---
@@ -1894,6 +1895,52 @@ object TaskManager {
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/643#issuecomment-98964566
Do you think these interfaces will work if at any point we want to do
incremental snapshots?
---
If your project is set up for it, you can reply to this email and have
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/651#issuecomment-98984867
Great!
I'll integrate it with my new Kafka Source and test everything on a cluster.
---
If your project is set up for it, you can reply to this email and have your
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/650#issuecomment-98985796
Good catch! Thanks @joey001!
---
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 andralungu commented on the pull request:
https://github.com/apache/flink/pull/649#issuecomment-98983169
For the test: did you have a look at the other Gelly
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14528075#comment-14528075
]
ASF GitHub Bot commented on FLINK-1707:
---
Github user andralungu commented on the
[
https://issues.apache.org/jira/browse/FLINK-1953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14528078#comment-14528078
]
ASF GitHub Bot commented on FLINK-1953:
---
Github user rmetzger commented on the pull
Github user bhatsachin commented on a diff in the pull request:
https://github.com/apache/flink/pull/553#discussion_r29650229
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
---
@@ -1894,6 +1895,52 @@ object TaskManager {
Github user bhatsachin commented on a diff in the pull request:
https://github.com/apache/flink/pull/553#discussion_r29650540
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala
---
@@ -1894,6 +1895,52 @@ object TaskManager {
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/600
---
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-1944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri resolved FLINK-1944.
--
Resolution: Implemented
Fix Version/s: 0.9
Add a Gelly-GSA PageRank example
Github user andralungu commented on the pull request:
https://github.com/apache/flink/pull/635#issuecomment-99157184
Hi @vasia,
The alternatives to having a single config class for all types of
iterations are:
- having two separate classes in spargel and in gsa = massive
[
https://issues.apache.org/jira/browse/FLINK-1942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14528901#comment-14528901
]
ASF GitHub Bot commented on FLINK-1942:
---
Github user andralungu commented on the
[
https://issues.apache.org/jira/browse/FLINK-1871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14528868#comment-14528868
]
ASF GitHub Bot commented on FLINK-1871:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-1944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14528867#comment-14528867
]
ASF GitHub Bot commented on FLINK-1944:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-1682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14529265#comment-14529265
]
ASF GitHub Bot commented on FLINK-1682:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14529347#comment-14529347
]
ASF GitHub Bot commented on FLINK-1523:
---
Github user andralungu commented on the
Github user andralungu commented on the pull request:
https://github.com/apache/flink/pull/537#issuecomment-99232613
Hey @vasia ,
Everyone is acting as though I do not want to make these methods
user-freindly. I do :), it's just not possible.
Keep in mind that in
39 matches
Mail list logo