[jira] [Commented] (SAMZA-2064) Cleanup dist repo releases

[ https://issues.apache.org/jira/browse/SAMZA-2064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16860268#comment-16860268 ] Yi Pan (Data Infrastructure) commented on SAMZA-2064: - [~pmaheshwari], the ask is to

[jira] [Assigned] (SAMZA-1935) Refactor TaskContextImpl to not include access to objects that are only used internally

[ https://issues.apache.org/jira/browse/SAMZA-1935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) reassigned SAMZA-1935: --- Assignee: Viktor > Refactor TaskContextImpl to not include

[jira] [Commented] (SAMZA-1935) Refactor TaskContextImpl to not include access to objects that are only used internally

[ https://issues.apache.org/jira/browse/SAMZA-1935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16775542#comment-16775542 ] Yi Pan (Data Infrastructure) commented on SAMZA-1935: - [~Wushen] and

[jira] [Created] (SAMZA-2064) Cleanup dist repo releases

Yi Pan (Data Infrastructure) created SAMZA-2064: --- Summary: Cleanup dist repo releases Key: SAMZA-2064 URL: https://issues.apache.org/jira/browse/SAMZA-2064 Project: Samza Issue

[jira] [Assigned] (SAMZA-1878) NPE when RocksDB restores from changelog topic

[ https://issues.apache.org/jira/browse/SAMZA-1878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) reassigned SAMZA-1878: --- Assignee: (was: Yi Pan (Data Infrastructure)) > NPE

[jira] [Assigned] (SAMZA-1878) NPE when RocksDB restores from changelog topic

[ https://issues.apache.org/jira/browse/SAMZA-1878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) reassigned SAMZA-1878: --- Assignee: Yi Pan (Data Infrastructure) > NPE when RocksDB

[jira] [Created] (SAMZA-2063) Update landing page to the latest 1.0 release

Yi Pan (Data Infrastructure) created SAMZA-2063: --- Summary: Update landing page to the latest 1.0 release Key: SAMZA-2063 URL: https://issues.apache.org/jira/browse/SAMZA-2063 Project:

[jira] [Created] (SAMZA-2062) Samza online doc page missing download links for 1.0

Yi Pan (Data Infrastructure) created SAMZA-2062: --- Summary: Samza online doc page missing download links for 1.0 Key: SAMZA-2062 URL: https://issues.apache.org/jira/browse/SAMZA-2062

[jira] [Commented] (SAMZA-1918) Add new Kafka connector documentation

[ https://issues.apache.org/jira/browse/SAMZA-1918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16742574#comment-16742574 ] Yi Pan (Data Infrastructure) commented on SAMZA-1918: - [~dnishimura], close this one?

[jira] [Commented] (SAMZA-1924) Documentation for case-studies and release-notes

[ https://issues.apache.org/jira/browse/SAMZA-1924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16742573#comment-16742573 ] Yi Pan (Data Infrastructure) commented on SAMZA-1924: - [~bharathkk], can we close

[jira] [Commented] (SAMZA-1911) Add documentation for quick start.

[ https://issues.apache.org/jira/browse/SAMZA-1911?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16742569#comment-16742569 ] Yi Pan (Data Infrastructure) commented on SAMZA-1911: - [~xinyu] can we close this one

[jira] [Commented] (SAMZA-1961) Samza 1.0 Doc cleanup

[ https://issues.apache.org/jira/browse/SAMZA-1961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16742568#comment-16742568 ] Yi Pan (Data Infrastructure) commented on SAMZA-1961: - [~Sanil] can we close this one

[jira] [Commented] (SAMZA-1776) Refactor KafkaSystemConsumer to remove the usage of deprecated SimpleConsumer client

[ https://issues.apache.org/jira/browse/SAMZA-1776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16677431#comment-16677431 ] Yi Pan (Data Infrastructure) commented on SAMZA-1776: - [~zhjohnzzh], thanks for

[jira] [Resolved] (SAMZA-1836) StreamApplicationIntegrationTest and TestLocalTableWithSideInput fails due to wrong system configured

[ https://issues.apache.org/jira/browse/SAMZA-1836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) resolved SAMZA-1836. - Resolution: Fixed Assignee: Sanil Jain >

[jira] [Commented] (SAMZA-1836) StreamApplicationIntegrationTest and TestLocalTableWithSideInput fails due to wrong system configured

[ https://issues.apache.org/jira/browse/SAMZA-1836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16648219#comment-16648219 ] Yi Pan (Data Infrastructure) commented on SAMZA-1836: - This is fixed with SAMZA-1818.

[jira] [Updated] (SAMZA-1371) Some Samza Containers get stuck at "Starting BrokerProxy for hostname:portnum" while others seem to be fine

[ https://issues.apache.org/jira/browse/SAMZA-1371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-1371: Fix Version/s: 1.0 > Some Samza Containers get stuck at "Starting

[jira] [Commented] (SAMZA-1371) Some Samza Containers get stuck at "Starting BrokerProxy for hostname:portnum" while others seem to be fine

[ https://issues.apache.org/jira/browse/SAMZA-1371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16646015#comment-16646015 ] Yi Pan (Data Infrastructure) commented on SAMZA-1371: - [~zhjohnzzh], please see

[jira] [Commented] (SAMZA-1776) Refactor KafkaSystemConsumer to remove the usage of deprecated SimpleConsumer client

[ https://issues.apache.org/jira/browse/SAMZA-1776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16646012#comment-16646012 ] Yi Pan (Data Infrastructure) commented on SAMZA-1776: - Hey, [~zhjohnzzh], there are

[jira] [Created] (SAMZA-1940) MetricsReporterFactory may need to have access to non-serializable dependencies to create MetricsReporter

Yi Pan (Data Infrastructure) created SAMZA-1940: --- Summary: MetricsReporterFactory may need to have access to non-serializable dependencies to create MetricsReporter Key: SAMZA-1940 URL:

[jira] [Resolved] (SAMZA-1814) System, Stream and Table configuration generation for low-level task application

[ https://issues.apache.org/jira/browse/SAMZA-1814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) resolved SAMZA-1814. - Resolution: Fixed > System, Stream and Table configuration

[jira] [Commented] (SAMZA-1814) System, Stream and Table configuration generation for low-level task application

[ https://issues.apache.org/jira/browse/SAMZA-1814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16635846#comment-16635846 ] Yi Pan (Data Infrastructure) commented on SAMZA-1814: - PR 642 is merged and

[jira] [Created] (SAMZA-1928) ExecutionPlanner should generate job.name and job.id from app.name and app.id

Yi Pan (Data Infrastructure) created SAMZA-1928: --- Summary: ExecutionPlanner should generate job.name and job.id from app.name and app.id Key: SAMZA-1928 URL:

[jira] [Created] (SAMZA-1895) Repeated definition of StreamConfig configuration prefix and keys should not be allowed

Yi Pan (Data Infrastructure) created SAMZA-1895: --- Summary: Repeated definition of StreamConfig configuration prefix and keys should not be allowed Key: SAMZA-1895 URL:

[jira] [Updated] (SAMZA-1895) Repeated definition of StreamConfig configuration prefix and keys should not be allowed

[ https://issues.apache.org/jira/browse/SAMZA-1895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-1895: Labels: newbie (was: ) > Repeated definition of StreamConfig

[jira] [Commented] (SAMZA-1894) Too many redundant definition of system configuration variables

[ https://issues.apache.org/jira/browse/SAMZA-1894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16622837#comment-16622837 ] Yi Pan (Data Infrastructure) commented on SAMZA-1894: - One more note: since

[jira] [Created] (SAMZA-1894) Too many redundant definition of system configuration variables

Yi Pan (Data Infrastructure) created SAMZA-1894: --- Summary: Too many redundant definition of system configuration variables Key: SAMZA-1894 URL: https://issues.apache.org/jira/browse/SAMZA-1894

[jira] [Created] (SAMZA-1893) JobNodeConfigurationGenerator should only generate configurations for operators, streams, stores, and tables that are reachable by a JobNode

Yi Pan (Data Infrastructure) created SAMZA-1893: --- Summary: JobNodeConfigurationGenerator should only generate configurations for operators, streams, stores, and tables that are reachable by a JobNode Key:

[jira] [Resolved] (SAMZA-1789) Refactor the application runtime classes so that we have a unified pattern to write and launch applications in high- and low-level APIs in YARN and standalone

[ https://issues.apache.org/jira/browse/SAMZA-1789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) resolved SAMZA-1789. - Resolution: Fixed > Refactor the application runtime classes so

[jira] [Resolved] (SAMZA-1837) Fix TestLocalTableWithSideInputs failures.

[ https://issues.apache.org/jira/browse/SAMZA-1837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) resolved SAMZA-1837. - Resolution: Fixed Fix Version/s: 1.0 > Fix

[jira] [Assigned] (SAMZA-1814) System, Stream and Table configuration generation for low-level task application

[ https://issues.apache.org/jira/browse/SAMZA-1814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) reassigned SAMZA-1814: --- Assignee: Yi Pan (Data Infrastructure) > System, Stream and

[jira] [Updated] (SAMZA-1814) System, Stream and Table configuration generation for low-level task application

[ https://issues.apache.org/jira/browse/SAMZA-1814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-1814: Summary: System, Stream and Table configuration generation for

[jira] [Commented] (SAMZA-1814) System, Stream and Table configuration generation for low-level task application

[ https://issues.apache.org/jira/browse/SAMZA-1814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16606537#comment-16606537 ] Yi Pan (Data Infrastructure) commented on SAMZA-1814: - This is to track the

[jira] [Assigned] (SAMZA-1714) Creating shared context factory for shared context objects in high-level API

[ https://issues.apache.org/jira/browse/SAMZA-1714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) reassigned SAMZA-1714: --- Assignee: Cameron Lee > Creating shared context factory for

[jira] [Assigned] (SAMZA-1815) Use TableDescriptors to generate configurations during planning phase

[ https://issues.apache.org/jira/browse/SAMZA-1815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) reassigned SAMZA-1815: --- Assignee: (was: Yi Pan (Data Infrastructure)) > Use

[jira] [Assigned] (SAMZA-1815) Use TableDescriptors to generate configurations during planning phase

[ https://issues.apache.org/jira/browse/SAMZA-1815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) reassigned SAMZA-1815: --- Assignee: Yi Pan (Data Infrastructure) > Use

[jira] [Assigned] (SAMZA-1818) TestRunner should consolidate all constructor to use SamzaApplication and config

[ https://issues.apache.org/jira/browse/SAMZA-1818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) reassigned SAMZA-1818: --- Assignee: Sanil Jain > TestRunner should consolidate all

[jira] [Created] (SAMZA-1842) Need consistent logic to calculate input, output, and intermediate streams in high and low-level API applications

Yi Pan (Data Infrastructure) created SAMZA-1842: --- Summary: Need consistent logic to calculate input, output, and intermediate streams in high and low-level API applications Key: SAMZA-1842 URL:

[jira] [Created] (SAMZA-1841) Add broadcast feature to InputDescriptor

Yi Pan (Data Infrastructure) created SAMZA-1841: --- Summary: Add broadcast feature to InputDescriptor Key: SAMZA-1841 URL: https://issues.apache.org/jira/browse/SAMZA-1841 Project: Samza

[jira] [Created] (SAMZA-1839) Cleanup the old constructors of StreamProcessor

Yi Pan (Data Infrastructure) created SAMZA-1839: --- Summary: Cleanup the old constructors of StreamProcessor Key: SAMZA-1839 URL: https://issues.apache.org/jira/browse/SAMZA-1839 Project:

[jira] [Commented] (SAMZA-1834) Too many IDs for processors in Samza

[ https://issues.apache.org/jira/browse/SAMZA-1834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16599445#comment-16599445 ] Yi Pan (Data Infrastructure) commented on SAMZA-1834: - One more: the configuration

[jira] [Commented] (SAMZA-1836) StreamApplicationIntegrationTest and TestLocalTableWithSideInput fails due to wrong system configured

[ https://issues.apache.org/jira/browse/SAMZA-1836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16599224#comment-16599224 ] Yi Pan (Data Infrastructure) commented on SAMZA-1836: - Chat with [~pmaheshwari] more

[jira] [Updated] (SAMZA-1818) TestRunner should consolidate all constructor to use SamzaApplication and config

[ https://issues.apache.org/jira/browse/SAMZA-1818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-1818: Summary: TestRunner should consolidate all constructor to use

[jira] [Resolved] (SAMZA-1813) ApplicationRunner should use Planner generated configs for StreamManager

[ https://issues.apache.org/jira/browse/SAMZA-1813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) resolved SAMZA-1813. - Resolution: Fixed Fix Version/s: 1.0 > ApplicationRunner

[jira] [Created] (SAMZA-1836) StreamApplicationIntegrationTest and TestLocalTableWithSideInput fails due to wrong system configured

Yi Pan (Data Infrastructure) created SAMZA-1836: --- Summary: StreamApplicationIntegrationTest and TestLocalTableWithSideInput fails due to wrong system configured Key: SAMZA-1836 URL:

[jira] [Created] (SAMZA-1835) Consolidate all processorId generation code to StreamProcessor

Yi Pan (Data Infrastructure) created SAMZA-1835: --- Summary: Consolidate all processorId generation code to StreamProcessor Key: SAMZA-1835 URL: https://issues.apache.org/jira/browse/SAMZA-1835

[jira] [Commented] (SAMZA-1811) Consolidate the ExecutionPlanner to handle both high-level DAG and low-level single node jobs

[ https://issues.apache.org/jira/browse/SAMZA-1811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16597877#comment-16597877 ] Yi Pan (Data Infrastructure) commented on SAMZA-1811: - As a tentative solution, job

[jira] [Created] (SAMZA-1834) Too many IDs for processors in Samza

Yi Pan (Data Infrastructure) created SAMZA-1834: --- Summary: Too many IDs for processors in Samza Key: SAMZA-1834 URL: https://issues.apache.org/jira/browse/SAMZA-1834 Project: Samza

[jira] [Created] (SAMZA-1833) StreamProcessor should not implicitly create JobCoordinator in the constructor

Yi Pan (Data Infrastructure) created SAMZA-1833: --- Summary: StreamProcessor should not implicitly create JobCoordinator in the constructor Key: SAMZA-1833 URL:

[jira] [Created] (SAMZA-1832) Race condition between SamzaContainerListener.onContainerFailure(t) and StreamProcessor.stop()

Yi Pan (Data Infrastructure) created SAMZA-1832: --- Summary: Race condition between SamzaContainerListener.onContainerFailure(t) and StreamProcessor.stop() Key: SAMZA-1832 URL:

[jira] [Created] (SAMZA-1831) Removing Whitebox usage in TestQueryTranslator

Yi Pan (Data Infrastructure) created SAMZA-1831: --- Summary: Removing Whitebox usage in TestQueryTranslator Key: SAMZA-1831 URL: https://issues.apache.org/jira/browse/SAMZA-1831 Project:

[jira] [Created] (SAMZA-1830) TestRepartitionJoinWindowApp should call runner.status() to determine whether the test is successful or not

Yi Pan (Data Infrastructure) created SAMZA-1830: --- Summary: TestRepartitionJoinWindowApp should call runner.status() to determine whether the test is successful or not Key: SAMZA-1830 URL:

[jira] [Created] (SAMZA-1828) MessageStreamAssert check passed but throwing exception

Yi Pan (Data Infrastructure) created SAMZA-1828: --- Summary: MessageStreamAssert check passed but throwing exception Key: SAMZA-1828 URL: https://issues.apache.org/jira/browse/SAMZA-1828

[jira] [Updated] (SAMZA-1804) Allow configuring input and output system and stream properties in code

[ https://issues.apache.org/jira/browse/SAMZA-1804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-1804: Fix Version/s: 1.0 > Allow configuring input and output system and

[jira] [Commented] (SAMZA-1822) Samza 0.14.1 not correctly handling OffsetOutOfRangeException exception

[ https://issues.apache.org/jira/browse/SAMZA-1822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16594266#comment-16594266 ] Yi Pan (Data Infrastructure) commented on SAMZA-1822: - Added a unit test, merged and

[jira] [Updated] (SAMZA-1826) Unit test for table tests failed with assert errors on PageViewToProfileJoinFunction

[ https://issues.apache.org/jira/browse/SAMZA-1826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-1826: Fix Version/s: 1.0 > Unit test for table tests failed with assert

[jira] [Resolved] (SAMZA-1826) Unit test for table tests failed with assert errors on PageViewToProfileJoinFunction

[ https://issues.apache.org/jira/browse/SAMZA-1826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) resolved SAMZA-1826. - Resolution: Fixed > Unit test for table tests failed with assert

[jira] [Created] (SAMZA-1826) Unit test for table tests failed with assert errors on PageViewToProfileJoinFunction

Yi Pan (Data Infrastructure) created SAMZA-1826: --- Summary: Unit test for table tests failed with assert errors on PageViewToProfileJoinFunction Key: SAMZA-1826 URL:

[jira] [Created] (SAMZA-1819) Deprecate ThreadJobFactory and ProcessJobFactory

Yi Pan (Data Infrastructure) created SAMZA-1819: --- Summary: Deprecate ThreadJobFactory and ProcessJobFactory Key: SAMZA-1819 URL: https://issues.apache.org/jira/browse/SAMZA-1819

[jira] [Created] (SAMZA-1818) TestRunner should consolidate all constructor to use ApplicationBase and config

Yi Pan (Data Infrastructure) created SAMZA-1818: --- Summary: TestRunner should consolidate all constructor to use ApplicationBase and config Key: SAMZA-1818 URL:

[jira] [Created] (SAMZA-1814) System, Stream and Table configuration generation should use a consistent pattern in the planner

Yi Pan (Data Infrastructure) created SAMZA-1814: --- Summary: System, Stream and Table configuration generation should use a consistent pattern in the planner Key: SAMZA-1814 URL:

[jira] [Created] (SAMZA-1811) Consolidate the ExecutionPlanner to handle both high-level DAG and low-level single node jobs

Yi Pan (Data Infrastructure) created SAMZA-1811: --- Summary: Consolidate the ExecutionPlanner to handle both high-level DAG and low-level single node jobs Key: SAMZA-1811 URL:

[jira] [Resolved] (SAMZA-1179) Documentation of ApplicationRunner

[ https://issues.apache.org/jira/browse/SAMZA-1179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) resolved SAMZA-1179. - Resolution: Fixed Closing as this is superseded by

[jira] [Resolved] (SAMZA-1218) Support StreamTaskFactory and AsyncStreamTaskFactory in LocalApplicationRunner

[ https://issues.apache.org/jira/browse/SAMZA-1218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) resolved SAMZA-1218. - Resolution: Duplicate Superseded by SAMZA-1789 > Support

[jira] [Resolved] (SAMZA-1130) ApplicationRunner for running StreamApplication

[ https://issues.apache.org/jira/browse/SAMZA-1130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) resolved SAMZA-1130. - Resolution: Duplicate Superseded by SAMZA-1789 >

[jira] [Created] (SAMZA-1789) Refactor the application runtime classes so that we have a unified pattern to write and launch applications in high- and low-level APIs in YARN and standalone

Yi Pan (Data Infrastructure) created SAMZA-1789: --- Summary: Refactor the application runtime classes so that we have a unified pattern to write and launch applications in high- and low-level APIs in YARN and standalone

[jira] [Commented] (SAMZA-1371) Some Samza Containers get stuck at "Starting BrokerProxy for hostname:portnum" while others seem to be fine

[ https://issues.apache.org/jira/browse/SAMZA-1371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16550095#comment-16550095 ] Yi Pan (Data Infrastructure) commented on SAMZA-1371: - [~hao.song], we just did an

[jira] [Created] (SAMZA-1776) Refactor KafkaSystemConsumer to remove the usage of deprecated SimpleConsumer client

Yi Pan (Data Infrastructure) created SAMZA-1776: --- Summary: Refactor KafkaSystemConsumer to remove the usage of deprecated SimpleConsumer client Key: SAMZA-1776 URL:

[jira] [Resolved] (SAMZA-1509) Upgrade Kafka client version to 0.11 in Samza

[ https://issues.apache.org/jira/browse/SAMZA-1509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) resolved SAMZA-1509. - Resolution: Fixed > Upgrade Kafka client version to 0.11 in

[jira] [Commented] (SAMZA-1371) Some Samza Containers get stuck at "Starting BrokerProxy for hostname:portnum" while others seem to be fine

[ https://issues.apache.org/jira/browse/SAMZA-1371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16522544#comment-16522544 ] Yi Pan (Data Infrastructure) commented on SAMZA-1371: - Hi, [~zhjohnzzh], apologize

[jira] [Commented] (SAMZA-1371) Some Samza Containers get stuck at "Starting BrokerProxy for hostname:portnum" while others seem to be fine

[ https://issues.apache.org/jira/browse/SAMZA-1371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503619#comment-16503619 ] Yi Pan (Data Infrastructure) commented on SAMZA-1371: - [~zhjohnzzh] thanks for the

[jira] [Assigned] (SAMZA-929) Support AM restart in Kerberos secured YARN after the original token in launch context expires

[ https://issues.apache.org/jira/browse/SAMZA-929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) reassigned SAMZA-929: -- Assignee: Apoorva Sareen > Support AM restart in Kerberos

[jira] [Assigned] (SAMZA-929) Support AM restart in Kerberos secured YARN after the original token in launch context expires

[ https://issues.apache.org/jira/browse/SAMZA-929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) reassigned SAMZA-929: -- Assignee: (was: Chen Song) > Support AM restart in

[jira] [Updated] (SAMZA-1130) ApplicationRunner for running StreamApplication

[ https://issues.apache.org/jira/browse/SAMZA-1130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-1130: Fix Version/s: (was: 0.13.0) 0.15.0 >

[jira] [Commented] (SAMZA-929) Support AM restart in Kerberos secured YARN after the original token in launch context expires

[ https://issues.apache.org/jira/browse/SAMZA-929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16500545#comment-16500545 ] Yi Pan (Data Infrastructure) commented on SAMZA-929: [~apoorva.sar...@gmail.com]

[jira] [Resolved] (SAMZA-1659) Making user functions serializable in high-level APIs

[ https://issues.apache.org/jira/browse/SAMZA-1659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) resolved SAMZA-1659. - Resolution: Fixed > Making user functions serializable in

[jira] [Commented] (SAMZA-1665) Fix race condition when stopping StreamProcessor.

[ https://issues.apache.org/jira/browse/SAMZA-1665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16490404#comment-16490404 ] Yi Pan (Data Infrastructure) commented on SAMZA-1665: - >From the above, there are

[jira] [Commented] (SAMZA-1665) Fix race condition when stopping StreamProcessor.

[ https://issues.apache.org/jira/browse/SAMZA-1665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16490386#comment-16490386 ] Yi Pan (Data Infrastructure) commented on SAMZA-1665: - There is another sequence in

[jira] [Assigned] (SAMZA-1715) Unit test for Kafka admin deletedMessagesCalled() fail

[ https://issues.apache.org/jira/browse/SAMZA-1715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) reassigned SAMZA-1715: --- Assignee: Yi Pan (Data Infrastructure) > Unit test for Kafka

[jira] [Resolved] (SAMZA-1715) Unit test for Kafka admin deletedMessagesCalled() fail

[ https://issues.apache.org/jira/browse/SAMZA-1715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) resolved SAMZA-1715. - Resolution: Fixed > Unit test for Kafka admin

[jira] [Created] (SAMZA-1716) merge-pull-request script does not close JIRA ticket automatically

Yi Pan (Data Infrastructure) created SAMZA-1716: --- Summary: merge-pull-request script does not close JIRA ticket automatically Key: SAMZA-1716 URL: https://issues.apache.org/jira/browse/SAMZA-1716

[jira] [Resolved] (SAMZA-1705) Switch to use snapshot in iterable impl of RocksDb

[ https://issues.apache.org/jira/browse/SAMZA-1705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) resolved SAMZA-1705. - Resolution: Fixed > Switch to use snapshot in iterable impl of

[jira] [Resolved] (SAMZA-1711) Reenable existing standalone integration tests.

[ https://issues.apache.org/jira/browse/SAMZA-1711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) resolved SAMZA-1711. - Resolution: Fixed > Reenable existing standalone integration

[jira] [Updated] (SAMZA-1700) Clean up SystemAdmins instance creation flows

[ https://issues.apache.org/jira/browse/SAMZA-1700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-1700: Fix Version/s: 0.15.0 > Clean up SystemAdmins instance creation

[jira] [Resolved] (SAMZA-1700) Clean up SystemAdmins instance creation flows

[ https://issues.apache.org/jira/browse/SAMZA-1700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) resolved SAMZA-1700. - Resolution: Fixed > Clean up SystemAdmins instance creation flows

[jira] [Resolved] (SAMZA-1670) When fetching a newest offset for a partition, also prefetch and cache the newest offsets for other partitions on the container

[ https://issues.apache.org/jira/browse/SAMZA-1670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) resolved SAMZA-1670. - Resolution: Fixed > When fetching a newest offset for a

[jira] [Assigned] (SAMZA-1670) When fetching a newest offset for a partition, also prefetch and cache the newest offsets for other partitions on the container

[ https://issues.apache.org/jira/browse/SAMZA-1670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) reassigned SAMZA-1670: --- Assignee: Cameron Lee > When fetching a newest offset for a

[jira] [Updated] (SAMZA-1713) :rat FAILED to Build

[ https://issues.apache.org/jira/browse/SAMZA-1713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-1713: Fix Version/s: 0.15.0 > :rat FAILED to Build >

[jira] [Updated] (SAMZA-1713) :rat FAILED to Build

[ https://issues.apache.org/jira/browse/SAMZA-1713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-1713: Affects Version/s: (was: 0.14.0) 0.15.0

[jira] [Updated] (SAMZA-1670) When fetching a newest offset for a partition, also prefetch and cache the newest offsets for other partitions on the container

[ https://issues.apache.org/jira/browse/SAMZA-1670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-1670: Fix Version/s: 0.15.0 > When fetching a newest offset for a

[jira] [Created] (SAMZA-1715) Unit test for Kafka admin deletedMessagesCalled() fail

Yi Pan (Data Infrastructure) created SAMZA-1715: --- Summary: Unit test for Kafka admin deletedMessagesCalled() fail Key: SAMZA-1715 URL: https://issues.apache.org/jira/browse/SAMZA-1715

[jira] [Updated] (SAMZA-1714) Creating shared context factory for shared context objects in high-level API

[ https://issues.apache.org/jira/browse/SAMZA-1714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-1714: Summary: Creating shared context factory for shared context objects

[jira] [Created] (SAMZA-1714) Creating shared context factory for shared context in high-level API

Yi Pan (Data Infrastructure) created SAMZA-1714: --- Summary: Creating shared context factory for shared context in high-level API Key: SAMZA-1714 URL: https://issues.apache.org/jira/browse/SAMZA-1714

[jira] [Assigned] (SAMZA-1659) Making user functions serializable in high-level APIs

[ https://issues.apache.org/jira/browse/SAMZA-1659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) reassigned SAMZA-1659: --- Assignee: Yi Pan (Data Infrastructure) > Making user

[jira] [Commented] (SAMZA-1371) Some Samza Containers get stuck at "Starting BrokerProxy for hostname:portnum" while others seem to be fine

[ https://issues.apache.org/jira/browse/SAMZA-1371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16460560#comment-16460560 ] Yi Pan (Data Infrastructure) commented on SAMZA-1371: - [~jagadish1...@gmail.com] in

[jira] [Commented] (SAMZA-1371) Some Samza Containers get stuck at "Starting BrokerProxy for hostname:portnum" while others seem to be fine

[ https://issues.apache.org/jira/browse/SAMZA-1371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16459874#comment-16459874 ] Yi Pan (Data Infrastructure) commented on SAMZA-1371: - Hi, [~zhjohnzzh], thanks a lot

[jira] [Assigned] (SAMZA-1476) Flaky test: TestStatefulTask testShouldStartAndRestore

[ https://issues.apache.org/jira/browse/SAMZA-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) reassigned SAMZA-1476: --- Assignee: Ahmed Abdul Hamid > Flaky test: TestStatefulTask

[jira] [Updated] (SAMZA-1659) Making user functions serializable in high-level APIs

[ https://issues.apache.org/jira/browse/SAMZA-1659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) updated SAMZA-1659: Attachment: Serialization of OperatorSpec.pdf > Making user

[jira] [Created] (SAMZA-1659) Making user functions serializable in high-level APIs

Yi Pan (Data Infrastructure) created SAMZA-1659: --- Summary: Making user functions serializable in high-level APIs Key: SAMZA-1659 URL: https://issues.apache.org/jira/browse/SAMZA-1659

[jira] [Commented] (SAMZA-1371) Some Samza Containers get stuck at "Starting BrokerProxy for hostname:portnum" while others seem to be fine

[ https://issues.apache.org/jira/browse/SAMZA-1371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16419893#comment-16419893 ] Yi Pan (Data Infrastructure) commented on SAMZA-1371: - [~jeremyvdw], we have updated

[jira] [Closed] (SAMZA-1599) AsyncRunLoop Slow When Some Partitions Are Empty

[ https://issues.apache.org/jira/browse/SAMZA-1599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Pan (Data Infrastructure) closed SAMZA-1599. --- PR #436 is merged and submitted. > AsyncRunLoop Slow When Some

  1   2   3   4   5   6   7   8   >