[
https://issues.apache.org/jira/browse/GEODE-5896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16869576#comment-16869576
]
Juan José Ramos Cassella commented on GEODE-5896:
-------------------------------------------------
I have a {{DUnit}} test that reproduces the behaviour (attached to the ticket)
and, after looking through the source code, the function execution _*works like
this by design*_.
Whenever a member acts as the _coordinator_ for function execution on a
partitioned region, it basically creates a map of buckets to member, fires a
message to each member containing the buckets on which the function will
execute and waits to aggregate all responses to return to the client. If the
client "dies" in the middle of the execution the _coordinator_ will know and
stop all local threads related to that function execution *BUT* it has no way
(currently) of letting the remote members know about this, so the remote
members will continue to execute the function until it finishes.
> Function sendResult can not finish correctly when client stop receive data
> --------------------------------------------------------------------------
>
> Key: GEODE-5896
> URL: https://issues.apache.org/jira/browse/GEODE-5896
> Project: Geode
> Issue Type: Bug
> Components: functions
> Reporter: Dong Yang
> Assignee: Juan José Ramos Cassella
> Priority: Major
> Labels: SmallFeature
> Attachments:
> ClientServerFunctionExecutionWithCoordinatorDUnitTest.java
>
>
> Scenario:
> # TCP client-server mode
> # on Region with filter invocation
> # single-hop enabled at client-side
> # lots of data transfer from server to client
> # Using sendResult send data from server to client as streaming style
> Incident:
> Client program killed or exit normally. Server-side can not detect the
> exception so still sending data to client. Resources occupied sometimes a
> very long time and get more worse when client resent the request. As result,
> the cluster looks like hang in and can not response any request include api
> invocation, gfsh comand , etc.
>
>
>
>
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
