@@ -155,7 +155,7 @@ protected V1ConfigMap computeDomainConfigMap() {
155
155
return cm ;
156
156
}
157
157
158
- private Map <String , String > loadScripts () {
158
+ private synchronized Map <String , String > loadScripts () {
159
159
URI uri = null ;
160
160
try {
161
161
uri = getClass ().getResource (SCRIPT_LOCATION ).toURI ();
@@ -164,15 +164,14 @@ private Map<String, String> loadScripts() {
164
164
throw new RuntimeException (e );
165
165
}
166
166
167
- try {
168
- FileSystem fileSystem = FileSystems .newFileSystem (uri , Collections .<String , Object >emptyMap ());
167
+ try (FileSystem fileSystem = FileSystems .newFileSystem (uri , Collections .<String , Object >emptyMap ())) {
169
168
Stream <Path > walk = Files .walk (fileSystem .getPath (SCRIPT_LOCATION ), 1 );
170
169
Map <String , String > data = new HashMap <>();
171
170
for (Iterator <Path > it = walk .iterator (); it .hasNext ();) {
172
171
Path script = it .next ();
173
172
String scriptName = script .toString ();
174
173
if (!SCRIPT_LOCATION .equals (scriptName )) {
175
- data .put (script .getFileName ().toString (), readScript (getClass (). getResourceAsStream ( scriptName ) ));
174
+ data .put (script .getFileName ().toString (), readScript (scriptName ));
176
175
}
177
176
}
178
177
LOGGER .info (MessageKeys .SCRIPT_LOADED , domainNamespace );
@@ -183,14 +182,18 @@ private Map<String, String> loadScripts() {
183
182
}
184
183
}
185
184
186
- private String readScript (InputStream inputStream ) throws IOException {
187
- ByteArrayOutputStream result = new ByteArrayOutputStream ();
188
- byte [] buffer = new byte [1024 ];
189
- int length ;
190
- while ((length = inputStream .read (buffer )) != -1 ) {
191
- result .write (buffer , 0 , length );
185
+ private String readScript (String scriptName ) throws IOException {
186
+ try (
187
+ InputStream inputStream = getClass ().getResourceAsStream (scriptName );
188
+ ByteArrayOutputStream result = new ByteArrayOutputStream ()
189
+ ) {
190
+ byte [] buffer = new byte [1024 ];
191
+ int length ;
192
+ while ((length = inputStream .read (buffer )) != -1 ) {
193
+ result .write (buffer , 0 , length );
194
+ }
195
+ return result .toString ();
192
196
}
193
- return result .toString ();
194
197
}
195
198
}
196
199
0 commit comments