Apache/druid
1
0
Fork 0
mirror of https://github.com/apache/druid.git synced 2025-02-16 15:05:24 +00:00
Code Issues Packages Projects Releases Wiki Activity

add licenses

Browse Source
This commit is contained in:
Jesse Tuglu 2024-11-05 17:36:59 -08:00
parent f096ddea64
commit 03d0fd3233
4 changed files with 39 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
server/src/main/java/org/apache/druid/server/BaseQueryCountResource.java
View File

@ -1,3 +1,22 @@
/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*/
package org.apache.druid.server;
import org.apache.druid.guice.LazySingleton;

1
server/src/main/java/org/apache/druid/server/BrokerQueryResource.java
View File

@ -77,7 +77,6 @@ public class BrokerQueryResource extends QueryResource
responseContextConfig,
selfNode,
counter
);
this.brokerServerView = brokerServerView;
}

19
server/src/main/java/org/apache/druid/server/QueryMetricCounter.java
View File

@ -1,3 +1,22 @@
/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*/
package org.apache.druid.server;
public interface QueryMetricCounter

2
server/src/main/java/org/apache/druid/server/QueryResultPusher.java
View File

@ -233,6 +233,7 @@ public abstract class QueryResultPusher
{
if (resultsWriter != null) {
resultsWriter.recordFailure(e);
counter.incrementFailed();
if (accumulator != null && accumulator.isInitialized()) {
// We already started sending a response when we got the error message. In this case we just give up
@ -242,7 +243,6 @@ public abstract class QueryResultPusher
// the future.
trailerFields.put(QueryResource.ERROR_MESSAGE_TRAILER_HEADER, e.getMessage());
trailerFields.put(QueryResource.RESPONSE_COMPLETE_TRAILER_HEADER, "false");
counter.incrementFailed();
return null;
}
}