Skip to content

Commit be84427

Browse files
committed
minor jetty upgrade related fixes
1 parent e75ac3c commit be84427

File tree

4 files changed

+4
-8
lines changed

4 files changed

+4
-8
lines changed

.semaphore/semaphore.yml

+1-1
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ fail_fast:
1414
when: "true"
1515

1616
execution_time_limit:
17-
hours: 3
17+
hours: 1
1818

1919
queue:
2020
- when: "branch != 'master' and branch !~ '[0-9]+\\.[0-9]+\\.[0-9]+'"

src/main/java/io/confluent/examples/streams/interactivequeries/WordCountInteractiveQueriesRestService.java

+1-3
Original file line numberDiff line numberDiff line change
@@ -275,9 +275,7 @@ void start(final int port) throws Exception {
275275
connector.setHost(hostInfo.host());
276276
connector.setPort(port);
277277
jettyServer.addConnector(connector);
278-
279-
context.start();
280-
278+
281279
try {
282280
jettyServer.start();
283281
} catch (final java.net.SocketException exception) {

src/main/java/io/confluent/examples/streams/interactivequeries/kafkamusic/MusicPlaysRestService.java

+1-3
Original file line numberDiff line numberDiff line change
@@ -232,9 +232,7 @@ void start() throws Exception {
232232
connector.setHost(hostInfo.host());
233233
connector.setPort(hostInfo.port());
234234
jettyServer.addConnector(connector);
235-
236-
context.start();
237-
235+
238236
try {
239237
jettyServer.start();
240238
} catch (final java.net.SocketException exception) {

src/test/java/io/confluent/examples/streams/interactivequeries/kafkamusic/KafkaMusicExampleTest.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -190,7 +190,7 @@ private void createStreams(final String host) throws Exception {
190190
restProxy = KafkaMusicExample.startRestProxy(streams, new HostInfo(host, appServerPort));
191191
break;
192192
} catch (final Exception ex) {
193-
log.error("Could not start Rest Service due to: " + ex.toString());
193+
log.error("Could not start Rest Service due to: " + ex.toString(), ex);
194194
}
195195
count++;
196196
}

0 commit comments

Comments
 (0)