[jira] [Commented] (CAMEL-14166) Netty is reporting a resource leak

["Andrea Cosentino (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/CAMEL-14166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16971526#comment-16971526 ] 

Andrea Cosentino commented on CAMEL-14166:
------------------------------------------

Fixed on RC3.

 

[https://github.com/apache/camel/commit/ae2719732eb4867ecdb182e969e02a301bddc9f3#diff-e6e9f7220479f25103b607fae7cc9b28]

> Netty is reporting a resource leak
> ----------------------------------
>
>                 Key: CAMEL-14166
>                 URL: https://issues.apache.org/jira/browse/CAMEL-14166
>             Project: Camel
>          Issue Type: Bug
>          Components: camel-netty-http
>    Affects Versions: 3.0.0.RC2
>         Environment: Java 1.8, MacOS Mojave 10.14.6
>            Reporter: Mark Grand
>            Priority: Major
>             Fix For: 3.0.0.RC3
>
>
> I am seeing this stack trace:
> {{[Camel (camel-1) thread #7 - NettyEventExecutorGroup|#7 - NettyEventExecutorGroup] ERROR io.netty.util.ResourceLeakDetector - LEAK: ByteBuf.release() was not called before it's garbage-collected. See [https://netty.io/wiki/reference-counted-objects.html] for more information.[Camel (camel-1) thread #7 - NettyEventExecutorGroup|#7 - NettyEventExecutorGroup] ERROR io.netty.util.ResourceLeakDetector - LEAK: ByteBuf.release() was not called before it's garbage-collected. See [https://netty.io/wiki/reference-counted-objects.html] for more information.Recent access records: Created at: io.netty.buffer.PooledByteBufAllocator.newDirectBuffer(PooledByteBufAllocator.java:349) io.netty.buffer.AbstractByteBufAllocator.directBuffer(AbstractByteBufAllocator.java:187) io.netty.buffer.AbstractByteBufAllocator.directBuffer(AbstractByteBufAllocator.java:178) io.netty.buffer.CompositeByteBuf.allocBuffer(CompositeByteBuf.java:1835) io.netty.buffer.CompositeByteBuf.copy(CompositeByteBuf.java:1487) io.netty.buffer.AbstractByteBuf.copy(AbstractByteBuf.java:1209) org.apache.camel.component.netty.http.NettyChannelBufferStreamCache.copy(NettyChannelBufferStreamCache.java:93) org.apache.camel.processor.MulticastProcessor.createProcessorExchangePairs(MulticastProcessor.java:620) org.apache.camel.processor.MulticastProcessor.process(MulticastProcessor.java:221) org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:228) org.apache.camel.processor.Pipeline.doProcess(Pipeline.java:103) org.apache.camel.processor.Pipeline.lambda$null$2(Pipeline.java:104) org.apache.camel.impl.engine.DefaultReactiveExecutor$3.run(DefaultReactiveExecutor.java:116) org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:185) org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:59) org.apache.camel.processor.Pipeline.process(Pipeline.java:87) org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:228) org.apache.camel.component.netty.handlers.ServerChannelHandler.processAsynchronously(ServerChannelHandler.java:141) org.apache.camel.component.netty.handlers.ServerChannelHandler.channelRead0(ServerChannelHandler.java:112) org.apache.camel.component.netty.http.handlers.HttpServerChannelHandler.channelRead0(HttpServerChannelHandler.java:202) io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105) org.apache.camel.component.netty.http.handlers.HttpServerMultiplexChannelHandler.channelRead0(HttpServerMultiplexChannelHandler.java:156) io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374) io.netty.channel.AbstractChannelHandlerContext.access$600(AbstractChannelHandlerContext.java:56) io.netty.channel.AbstractChannelHandlerContext$7.run(AbstractChannelHandlerContext.java:365) io.netty.util.concurrent.DefaultEventExecutor.run(DefaultEventExecutor.java:66) io.netty.util.concurrent.SingleThreadEventExecutor$6.run(SingleThreadEventExecutor.java:1044) io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) java.base/java.lang.Thread.run(Thread.java:834)}}
>  
>  Here is the rest configuration:
> {{restConfiguration()}}
> {{ .component("netty-http")}}
> {{ .host("0.0.0.0").port(config.getUiaPortNumber())}}
> {{ .bindingMode(RestBindingMode.off)}}
> {{ .apiContextPath("api-doc")}}
> {{ .apiProperty("api.title", "Unified Item API")}}
> {{ .apiProperty("api.version", "0.1.0")}}
> {{ .apiProperty("api.description",}}
> {{ "This API allows callers to get information from multiple sources by sending just one request."}}
> {{ + " A single response is returned that contains all of the requested information in a single JSON object.\n\n"}}
> {{ + "Currently supported sources include\n"}}
> {{ + "* " + PRODUCT_API_HD_CATALOG_HOST + "\n"}}
> {{ + "* " + PRICING_API_HOST + "\n"}}
> {{ + "* " + ASSORTMENT_COMMONS_HOST)}}
> {{ .apiProperty("api.contact.name", "Mark Grand")}}
> {{ .apiProperty("api.contact.email", "mark_grand@homedepot.com")}}
> {{ .apiProperty("api.specification.contentType.json", APPLICATION_JSON)}}
> {{ .scheme("http")}}
> Here is rest endpoint configuration:
> {{rest().path("/uia").bindingMode(RestBindingMode.off)}}
> {{ .get("/admin/health").produces("text/plain")}}
> {{ .description("This returns a static \"Hello world!\\n\" response. It is intended to be used as a health check.")}}
> {{ .to("bean:helloBean")}}
> {{ .responseMessage().code(200).message("Hello world!").endResponseMessage()}}
> {{;}}{{}}
>  
> rest().path("/uia/api/v1").bindingMode(RestBindingMode.off).produces(APPLICATION_JSON)
>  .post("/authorization").consumes("text/plain").type(String.class).produces("text/plain")
>  .description("This should be a client's first request to this API. "
>  + "The request includes the client's credentials for accessing the aggregated services. "
>  + "The response is a JWT that contains the client's credentials.")
>  .param().name(JwtConstants.PRICING_TOKEN_TAG)
>  .type(RestParamType.header)
>  .dataType("string")
>  .required(false)
>  .description("The OAuth2 token to be used for accessing pricing information. This will be included in the JWT returned by this operation.")
>  .endParam()
>  .param().name(JwtConstants.SERVICE_ACCT_TAG)
>  .type(RestParamType.header)
>  .dataType("string")
>  .required(true)
>  .description("This is a service account that identifies the client.")
>  .endParam()
>  .to(DIRECT_AUTHORIZATION)
>  .responseMessage().code(200)
>  .example("credentialJwt", "eyJhbGciOiJub25lIn0.eyJpc3MiOiJ1bmlmaWVkLWl0ZW0tYXBpIiwiWC1wcmljaW5nLXRva2VuIjoiZXlKcmFXUWlPaUl4SWl3aWRIbHdJam9pU2xkVUlpd2lZV3huSWpvaVVsTXlOVFlpZlEuZXlKaFkyTmxjM05mZEc5clpXNGlPaUpVYm05cE1XeEpaVGxIU2xocGJuSnlhMkV4ZHpkelJrdGxUWFkzSWl3aVlYVmtJam9pYldsamNtOW5ZWFJsZDJGNUlpd2lZWEJwWDNCeWIyUjFZM1JmYkdsemRDSTZXeUpTWlhSaGFXd2dSRzl0WVdsdUlGTmxjblpwWTJVZ0xTQk9iMjRnVUhKdlpDSmRMQ0poY0hCc2FXTmhkR2x2Ymw5dVlXMWxJam9pVWtSVElDMGdSVkFnTFNCT2IyNHRVSEp2WkNJc0ltNWlaaUk2TVRVM01ESXdNRFExTXl3aVpHVjJaV3h2Y0dWeVgyVnRZV2xzSWpvaVpXNTBaWEp3Y21selpYQnlhV05wYm1kQWFHOXRaV1JsY0c5MExtTnZiU0lzSW1semN5STZJbWgwZEhBNlhDOWNMMmh2YldWa1pYQnZkQzF3Y21samFXNW5MV1JsZGk1aGNHbG5aV1V1Ym1WMFhDOWxaR2RsYldsamNtOHRZWFYwYUZ3dmRHOXJaVzRpTENKbGVIQWlPakUxTnpBeU1ESXlOVE1zSW1saGRDSTZNVFUzTURJd01EUTFNeXdpWTJ4cFpXNTBYMmxrSWpvaWRHNDBlalJXTTNKV1JWVktRbHBvUm1kUFVVTk1hVWRRZUdKbWQwazBURzRpTENKcWRHa2lPaUkwWm1aak9EVmxOUzFoTnpFNExUUmlaamt0T0dFek5pMHdZek0xWlRBNE9HRmlNbVlpZlEuR3IzSEdNRl9sUk44eF9qM01YbXRMMHRJWGxCeWZxUEpLVWFuX3hYSF80aHB6Q0Q4eDJJSnQyV1gtR3N3Zm1ZT0pWUm8zMDFyWmZBUDBRdTVkUS12TzM0VDVLcDhmX2txZmpkeFRCM1ZtbUdtQ3p2SlN6eEVDbmVqZU56SG5NTk9BUTAzTVRRX3FnYXB0d0taWjNDTjVwLVU1YXdYN2Rya2NiWldsV0lpS0dmTmNVaFhFZjc5bHpJMnVXbXV2TjgxN3lIMDdXUU16cEJteGh5TFpMdUQ3ZW5CRktvMmwwcnNJYXlORnJqbU5ycl9GTWxCMlVMRkRxcUd4UGpmcDJ2N184TlJ6ZS1hcjIzZUlPelpWdGo3YkRBOW5uQzNoWS1jNk8zckpXRXR6ZzVzT3VqUExNZTFYLS1QNXg1NzhmajZ2R3U0WnFGXzFaNDgwVTZWVFpld1B3Iiwic3ZjQWNjdCI6InBsYWNlaG9sZGVyIGZvciBhIHNlcnZpY2UgYWNjb3VudCJ9.")
>  .message("An encoded JWT whose payload contains the service account and credentials provided by the client. "
>  + "This JWT will be needed to authorize requests to other endpoints")
>  .responseModel(String.class)
>  .endResponseMessage()
>  .responseMessage().code(400).message("Bad Request").endResponseMessage()
>  .get("/raw?skus=\{skus}&stores=\{stores}")
>  .description("Queries `" + PRODUCT_API_HD_CATALOG_HOST + "`, `" + PRICING_API_HOST + "` and `"
>  + ASSORTMENT_COMMONS_HOST + "` for data about combinations of the given stores and SKUs. "
>  + "The data from the individual services is returned as-is, without being combined.")
>  .param().name(JwtConstants.SKUS_ITAG).description("A comma-separated list of SKUS").required(true).type(RestParamType.header).endParam()
>  .param().name(JwtConstants.STORES_ITAG).description("A comma-separated list of stores").required(true).type(RestParamType.header).endParam()
>  .clientRequestValidation(true)
>  .responseMessage().code(200)
>  .message("Returns a JSON object whose fields have the values returned by the queried services and "
>  + "also the status codes returned by the queried services.")
>  .example("success", RAW_RESULT_EXAMPLE)
>  .endResponseMessage()
>  .responseMessage().code(400).message("Bad Request").endResponseMessage()
>  .to(DIRECT_RAW)
>  .get("/skus-stores?skus=\{skus}&stores=\{stores}")
>  .description("Queries `" + PRODUCT_API_HD_CATALOG_HOST + "`, `" + PRICING_API_HOST + "` and `"
>  + ASSORTMENT_COMMONS_HOST + "` for data about combinations of the given stores and SKUs. "
>  + "Data from the individual services is reorganized into JSON objects that each refer to a single store-SKU combination.")
>  .param().name(JwtConstants.SKUS_ITAG).description("A comma-separated list of SKUS").required(true).type(RestParamType.header).endParam()
>  .param().name(JwtConstants.STORES_ITAG).description("A comma-separated list of stores").required(true).type(RestParamType.header).endParam()
>  .clientRequestValidation(true)
>  .responseMessage().code(200)
>  .message("Returns a JSON object whose fields describe the request and result. "
>  + "One field is an array of JSON objects that each describe a different store-sku combination")
>  .example("success", SKU_STORE_RESULT_EXAMPLE)
>  .endResponseMessage()
>  .responseMessage().code(400).message("Bad Request").endResponseMessage()
>  .to(DIRECT_SKU_STORES)
> ;



--
This message was sent by Atlassian Jira
(v8.3.4#803005)