From c93cc80d21f1e441480e8e582238fe09cb156c9b Mon Sep 17 00:00:00 2001 From: nikita15p <37657012+nikita15p@users.noreply.github.com> Date: Sat, 8 Apr 2023 16:55:38 +0530 Subject: [PATCH] [FLUME-3468] fix default value of passwordFile property when userName is set for jms source --- .../main/java/org/apache/flume/source/jms/JMSSource.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/flume-ng-sources/flume-jms-source/src/main/java/org/apache/flume/source/jms/JMSSource.java b/flume-ng-sources/flume-jms-source/src/main/java/org/apache/flume/source/jms/JMSSource.java index 43df145187..75150fdabb 100644 --- a/flume-ng-sources/flume-jms-source/src/main/java/org/apache/flume/source/jms/JMSSource.java +++ b/flume-ng-sources/flume-jms-source/src/main/java/org/apache/flume/source/jms/JMSSource.java @@ -170,7 +170,12 @@ protected void doConfigure(Context context) throws FlumeException { String passwordFile = context.getString(JMSSourceConfiguration.PASSWORD_FILE, "").trim(); if (passwordFile.isEmpty()) { - password = Optional.absent(); + if (userName.isPresent()){ + logger.warn("passwordFile property is not set but userName property is set. Setting password to default value"); + password = Optional.of(""); + }else{ + password = Optional.absent(); + } } else { try { password = Optional.of(Files.toString(new File(passwordFile),