This is an automated email from the ASF dual-hosted git repository.
rgoers pushed a commit to branch flume-1.10.0
in repository https://gitbox.apache.org/repos/asf/flume.git
The following commit(s) were added to refs/heads/flume-1.10.0 by this push:
new 2c269b4c Fix command line option conflicts
2c269b4c is described below
commit 2c269b4c5f970c50f7ecf2144fe4bb7e6b10b9f8
Author: Ralph Goers <[email protected]>
AuthorDate: Wed Jun 1 21:02:33 2022 -0700
Fix command line option conflicts
---
bin/flume-ng | 8 ++++++--
flume-ng-dist/pom.xml | 4 ----
.../src/main/java/org/apache/flume/node/Application.java | 8 ++++----
.../main/java/org/apache/flume/node/HttpConfigurationSource.java | 4 ++++
4 files changed, 14 insertions(+), 10 deletions(-)
diff --git a/bin/flume-ng b/bin/flume-ng
index 9bea01f5..d402912e 100755
--- a/bin/flume-ng
+++ b/bin/flume-ng
@@ -164,7 +164,11 @@ commands:
version show Flume version info
global options:
- --conf,-c <conf> use configs in <conf> directory
+ --conf-file,-f <conf> use configs in <conf> directory
+ --conf-uri, -u <conf> use configs located at <conf>
+ --conf-provider, -prov <provider-class> use the configuration provided by
the provider class
+ --conf-user, -user <user> the user for accessing the configuration uri
+ --conf-oassword, -pwd <password> the password for accessing the
configuration uri
--classpath,-C <cp> append to the classpath
--dryrun,-d do not actually start Flume, just print the command
--plugins-path <dirs> colon-separated list of plugins.d directories. See
the
@@ -175,7 +179,7 @@ global options:
agent options:
--name,-n <name> the name of this agent (required)
- --conf-file,-f <file> specify a config file (required if -z missing)
+ --conf-file,-f <file> specify a config file (required if -z, -u, and
-prov are missing)
--zkConnString,-z <str> specify the ZooKeeper connection to use (required
if -f missing)
--zkBasePath,-p <path> specify the base path in ZooKeeper for agent
configs
--no-reload-conf do not reload config file if changed
diff --git a/flume-ng-dist/pom.xml b/flume-ng-dist/pom.xml
index b5f0495c..5ca3783e 100644
--- a/flume-ng-dist/pom.xml
+++ b/flume-ng-dist/pom.xml
@@ -151,10 +151,6 @@
<groupId>org.apache.flume.flume-ng-sinks</groupId>
<artifactId>flume-ng-kafka-sink</artifactId>
</dependency>
- <dependency>
- <groupId>org.apache.flume.flume-ng-sinks</groupId>
- <artifactId>flume-dataset-sink</artifactId>
- </dependency>
<dependency>
<groupId>org.apache.flume.flume-ng-sinks</groupId>
<artifactId>flume-hive-sink</artifactId>
diff --git a/flume-ng-node/src/main/java/org/apache/flume/node/Application.java
b/flume-ng-node/src/main/java/org/apache/flume/node/Application.java
index e30ede84..28df67de 100644
--- a/flume-ng-node/src/main/java/org/apache/flume/node/Application.java
+++ b/flume-ng-node/src/main/java/org/apache/flume/node/Application.java
@@ -320,16 +320,16 @@ public class Application {
option.setRequired(false);
options.addOption(option);
- option = new Option("c", "conf-provider", true,
+ option = new Option("prov", "conf-provider", true,
"specify a configuration provider class (required if -f, -u, and
-z are missing)");
option.setRequired(false);
options.addOption(option);
- option = new Option("n", "conf-user", true, "user name to access
configuration uri");
+ option = new Option("user", "conf-user", true, "user name to access
configuration uri");
option.setRequired(false);
options.addOption(option);
- option = new Option("p", "conf-password", true, "password to access
configuration uri");
+ option = new Option("pwd", "conf-password", true, "password to access
configuration uri");
option.setRequired(false);
options.addOption(option);
@@ -395,7 +395,7 @@ public class Application {
}
}
- if (commandLine.hasOption("c") ||
commandLine.hasOption("conf-provider")) {
+ if (commandLine.hasOption("prov") ||
commandLine.hasOption("conf-provider")) {
String className = commandLine.getOptionValue("conf-provider");
try {
Class<?> clazz =
Application.class.getClassLoader().loadClass(className);
diff --git
a/flume-ng-node/src/main/java/org/apache/flume/node/HttpConfigurationSource.java
b/flume-ng-node/src/main/java/org/apache/flume/node/HttpConfigurationSource.java
index a877d852..e9a395ca 100644
---
a/flume-ng-node/src/main/java/org/apache/flume/node/HttpConfigurationSource.java
+++
b/flume-ng-node/src/main/java/org/apache/flume/node/HttpConfigurationSource.java
@@ -37,6 +37,7 @@ public class HttpConfigurationSource implements
ConfigurationSource {
private static final Logger LOGGER =
LoggerFactory.getLogger(HttpConfigurationSource.class);
private static final int NOT_MODIFIED = 304;
private static final int NOT_AUTHORIZED = 401;
+ private static final int NOT_FOUND = 404;
private static final int OK = 200;
private static final int BUF_SIZE = 1024;
@@ -119,6 +120,9 @@ public class HttpConfigurationSource implements
ConfigurationSource {
throw new ConfigurationException("Unable to access " +
uri.toString(), e);
}
}
+ case NOT_FOUND: {
+ throw new ConfigurationException("Unable to locate " +
uri.toString());
+ }
case NOT_AUTHORIZED: {
throw new ConfigurationException("Authorization failed");
}
