[ 
https://issues.apache.org/jira/browse/BAHIR-91?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15895730#comment-15895730
 ] 

ASF subversion and git services commented on BAHIR-91:
------------------------------------------------------

Commit 3f180342ca0efaf48ffa4d1f7b6dbfcb4cd892b6 in bahir-flink's branch 
refs/heads/master from [~tzulitai]
[ https://git-wip-us.apache.org/repos/asf?p=bahir-flink.git;h=3f18034 ]

[BAHIR-91] Upgrade Flink version to 1.2.0

This closes #11
This closes #9 (Closing PR due to inactivity)


> Upgrade bahir-flink to support Flink 1.2
> ----------------------------------------
>
>                 Key: BAHIR-91
>                 URL: https://issues.apache.org/jira/browse/BAHIR-91
>             Project: Bahir
>          Issue Type: New Feature
>          Components: Flink Streaming Connectors
>    Affects Versions: Flink-0.1
>         Environment: Ubuntu Yakkety Yak
>            Reporter: Markus Müller
>            Assignee: Tzu-Li (Gordon) Tai
>             Fix For: Flink-0.1
>
>
> After working around  https://issues.apache.org/jira/browse/FLINK-4813 by 
> specifying Flink version 1.3-SNAPSHOT instead of 1.2.0 in the bahir-flink pom 
> file, I get the following compiler errors for the ActiveMQ connector:
> {code}
> ERROR] 
> /home/markus/src/bahir-flink/flink-connector-activemq/src/test/java/org/apache/flink/streaming/connectors/activemq/ActiveMQConnectorITCase.java:[32,33]
>  error: cannot find symbol
> [ERROR]   symbol:   class ForkableFlinkMiniCluster
>   location: package org.apache.flink.test.util
> /home/markus/src/bahir-flink/flink-connector-activemq/src/test/java/org/apache/flink/streaming/connectors/activemq/ActiveMQConnectorITCase.java:[54,19]
>  error: cannot find symbol
> [ERROR]   symbol:   class ForkableFlinkMiniCluster
>   location: class ActiveMQConnectorITCase
> /home/markus/src/bahir-flink/flink-connector-activemq/src/test/java/org/apache/flink/streaming/connectors/activemq/ActiveMQConnectorITCase.java:[66,20]
>  error: cannot find symbol
> [ERROR]   symbol:   class ForkableFlinkMiniCluster
>   location: class ActiveMQConnectorITCase
> /home/markus/src/bahir-flink/flink-connector-activemq/src/test/java/org/apache/flink/streaming/connectors/activemq/ActiveMQConnectorITCase.java:[216,22]
>  error: method snapshotState in class 
> MessageAcknowledgingSourceBase<Type,UId> cannot be applied to given types;
> [ERROR]   required: FunctionSnapshotContext
>   found: long,long
>   reason: actual and formal argument lists differ in length
>   where Type,UId are type-variables:
>     Type extends Object declared in class MessageAcknowledgingSourceBase
>     UId extends Object declared in class MessageAcknowledgingSourceBase
> /home/markus/src/bahir-flink/flink-connector-activemq/src/test/java/org/apache/flink/streaming/connectors/activemq/ActiveMQConnectorITCase.java:[229,4]
>  error: ActiveMQConnectorITCase.TestSourceContext is not abstract and does 
> not override abstract method markAsTemporarilyIdle() in SourceContext
> Excluding ActiveMQ from compilation leads to the next issue in the 
> Akka-Connector:
> [ERROR] 
> /home/markus/src/bahir-flink/flink-connector-akka/src/test/java/org/apache/flink/streaming/connectors/akka/AkkaSourceTest.java:[210,17]
>  error: DummySourceContext is not abstract and does not override abstract 
> method markAsTemporarilyIdle() in SourceContext
> [INFO] 1 error
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Reply via email to