GitHub user senorcarbone opened a pull request:
https://github.com/apache/flink/pull/432
[FLINK-1586] [streaming] Add support for iterative streaming graphs on JSON
generation
I refactored a bit the current JSON generation for streaming job graphs to
further allow iterations.
[
https://issues.apache.org/jira/browse/FLINK-1586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14332374#comment-14332374
]
ASF GitHub Bot commented on FLINK-1586:
---
GitHub user senorcarbone opened a pull requ
[
https://issues.apache.org/jira/browse/FLINK-1505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14332352#comment-14332352
]
ASF GitHub Bot commented on FLINK-1505:
---
Github user senorcarbone commented on the p
Github user senorcarbone commented on the pull request:
https://github.com/apache/flink/pull/428#issuecomment-75456574
+1 from me as well, works fine! Nice decoupling :)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
[
https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14332277#comment-14332277
]
Carsten Brandt commented on FLINK-1520:
---
[~rmetzger], thanks it is working!
> Read
[
https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Carsten Brandt updated FLINK-1520:
--
Assignee: (was: Carsten Brandt)
> Read edges and vertices from CSV files
> -
[
https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Carsten Brandt reassigned FLINK-1520:
-
Assignee: Carsten Brandt
> Read edges and vertices from CSV files
> -
Martin Kiefer created FLINK-1597:
Summary: VertexCentricIterations create inefficient execution plans
Key: FLINK-1597
URL: https://issues.apache.org/jira/browse/FLINK-1597
Project: Flink
Issu
[
https://issues.apache.org/jira/browse/FLINK-1596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14332236#comment-14332236
]
Johannes commented on FLINK-1596:
-
Hi [~hsaputra], indeed the file not found error seems t
[
https://issues.apache.org/jira/browse/FLINK-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14332171#comment-14332171
]
Paris Carbone commented on FLINK-1421:
--
Perfect, thanks! In the meantime I will try t
[
https://issues.apache.org/jira/browse/FLINK-1592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-1592.
-
Resolution: Fixed
Fix Version/s: 0.9
https://github.com/apache/flink/commit/a911559a1d8d8d160edcdb7
[
https://issues.apache.org/jira/browse/FLINK-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14332153#comment-14332153
]
Gianmarco De Francisci Morales commented on FLINK-1421:
---
That's grea
[
https://issues.apache.org/jira/browse/FLINK-1567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14332112#comment-14332112
]
ASF GitHub Bot commented on FLINK-1567:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/413#issuecomment-75429131
I've updated the PR addressing Till's comments and adding a
`GenericAvroTypeInfo` giving users an additional way to enforce the Avro
serializer.
---
If your project is
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/413#discussion_r25130805
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/typeutils/GenericTypeInfo.java
---
@@ -66,6 +71,9 @@ public boolean isKeyType() {
[
https://issues.apache.org/jira/browse/FLINK-1567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14332108#comment-14332108
]
ASF GitHub Bot commented on FLINK-1567:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/413#discussion_r25130794
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/typeutils/runtime/AvroSerializer.java
---
@@ -91,7 +98,22 @@ public T createInstance() {
[
https://issues.apache.org/jira/browse/FLINK-1567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14332107#comment-14332107
]
ASF GitHub Bot commented on FLINK-1567:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14332101#comment-14332101
]
ASF GitHub Bot commented on FLINK-1567:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/413#discussion_r25130737
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/typeutils/runtime/AvroSerializer.java
---
@@ -154,6 +176,7 @@ private void checkAvroInitialized(
20 matches
Mail list logo
