You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@openwhisk.apache.org by GitBox <gi...@apache.org> on 2018/11/27 10:12:27 UTC
[GitHub] jiangpengcheng edited a comment on issue #4134: the
`processAcknowledgement` may process `CompletionMessage` first for blocking
incovation even the message is sent ahead of `ResultMessage`
jiangpengcheng edited a comment on issue #4134: the `processAcknowledgement` may process `CompletionMessage` first for blocking incovation even the message is sent ahead of `ResultMessage`
URL: https://github.com/apache/incubator-openwhisk/issues/4134#issuecomment-442002306
add `logging.warn` in `PrimitiveActions.scala`:
```
// 1. Wait for the active-ack to happen. Either immediately resolve the promise or poll the database quickly
// in case of an incomplete active-ack (record too large for example).
activeAckResponse.foreach {
case Right(activation) => result.trySuccess(Right(activation))
case Left(aid) if volatile => result.trySuccess(Left(aid))
case _ =>
logging.warn(this, s"Received a left for activation: $docid") // added log
pollActivation(docid, context, result, i => 1.seconds + (2.seconds * i), maxRetries = 4)
}
```
and found the warn log:
```
[2018-11-27T10:04:02.054Z] [INFO] [#tid_fc7c0e23fc514d8d98c69fedb4cba8e2] GET /api/v1/web/whisk.system/default/hello.json __ow_volatile=true
[2018-11-27T10:04:02.057Z] [INFO] [#tid_fc7c0e23fc514d8d98c69fedb4cba8e2] [Identity] [GET] serving from cache: CacheKey(whisk.system) [marker:database_cacheHit_count:2]
[2018-11-27T10:04:02.057Z] [INFO] [#tid_fc7c0e23fc514d8d98c69fedb4cba8e2] [WhiskActionMetaData] [GET] serving from cache: CacheKey(whisk.system/hello) [marker:database_cacheHit_count:3]
[2018-11-27T10:04:02.058Z] [INFO] [#tid_fc7c0e23fc514d8d98c69fedb4cba8e2] [WebActionsApi] [marker:controller_blockingActivation_start:4]
[2018-11-27T10:04:02.059Z] [INFO] [#tid_fc7c0e23fc514d8d98c69fedb4cba8e2] [WebActionsApi] action activation id: e098c63507c14b5498c63507c15b548f [marker:controller_loadbalancer_start:4]
[2018-11-27T10:04:02.059Z] [INFO] [#tid_fc7c0e23fc514d8d98c69fedb4cba8e2] [ShardingContainerPoolBalancer] posting to 'invoker0/0' with activation id 'e098c63507c14b5498c63507c15b548f' [marker
:controller_kafka_start:5]
[2018-11-27T10:04:02.061Z] [INFO] [#tid_fc7c0e23fc514d8d98c69fedb4cba8e2] [ShardingContainerPoolBalancer] posted to invoker0[0][3968] [marker:controller_kafka_finish:7:2]
[2018-11-27T10:04:02.061Z] [INFO] [#tid_fc7c0e23fc514d8d98c69fedb4cba8e2] [WebActionsApi] [marker:controller_loadbalancer_finish:7:3]
[2018-11-27T10:04:02.097Z] [INFO] [#tid_fc7c0e23fc514d8d98c69fedb4cba8e2] [ShardingContainerPoolBalancer] received completion ack for 'e098c63507c14b5498c63507c15b548f'
[2018-11-27T10:04:02.097Z] [WARN] [#tid_fc7c0e23fc514d8d98c69fedb4cba8e2] [WebActionsApi] Received a left for activation: whisk.system/e098c63507c14b5498c63507c15b548f
[2018-11-27T10:04:02.098Z] [INFO] [#tid_fc7c0e23fc514d8d98c69fedb4cba8e2] [ShardingContainerPoolBalancer] received result ack for 'e098c63507c14b5498c63507c15b548f'
[2018-11-27T10:04:03.113Z] [INFO] [#tid_fc7c0e23fc514d8d98c69fedb4cba8e2] [CouchDbRestStore] [GET] 'whisk_local_activations' finding document: 'id: whisk.system/e098c63507c14b5498c63507c15b54
8f' [marker:database_getDocument_start:1058]
[2018-11-27T10:04:03.123Z] [INFO] [#tid_fc7c0e23fc514d8d98c69fedb4cba8e2] [CouchDbRestStore] [marker:database_getDocument_finish:1069:10]
[2018-11-27T10:04:03.124Z] [INFO] [#tid_fc7c0e23fc514d8d98c69fedb4cba8e2] [WebActionsApi] retrieved activation for blocking invocation via DB polling [marker:controller_blockingActivationData
baseRetrieval_count:1070]
[2018-11-27T10:04:03.124Z] [INFO] [#tid_fc7c0e23fc514d8d98c69fedb4cba8e2] [WebActionsApi] [marker:controller_blockingActivation_finish:1070:1066]
[2018-11-27T10:04:03.125Z] [INFO] [#tid_fc7c0e23fc514d8d98c69fedb4cba8e2] [BasicHttpService] [marker:http_get.200_count:1071:1071]
```
the reason why I found this is that we have a custom feature which can skip saving activations into DB when some request parameters are set, then some of these requests will hang until timeout and return a 202 response
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
With regards,
Apache Git Services