github/sql-server-samples
1
0
Fork 0
mirror of https://github.com/Microsoft/sql-server-samples.git synced 2025-12-08 14:58:54 +00:00
Code Issues Releases Wiki Activity

Fix

Browse Source
This commit is contained in:
pengyuehaha
2020-10-25 22:19:59 -07:00
parent 33e379983b
commit b971afb0cb
3 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
samples/features/sql-big-data-cluster/connectivity/webhdfs-java-client/README.md
+1
View File
@@ -3,6 +3,7 @@
## Prepare dependencies jar into work dir
bash ./prepare.sh
## Building jars
bash ./build.sh
samples/features/sql-big-data-cluster/connectivity/webhdfs-java-client/pom.xml
-4
View File
@@ -8,10 +8,6 @@
<artifactId>webhdfsclientsample</artifactId>
<version>1.0-SNAPSHOT</version>
<name>webhdfsclientsample</name>
<!-- FIXME change it to the project's website -->
<url>http://www.example.com</url>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<maven.compiler.source>1.7</maven.compiler.source>
samples/features/sql-big-data-cluster/connectivity/webhdfs-java-client/src/main/java/com/microsoft/mssql/App.java
+7 -4
View File
@@ -1,3 +1,6 @@
/**
* Copyright (c) Microsoft Corporation. All rights reserved.
*/
package com.microsoft.mssql;
import java.security.Principal;
@@ -50,7 +53,7 @@ public class App {
@Override
public Credentials getCredentials(AuthScope authscope) {
//TODO: this can be enhanced to pass controller use name and password in case the AuthScope authscheme is basic.
//TODO: this can be enhanced to pass user name and password in case the AuthScope authscheme is basic.
return emptyCredentials;
}
@@ -61,8 +64,8 @@ public class App {
};
private static void uploadResource(String inputFilePath, String outputFilePath){
System.out.println("Entering create resource");
// Construct Knox endpoint
String createOperationEndpoint = GW_ENDPOINT + outputFilePath + "?op=CREATE&overwrite=true";
// Construct Knox endpoint
String createOperationEndpoint = GW_ENDPOINT + outputFilePath + "?op=CREATE&overwrite=true";
try (CloseableHttpClient client2 = HttpClients.custom().setDefaultCredentialsProvider(provider).build()) {
HttpUriRequest request = new HttpPut(createOperationEndpoint);
// First request to get the location in data nodes
@@ -81,7 +84,7 @@ public class App {
// Second request to put the content to that location
File testUploadFile = new File(inputFilePath);
HttpEntity putData = MultipartEntityBuilder.create().addBinaryBody("upfile", testUploadFile).build();
HttpUriRequest putRequest = RequestBuilder.put(newlocation).setEntity(putData).build();//setEntity(postData).build();
HttpUriRequest putRequest = RequestBuilder.put(newlocation).setEntity(putData).build();
System.out.println("Executing request " + putRequest.getRequestLine());
CloseableHttpResponse response2 = client2.execute(putRequest);
HttpEntity entity2 = response2.getEntity();