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

ASF GitHub Bot commented on BAHIR-91:
-------------------------------------

Github user rmetzger commented on the issue:

    https://github.com/apache/bahir-flink/pull/11
  
    I think the travis tests will fail because they are overwriting the Flink 
version.
    I have a constant there for the Flink version. My initial plan was to 
support multiple Flink versions at the same time.
    Do you think there is an easy way to still support 1.1. and 1.2 with the 
Bahir connectors?


> 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
>             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:
> 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



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

Reply via email to