[BAHIR-129] Upgrade Flink version to 1.3.0
Upgrade Flink version from 1.2.0 to 1.3.0.
Closes #18
diff --git a/.travis.yml b/.travis.yml
index 6f633e0..894ee36 100644
--- a/.travis.yml
+++ b/.travis.yml
@@ -15,31 +15,49 @@
# limitations under the License.
#
+sudo: required
+dist: trusty
+
+cache:
+ directories:
+ - $HOME/.m2
+
+# do not cache our own artifacts
+before_cache:
+ - rm -rf $HOME/.m2/repository/org/apache/flink/
+
language: java
matrix:
include:
- jdk: oraclejdk8
- env: FLINK_VERSION="1.2.0" SCALA_VER="2.11"
-
+ env:
+ - FLINK_VERSION="1.3.0" SCALA_VERSION="2.11"
+ - CACHE_NAME=JDK8_F130_A
- jdk: oraclejdk8
- env: FLINK_VERSION="1.2.0" SCALA_VER="2.10"
-
- - jdk: oraclejdk7
- env: FLINK_VERSION="1.2.0" SCALA_VER="2.11"
-
- - jdk: oraclejdk7
- env: FLINK_VERSION="1.2.0" SCALA_VER="2.10"
-
+ env:
+ - FLINK_VERSION="1.3.0" SCALA_VERSION="2.10"
+ - CACHE_NAME=JDK8_F130_B
+ - jdk: openjdk8
+ env:
+ - FLINK_VERSION="1.3.0" SCALA_VERSION="2.11"
+ - CACHE_NAME=JDK8_F130_C
+ - jdk: openjdk8
+ env:
+ - FLINK_VERSION="1.3.0" SCALA_VERSION="2.10"
+ - CACHE_NAME=JDK8_F130_D
- jdk: openjdk7
- env: FLINK_VERSION="1.2.0" SCALA_VER="2.11"
-
+ env:
+ - FLINK_VERSION="1.3.0" SCALA_VERSION="2.11"
+ - CACHE_NAME=JDK7_F130_A
- jdk: openjdk7
- env: FLINK_VERSION="1.2.0" SCALA_VER="2.10"
+ env:
+ - FLINK_VERSION="1.3.0" SCALA_VERSION="2.10"
+ - CACHE_NAME=JDK7_F130_B
before_install:
- - ./dev/change-scala-version.sh $SCALA_VER
+ - ./dev/change-scala-version.sh $SCALA_VERSION
install: true
-script: mvn clean verify -Pscala-$SCALA_VER -Dflink.version=$FLINK_VERSION
+script: mvn clean verify -Pscala-$SCALA_VERSION -Dflink.version=$FLINK_VERSION
diff --git a/flink-connector-activemq/src/test/java/org/apache/flink/streaming/connectors/activemq/AMQSinkTest.java b/flink-connector-activemq/src/test/java/org/apache/flink/streaming/connectors/activemq/AMQSinkTest.java
index b9ecfd8..e4d67c3 100644
--- a/flink-connector-activemq/src/test/java/org/apache/flink/streaming/connectors/activemq/AMQSinkTest.java
+++ b/flink-connector-activemq/src/test/java/org/apache/flink/streaming/connectors/activemq/AMQSinkTest.java
@@ -115,6 +115,7 @@
verify(session).createTopic(DESTINATION_NAME);
}
+ @SuppressWarnings("unchecked")
@Test
public void exceptionOnSendAreNotThrown() throws Exception {
when(session.createBytesMessage()).thenThrow(JMSException.class);
@@ -123,6 +124,7 @@
amqSink.invoke("msg");
}
+ @SuppressWarnings("unchecked")
@Test(expected = RuntimeException.class)
public void exceptionOnSendAreThrownByDefault() throws Exception {
when(session.createBytesMessage()).thenThrow(JMSException.class);
diff --git a/flink-connector-activemq/src/test/java/org/apache/flink/streaming/connectors/activemq/AMQSourceTest.java b/flink-connector-activemq/src/test/java/org/apache/flink/streaming/connectors/activemq/AMQSourceTest.java
index 2e6efa6..0e6dd31 100644
--- a/flink-connector-activemq/src/test/java/org/apache/flink/streaming/connectors/activemq/AMQSourceTest.java
+++ b/flink-connector-activemq/src/test/java/org/apache/flink/streaming/connectors/activemq/AMQSourceTest.java
@@ -72,6 +72,7 @@
private SimpleStringSchema deserializationSchema;
SourceFunction.SourceContext<String> context;
+ @SuppressWarnings("unchecked")
@Before
public void before() throws Exception {
connectionFactory = mock(ActiveMQConnectionFactory.class);
diff --git a/flink-connector-activemq/src/test/java/org/apache/flink/streaming/connectors/activemq/ActiveMQConnectorITCase.java b/flink-connector-activemq/src/test/java/org/apache/flink/streaming/connectors/activemq/ActiveMQConnectorITCase.java
index 24a257f..9af6dd5 100644
--- a/flink-connector-activemq/src/test/java/org/apache/flink/streaming/connectors/activemq/ActiveMQConnectorITCase.java
+++ b/flink-connector-activemq/src/test/java/org/apache/flink/streaming/connectors/activemq/ActiveMQConnectorITCase.java
@@ -254,6 +254,11 @@
public void emitWatermark(Watermark mark) { }
@Override
+ public void markAsTemporarilyIdle() {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
public Object getCheckpointLock() {
return contextLock;
}
diff --git a/flink-connector-akka/src/test/java/org/apache/flink/streaming/connectors/akka/AkkaSourceTest.java b/flink-connector-akka/src/test/java/org/apache/flink/streaming/connectors/akka/AkkaSourceTest.java
index e7114d7..99a1893 100644
--- a/flink-connector-akka/src/test/java/org/apache/flink/streaming/connectors/akka/AkkaSourceTest.java
+++ b/flink-connector-akka/src/test/java/org/apache/flink/streaming/connectors/akka/AkkaSourceTest.java
@@ -237,6 +237,11 @@
}
@Override
+ public void markAsTemporarilyIdle() {
+ throw new UnsupportedOperationException();
+ }
+
+ @Override
public Object getCheckpointLock() {
return lock;
}
diff --git a/pom.xml b/pom.xml
index b6d8dd1..2e39a83 100644
--- a/pom.xml
+++ b/pom.xml
@@ -91,7 +91,7 @@
<log4j.version>1.2.17</log4j.version>
<!-- Flink version -->
- <flink.version>1.2.0</flink.version>
+ <flink.version>1.3.0</flink.version>
<PermGen>64m</PermGen>
<MaxPermGen>512m</MaxPermGen>
