[jira] [Resolved] (SAMZA-2799) Remove worker.opts handling in shell command builder

2024-01-22 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-2799. -- Resolution: Fixed > Remove worker.opts handling in shell command builde

[jira] [Closed] (SAMZA-2799) Remove worker.opts handling in shell command builder

2024-01-22 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian closed SAMZA-2799. > Remove worker.opts handling in shell command builder > --

[jira] [Updated] (SAMZA-2799) Remove worker.opts handling in shell command builder

2024-01-22 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian updated SAMZA-2799: - Description: *Description* Remove _worker.opts_ handling within `ShellCom

[jira] [Created] (SAMZA-2799) Remove worker.opts handling in shell command builder

2024-01-22 Thread Bharath Kumarasubramanian (Jira)
Bharath Kumarasubramanian created SAMZA-2799: Summary: Remove worker.opts handling in shell command builder Key: SAMZA-2799 URL: https://issues.apache.org/jira/browse/SAMZA-2799 Project: Sa

[jira] [Created] (SAMZA-2798) Populate worker.opts in environment variables only if configured

2023-11-22 Thread Bharath Kumarasubramanian (Jira)
Bharath Kumarasubramanian created SAMZA-2798: Summary: Populate worker.opts in environment variables only if configured Key: SAMZA-2798 URL: https://issues.apache.org/jira/browse/SAMZA-2798

[jira] [Updated] (SAMZA-2798) Populate worker.opts in environment variables only if configured

2023-11-22 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian updated SAMZA-2798: - Description: *Description* Populate _worker.opts_ in the environment vari

[jira] [Created] (SAMZA-2796) Introduce config knob for framework thread sub DAG execution

2023-11-15 Thread Bharath Kumarasubramanian (Jira)
Bharath Kumarasubramanian created SAMZA-2796: Summary: Introduce config knob for framework thread sub DAG execution Key: SAMZA-2796 URL: https://issues.apache.org/jira/browse/SAMZA-2796 Pr

[jira] [Created] (SAMZA-2795) Set thread to deamon thread for operator executor service

2023-11-07 Thread Bharath Kumarasubramanian (Jira)
Bharath Kumarasubramanian created SAMZA-2795: Summary: Set thread to deamon thread for operator executor service Key: SAMZA-2795 URL: https://issues.apache.org/jira/browse/SAMZA-2795 Projec

[jira] [Created] (SAMZA-2791) Introduce callback timeout specific to watermark messages

2023-08-15 Thread Bharath Kumarasubramanian (Jira)
Bharath Kumarasubramanian created SAMZA-2791: Summary: Introduce callback timeout specific to watermark messages Key: SAMZA-2791 URL: https://issues.apache.org/jira/browse/SAMZA-2791 Projec

[jira] [Updated] (SAMZA-2790) Cleanup RunLoop constructor explosion

2023-08-15 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian updated SAMZA-2790: - Description: Runloop currently takes in lot of parameters and the constru

[jira] [Assigned] (SAMZA-2790) Cleanup RunLoop constructor explosion

2023-08-15 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian reassigned SAMZA-2790: Assignee: Bharath Kumarasubramanian > Cleanup RunLoop constructor

[jira] [Updated] (SAMZA-2790) Cleanup RunLoop constructor explosion

2023-08-15 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian updated SAMZA-2790: - Summary: Cleanup RunLoop constructor explosion (was: Cleanup runloop DI

[jira] [Created] (SAMZA-2790) Cleanup runloop DI and constructor explosion

2023-08-15 Thread Bharath Kumarasubramanian (Jira)
Bharath Kumarasubramanian created SAMZA-2790: Summary: Cleanup runloop DI and constructor explosion Key: SAMZA-2790 URL: https://issues.apache.org/jira/browse/SAMZA-2790 Project: Samza

[jira] [Created] (SAMZA-2789) Remove cap on intermediate stream partition count for stream mode

2023-08-03 Thread Bharath Kumarasubramanian (Jira)
Bharath Kumarasubramanian created SAMZA-2789: Summary: Remove cap on intermediate stream partition count for stream mode Key: SAMZA-2789 URL: https://issues.apache.org/jira/browse/SAMZA-2789

[jira] [Created] (SAMZA-2782) Clean up container thread pool dependency injection for StreamOperatorTask

2023-05-23 Thread Bharath Kumarasubramanian (Jira)
Bharath Kumarasubramanian created SAMZA-2782: Summary: Clean up container thread pool dependency injection for StreamOperatorTask Key: SAMZA-2782 URL: https://issues.apache.org/jira/browse/SAMZA-2782

[jira] [Updated] (SAMZA-2781) Use framework thread to execute hand-offs and sub-DAG execution

2023-05-23 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian updated SAMZA-2781: - Description: {*}Summary{*}: Use framework thread pool to execute operator

[jira] [Created] (SAMZA-2781) Use framework thread to execute hand-offs and sub-DAG execution

2023-05-23 Thread Bharath Kumarasubramanian (Jira)
Bharath Kumarasubramanian created SAMZA-2781: Summary: Use framework thread to execute hand-offs and sub-DAG execution Key: SAMZA-2781 URL: https://issues.apache.org/jira/browse/SAMZA-2781

[jira] [Updated] (SAMZA-2763) Support worker JVM options for Samza Beam portable mode

2022-10-25 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian updated SAMZA-2763: - Description: {*}Summary{*}: Support JVM options for worker process in Sam

[jira] [Created] (SAMZA-2763) Support worker JVM options for Samza Beam portable mode

2022-10-25 Thread Bharath Kumarasubramanian (Jira)
Bharath Kumarasubramanian created SAMZA-2763: Summary: Support worker JVM options for Samza Beam portable mode Key: SAMZA-2763 URL: https://issues.apache.org/jira/browse/SAMZA-2763 Project:

[jira] [Created] (SAMZA-2747) Standby bug fixes

2022-06-06 Thread Bharath Kumarasubramanian (Jira)
Bharath Kumarasubramanian created SAMZA-2747: Summary: Standby bug fixes Key: SAMZA-2747 URL: https://issues.apache.org/jira/browse/SAMZA-2747 Project: Samza Issue Type: Bug

[jira] [Resolved] (SAMZA-2721) Container should exit with non-zero status code in case of errors during launch

2022-02-14 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-2721. -- Resolution: Fixed > Container should exit with non-zero status code in

[jira] [Assigned] (SAMZA-2721) Container should exit with non-zero status code in case of errors during launch

2022-02-14 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian reassigned SAMZA-2721: Assignee: Bharath Kumarasubramanian > Container should exit with n

[jira] [Commented] (SAMZA-2721) Container should exit with non-zero status code in case of errors during launch

2022-02-09 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489906#comment-17489906 ] Bharath Kumarasubramanian commented on SAMZA-2721: -- Here is the sample c

[jira] [Created] (SAMZA-2721) Container should exit with non-zero status code in case of errors during launch

2022-02-09 Thread Bharath Kumarasubramanian (Jira)
Bharath Kumarasubramanian created SAMZA-2721: Summary: Container should exit with non-zero status code in case of errors during launch Key: SAMZA-2721 URL: https://issues.apache.org/jira/browse/SAMZA-2

[jira] [Updated] (SAMZA-2663) Handle job model expiration and new job model flows for multiple incomplete rebalances

2021-09-07 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian updated SAMZA-2663: - Summary: Handle job model expiration and new job model flows for multiple

[jira] [Commented] (SAMZA-2663) Update active job model to proposed job model on job model expiration

2021-09-07 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17411374#comment-17411374 ] Bharath Kumarasubramanian commented on SAMZA-2663: -- Potential Solutions

[jira] [Assigned] (SAMZA-2663) Update active job model to proposed job model on job model expiration

2021-07-12 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian reassigned SAMZA-2663: Assignee: Bharath Kumarasubramanian > Update active job model to p

[jira] [Created] (SAMZA-2663) Update active job model to proposed job model on job model expiration

2021-07-12 Thread Bharath Kumarasubramanian (Jira)
Bharath Kumarasubramanian created SAMZA-2663: Summary: Update active job model to proposed job model on job model expiration Key: SAMZA-2663 URL: https://issues.apache.org/jira/browse/SAMZA-2663

[jira] [Resolved] (SAMZA-2638) Skip container stop/restart for processors that have same work assignment across rebalances

2021-05-05 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-2638. -- Fix Version/s: 1.7 Resolution: Fixed > Skip container stop/resta

[jira] [Updated] (SAMZA-2633) Rolling deployment/upgrade causes downtime for processors for the entire deployment window

2021-05-05 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian updated SAMZA-2633: - Fix Version/s: 1.7 > Rolling deployment/upgrade causes downtime for proce

[jira] [Resolved] (SAMZA-2633) Rolling deployment/upgrade causes downtime for processors for the entire deployment window

2021-05-05 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-2633. -- Resolution: Fixed > Rolling deployment/upgrade causes downtime for proc

[jira] [Created] (SAMZA-2645) Allow OnNewJobModel as a valid state transition from start

2021-04-02 Thread Bharath Kumarasubramanian (Jira)
Bharath Kumarasubramanian created SAMZA-2645: Summary: Allow OnNewJobModel as a valid state transition from start Key: SAMZA-2645 URL: https://issues.apache.org/jira/browse/SAMZA-2645 Proje

[jira] [Commented] (SAMZA-2633) Rolling deployment/upgrade causes downtime for processors for the entire deployment window

2021-03-23 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306843#comment-17306843 ] Bharath Kumarasubramanian commented on SAMZA-2633: -- We will tackle the c

[jira] [Commented] (SAMZA-2638) Skip container stop/restart for processors that have same work assignment across rebalances

2021-03-23 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306842#comment-17306842 ] Bharath Kumarasubramanian commented on SAMZA-2638: -- We also make changes

[jira] [Created] (SAMZA-2638) Skip container stop/restart for processors that have same work assignment across rebalances

2021-03-22 Thread Bharath Kumarasubramanian (Jira)
Bharath Kumarasubramanian created SAMZA-2638: Summary: Skip container stop/restart for processors that have same work assignment across rebalances Key: SAMZA-2638 URL: https://issues.apache.org/jira/br

[jira] [Created] (SAMZA-2635) Rebalances in standalone doesn't handle DAG changes for restarted processor

2021-03-15 Thread Bharath Kumarasubramanian (Jira)
Bharath Kumarasubramanian created SAMZA-2635: Summary: Rebalances in standalone doesn't handle DAG changes for restarted processor Key: SAMZA-2635 URL: https://issues.apache.org/jira/browse/SAMZA-2635

[jira] [Created] (SAMZA-2633) Rolling deployment/upgrade causes downtime for processors for the entire deployment window

2021-03-12 Thread Bharath Kumarasubramanian (Jira)
Bharath Kumarasubramanian created SAMZA-2633: Summary: Rolling deployment/upgrade causes downtime for processors for the entire deployment window Key: SAMZA-2633 URL: https://issues.apache.org/jira/bro

[jira] [Created] (SAMZA-2632) Processors should only write their own task locality to zookeeper

2021-03-10 Thread Bharath Kumarasubramanian (Jira)
Bharath Kumarasubramanian created SAMZA-2632: Summary: Processors should only write their own task locality to zookeeper Key: SAMZA-2632 URL: https://issues.apache.org/jira/browse/SAMZA-2632

[jira] [Commented] (SAMZA-2439) Remove LocalityManager and container location information from JobModel

2021-02-02 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17277517#comment-17277517 ] Bharath Kumarasubramanian commented on SAMZA-2439: -- Absolutely! > Remov

[jira] [Resolved] (SAMZA-2439) Remove LocalityManager and container location information from JobModel

2021-02-02 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-2439. -- Resolution: Fixed > Remove LocalityManager and container location infor

[jira] [Closed] (SAMZA-2439) Remove LocalityManager and container location information from JobModel

2021-02-02 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian closed SAMZA-2439. > Remove LocalityManager and container location information from JobModel > ---

[jira] [Created] (SAMZA-2615) Metrics for Application Master High Availability

2021-01-06 Thread Bharath Kumarasubramanian (Jira)
Bharath Kumarasubramanian created SAMZA-2615: Summary: Metrics for Application Master High Availability Key: SAMZA-2615 URL: https://issues.apache.org/jira/browse/SAMZA-2615 Project: Samza

[jira] [Resolved] (SAMZA-2609) Data model changes to track lifecycle information of job coordinator

2020-12-08 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-2609. -- Resolution: Fixed > Data model changes to track lifecycle information o

[jira] [Closed] (SAMZA-2609) Data model changes to track lifecycle information of job coordinator

2020-12-08 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian closed SAMZA-2609. > Data model changes to track lifecycle information of job coordinator > --

[jira] [Updated] (SAMZA-2609) Data model changes to track lifecycle information of job coordinator

2020-12-08 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian updated SAMZA-2609: - Fix Version/s: 1.7 > Data model changes to track lifecycle information of

[jira] [Created] (SAMZA-2610) Handle Metadata changes for AM HA orchestration

2020-12-02 Thread Bharath Kumarasubramanian (Jira)
Bharath Kumarasubramanian created SAMZA-2610: Summary: Handle Metadata changes for AM HA orchestration Key: SAMZA-2610 URL: https://issues.apache.org/jira/browse/SAMZA-2610 Project: Samza

[jira] [Created] (SAMZA-2609) Data model changes to track lifecycle information of job coordinator

2020-12-02 Thread Bharath Kumarasubramanian (Jira)
Bharath Kumarasubramanian created SAMZA-2609: Summary: Data model changes to track lifecycle information of job coordinator Key: SAMZA-2609 URL: https://issues.apache.org/jira/browse/SAMZA-2609

[jira] [Closed] (SAMZA-2600) Extract constants for strings used by both AM and container

2020-11-17 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian closed SAMZA-2600. > Extract constants for strings used by both AM and container > ---

[jira] [Resolved] (SAMZA-2600) Extract constants for strings used by both AM and container

2020-11-17 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-2600. -- Resolution: Fixed > Extract constants for strings used by both AM and c

[jira] [Updated] (SAMZA-2600) Extract constants for strings used by both AM and container

2020-11-17 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian updated SAMZA-2600: - Fix Version/s: 1.6 > Extract constants for strings used by both AM and co

[jira] [Updated] (SAMZA-2600) Extract constants for strings used by both AM and container

2020-11-17 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian updated SAMZA-2600: - Description: AM and container share a bunch of string literals but these

[jira] [Updated] (SAMZA-2600) Extract constants for strings used by both AM and container

2020-11-17 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian updated SAMZA-2600: - Summary: Extract constants for strings used by both AM and container (was

[jira] [Updated] (SAMZA-2597) Maintain traversal order for registered operators

2020-10-28 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian updated SAMZA-2597: - Priority: Minor (was: Blocker) > Maintain traversal order for registered

[jira] [Created] (SAMZA-2597) Maintain traversal order for registered operators

2020-10-28 Thread Bharath Kumarasubramanian (Jira)
Bharath Kumarasubramanian created SAMZA-2597: Summary: Maintain traversal order for registered operators Key: SAMZA-2597 URL: https://issues.apache.org/jira/browse/SAMZA-2597 Project: Samza

[jira] [Closed] (SAMZA-1314) Update documentation for batch processing

2020-10-26 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-1314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian closed SAMZA-1314. > Update documentation for batch processing > -

[jira] [Resolved] (SAMZA-1314) Update documentation for batch processing

2020-10-26 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-1314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-1314. -- Resolution: Won't Fix > Update documentation for batch processing > ---

[jira] [Closed] (SAMZA-2211) [Cleanup] Move RunLoop to container package

2020-10-26 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian closed SAMZA-2211. > [Cleanup] Move RunLoop to container package > ---

[jira] [Resolved] (SAMZA-2232) Move StreamOperatorTaskFactory to samza-api

2020-10-26 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-2232. -- Resolution: Fixed > Move StreamOperatorTaskFactory to samza-api > -

[jira] [Closed] (SAMZA-2232) Move StreamOperatorTaskFactory to samza-api

2020-10-26 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian closed SAMZA-2232. > Move StreamOperatorTaskFactory to samza-api > ---

[jira] [Resolved] (SAMZA-2211) [Cleanup] Move RunLoop to container package

2020-10-26 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-2211. -- Resolution: Fixed > [Cleanup] Move RunLoop to container package > -

[jira] [Resolved] (SAMZA-2285) Sample async application for hello-samza

2020-10-26 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-2285. -- Resolution: Fixed > Sample async application for hello-samza >

[jira] [Assigned] (SAMZA-2531) Async Commit is Blocking for Window, Timer & End of Stream

2020-10-26 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian reassigned SAMZA-2531: Assignee: Daniel Chen Can you evaluate this ticket as part of you

[jira] [Updated] (SAMZA-2593) Update task callback to store only necessary fields instead of the message envelope

2020-10-26 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian updated SAMZA-2593: - Fix Version/s: 1.6 > Update task callback to store only necessary fields

[jira] [Resolved] (SAMZA-2593) Update task callback to store only necessary fields instead of the message envelope

2020-10-26 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-2593. -- Resolution: Fixed > Update task callback to store only necessary fields

[jira] [Created] (SAMZA-2594) StorageConfig should dedup store names in getStoreNames()

2020-10-08 Thread Bharath Kumarasubramanian (Jira)
Bharath Kumarasubramanian created SAMZA-2594: Summary: StorageConfig should dedup store names in getStoreNames() Key: SAMZA-2594 URL: https://issues.apache.org/jira/browse/SAMZA-2594 Projec

[jira] [Updated] (SAMZA-2593) Update task callback to store only necessary fields instead of the message envelope

2020-09-23 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian updated SAMZA-2593: - Summary: Update task callback to store only necessary fields instead of th

[jira] [Created] (SAMZA-2593) Update task callback to store only necessary fields instead of entire message envelope

2020-09-23 Thread Bharath Kumarasubramanian (Jira)
Bharath Kumarasubramanian created SAMZA-2593: Summary: Update task callback to store only necessary fields instead of entire message envelope Key: SAMZA-2593 URL: https://issues.apache.org/jira/browse/

[jira] [Updated] (SAMZA-2578) Excessive trimming during transactional state restore

2020-08-18 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian updated SAMZA-2578: - Description: Samza 1.5 enabled transaction state feature by default for a

[jira] [Closed] (SAMZA-2578) Excessive trimming during transactional state restore

2020-08-18 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian closed SAMZA-2578. > Excessive trimming during transactional state restore > -

[jira] [Resolved] (SAMZA-2578) Excessive trimming during transactional state restore

2020-08-18 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-2578. -- Resolution: Fixed > Excessive trimming during transactional state resto

[jira] [Updated] (SAMZA-2578) Excessive trimming during transactional state restore

2020-08-18 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian updated SAMZA-2578: - Fix Version/s: 1.5.1 > Excessive trimming during transactional state rest

[jira] [Created] (SAMZA-2580) Evaluate when to update locality mapping

2020-08-12 Thread Bharath Kumarasubramanian (Jira)
Bharath Kumarasubramanian created SAMZA-2580: Summary: Evaluate when to update locality mapping Key: SAMZA-2580 URL: https://issues.apache.org/jira/browse/SAMZA-2580 Project: Samza

[jira] [Resolved] (SAMZA-2533) Fix DiagnosticsUtil to use configured factory when instantiating the metrics reporter

2020-06-10 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-2533. -- Fix Version/s: 1.6 Resolution: Fixed > Fix DiagnosticsUtil to us

[jira] [Closed] (SAMZA-2533) Fix DiagnosticsUtil to use configured factory when instantiating the metrics reporter

2020-06-10 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian closed SAMZA-2533. > Fix DiagnosticsUtil to use configured factory when instantiating the metrics

[jira] [Closed] (SAMZA-2504) Improve unit test running time for Container Placement Tests

2020-06-08 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian closed SAMZA-2504. > Improve unit test running time for Container Placement Tests > --

[jira] [Resolved] (SAMZA-2504) Improve unit test running time for Container Placement Tests

2020-06-08 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-2504. -- Fix Version/s: 1.5 Resolution: Fixed > Improve unit test running

[jira] [Closed] (SAMZA-2545) Fix testBatchOperationTriggeredByBatchSize flakiness

2020-06-08 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian closed SAMZA-2545. > Fix testBatchOperationTriggeredByBatchSize flakiness > --

[jira] [Resolved] (SAMZA-2545) Fix testBatchOperationTriggeredByBatchSize flakiness

2020-06-08 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-2545. -- Resolution: Fixed > Fix testBatchOperationTriggeredByBatchSize flakines

[jira] [Closed] (SAMZA-2544) OSS gradle test running into OOMs for Container Placements integ tests

2020-06-08 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian closed SAMZA-2544. > OSS gradle test running into OOMs for Container Placements integ tests >

[jira] [Resolved] (SAMZA-2544) OSS gradle test running into OOMs for Container Placements integ tests

2020-06-08 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-2544. -- Resolution: Fixed > OSS gradle test running into OOMs for Container Pla

[jira] [Updated] (SAMZA-2544) OSS gradle test running into OOMs for Container Placements integ tests

2020-06-08 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian updated SAMZA-2544: - Fix Version/s: 1.5 > OSS gradle test running into OOMs for Container Plac

[jira] [Created] (SAMZA-2545) Fix testBatchOperationTriggeredByBatchSize flakiness

2020-06-08 Thread Bharath Kumarasubramanian (Jira)
Bharath Kumarasubramanian created SAMZA-2545: Summary: Fix testBatchOperationTriggeredByBatchSize flakiness Key: SAMZA-2545 URL: https://issues.apache.org/jira/browse/SAMZA-2545 Project: Sa

[jira] [Closed] (SAMZA-2542) Fix integration-tests

2020-06-04 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian closed SAMZA-2542. > Fix integration-tests > - > > Key: SAMZA-

[jira] [Resolved] (SAMZA-2542) Fix integration-tests

2020-06-04 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-2542. -- Resolution: Fixed > Fix integration-tests > - > >

[jira] [Updated] (SAMZA-2442) Update doc/tutorials from config factory to config loader

2020-06-03 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian updated SAMZA-2442: - Fix Version/s: 1.5 > Update doc/tutorials from config factory to config l

[jira] [Resolved] (SAMZA-2442) Update doc/tutorials from config factory to config loader

2020-06-03 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-2442. -- Resolution: Fixed > Update doc/tutorials from config factory to config

[jira] [Closed] (SAMZA-2442) Update doc/tutorials from config factory to config loader

2020-06-03 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian closed SAMZA-2442. > Update doc/tutorials from config factory to config loader > -

[jira] [Resolved] (SAMZA-2537) Fix JobCoordinatorLaunchUtil's execution sequence.

2020-06-02 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-2537. -- Resolution: Fixed > Fix JobCoordinatorLaunchUtil's execution sequence.

[jira] [Closed] (SAMZA-2537) Fix JobCoordinatorLaunchUtil's execution sequence.

2020-06-02 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian closed SAMZA-2537. > Fix JobCoordinatorLaunchUtil's execution sequence. >

[jira] [Resolved] (SAMZA-2478) Add new metrics to track key and value size of records written to RocksDb

2020-05-26 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-2478. -- Fix Version/s: 1.5 Resolution: Fixed > Add new metrics to track

[jira] [Resolved] (SAMZA-2503) Adding retry when getting ssp metadata from kafka

2020-05-26 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-2503. -- Resolution: Fixed > Adding retry when getting ssp metadata from kafka >

[jira] [Resolved] (SAMZA-2507) Samza Sql: Move to Calcite version 1.22.0

2020-05-26 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-2507. -- Fix Version/s: 1.5 Resolution: Fixed > Samza Sql: Move to Calcit

[jira] [Closed] (SAMZA-2477) JobModel isn't updated with latest "task.inputs" if enabled regex topic rewriter

2020-05-26 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian closed SAMZA-2477. > JobModel isn't updated with latest "task.inputs" if enabled regex topic > re

[jira] [Closed] (SAMZA-2527) MetadataStore is not initialized before reading in JobCoordinatorLaunchUtil

2020-05-26 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian closed SAMZA-2527. > MetadataStore is not initialized before reading in JobCoordinatorLaunchUtil >

[jira] [Resolved] (SAMZA-2527) MetadataStore is not initialized before reading in JobCoordinatorLaunchUtil

2020-05-26 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-2527. -- Fix Version/s: 1.5 Resolution: Fixed > MetadataStore is not init

[jira] [Resolved] (SAMZA-2506) Inconsistent end of stream semantics in SystemStreamPartitionMetadata

2020-05-26 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-2506. -- Fix Version/s: 1.5 Resolution: Fixed > Inconsistent end of strea

[jira] [Closed] (SAMZA-2506) Inconsistent end of stream semantics in SystemStreamPartitionMetadata

2020-05-26 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian closed SAMZA-2506. > Inconsistent end of stream semantics in SystemStreamPartitionMetadata > -

[jira] [Closed] (SAMZA-2493) Keep checkpoint manager consumer open for repeated polling

2020-05-26 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian closed SAMZA-2493. > Keep checkpoint manager consumer open for repeated polling >

[jira] [Resolved] (SAMZA-2493) Keep checkpoint manager consumer open for repeated polling

2020-05-26 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian resolved SAMZA-2493. -- Fix Version/s: 1.5 Resolution: Fixed > Keep checkpoint manager c

[jira] [Closed] (SAMZA-2419) Duplicate store cleaning in TransactionalStateTaskRestoreManager

2020-05-26 Thread Bharath Kumarasubramanian (Jira)
[ https://issues.apache.org/jira/browse/SAMZA-2419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bharath Kumarasubramanian closed SAMZA-2419. > Duplicate store cleaning in TransactionalStateTaskRestoreManager > --

  1   2   3   4   >