Xinyu Liu comments

Repositories
Issues
Comments

Results 6 comments of


                                            Xinyu Liu

Stack trace decoration with Operator name for Samza Runner

Discussed offline and found out the actual use cases is for full TransformName. Suggest encoding that in the OpAdapter layer instead of pushing down to each Op and then only...

SAMZA-2044 - Change handleEndOfStream to avoid OOMem Exceptions

Sure. Happy to take a look!

Stack Trace Decoration for Beam Samza Runner

Run Java PreCommit

Stack Trace Decoration for Beam Samza Runner

Run Java PreCommit

Adds support in Samza Runner to run DoFn.processElement in parallel inside Samza tasks

@mynameborat : pls take a look

Adds support in Samza Runner to run DoFn.processElement in parallel inside Samza tasks

> Does this PR remove the limitation of `job.container.thread.pool.size > 1` and `max.bundle.size > ` existing together? > > If not, then the place where we set `setNumThreadsForProcessElement` to >...