[jira] [Created] (BAHIR-91) Upgrade bahir-flink to support Flink 1.2

["Markus Müller (JIRA)" <ji...@apache.org>]

Markus Müller created BAHIR-91:
----------------------------------

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