[
https://issues.apache.org/jira/browse/IMPALA-12968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Csaba Ringhofer updated IMPALA-12968:
-------------------------------------
Description:
When a producer fragment sends no rows and finishes before the receiver is
initialized the EndDataStream rpc is stored as early sender and is responded
when the receiver is registered.
[https://github.com/apache/impala/blob/effc9df933b46eb5b0acf55a858606415425505f/be/src/runtime/krpc-data-stream-mgr.cc#L150]
While it is important to store the information that the EOS has happened to
unregister the sender from the receiver, the RPC itself could be responded
right after it was stored in the early sender map.
was:
When a producer fragment sends no rows and finishes before the receiver is
initialized te e EndDataStream rpc is stored as early sender and is responded
when the receiver is registered.
[https://github.com/apache/impala/blob/effc9df933b46eb5b0acf55a858606415425505f/be/src/runtime/krpc-data-stream-mgr.cc#L150]
While it is important to store the information that the EOS has happened to
unregister the sender from the receiver, the RPC itself could be responded
right after it was stored in the early sender map.
> Early EndDataStream RPC could be responded earlier
> --------------------------------------------------
>
> Key: IMPALA-12968
> URL: https://issues.apache.org/jira/browse/IMPALA-12968
> Project: IMPALA
> Issue Type: Improvement
> Components: Backend
> Reporter: Csaba Ringhofer
> Priority: Minor
> Labels: krpc
>
> When a producer fragment sends no rows and finishes before the receiver is
> initialized the EndDataStream rpc is stored as early sender and is responded
> when the receiver is registered.
> [https://github.com/apache/impala/blob/effc9df933b46eb5b0acf55a858606415425505f/be/src/runtime/krpc-data-stream-mgr.cc#L150]
> While it is important to store the information that the EOS has happened to
> unregister the sender from the receiver, the RPC itself could be responded
> right after it was stored in the early sender map.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-all-unsubscr...@impala.apache.org
For additional commands, e-mail: issues-all-h...@impala.apache.org
