Github user srdo commented on a diff in the pull request:

    https://github.com/apache/storm/pull/2566#discussion_r170300322
  
    --- Diff: storm-client/src/jvm/org/apache/storm/utils/Utils.java ---
    @@ -1505,35 +1508,36 @@ public static StormTopology 
addVersions(StormTopology topology) {
             Map<String, Object> defaultsConf = null;
             Map<String, Object> stormConf = null;
             for (String part: cp) {
    -            File f = new File(part);
    -            if (f.isDirectory()) {
    -                if (defaultsConf == null) {
    -                    defaultsConf = readConfIgnoreNotFound(yaml, new 
File(f, "defaults.yaml"));
    -                }
    -                
    -                if (stormConf == null) {
    -                    stormConf = readConfIgnoreNotFound(yaml, new File(f, 
"storm.yaml"));
    +            String wildcardSuffix = File.separator + "*";
    +            if (part.endsWith(wildcardSuffix)) {
    +                // wildcard is given
    +                // in java classpath, '*' is translated to '*.jar'
    +                File dir = new File(part.substring(0, part.length() - 
wildcardSuffix.length()));
    +                File[] jarFiles = dir.listFiles((dir1, name) -> 
name.endsWith(".jar"));
    +
    +                if (jarFiles != null) {
    --- End diff --
    
    Nit: Isn't there something really weird going on if this is null? The 
javadoc only mentions that this can be null if there's an IO error or the dir 
isn't a directory.


---

Reply via email to