mirror of
https://github.com/seaweedfs/seaweedfs.git
synced 2024-01-19 02:48:24 +00:00
update hdfs client
This commit is contained in:
parent
f8d4b7d1c0
commit
a999ed94d0
|
@ -4,7 +4,7 @@
|
||||||
|
|
||||||
<groupId>com.github.chrislusf</groupId>
|
<groupId>com.github.chrislusf</groupId>
|
||||||
<artifactId>seaweedfs-client</artifactId>
|
<artifactId>seaweedfs-client</artifactId>
|
||||||
<version>1.1.6</version>
|
<version>1.1.8</version>
|
||||||
|
|
||||||
<parent>
|
<parent>
|
||||||
<groupId>org.sonatype.oss</groupId>
|
<groupId>org.sonatype.oss</groupId>
|
||||||
|
|
|
@ -16,8 +16,8 @@ public class SeaweedFilerTest {
|
||||||
filerClient.mkdirs("/new_folder", 0755);
|
filerClient.mkdirs("/new_folder", 0755);
|
||||||
filerClient.touch("/new_folder/new_empty_file", 0755);
|
filerClient.touch("/new_folder/new_empty_file", 0755);
|
||||||
filerClient.touch("/new_folder/new_empty_file2", 0755);
|
filerClient.touch("/new_folder/new_empty_file2", 0755);
|
||||||
filerClient.rm("/new_folder/new_empty_file", false);
|
filerClient.rm("/new_folder/new_empty_file", false, true);
|
||||||
filerClient.rm("/new_folder", true);
|
filerClient.rm("/new_folder", true, true);
|
||||||
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -123,7 +123,7 @@
|
||||||
</snapshotRepository>
|
</snapshotRepository>
|
||||||
</distributionManagement>
|
</distributionManagement>
|
||||||
<properties>
|
<properties>
|
||||||
<seaweedfs.client.version>1.1.6</seaweedfs.client.version>
|
<seaweedfs.client.version>1.1.8</seaweedfs.client.version>
|
||||||
<hadoop.version>2.9.2</hadoop.version>
|
<hadoop.version>2.9.2</hadoop.version>
|
||||||
</properties>
|
</properties>
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -5,7 +5,7 @@
|
||||||
<modelVersion>4.0.0</modelVersion>
|
<modelVersion>4.0.0</modelVersion>
|
||||||
|
|
||||||
<properties>
|
<properties>
|
||||||
<seaweedfs.client.version>1.1.6</seaweedfs.client.version>
|
<seaweedfs.client.version>1.1.8</seaweedfs.client.version>
|
||||||
<hadoop.version>2.9.2</hadoop.version>
|
<hadoop.version>2.9.2</hadoop.version>
|
||||||
</properties>
|
</properties>
|
||||||
|
|
||||||
|
|
|
@ -137,7 +137,7 @@ public class SeaweedFileSystemStore {
|
||||||
if (source.isRoot()) {
|
if (source.isRoot()) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
LOG.warn("rename source: {} destination:{}", source, destination);
|
LOG.info("rename source: {} destination:{}", source, destination);
|
||||||
FilerProto.Entry entry = lookupEntry(source);
|
FilerProto.Entry entry = lookupEntry(source);
|
||||||
if (entry == null) {
|
if (entry == null) {
|
||||||
LOG.warn("rename non-existing source: {}", source);
|
LOG.warn("rename non-existing source: {}", source);
|
||||||
|
|
|
@ -123,7 +123,7 @@
|
||||||
</snapshotRepository>
|
</snapshotRepository>
|
||||||
</distributionManagement>
|
</distributionManagement>
|
||||||
<properties>
|
<properties>
|
||||||
<seaweedfs.client.version>1.1.6</seaweedfs.client.version>
|
<seaweedfs.client.version>1.1.8</seaweedfs.client.version>
|
||||||
<hadoop.version>3.1.1</hadoop.version>
|
<hadoop.version>3.1.1</hadoop.version>
|
||||||
</properties>
|
</properties>
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -5,7 +5,7 @@
|
||||||
<modelVersion>4.0.0</modelVersion>
|
<modelVersion>4.0.0</modelVersion>
|
||||||
|
|
||||||
<properties>
|
<properties>
|
||||||
<seaweedfs.client.version>1.1.6</seaweedfs.client.version>
|
<seaweedfs.client.version>1.1.8</seaweedfs.client.version>
|
||||||
<hadoop.version>3.1.1</hadoop.version>
|
<hadoop.version>3.1.1</hadoop.version>
|
||||||
</properties>
|
</properties>
|
||||||
|
|
||||||
|
|
|
@ -137,7 +137,7 @@ public class SeaweedFileSystemStore {
|
||||||
if (source.isRoot()) {
|
if (source.isRoot()) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
LOG.warn("rename source: {} destination:{}", source, destination);
|
LOG.info("rename source: {} destination:{}", source, destination);
|
||||||
FilerProto.Entry entry = lookupEntry(source);
|
FilerProto.Entry entry = lookupEntry(source);
|
||||||
if (entry == null) {
|
if (entry == null) {
|
||||||
LOG.warn("rename non-existing source: {}", source);
|
LOG.warn("rename non-existing source: {}", source);
|
||||||
|
|
Loading…
Reference in a new issue