[
https://issues.apache.org/jira/browse/FLINK-1052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-1052:
--
Component/s: JobManager
Access to stdout and log information of Taskmanagers from the web
[
https://issues.apache.org/jira/browse/FLINK-1052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-1052:
--
Priority: Major (was: Minor)
Access to stdout and log information of Taskmanagers from the
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/383
support for secure HDFS access using kerberos
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mxm/flink kerberos_hdfs
Alternatively you can review
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/383#issuecomment-73912267
Looks 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
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/378
---
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 fhueske commented on the pull request:
https://github.com/apache/flink/pull/370#issuecomment-73914381
Oh, just saw that you updated your PR.
Won't open a PR. You can have a look at my branch here:
https://github.com/fhueske/flink/tree/chained_all_reduce
---
If your
[
https://issues.apache.org/jira/browse/FLINK-1504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14316516#comment-14316516
]
ASF GitHub Bot commented on FLINK-1504:
---
Github user rmetzger commented on the pull
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/378#issuecomment-73908802
I added the UpdateTask message aggregation. I also had to rework the
PartitionInfo creation to make it work with the concurrent task updates. This
requires another
[
https://issues.apache.org/jira/browse/FLINK-1504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14316453#comment-14316453
]
ASF GitHub Bot commented on FLINK-1504:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14316451#comment-14316451
]
ASF GitHub Bot commented on FLINK-1489:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/383#issuecomment-73916367
Rebased to master: https://github.com/rmetzger/flink/tree/kerberos_hdfs
---
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-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14316518#comment-14316518
]
ASF GitHub Bot commented on FLINK-1510:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/382#issuecomment-73917179
I'm closing the PR until I've added tests.
---
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-1499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-1499:
-
Summary: Make TaskManager to disconnect from JobManager in case of a
restart (was: Make
Ufuk Celebi created FLINK-1519:
--
Summary: Web frontend task state mismatch when cancelling
Key: FLINK-1519
URL: https://issues.apache.org/jira/browse/FLINK-1519
Project: Flink
Issue Type:
Aljoscha Krettek created FLINK-1521:
---
Summary: Some Chained Drivers do not respect
object-reuse/non-reuse flag
Key: FLINK-1521
URL: https://issues.apache.org/jira/browse/FLINK-1521
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-1521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14316240#comment-14316240
]
Ufuk Celebi commented on FLINK-1521:
Is the discussion here related?
[
https://issues.apache.org/jira/browse/FLINK-1524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14316300#comment-14316300
]
Chesnay Schepler commented on FLINK-1524:
-
this issue was discussed earlier today
Vasia Kalavri created FLINK-1528:
Summary: Add local clustering coefficient library method and
example
Key: FLINK-1528
URL: https://issues.apache.org/jira/browse/FLINK-1528
Project: Flink
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/383#issuecomment-73910366
https://issues.apache.org/jira/browse/FLINK-1504
---
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-785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14316496#comment-14316496
]
ASF GitHub Bot commented on FLINK-785:
--
Github user fhueske commented on the pull
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/370#issuecomment-73923184
sorry for not making it clear that i forced pushed some changes, forgot
making a separate branch.
the changes you made to the driver are already in, sorry for
[
https://issues.apache.org/jira/browse/FLINK-1504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-1504.
---
Resolution: Fixed
Fix Version/s: 0.9
Assignee: Max Michels
Resolved in
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/383
---
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-1052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14316426#comment-14316426
]
Robert Metzger commented on FLINK-1052:
---
I'm assigning the issue to myself, but I
[
https://issues.apache.org/jira/browse/FLINK-1052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-1052:
-
Assignee: Robert Metzger
Access to stdout and log information of Taskmanagers from the
[
https://issues.apache.org/jira/browse/FLINK-1489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14316438#comment-14316438
]
ASF GitHub Bot commented on FLINK-1489:
---
Github user tillrohrmann commented on the
[
https://issues.apache.org/jira/browse/FLINK-1489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14316466#comment-14316466
]
ASF GitHub Bot commented on FLINK-1489:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1455.
-
Resolution: Fixed
Fix Version/s: 0.9
Assignee: Stephan Ewen
Fixed (again) in
[
https://issues.apache.org/jira/browse/FLINK-1455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14316504#comment-14316504
]
Stephan Ewen commented on FLINK-1455:
-
I improved the robustness for the tests by
[
https://issues.apache.org/jira/browse/FLINK-1052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-1052:
--
Affects Version/s: 0.9
Access to stdout and log information of Taskmanagers from the web
[
https://issues.apache.org/jira/browse/FLINK-1504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14316475#comment-14316475
]
ASF GitHub Bot commented on FLINK-1504:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14316489#comment-14316489
]
ASF GitHub Bot commented on FLINK-785:
--
Github user fhueske commented on the pull
Github user rmetzger closed the pull request at:
https://github.com/apache/flink/pull/382
---
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-1504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14316567#comment-14316567
]
ASF GitHub Bot commented on FLINK-1504:
---
Github user asfgit closed the pull request
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/378#issuecomment-73911265
The job that was previously failing is fixed with this change.
We should merge this change ASAP, because its kinda impossible right now to
seriously use flink
[
https://issues.apache.org/jira/browse/FLINK-1489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14316484#comment-14316484
]
ASF GitHub Bot commented on FLINK-1489:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-1489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-1489.
---
Resolution: Fixed
Fix Version/s: 0.9
Merged in
Stephan Ewen created FLINK-1529:
---
Summary: Improve JobManager startup robustness
Key: FLINK-1529
URL: https://issues.apache.org/jira/browse/FLINK-1529
Project: Flink
Issue Type: Improvement
Stephan Ewen created FLINK-1530:
---
Summary: Cache ExecutionConfig in AbstractInvokable
Key: FLINK-1530
URL: https://issues.apache.org/jira/browse/FLINK-1530
Project: Flink
Issue Type:
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/202#issuecomment-73931484
Why should the resulting address be different from the one Java uses? What
does
import socket
socket.getaddrinfo(socket.gethostname(), None,
[
https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14316632#comment-14316632
]
ASF GitHub Bot commented on FLINK-377:
--
Github user zentol commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14316819#comment-14316819
]
Martin Kiefer commented on FLINK-1515:
--
I will do it. You can assign me.
[Gelly]
[
https://issues.apache.org/jira/browse/FLINK-1530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1530.
-
Resolution: Fixed
Fixed via 69b794561c151261d48f7fa5463c3b24894a8efa
Cache ExecutionConfig in
[
https://issues.apache.org/jira/browse/FLINK-1491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-1491.
Resolution: Fixed
Fixed with 90834ca706d369b7c2bd739835766c490ee44042
Inconsistent logging
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/202#issuecomment-73926790
No, same result. I tried including my hostname in /etc/hosts which got me
past the above exception. However, now I get
02/11/2015 18:41:00 Job execution
[
https://issues.apache.org/jira/browse/FLINK-1487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-1487:
--
Component/s: JobManager
Failing SchedulerIsolatedTasksTest.testScheduleQueueing test case
[
https://issues.apache.org/jira/browse/FLINK-1487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-1487:
--
Affects Version/s: 0.9
Failing SchedulerIsolatedTasksTest.testScheduleQueueing test case
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/202#issuecomment-73936205
in my case, it returns this:
```python
import socket
socket.gethostname()
'Linux'
socket.getaddrinfo(socket.gethostname(), None, socket.AF_INET,
[
https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14316728#comment-14316728
]
ASF GitHub Bot commented on FLINK-377:
--
Github user zentol commented on the pull
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/202#issuecomment-73945405
@mxm I've added another potential fix.
---
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
Ufuk Celebi created FLINK-1518:
--
Summary: Laggy task cancelling on task managers
Key: FLINK-1518
URL: https://issues.apache.org/jira/browse/FLINK-1518
Project: Flink
Issue Type: Improvement
Robert Metzger created FLINK-1525:
-
Summary: Provide utils to pass -D parameters to UDFs
Key: FLINK-1525
URL: https://issues.apache.org/jira/browse/FLINK-1525
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-1524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-1524:
---
Assignee: Chesnay Schepler
Job Manager does not handle the RequestArchivedJobs
[
https://issues.apache.org/jira/browse/FLINK-1515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-1515:
-
Component/s: Gelly
[Gelly] Enable access to aggregators and broadcast sets in vertex-centric
[
https://issues.apache.org/jira/browse/FLINK-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-1514:
-
Component/s: Gelly
[Gelly] Add a Gather-Sum-Apply iteration method
[
https://issues.apache.org/jira/browse/FLINK-1524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi resolved FLINK-1524.
Resolution: Fixed
Fixed in bec9c4dae79928f55bcc3de3c6f5d5417f9b5608
Job Manager does not handle
Vasia Kalavri created FLINK-1522:
Summary: Add tests for the library methods and examples
Key: FLINK-1522
URL: https://issues.apache.org/jira/browse/FLINK-1522
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-1455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14316231#comment-14316231
]
Stephan Ewen commented on FLINK-1455:
-
Again, this is not a memory leak. See
[
https://issues.apache.org/jira/browse/FLINK-1529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14316860#comment-14316860
]
ASF GitHub Bot commented on FLINK-1529:
---
GitHub user StephanEwen opened a pull
[
https://issues.apache.org/jira/browse/FLINK-1515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14316881#comment-14316881
]
Vasia Kalavri commented on FLINK-1515:
--
Done! Thank you :)
[Gelly] Enable access to
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chiwan Park reassigned FLINK-1512:
--
Assignee: Chiwan Park
Add CsvReader for reading into POJOs.
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14317644#comment-14317644
]
Chiwan Park commented on FLINK-1512:
I'm trying to implement this feature. I can't
[
https://issues.apache.org/jira/browse/FLINK-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14315889#comment-14315889
]
ASF GitHub Bot commented on FLINK-1510:
---
GitHub user rmetzger opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14315897#comment-14315897
]
ASF GitHub Bot commented on FLINK-1510:
---
Github user StephanEwen commented on the
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/378#issuecomment-73854842
There is a problem: https://travis-ci.org/apache/flink/jobs/50215407
```
java.lang.IllegalStateException: Consumer state is FINISHED but was
expected to be RUNNING.
Stephan Ewen created FLINK-1513:
---
Summary: Remove GlobalConfiguration Singleton
Key: FLINK-1513
URL: https://issues.apache.org/jira/browse/FLINK-1513
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-1511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14315935#comment-14315935
]
Aljoscha Krettek commented on FLINK-1511:
-
From the flink documentation:
[
https://issues.apache.org/jira/browse/FLINK-1511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-1511:
---
Assignee: Aljoscha Krettek
Scala classes not identified as Pojos
[
https://issues.apache.org/jira/browse/FLINK-1496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi resolved FLINK-1496.
Resolution: Fixed
Fixed in 0a4c7694cb4189129ae7686120921818343123ed
Events at unitialized input
[
https://issues.apache.org/jira/browse/FLINK-1511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-1511.
Resolution: Not a Problem
Scala classes not identified as Pojos
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/376#issuecomment-73859776
The problem is totally deterministic when shutting down the job/task
managers.
I've fixed it here:
[
https://issues.apache.org/jira/browse/FLINK-1492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14315958#comment-14315958
]
ASF GitHub Bot commented on FLINK-1492:
---
Github user uce commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14315815#comment-14315815
]
Ufuk Celebi commented on FLINK-1343:
I've just checked this with
[
https://issues.apache.org/jira/browse/FLINK-1496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14315823#comment-14315823
]
ASF GitHub Bot commented on FLINK-1496:
---
Github user uce commented on the pull
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/380#issuecomment-73850043
I will merge this. From the linked discussion it seems to solve the issue
for now.
---
If your project is set up for it, you can reply to this email and have your
reply
Robert Metzger created FLINK-1512:
-
Summary: Add CsvReader for reading into POJOs.
Key: FLINK-1512
URL: https://issues.apache.org/jira/browse/FLINK-1512
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-1489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14315843#comment-14315843
]
ASF GitHub Bot commented on FLINK-1489:
---
Github user tillrohrmann commented on the
[
https://issues.apache.org/jira/browse/FLINK-1496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14315884#comment-14315884
]
ASF GitHub Bot commented on FLINK-1496:
---
Github user asfgit closed the pull request
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/382
[FLINK-1510] Make AvroInputFormat splittable
I'm currently working on testing the format on a cluster.
You can merge this pull request into a Git repository by running:
$ git pull
[
https://issues.apache.org/jira/browse/FLINK-1489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14315899#comment-14315899
]
ASF GitHub Bot commented on FLINK-1489:
---
Github user uce commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14315902#comment-14315902
]
ASF GitHub Bot commented on FLINK-1492:
---
Github user mxm commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14315909#comment-14315909
]
ASF GitHub Bot commented on FLINK-1492:
---
Github user uce commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14315952#comment-14315952
]
Robert Metzger commented on FLINK-1511:
---
By the way, at least for the Java API, the
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/372#issuecomment-73853743
I think this is very valuable. I've tried it out and it looks good to me.
Personally, I would prefer the shorter versions proposed by Fabian. If we
don't
[
https://issues.apache.org/jira/browse/FLINK-1461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14315786#comment-14315786
]
ASF GitHub Bot commented on FLINK-1461:
---
GitHub user fhueske opened a pull request:
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/378#issuecomment-73851481
You're right. At the moment there is no aggregation of messages. I'll add
it.
---
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-1343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14315846#comment-14315846
]
Fabian Hueske commented on FLINK-1343:
--
Very nice!
Does that mean we can get rid of
[
https://issues.apache.org/jira/browse/FLINK-1486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14315882#comment-14315882
]
ASF GitHub Bot commented on FLINK-1486:
---
Github user uce commented on the pull
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/380
---
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
Vasia Kalavri created FLINK-1514:
Summary: [Gelly] Add a Gather-Sum-Apply iteration method
Key: FLINK-1514
URL: https://issues.apache.org/jira/browse/FLINK-1514
Project: Flink
Issue Type:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/335
---
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-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14316088#comment-14316088
]
Vasia Kalavri commented on FLINK-1514:
--
[~balidani] is working on this and already
Vasia Kalavri created FLINK-1515:
Summary: [Gelly] Enable access to aggregators and broadcast sets
in vertex-centric iteration
Key: FLINK-1515
URL: https://issues.apache.org/jira/browse/FLINK-1515
[
https://issues.apache.org/jira/browse/FLINK-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14316102#comment-14316102
]
Fabian Hueske commented on FLINK-1514:
--
[~balidani] needs to have the contributor
[
https://issues.apache.org/jira/browse/FLINK-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14316113#comment-14316113
]
Vasia Kalavri commented on FLINK-1514:
--
Thanks a lot [~fhueske]!
Yes, it seems that
[
https://issues.apache.org/jira/browse/FLINK-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-1514:
-
Assignee: Daniel Bali
[Gelly] Add a Gather-Sum-Apply iteration method
[
https://issues.apache.org/jira/browse/FLINK-1517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14316192#comment-14316192
]
Gyula Fora commented on FLINK-1517:
---
[
https://issues.apache.org/jira/browse/FLINK-1493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14316204#comment-14316204
]
Gyula Fora commented on FLINK-1493:
---
Hey,
I implemented a simple indexed iterator from
99 matches
Mail list logo
