Skip to content

Commit

Permalink
Use newer Alluxio client
Browse files Browse the repository at this point in the history
  • Loading branch information
apc999 authored and highker committed Sep 30, 2020
1 parent 544b5a4 commit 9a11908
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -63,7 +63,7 @@
<dep.nexus-staging-plugin.version>1.6.8</dep.nexus-staging-plugin.version>
<dep.asm.version>6.2.1</dep.asm.version>
<dep.gcs.version>1.9.17</dep.gcs.version>
<dep.alluxio.version>2.2.2-2</dep.alluxio.version>
<dep.alluxio.version>2.3.0-1</dep.alluxio.version>
<dep.kafka.version>2.3.1</dep.kafka.version>
<dep.druid.version>0.19.0</dep.druid.version>
<dep.jaxb.version>2.3.1</dep.jaxb.version>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,6 @@
import java.io.IOException;
import java.net.URI;
import java.net.URISyntaxException;
import java.nio.file.AccessDeniedException;
import java.util.HashMap;
import java.util.Map;
import java.util.Optional;
Expand Down Expand Up @@ -188,7 +187,7 @@ public void testStress()
}

// This test must go first or the LocalCacheManager singleton will be created by other tests
@Test(timeOut = 30_000, expectedExceptions = {AccessDeniedException.class}, priority = -1)
@Test(timeOut = 30_000, expectedExceptions = {IOException.class}, priority = -1)
public void testCreationFailure()
throws Exception
{
Expand Down Expand Up @@ -274,6 +273,7 @@ private Configuration getHdfsConfiguration(CacheConfig cacheConfig, AlluxioCache
configuration.set("alluxio.user.client.cache.page.size", Integer.toString(PAGE_SIZE));
configuration.set("alluxio.user.metrics.collection.enabled", String.valueOf(alluxioCacheConfig.isMetricsCollectionEnabled()));
configuration.set("alluxio.user.client.cache.async.write.enabled", String.valueOf(alluxioCacheConfig.isAsyncWriteEnabled()));
configuration.set("alluxio.user.client.cache.async.restore.enabled", String.valueOf(false));
configuration.set("sink.jmx.class", alluxioCacheConfig.getJmxClass());
configuration.set("sink.jmx.domain", alluxioCacheConfig.getMetricsDomain());
}
Expand Down

0 comments on commit 9a11908

Please sign in to comment.