[
https://issues.apache.org/jira/browse/SAMOA-16?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14354401#comment-14354401
]
ASF GitHub Bot commented on SAMOA-16:
-------------------------------------
Github user arinto commented on the pull request:
https://github.com/apache/incubator-samoa/pull/11#issuecomment-78001679
I can't build this PR successfully on my local. Here's the error message:
```
[ERROR] Failed to execute goal
org.apache.maven.plugins:maven-compiler-plugin:3.1:compile (default-compile) on
project samoa-flink: Compilation failure: Compilation failure:
[ERROR]
/Users/arinto/git/incubator-samoa/samoa-flink/src/main/java/com/yahoo/labs/flink/topology/impl/FlinkEntranceProcessingItem.java:[54,79]
<anonymous com.yahoo.labs.flink.topology.impl.FlinkEntranceProcessingItem$1>
is not abstract and does not override abstract method cancel() in
org.apache.flink.streaming.api.function.source.SourceFunction
[ERROR]
/Users/arinto/git/incubator-samoa/samoa-flink/src/main/java/com/yahoo/labs/flink/topology/impl/FlinkEntranceProcessingItem.java:[64,25]
method does not override or implement a method from a supertype
```
Apparently there are API changes
<https://github.com/apache/flink/commit/8436e9ce31b52f1bd8c55b8e8c50cafb57cff84f>
due to [FLINK-1625](https://issues.apache.org/jira/browse/FLINK-1625).
Probably we can use stable version of Flink for this PR. What do you guys think?
> Add an adapter for Apache Flink-Streaming
> -----------------------------------------
>
> Key: SAMOA-16
> URL: https://issues.apache.org/jira/browse/SAMOA-16
> Project: SAMOA
> Issue Type: New Feature
> Reporter: Paris Carbone
>
> Apache Flink-Streaming is a new system for distributed stream processing
> built for unique and flexible high level stream transformations. A Flink
> adapter for Samoa should be able to translate a Samoa Task topology into
> Flink streaming transformations. Some of the challenges are the compositional
> topology support, circle detection and their translation to Flink iterations.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
