NIFI-9234 - Upgrade Atlas dependency to 2.2.0

This closes #5404.

Signed-off-by: Peter Turcsanyi <turcsanyi@apache.org>
This commit is contained in:
Pierre Villard 2021-09-21 15:47:45 +02:00 committed by Peter Turcsanyi
parent e29c8af708
commit 4a5fe698f7
4 changed files with 4 additions and 4 deletions

View File

@ -133,7 +133,7 @@ public class EmbeddedKafka {
ServerConfig configuration = new ServerConfig();
configuration.readFrom(quorumConfiguration);
FileTxnSnapLog txnLog = new FileTxnSnapLog(new File(configuration.getDataLogDir()), new File(configuration.getDataDir()));
FileTxnSnapLog txnLog = new FileTxnSnapLog(configuration.getDataLogDir(), configuration.getDataDir());
zkServer.setTxnLogFactory(txnLog);
zkServer.setTickTime(configuration.getTickTime());

View File

@ -82,7 +82,7 @@ public class TestAwsS3DirectoryV2 extends AbstractTestAwsS3Directory {
assertEquals(AwsS3Directory.TYPE_DIRECTORY_V2, ref.getTypeName());
assertEquals(String.format("s3a://%s%s/@%s", AWS_BUCKET, actualPath, ATLAS_NAMESPACE), ref.get(ATTR_QUALIFIED_NAME));
assertEquals(directory, ref.get(ATTR_NAME));
assertEquals(actualPath + "/", ref.get(ATTR_OBJECT_PREFIX_V2));
assertEquals(StringUtils.substringBeforeLast(actualPath, "/") + "/", ref.get(ATTR_OBJECT_PREFIX_V2));
assertNotNull(ref.get(ATTR_CONTAINER_V2));
ref = (Referenceable) ref.get(ATTR_CONTAINER_V2);

View File

@ -129,7 +129,7 @@ public class TestAzureADLSDirectory {
String directory = StringUtils.substringAfterLast(actualPath, "/");
assertEquals(TYPE_DIRECTORY, ref.getTypeName());
assertEquals(String.format("abfs://%s@%s%s/@%s", ADLS_FILESYSTEM, ADLS_ACCOUNT, actualPath, ATLAS_NAMESPACE), ref.get(ATTR_QUALIFIED_NAME));
assertEquals(String.format("abfs://%s@%s%s@%s", ADLS_FILESYSTEM, ADLS_ACCOUNT, actualPath, ATLAS_NAMESPACE), ref.get(ATTR_QUALIFIED_NAME));
assertEquals(directory, ref.get(ATTR_NAME));
assertNotNull(ref.get(ATTR_PARENT));

View File

@ -26,7 +26,7 @@
<packaging>pom</packaging>
<properties>
<atlas.version>2.1.0</atlas.version>
<atlas.version>2.2.0</atlas.version>
<spring.version>5.3.9</spring.version>
</properties>