Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1734#issuecomment-190417170
Merging this one too!
---
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 vasia commented on the pull request:
https://github.com/apache/flink/pull/1733#issuecomment-190417099
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
GitHub user vasia opened a pull request:
https://github.com/apache/flink/pull/1743
[docs] fix readme typos; use the same scala style in the examples
Fixes issues with #1736 I didn't have to report ;)
You can merge this pull request into a Git repository by running:
$ git pull
Vasia Kalavri created FLINK-3547:
Summary: Add support for streaming projection, selection, and union
Key: FLINK-3547
URL: https://issues.apache.org/jira/browse/FLINK-3547
Project: Flink
Vasia Kalavri created FLINK-3546:
Summary: Streaming Table API
Key: FLINK-3546
URL: https://issues.apache.org/jira/browse/FLINK-3546
Project: Flink
Issue Type: New Feature
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1734#issuecomment-190272164
looks good, thanks!
---
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 vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1738#discussion_r54430318
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/table.scala
---
@@ -98,7 +100,19 @@ class Table(
.map(toRexNode
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1734#issuecomment-190247404
Looks good, thanks!
Just one thing. If the `FlinkJoinRule` doesn't match, could we throw some
meaningful exception, e.g. "Join equality predicates should
[
https://issues.apache.org/jira/browse/FLINK-3506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15171856#comment-15171856
]
Vasia Kalavri commented on FLINK-3506:
--
I think this issue is invalid after the calc translation
Vasia Kalavri created FLINK-3533:
Summary: Update the Gelly docs wrt examples and cluster execution
Key: FLINK-3533
URL: https://issues.apache.org/jira/browse/FLINK-3533
Project: Flink
Issue
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1729#discussion_r54353877
--- Diff: PULL_REQUEST_TEMPLATE.md ---
@@ -0,0 +1,18 @@
+Thanks for contributing to Apache Flink, before you open your PR please
kindly take
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1729#discussion_r54353870
--- Diff: PULL_REQUEST_TEMPLATE.md ---
@@ -0,0 +1,18 @@
+Thanks for contributing to Apache Flink, before you open your PR please
kindly take
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1729#discussion_r54353866
--- Diff: PULL_REQUEST_TEMPLATE.md ---
@@ -0,0 +1,18 @@
+Thanks for contributing to Apache Flink, before you open your PR please
kindly take
[
https://issues.apache.org/jira/browse/FLINK-3518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri resolved FLINK-3518.
--
Resolution: Fixed
> Stale docs for quickstart se
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1718#issuecomment-189259231
Thanks @stefanobaghino. Merging this together with #1714.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1714#issuecomment-189258774
Thanks, merging.
---
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
[
https://issues.apache.org/jira/browse/FLINK-3518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168852#comment-15168852
]
Vasia Kalavri commented on FLINK-3518:
--
I see you've already updated the PR [~stefanobaghino] :)
I'll
[
https://issues.apache.org/jira/browse/FLINK-3482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri resolved FLINK-3482.
--
Resolution: Implemented
> Implement Union Supp
Github user vasia closed the pull request at:
https://github.com/apache/flink/pull/1715
---
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
[
https://issues.apache.org/jira/browse/FLINK-3463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri resolved FLINK-3463.
--
Resolution: Fixed
> Implement Calc Support
> --
>
>
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1715#issuecomment-189210225
Thanks, I will 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
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168716#comment-15168716
]
Vasia Kalavri commented on FLINK-1707:
--
Hey [~joseprupi],
thank you for the document!
I have left
GitHub user vasia opened a pull request:
https://github.com/apache/flink/pull/1715
[FLINK-3482] implement union translation
This PR add union support to Table on Calcite. I've implemented a custom
`JoinUnionTransposeRule`
because Calcite's only matches with LogicalUnion.
You
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1709#issuecomment-188933506
You can close this now @twalthr. I've merged it.
---
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 vasia closed the pull request at:
https://github.com/apache/flink/pull/1696
---
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
GitHub user vasia opened a pull request:
https://github.com/apache/flink/pull/1714
[hotfix] fix PageRank example to run with no args; some doc fixes
This PR includes a fix for the java PageRank example to retrieve the
required parameter `numPages ` when run with no arguments
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1696#issuecomment-188878585
Thanks! I'll merge both once Travis passes.
---
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-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167027#comment-15167027
]
Vasia Kalavri commented on FLINK-1707:
--
Thank you for the document [~joseprupi]! Would you mind
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1696#issuecomment-188701788
Thanks @twalthr! You PR solves the problem indeed :)
If no objections, I will merge both #1709 and this one rebased on your
changes.
---
If your project is set up
[
https://issues.apache.org/jira/browse/FLINK-3489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15163087#comment-15163087
]
Vasia Kalavri commented on FLINK-3489:
--
I would also rename
- {{o.a.f.api.table.plan.nodes.logical
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1696#issuecomment-188268518
I've updated the PR.
Changing the test to `TableProgramsTestBase ` actually made the
`TestCalcWithAggregation` test fail for `config=EFFICIENT
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1696#discussion_r53941468
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/table/test/CalcITCase.scala
---
@@ -0,0 +1,96 @@
+/*
+ * Licensed
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1696#issuecomment-188181343
Thanks @fhueske and @twalthr for the comments! Apart from a small doubt
with the test, I've addressed the rest.
---
If your project is set up for it, you can reply
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1696#discussion_r53918915
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/table/test/CalcITCase.scala
---
@@ -0,0 +1,96 @@
+/*
+ * Licensed
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1697#issuecomment-188169155
looks good +1
---
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
Vasia Kalavri created FLINK-3482:
Summary: Implement Union Support
Key: FLINK-3482
URL: https://issues.apache.org/jira/browse/FLINK-3482
Project: Flink
Issue Type: Sub-task
GitHub user vasia opened a pull request:
https://github.com/apache/flink/pull/1696
[FLINK-3463] implement calc translation
This PR implements the `DataSetCalcRule`, so that filters, projections, and
their combinations are now translated to `FlinkCalc`s. `FlinkFilterRule
Vasia Kalavri created FLINK-3463:
Summary: Implement Calc Support
Key: FLINK-3463
URL: https://issues.apache.org/jira/browse/FLINK-3463
Project: Flink
Issue Type: Sub-task
Vasia Kalavri created FLINK-3444:
Summary: env.fromElements relies on the first input element for
determining the DataSet/DataStream type
Key: FLINK-3444
URL: https://issues.apache.org/jira/browse/FLINK-3444
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1663#issuecomment-185876066
Thanks, merging.
---
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
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-1707:
-
Assignee: Josep Rubió
> Add an Affinity Propagation Library Met
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-1707:
-
Labels: requires-design-doc (was: )
> Add an Affinity Propagation Library Met
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15152139#comment-15152139
]
Vasia Kalavri commented on FLINK-1707:
--
Alright! Shall I assign this to you then?
I will also mark
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15152009#comment-15152009
]
Vasia Kalavri commented on FLINK-1707:
--
Hi [~joseprupi],
the binary model looks simpler, so I guess
GitHub user vasia opened a pull request:
https://github.com/apache/flink/pull/1663
[docs] fix typos in quickstart and CEP docs
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vasia/flink docs_typos
Alternatively you can review
[
https://issues.apache.org/jira/browse/FLINK-3419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15149411#comment-15149411
]
Vasia Kalavri commented on FLINK-3419:
--
Hey,
is it really necessary to drop this one? We are using
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1624#issuecomment-184278657
You can close the PR @twalthr. It's merged (but doesn't automatically
close).
---
If your project is set up for it, you can reply to this email and have your
reply
Github user vasia closed the pull request at:
https://github.com/apache/flink/pull/1632
---
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
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1624#issuecomment-184170079
Thanks @twalthr. I'll merge 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
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1632#issuecomment-184170164
Great, merging this also.
---
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 vasia commented on the pull request:
https://github.com/apache/flink/pull/1632#issuecomment-183957839
Thanks for the review @twalthr! I've addressed your comments.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
GitHub user vasia opened a pull request:
https://github.com/apache/flink/pull/1632
[FLINK-3226] Translate logical joins to physical
This PR contains the logical to physical translation for joins.
- Joins with equality conditions only do not generate a join function.
- Joins
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1600#issuecomment-182872698
@fhueske I fixed the aggregation hashCode and enables the ignored tests.
Let me know if it's OK now!
---
If your project is set up for it, you can reply to this email
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1567#issuecomment-182959195
Hey @ChengXiangLi,
I merged your changes together with #1600. You can close this.
---
If your project is set up for it, you can reply to this email and have your
Github user vasia closed the pull request at:
https://github.com/apache/flink/pull/1600
---
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
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1600#issuecomment-182957377
It's all green :D Merging.
---
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 vasia commented on the pull request:
https://github.com/apache/flink/pull/1600#issuecomment-182392029
I've rebased this one on top of `tableOnCalcite` which includes #1595.
Regarding the average aggregate, I went for @tillrohrmann's suggestion of
adding 0.5
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1595#issuecomment-182390675
Hey @twalthr,
I merged this yesterday but the PR didn't automatically close. Could you
please close it manually? Thanks!
---
If your project is set up for it, you
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1600#issuecomment-181794348
Thanks for the feedback @tillrohrmann, @twalthr!
I've moved the classes to `org.apache.flink.api.table.runtime` and tried to
shorten the aggregates code using Numerics
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1600#discussion_r52320399
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AvgAggregate.scala
---
@@ -0,0 +1,145
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1595#issuecomment-181955939
Thanks for the quick update @twalthr! Some tests are failing because the
wrong type of exception is expected. I'll fix those and then merge this.
---
If your project
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1600#discussion_r52192844
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/functions/AggregateFunction.scala
---
@@ -0,0 +1,76
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1600#discussion_r52192508
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/logical/FlinkAggregate.scala
---
@@ -58,19 +58,23 @@ class
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1600#discussion_r52192307
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/functions/aggregate/MaxAggregate.scala
---
@@ -0,0 +1,136
GitHub user vasia opened a pull request:
https://github.com/apache/flink/pull/1600
[FLINK-3226] Translate logical aggregations to physical
This PR builds on #1567 and addresses @fhueske's comments on translating
aggregations.
Join translation is not part of this PR.
You can
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1600#discussion_r52204752
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/functions/aggregate/SumAggregate.scala
---
@@ -0,0 +1,130
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1514#issuecomment-178453684
Cool, I'll rebase and 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
GitHub user vasia opened a pull request:
https://github.com/apache/flink/pull/1572
[FLINK-3049] move Either type to org.apache.flink.types
I went for option 2, i.e. creating the package in `flink-java`. Let me know
if you think it makes more sense to move the type to `flink-core
[
https://issues.apache.org/jira/browse/FLINK-3208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri resolved FLINK-3208.
--
Resolution: Fixed
Fix Version/s: 1.0.0
> Rename Gelly vertex-centric model to scat
GitHub user vasia opened a pull request:
https://github.com/apache/flink/pull/1575
[FLINK-3207] [gelly] adds the vertex-centric iteration abstraction
As per the mailing list discussion, this PR adds the vertex-centric /
pregel iteration abstraction to gelly. In this model
Github user vasia closed the pull request at:
https://github.com/apache/flink/pull/1572
---
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
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1572#issuecomment-178509129
Then I'll close it :)
---
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 vasia commented on the pull request:
https://github.com/apache/flink/pull/1521#issuecomment-173260743
Thank you @s1ck! Looks good to me. I will merge it later if no objections.
---
If your project is set up for it, you can reply to this email and have your
reply appear
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1521#issuecomment-173360370
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 feature
[
https://issues.apache.org/jira/browse/FLINK-3122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-3122:
-
Fix Version/s: 1.0.0
> Generalize value type in LabelPropagat
[
https://issues.apache.org/jira/browse/FLINK-3122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-3122:
-
Affects Version/s: (was: 1.0.0)
0.10.0
0.10.1
[
https://issues.apache.org/jira/browse/FLINK-3122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri resolved FLINK-3122.
--
Resolution: Fixed
> Generalize value type in LabelPropagat
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1291#issuecomment-172475425
Thanks @andralungu! Maybe you could open a PR with the bugfix only? Is
there a jira for it?
---
If your project is set up for it, you can reply to this email and have
GitHub user vasia opened a pull request:
https://github.com/apache/flink/pull/1514
[FLINK-3208] [gelly] rename vertex-centric iteration model to scatter-gather
This is the first step to introducing a Pregel abstraction in Gelly.
You can merge this pull request into a Git repository
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/598#issuecomment-172196328
Hey @markus-h,
are there any news regarding this PR? If not, would you mind closing it?
Thanks!
---
If your project is set up for it, you can reply to this email
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1291#issuecomment-172196411
Hey @andralungu,
is this something you'd like to continue working on? If not, would you mind
closing this PR?
Thanks!
---
If your project is set up for it, you
[
https://issues.apache.org/jira/browse/FLINK-3118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-3118:
-
Fix Version/s: 1.0.0
> Check if MessageFunction implements ResultTypeQuerya
[
https://issues.apache.org/jira/browse/FLINK-3118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri resolved FLINK-3118.
--
Resolution: Fixed
> Check if MessageFunction implements ResultTypeQuerya
[
https://issues.apache.org/jira/browse/FLINK-3118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-3118:
-
Affects Version/s: 0.10.0
0.10.1
> Check if MessageFunction impleme
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1471#issuecomment-171201543
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 feature
GitHub user vasia opened a pull request:
https://github.com/apache/flink/pull/1490
corrections in the javadoc examples of tumbling and sliding windows
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vasia/flink window-javadoc
[
https://issues.apache.org/jira/browse/FLINK-3207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri reassigned FLINK-3207:
Assignee: Vasia Kalavri
> Add a Pregel iteration abstraction to Ge
Vasia Kalavri created FLINK-3207:
Summary: Add a Pregel iteration abstraction to Gelly
Key: FLINK-3207
URL: https://issues.apache.org/jira/browse/FLINK-3207
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-3208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri reassigned FLINK-3208:
Assignee: Vasia Kalavri
> Rename Gelly vertex-centric model to scatter-gat
Vasia Kalavri created FLINK-3208:
Summary: Rename Gelly vertex-centric model to scatter-gather
Key: FLINK-3208
URL: https://issues.apache.org/jira/browse/FLINK-3208
Project: Flink
Issue Type
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1471#issuecomment-168386683
Thanks a lot for the PR @s1ck!
How about adding a test case in `TypeExtractorTest`, where you create an
instance that implements `ResultTypeQueryable` and one
[
https://issues.apache.org/jira/browse/FLINK-3181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri resolved FLINK-3181.
--
Resolution: Fixed
> The vertex-centric SSSP example and library method send unnecess
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1467#issuecomment-167564868
Thanks, I am 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
[
https://issues.apache.org/jira/browse/FLINK-3110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-3110:
-
Labels: requires-design-doc (was: )
> Add support for partition-centric iterati
[
https://issues.apache.org/jira/browse/FLINK-3181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri reassigned FLINK-3181:
Assignee: Vasia Kalavri
> The vertex-centric SSSP example and library method s
Vasia Kalavri created FLINK-3181:
Summary: The vertex-centric SSSP example and library method send
unnecessary messages during the first superstep
Key: FLINK-3181
URL: https://issues.apache.org/jira/browse/FLINK
GitHub user vasia opened a pull request:
https://github.com/apache/flink/pull/1467
[FLINK-3181] [gelly] avoid unnecessary messages in SSSP examples and
library method
I added a simple check in the messaging function to avoid sending
unnecessary messages during the first superstep
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1440#issuecomment-162681503
Thanks for fixing this so quickly @twalthr! I confirm it solves my problem
:)
---
If your project is set up for it, you can reply to this email and have your
reply
Vasia Kalavri created FLINK-3110:
Summary: Add support for the partition-centric iterations
Key: FLINK-3110
URL: https://issues.apache.org/jira/browse/FLINK-3110
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-3110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-3110:
-
Summary: Add support for partition-centric iterations (was: Add support
for the partition
501 - 600 of 1146 matches
Mail list logo
