You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Tzu-Li (Gordon) Tai (Jira)" <ji...@apache.org> on 2020/05/12 06:23:00 UTC

[jira] [Comment Edited] (FLINK-17611) Support unix domain sockets for sidecar communication in Stateful Functions

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

Tzu-Li (Gordon) Tai edited comment on FLINK-17611 at 5/12/20, 6:22 AM:
-----------------------------------------------------------------------

I like this a lot, +1. And thanks a lot for bringing this up + willing to implement this!

For starters, I'd suggest first looking at how to implement a new {{kind}} of request reply protocol based remote function. For that, I suggest taking a look at the {{JsonModule}} class. In there, you'll find the {{configureFunctions}} method which figures out what functions to provide based on the configured kind. From there, you'll also be able to figure out how the HTTP-based request-reply protocol is implemented, as a reference example.

In any case, lets also wait for [~igal] to chime in as he'll have the best judgement here.


was (Author: tzulitai):
I like this a lot, +1. And thanks a lot for bringing this up + willing to implement this!

For starters, I'd suggest first looking at how to implement a new {{kind}} of request reply protocol based remote function. For that, I suggest taking a look at the {{JsonModule}} class. In there, you'll find the {{configureFunctions}} method which figures out what functions to provide based on the configured kind.

In any case, lets also wait for [~igal] to chime in as he'll have the best judgement here.

> Support unix domain sockets for sidecar communication in Stateful Functions
> ---------------------------------------------------------------------------
>
>                 Key: FLINK-17611
>                 URL: https://issues.apache.org/jira/browse/FLINK-17611
>             Project: Flink
>          Issue Type: New Feature
>          Components: Stateful Functions
>            Reporter: Francesco Guardiani
>            Priority: Major
>   Original Estimate: 48h
>  Remaining Estimate: 48h
>
> Hi all,
> I'm quite new to this project and I've started investigating its potential usage in Kubernetes.
> I've found in past that using Unix Domain Sockets across several containers in the same pod gives an interesting performance boost and drastically reduces the overhead of going through the network stack. Given that containers in a pod run in the same host, it's perfectly reasonable to let them communicate through unix domain sockets.
> If you're interested in such feature, I'm more than willing to help implementing that, given that I need a few pointers where to start from



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