You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2018/09/18 17:54:56 UTC

[flink] 03/04: [hotfix] [hdfs] Suppress some deprecation warnings

This is an automated email from the ASF dual-hosted git repository.

sewen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 48931c1e74ff1078e1f9062fab4b2a6085253b7b
Author: Stephan Ewen <se...@apache.org>
AuthorDate: Thu Sep 13 20:46:16 2018 +0200

    [hotfix] [hdfs] Suppress some deprecation warnings
---
 .../src/main/java/org/apache/flink/runtime/util/HadoopUtils.java         | 1 +
 .../java/org/apache/flink/runtime/fs/hdfs/HadoopConfigLoadingTest.java   | 1 +
 2 files changed, 2 insertions(+)

diff --git a/flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/util/HadoopUtils.java b/flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/util/HadoopUtils.java
index d0b3a7a..1e774fe 100644
--- a/flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/util/HadoopUtils.java
+++ b/flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/util/HadoopUtils.java
@@ -44,6 +44,7 @@ public class HadoopUtils {
 
 	private static final Text HDFS_DELEGATION_TOKEN_KIND = new Text("HDFS_DELEGATION_TOKEN");
 
+	@SuppressWarnings("deprecation")
 	public static Configuration getHadoopConfiguration(org.apache.flink.configuration.Configuration flinkConfiguration) {
 
 		// Instantiate a HdfsConfiguration to load the hdfs-site.xml and hdfs-default.xml
diff --git a/flink-filesystems/flink-hadoop-fs/src/test/java/org/apache/flink/runtime/fs/hdfs/HadoopConfigLoadingTest.java b/flink-filesystems/flink-hadoop-fs/src/test/java/org/apache/flink/runtime/fs/hdfs/HadoopConfigLoadingTest.java
index bb2c492..bb3d088 100644
--- a/flink-filesystems/flink-hadoop-fs/src/test/java/org/apache/flink/runtime/fs/hdfs/HadoopConfigLoadingTest.java
+++ b/flink-filesystems/flink-hadoop-fs/src/test/java/org/apache/flink/runtime/fs/hdfs/HadoopConfigLoadingTest.java
@@ -41,6 +41,7 @@ import static org.junit.Assert.assertTrue;
  * Tests that validate the loading of the Hadoop configuration, relative to
  * entries in the Flink configuration and the environment variables.
  */
+@SuppressWarnings("deprecation")
 public class HadoopConfigLoadingTest {
 
 	private static final String IN_CP_CONFIG_KEY = "cp_conf_key";