[ https://issues.apache.org/jira/browse/BAHIR-91?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Christian Kadner reassigned BAHIR-91: ------------------------------------- Assignee: Tzu-Li (Gordon) Tai > 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: > 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)