diff --git a/extensions/big-data-cluster/src/bigDataCluster/controller/clusterControllerApi.ts b/extensions/big-data-cluster/src/bigDataCluster/controller/clusterControllerApi.ts
index d24d761665..104dbda87b 100644
--- a/extensions/big-data-cluster/src/bigDataCluster/controller/clusterControllerApi.ts
+++ b/extensions/big-data-cluster/src/bigDataCluster/controller/clusterControllerApi.ts
@@ -20,9 +20,7 @@ class SslAuth implements Authentication {
 	constructor() { }
 
 	applyToRequest(requestOptions: request.Options): void {
-		requestOptions['agentOptions'] = {
-			rejectUnauthorized: !getIgnoreSslVerificationConfigSetting()
-		};
+		requestOptions.rejectUnauthorized = !getIgnoreSslVerificationConfigSetting();
 	}
 }
 
diff --git a/extensions/mssql/src/hdfs/webhdfs.ts b/extensions/mssql/src/hdfs/webhdfs.ts
index bc3e7802e5..0afad1160b 100644
--- a/extensions/mssql/src/hdfs/webhdfs.ts
+++ b/extensions/mssql/src/hdfs/webhdfs.ts
@@ -961,7 +961,7 @@ export class WebHDFS {
 		this.unlink(path, recursive, callback);
 	}
 
-	public static createClient(opts: IHdfsOptions, requestParams: IRequestParams): WebHDFS {
+	public static createClient(opts: IHdfsOptions): WebHDFS {
 		return new WebHDFS(
 			Object.assign(
 				{
@@ -971,7 +971,7 @@ export class WebHDFS {
 				},
 				opts || {}
 			),
-			requestParams
+			opts.requestParams ?? { }
 		);
 	}
 }
diff --git a/extensions/mssql/src/objectExplorerNodeProvider/connection.ts b/extensions/mssql/src/objectExplorerNodeProvider/connection.ts
index 1657521356..52e04592b7 100644
--- a/extensions/mssql/src/objectExplorerNodeProvider/connection.ts
+++ b/extensions/mssql/src/objectExplorerNodeProvider/connection.ts
@@ -8,6 +8,7 @@ import * as nls from 'vscode-nls';
 const localize = nls.loadMessageBundle();
 
 import * as constants from '../constants';
+import { getIgnoreSslVerificationConfigSetting } from '../util/auth';
 import { IFileSource, IHdfsOptions, FileSourceFactory } from './fileSources';
 
 export class SqlClusterConnection {
@@ -56,6 +57,7 @@ export class SqlClusterConnection {
 			user: this.user,
 			path: 'gateway/default/webhdfs/v1',
 			requestParams: {
+				rejectUnauthorized: !getIgnoreSslVerificationConfigSetting()
 			}
 		};
 		if (this.isIntegratedAuth()) {
diff --git a/extensions/mssql/src/objectExplorerNodeProvider/fileSources.ts b/extensions/mssql/src/objectExplorerNodeProvider/fileSources.ts
index ef6fd8ee4a..e472e39337 100644
--- a/extensions/mssql/src/objectExplorerNodeProvider/fileSources.ts
+++ b/extensions/mssql/src/objectExplorerNodeProvider/fileSources.ts
@@ -18,7 +18,6 @@ import { WebHDFS, HdfsError } from '../hdfs/webhdfs';
 import { PermissionStatus } from '../hdfs/aclEntry';
 import { Mount, MountStatus } from '../hdfs/mount';
 import { FileStatus, hdfsFileTypeToFileType } from '../hdfs/fileStatus';
-import { getIgnoreSslVerificationConfigSetting } from '../util/auth';
 
 const localize = nls.loadMessageBundle();
 
@@ -129,6 +128,7 @@ export interface IRequestParams {
 	timeout?: number;
 	agent?: https.Agent;
 	headers?: {};
+	rejectUnauthorized?: boolean;
 }
 
 export class FileSourceFactory {
@@ -143,19 +143,7 @@ export class FileSourceFactory {
 
 	public async createHdfsFileSource(options: IHdfsOptions): Promise<IFileSource> {
 		options = options && options.host ? FileSourceFactory.removePortFromHost(options) : options;
-		let requestParams: IRequestParams = options.requestParams ? options.requestParams : {};
-		if (requestParams.auth || requestParams.isKerberos) {
-			let agentOptions = {
-				host: options.host,
-				port: options.port,
-				path: constants.hdfsRootPath,
-				rejectUnauthorized: !getIgnoreSslVerificationConfigSetting()
-			};
-			let agent = new https.Agent(agentOptions);
-			requestParams['agent'] = agent;
-
-		}
-		return new HdfsFileSource(WebHDFS.createClient(options, requestParams));
+		return new HdfsFileSource(WebHDFS.createClient(options));
 	}
 
 	// remove port from host when port is specified after a comma or colon