Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/537#discussion_r28643293
--- Diff: docs/gelly_guide.md ---
@@ -380,6 +380,16 @@ all aggregates globally once per superstep and makes
them available in the next
*
[
https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501275#comment-14501275
]
ASF GitHub Bot commented on FLINK-1523:
---
Github user vasia commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501274#comment-14501274
]
ASF GitHub Bot commented on FLINK-1523:
---
Github user vasia commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501364#comment-14501364
]
ASF GitHub Bot commented on FLINK-1523:
---
Github user vasia commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-1909:
--
Priority: Major (was: Minor)
Refactor streaming scala api to use returns for adding typeinfo
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/537#discussion_r28644140
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/spargel/VertexUpdateFunction.java
---
@@ -40,7 +42,37 @@
VertexValue extends
[
https://issues.apache.org/jira/browse/FLINK-1906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chiwan Park reassigned FLINK-1906:
--
Assignee: Chiwan Park
Add tip to work around plain Tuple return type of project operator
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/537#discussion_r28643290
--- Diff: docs/gelly_guide.md ---
@@ -380,6 +380,16 @@ all aggregates globally once per superstep and makes
them available in the next
*
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/537#discussion_r28643470
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/IncrementalSSSPExample.java
---
@@ -0,0 +1,304 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501313#comment-14501313
]
ASF GitHub Bot commented on FLINK-1523:
---
Github user vasia commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501314#comment-14501314
]
ASF GitHub Bot commented on FLINK-1523:
---
Github user vasia commented on a diff in
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/537#discussion_r28643473
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/IncrementalSSSPExample.java
---
@@ -0,0 +1,304 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501312#comment-14501312
]
ASF GitHub Bot commented on FLINK-1523:
---
Github user vasia commented on a diff in
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/537#discussion_r28643463
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/IncrementalSSSPExample.java
---
@@ -0,0 +1,304 @@
+/*
+ * Licensed to
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/537#discussion_r28643683
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/spargel/VertexCentricIteration.java
---
@@ -24,18 +24,24 @@
import
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/537#issuecomment-94167112
Hi @andralungu! Thanks for the update :-)
I left a few inline comments. Overall it looks good, I just had a little
trouble following the logic in
[
https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501376#comment-14501376
]
ASF GitHub Bot commented on FLINK-1523:
---
Github user vasia commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-1910:
Description:
{code:java}
public static LinkedList values=new LinkedListString();
public
[
https://issues.apache.org/jira/browse/FLINK-1910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501395#comment-14501395
]
Chesnay Schepler commented on FLINK-1910:
-
save the LinkedList in a field inside
Lukas Raska created FLINK-1908:
--
Summary: JobManager startup delay isn't considered when using
start-cluster.sh script
Key: FLINK-1908
URL: https://issues.apache.org/jira/browse/FLINK-1908
Project:
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/537#discussion_r28643437
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/IncrementalSSSPExample.java
---
@@ -0,0 +1,304 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501319#comment-14501319
]
ASF GitHub Bot commented on FLINK-1523:
---
Github user vasia commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501320#comment-14501320
]
Gyula Fora commented on FLINK-1869:
---
Hey,
The purpose of operator chaining is to make
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/537#discussion_r28643520
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/spargel/IterationConfiguration.java
---
@@ -189,4 +199,33 @@ public void
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/537#discussion_r28643695
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/spargel/VertexCentricIteration.java
---
@@ -86,7 +92,9 @@
private
[
https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501335#comment-14501335
]
ASF GitHub Bot commented on FLINK-1523:
---
Github user vasia commented on a diff in
Gyula Fora created FLINK-1909:
-
Summary: Refactor streaming scala api to use returns for adding
typeinfo
Key: FLINK-1909
URL: https://issues.apache.org/jira/browse/FLINK-1909
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501366#comment-14501366
]
ASF GitHub Bot commented on FLINK-1523:
---
Github user vasia commented on a diff in
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/537#discussion_r28644150
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/spargel/MessagingFunction.java
---
@@ -38,25 +42,57 @@
* @param Message The type
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/537#discussion_r28643344
--- Diff: docs/gelly_guide.md ---
@@ -380,6 +380,16 @@ all aggregates globally once per superstep and makes
them available in the next
*
[
https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501278#comment-14501278
]
ASF GitHub Bot commented on FLINK-1523:
---
Github user vasia commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501336#comment-14501336
]
ASF GitHub Bot commented on FLINK-1523:
---
Github user vasia commented on a diff in
GitHub user gyfora opened a pull request:
https://github.com/apache/flink/pull/610
[FLINK-1909] [streaming] Type handling refactor for sources + scala api
This PR reworks the way sources handle type extraction, allowing for
missing types (with returns) and also fixes some issues
[
https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501359#comment-14501359
]
ASF GitHub Bot commented on FLINK-1523:
---
Github user vasia commented on a diff in
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/537#discussion_r28644120
--- Diff:
flink-staging/flink-gelly/src/test/java/org/apache/flink/graph/test/example/IncrementalSSSPITCase.java
---
@@ -0,0 +1,84 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-1909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501360#comment-14501360
]
ASF GitHub Bot commented on FLINK-1909:
---
GitHub user gyfora opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-1909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-1909:
--
Issue Type: Improvement (was: Bug)
Refactor streaming scala api to use returns for adding typeinfo
hagersaleh created FLINK-1910:
-
Summary: why this code flink not reurn value when use variable in
filter
Key: FLINK-1910
URL: https://issues.apache.org/jira/browse/FLINK-1910
Project: Flink
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/600#issuecomment-94175152
I like it that you are using the example to show the migration process, but
I think it would also be helpful to add a section with more general guidelines,
describing all
[
https://issues.apache.org/jira/browse/FLINK-1871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501424#comment-14501424
]
ASF GitHub Bot commented on FLINK-1871:
---
Github user vasia commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501279#comment-14501279
]
ASF GitHub Bot commented on FLINK-1908:
---
GitHub user DarkKnightCZ opened a pull
[
https://issues.apache.org/jira/browse/FLINK-1908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501280#comment-14501280
]
Lukas Raska commented on FLINK-1908:
Implemented in
[
https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501317#comment-14501317
]
ASF GitHub Bot commented on FLINK-1523:
---
Github user vasia commented on a diff in
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/537#discussion_r28643494
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/library/SingleSourceShortestPaths.java
---
@@ -77,7 +77,7 @@ public Double
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/537#discussion_r28643926
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/spargel/VertexCentricIteration.java
---
@@ -138,69 +146,46 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501353#comment-14501353
]
ASF GitHub Bot commented on FLINK-1523:
---
Github user vasia commented on a diff in
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/537#discussion_r28643920
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/spargel/VertexCentricIteration.java
---
@@ -138,69 +146,46 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-1910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501384#comment-14501384
]
Chesnay Schepler commented on FLINK-1910:
-
okay, if you create an issue, please do
[
https://issues.apache.org/jira/browse/FLINK-1910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501390#comment-14501390
]
hagersaleh commented on FLINK-1910:
---
the result should happen
[
https://issues.apache.org/jira/browse/FLINK-1910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501400#comment-14501400
]
hagersaleh commented on FLINK-1910:
---
when write inside not working
DataSetCustomer
Github user andralungu commented on the pull request:
https://github.com/apache/flink/pull/596#issuecomment-94177583
Hi @vasia ,
I will change the code to match Spargel, probably Monday :)
I came across this class in our tests the other day, while searching for
something
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/408#discussion_r28645524
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/GSASingleSourceShortestPathsExample.java
---
@@ -0,0 +1,216 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501471#comment-14501471
]
ASF GitHub Bot commented on FLINK-1514:
---
Github user vasia commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501461#comment-14501461
]
ASF GitHub Bot commented on FLINK-1514:
---
Github user vasia commented on a diff in
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/408#discussion_r28645462
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/Graph.java ---
@@ -79,7 +83,8 @@
private final DataSetEdgeK, EV edges;
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/408#discussion_r28645450
--- Diff: flink-staging/flink-gelly/pom.xml ---
@@ -57,4 +57,35 @@ under the License.
version${guava.version}/version
[
https://issues.apache.org/jira/browse/FLINK-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501458#comment-14501458
]
ASF GitHub Bot commented on FLINK-1514:
---
Github user vasia commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501501#comment-14501501
]
ASF GitHub Bot commented on FLINK-703:
--
Github user chiwanpark commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501433#comment-14501433
]
Chesnay Schepler commented on FLINK-1910:
-
This is what i meant by saving the
[
https://issues.apache.org/jira/browse/FLINK-1883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501429#comment-14501429
]
ASF GitHub Bot commented on FLINK-1883:
---
Github user vasia commented on a diff in
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/408#discussion_r28645478
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/Graph.java ---
@@ -914,7 +919,7 @@ public long numberOfVertices() throws Exception {
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/408#discussion_r28645507
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/GSAConnectedComponentsExample.java
---
@@ -0,0 +1,190 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501464#comment-14501464
]
ASF GitHub Bot commented on FLINK-1514:
---
Github user vasia commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501466#comment-14501466
]
ASF GitHub Bot commented on FLINK-1514:
---
Github user vasia commented on a diff in
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/408#issuecomment-94183509
Thanks @balidani for the update! I left some inline comments which should
be fairly easy to address.
I would like to merge this soon and then we should open separate
[
https://issues.apache.org/jira/browse/FLINK-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501472#comment-14501472
]
ASF GitHub Bot commented on FLINK-1514:
---
Github user vasia commented on the pull
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/572#issuecomment-94188129
Hi. I updated this PR. The changes are following.
* Re-implement this feature with generalizing `ExpressionKeys`.
* Modify `CoGroupOperatorBase`,
[
https://issues.apache.org/jira/browse/FLINK-1906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501513#comment-14501513
]
ASF GitHub Bot commented on FLINK-1906:
---
GitHub user chiwanpark opened a pull
GitHub user chiwanpark opened a pull request:
https://github.com/apache/flink/pull/611
[FLINK-1906] [docs] Add tip to work around plain Tuple return type of
project operator
Add a tip about project transformation with type hinting in documentation.
Related JIRA is
[
https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501529#comment-14501529
]
Chiwan Park commented on FLINK-1745:
Hello. I want to contribute for this issue. I
Gyula Fora created FLINK-1911:
-
Summary: DataStream and DataSet projection is out of sync
Key: FLINK-1911
URL: https://issues.apache.org/jira/browse/FLINK-1911
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-1910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved FLINK-1910.
-
Resolution: Not A Problem
Could you please post questions about using Flink to the user
[
https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14501182#comment-14501182
]
ASF GitHub Bot commented on FLINK-1297:
---
Github user uce commented on a diff in the
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/605#discussion_r28642379
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/accumulators/OperatorStatsAccumulatorsTest.java
---
@@ -0,0 +1,118 @@
+/*
+ * Licensed to the
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/112#issuecomment-94143997
@rmetzger, you were working on metrics. Will you include some of the
profiling information from this PR?
---
If your project is set up for it, you can reply to this email
75 matches
Mail list logo
