GitHub user StephanEwen opened a pull request:
https://github.com/apache/incubator-flink/pull/166
Add DeltaPageRank example
Illustrates a somewhat advanced use case for delta iterations.
Runs self-contained.
You can merge this pull request into a Git repository by running:
[
https://issues.apache.org/jira/browse/FLINK-1184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi updated FLINK-1184:
--
Assignee: Gyula Fora (was: Márton Balassi)
> Streaming stateful computation support
> -
Github user asfgit closed the pull request at:
https://github.com/apache/incubator-flink/pull/163
---
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 featur
Github user hsaputra commented on the pull request:
https://github.com/apache/incubator-flink/pull/163#issuecomment-60627135
Thx, will merge sometimes today
---
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
[
https://issues.apache.org/jira/browse/FLINK-1186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14185360#comment-14185360
]
Robert Metzger commented on FLINK-1186:
---
I'm trying to look into the issue in the ne
[
https://issues.apache.org/jira/browse/FLINK-1185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-1185.
-
Resolution: Implemented
Fix Version/s: 0.8-incubating
Implemented in the following commit:
[
https://issues.apache.org/jira/browse/FLINK-1175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-1175.
-
Resolution: Implemented
Fix Version/s: 0.8-incubating
Implemented in the following commit:
[
https://issues.apache.org/jira/browse/FLINK-1187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-1187.
-
Resolution: Implemented
Implemented in the following commit:
https://git-wip-us.apache.org/repos/
[
https://issues.apache.org/jira/browse/FLINK-1161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi reassigned FLINK-1161:
-
Assignee: Márton Balassi
> Modify streaming api type extractor classes to allow java 8 la
[
https://issues.apache.org/jira/browse/FLINK-1188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-1188.
-
Resolution: Implemented
Fix Version/s: 0.8-incubating
Resolved in the following commit:
ht
[
https://issues.apache.org/jira/browse/FLINK-1178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-1178.
Resolution: Fixed
Fixed in
https://github.com/apache/incubator-flink/commit/f2b8650e3968daf695af832
[
https://issues.apache.org/jira/browse/FLINK-1189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-1189.
-
Resolution: Fixed
Fix Version/s: 0.8-incubating
The following commits addressed this issue:
[
https://issues.apache.org/jira/browse/FLINK-1178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14185299#comment-14185299
]
ASF GitHub Bot commented on FLINK-1178:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/incubator-flink/pull/162
---
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 featur
[
https://issues.apache.org/jira/browse/FLINK-1191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14185275#comment-14185275
]
Aljoscha Krettek commented on FLINK-1191:
-
Yes, I was aware of the problem. Some s
[
https://issues.apache.org/jira/browse/FLINK-1191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-1191:
---
Assignee: Aljoscha Krettek
> TypeAnalyzer MatchError when analyzing BitSet type with
[
https://issues.apache.org/jira/browse/FLINK-1178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14185269#comment-14185269
]
ASF GitHub Bot commented on FLINK-1178:
---
Github user tillrohrmann commented on the p
Github user tillrohrmann commented on the pull request:
https://github.com/apache/incubator-flink/pull/162#issuecomment-60616930
Ok, I'll 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-1027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14185149#comment-14185149
]
ASF GitHub Bot commented on FLINK-1027:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/incubator-flink/pull/161#issuecomment-60596192
How does that affect using the trailing parameters as program arguments?
Right now, you can call
```
bin/flink run my_prog.jar parameter1 para
[
https://issues.apache.org/jira/browse/FLINK-1178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14185147#comment-14185147
]
ASF GitHub Bot commented on FLINK-1178:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14185145#comment-14185145
]
ASF GitHub Bot commented on FLINK-1194:
---
GitHub user StephanEwen opened a pull reque
Github user StephanEwen commented on the pull request:
https://github.com/apache/incubator-flink/pull/162#issuecomment-60595832
Good catch.
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. I
Github user StephanEwen commented on the pull request:
https://github.com/apache/incubator-flink/pull/163#issuecomment-60595788
Looks good
---
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 StephanEwen opened a pull request:
https://github.com/apache/incubator-flink/pull/165
[FLINK-1194] Fix Java quickstart archetype POM file
Fixes the quickstart archetype for java:
- sets correct main class attribute in jar
- sets correct main class attribute in
Stephan Ewen created FLINK-1194:
---
Summary: Wrong manifest entries and compiler configuration in Java
Quickstarts
Key: FLINK-1194
URL: https://issues.apache.org/jira/browse/FLINK-1194
Project: Flink
Till Rohrmann created FLINK-1193:
Summary: InvalidTypesException for Array[Array[Tuple2[Int,
Double]]]
Key: FLINK-1193
URL: https://issues.apache.org/jira/browse/FLINK-1193
Project: Flink
Is
Márton Balassi created FLINK-1192:
-
Summary: Streaming source fault tolerance
Key: FLINK-1192
URL: https://issues.apache.org/jira/browse/FLINK-1192
Project: Flink
Issue Type: Improvement
Till Rohrmann created FLINK-1191:
Summary: TypeAnalyzer MatchError when analyzing BitSet type with
Scala API
Key: FLINK-1191
URL: https://issues.apache.org/jira/browse/FLINK-1191
Project: Flink
Márton Balassi created FLINK-1190:
-
Summary: Enhanced windowing semantics
Key: FLINK-1190
URL: https://issues.apache.org/jira/browse/FLINK-1190
Project: Flink
Issue Type: Improvement
Márton Balassi created FLINK-1189:
-
Summary: Temporal cross operator for streaming
Key: FLINK-1189
URL: https://issues.apache.org/jira/browse/FLINK-1189
Project: Flink
Issue Type: Improvement
Márton Balassi created FLINK-1188:
-
Summary: Streaming aggregations on array types
Key: FLINK-1188
URL: https://issues.apache.org/jira/browse/FLINK-1188
Project: Flink
Issue Type: Improvement
Márton Balassi created FLINK-1187:
-
Summary: API support for registering persistent states
Key: FLINK-1187
URL: https://issues.apache.org/jira/browse/FLINK-1187
Project: Flink
Issue Type: Sub
Robert Waury created FLINK-1186:
---
Summary: Join key selection for nested Tuples is broken
Key: FLINK-1186
URL: https://issues.apache.org/jira/browse/FLINK-1186
Project: Flink
Issue Type: Bug
Márton Balassi created FLINK-1185:
-
Summary: State interfaces for streaming checkpointing
Key: FLINK-1185
URL: https://issues.apache.org/jira/browse/FLINK-1185
Project: Flink
Issue Type: Sub-
[
https://issues.apache.org/jira/browse/FLINK-1186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Waury updated FLINK-1186:
Attachment: KeySelectionBug.java
> Join key selection for nested Tuples is broken
>
Márton Balassi created FLINK-1184:
-
Summary: Streaming stateful computation support
Key: FLINK-1184
URL: https://issues.apache.org/jira/browse/FLINK-1184
Project: Flink
Issue Type: Improvemen
37 matches
Mail list logo