From commits-return-15615-archive-asf-public=cust-asf.ponee.io@flink.apache.org Tue Feb 6 20:02:28 2018 Return-Path: X-Original-To: archive-asf-public@eu.ponee.io Delivered-To: archive-asf-public@eu.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by mx-eu-01.ponee.io (Postfix) with ESMTP id 09835180771 for ; Tue, 6 Feb 2018 20:02:28 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id EDF12160C5F; Tue, 6 Feb 2018 19:02:27 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 4350D160C60 for ; Tue, 6 Feb 2018 20:02:27 +0100 (CET) Received: (qmail 80939 invoked by uid 500); 6 Feb 2018 19:02:26 -0000 Mailing-List: contact commits-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.apache.org Delivered-To: mailing list commits@flink.apache.org Received: (qmail 80647 invoked by uid 99); 6 Feb 2018 19:02:26 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 06 Feb 2018 19:02:26 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id A5B32F320A; Tue, 6 Feb 2018 19:02:25 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: tzulitai@apache.org To: commits@flink.apache.org Date: Tue, 06 Feb 2018 19:02:34 -0000 Message-Id: In-Reply-To: References: X-Mailer: ASF-Git Admin Mailer Subject: [10/31] flink git commit: [FLINK-8472] [scala, test] Extend StatefulJobSavepointMigrationITCase for Flink 1.4 [FLINK-8472] [scala, test] Extend StatefulJobSavepointMigrationITCase for Flink 1.4 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/45c4b664 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/45c4b664 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/45c4b664 Branch: refs/heads/master Commit: 45c4b66483e7d949452d90682b5f65e1d15d9d49 Parents: c71fb42 Author: Tzu-Li (Gordon) Tai Authored: Thu Jan 25 16:20:31 2018 +0100 Committer: Tzu-Li (Gordon) Tai Committed: Tue Feb 6 19:58:58 2018 +0100 ---------------------------------------------------------------------- .../_metadata | Bin 0 -> 204543 bytes .../_metadata | Bin 0 -> 204543 bytes .../StatefulJobSavepointMigrationITCase.scala | 6 ++++-- 3 files changed, 4 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/45c4b664/flink-tests/src/test/resources/stateful-scala2.11-udf-migration-itcase-flink1.4-jobmanager-savepoint/_metadata ---------------------------------------------------------------------- diff --git a/flink-tests/src/test/resources/stateful-scala2.11-udf-migration-itcase-flink1.4-jobmanager-savepoint/_metadata b/flink-tests/src/test/resources/stateful-scala2.11-udf-migration-itcase-flink1.4-jobmanager-savepoint/_metadata new file mode 100644 index 0000000..69aa8d4 Binary files /dev/null and b/flink-tests/src/test/resources/stateful-scala2.11-udf-migration-itcase-flink1.4-jobmanager-savepoint/_metadata differ http://git-wip-us.apache.org/repos/asf/flink/blob/45c4b664/flink-tests/src/test/resources/stateful-scala2.11-udf-migration-itcase-flink1.4-rocksdb-savepoint/_metadata ---------------------------------------------------------------------- diff --git a/flink-tests/src/test/resources/stateful-scala2.11-udf-migration-itcase-flink1.4-rocksdb-savepoint/_metadata b/flink-tests/src/test/resources/stateful-scala2.11-udf-migration-itcase-flink1.4-rocksdb-savepoint/_metadata new file mode 100644 index 0000000..7dcef9c Binary files /dev/null and b/flink-tests/src/test/resources/stateful-scala2.11-udf-migration-itcase-flink1.4-rocksdb-savepoint/_metadata differ http://git-wip-us.apache.org/repos/asf/flink/blob/45c4b664/flink-tests/src/test/scala/org/apache/flink/api/scala/migration/StatefulJobSavepointMigrationITCase.scala ---------------------------------------------------------------------- diff --git a/flink-tests/src/test/scala/org/apache/flink/api/scala/migration/StatefulJobSavepointMigrationITCase.scala b/flink-tests/src/test/scala/org/apache/flink/api/scala/migration/StatefulJobSavepointMigrationITCase.scala index 435262c..cba31d3 100644 --- a/flink-tests/src/test/scala/org/apache/flink/api/scala/migration/StatefulJobSavepointMigrationITCase.scala +++ b/flink-tests/src/test/scala/org/apache/flink/api/scala/migration/StatefulJobSavepointMigrationITCase.scala @@ -54,13 +54,15 @@ object StatefulJobSavepointMigrationITCase { (MigrationVersion.v1_2, StateBackendLoader.MEMORY_STATE_BACKEND_NAME), (MigrationVersion.v1_2, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME), (MigrationVersion.v1_3, StateBackendLoader.MEMORY_STATE_BACKEND_NAME), - (MigrationVersion.v1_3, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME)) + (MigrationVersion.v1_3, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME), + (MigrationVersion.v1_4, StateBackendLoader.MEMORY_STATE_BACKEND_NAME), + (MigrationVersion.v1_4, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME)) } // TODO to generate savepoints for a specific Flink version / backend type, // TODO change these values accordingly, e.g. to generate for 1.3 with RocksDB, // TODO set as (MigrationVersion.v1_3, StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME) - val GENERATE_SAVEPOINT_VER: MigrationVersion = MigrationVersion.v1_3 + val GENERATE_SAVEPOINT_VER: MigrationVersion = MigrationVersion.v1_4 val GENERATE_SAVEPOINT_BACKEND_TYPE: String = StateBackendLoader.ROCKSDB_STATE_BACKEND_NAME val SCALA_VERSION: String = {