You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@bahir.apache.org by "Christian Kadner (JIRA)" <ji...@apache.org> on 2017/03/03 01:50:45 UTC
[jira] [Updated] (BAHIR-91) Upgrade bahir-flink to support Flink
1.2
[ https://issues.apache.org/jira/browse/BAHIR-91?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Christian Kadner updated BAHIR-91:
----------------------------------
Description:
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}
was:
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
> 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)