[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&focusedCommentId=16860268#comment-16860268 ] Yi Pan (Data Infrastructure) commented on SAMZA-2064: - [~pmaheshwari]

[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&focusedCommentId=16819313#comment-16819313 ] Yi Pan (Data Infrastructure) commented on SAMZA-2064: - [~xinyu] and [

[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 a

[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&focusedCommentId=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 when

[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 re

[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: Sam

[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 Proje

[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&focusedCommentId=16742574#comment-16742574 ] Yi Pan (Data Infrastructure) commented on SAMZA-1918: - [~dnishimura],

[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&focusedCommentId=16742573#comment-16742573 ] Yi Pan (Data Infrastructure) commented on SAMZA-1924: - [~bharathkk],

[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&focusedCommentId=16742569#comment-16742569 ] Yi Pan (Data Infrastructure) commented on SAMZA-1911: - [~xinyu] can w

[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&focusedCommentId=16742568#comment-16742568 ] Yi Pan (Data Infrastructure) commented on SAMZA-1961: - [~Sanil] can w

[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&focusedCommentId=16677431#comment-16677431 ] Yi Pan (Data Infrastructure) commented on SAMZA-1776: - [~zhjohnzzh],

[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 > StreamApplicationI

[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&focusedCommentId=16648219#comment-16648219 ] Yi Pan (Data Infrastructure) commented on SAMZA-1836: - This is fixed

[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 B

[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&focusedCommentId=16646015#comment-16646015 ] Yi Pan (Data Infrastructure) commented on SAMZA-1371: - [~zhjohnzzh],

[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&focusedCommentId=16646012#comment-16646012 ] Yi Pan (Data Infrastructure) commented on SAMZA-1776: - Hey, [~zhjohnz

[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: https://issue

[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 genera

[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&focusedCommentId=16635846#comment-16635846 ] Yi Pan (Data Infrastructure) commented on SAMZA-1814: - PR 642 is merg

[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: https://issues.apache.org/jira/browse/SAM

[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: https://issues.apache.org/jira/

[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 confi

[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&focusedCommentId=16622837#comment-16622837 ] Yi Pan (Data Infrastructure) commented on SAMZA-1894: - One more note:

[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: SAMZA-1893

[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 t

[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 TestLocalTableW

[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 low-l

[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&focusedCommentId=16606537#comment-16606537 ] Yi Pan (Data Infrastructure) commented on SAMZA-1814: - This is to tra

[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 Tabl

[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 TableDescriptor

[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 con

[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: https

[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: S

[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&focusedCommentId=16599445#comment-16599445 ] Yi Pan (Data Infrastructure) commented on SAMZA-1834: - One more: the

[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&focusedCommentId=16599224#comment-16599224 ] Yi Pan (Data Infrastructure) commented on SAMZA-1836: - Chat with [~pm

[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 Samza

[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 s

[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: https://issues.ap

[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&focusedCommentId=16597877#comment-16597877 ] Yi Pan (Data Infrastructure) commented on SAMZA-1811: - As a tentative

[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: https://issues.apache.org/jira/browse/SA

[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: https://issues.apache.or

[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: Sa

[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: https://iss

[jira] [Created] (SAMZA-1829) MessageStreamAssert check throws NPE on expected.toArray()

Yi Pan (Data Infrastructure) created SAMZA-1829: --- Summary: MessageStreamAssert check throws NPE on expected.toArray() Key: SAMZA-1829 URL: https://issues.apache.org/jira/browse/SAMZA-1829

[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 Pr

[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&focusedCommentId=16594266#comment-16594266 ] Yi Pan (Data Infrastructure) commented on SAMZA-1822: - Added a unit t

[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 e

[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: https://issues.apache.org/jira/bro

[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 Project:

[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: https://issues.apache.org/jira/browse/S

[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: https://issues.apache.

[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: https://issues.apache.org

[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 [SEP-13|https

[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 StreamT

[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 > ApplicationRunn

[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&focusedCommentId=16550095#comment-16550095 ] Yi Pan (Data Infrastructure) commented on SAMZA-1371: - [~hao.song], w

[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: https://issues.apache.org/jira/bro

[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 Samza

[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&focusedCommentId=16522544#comment-16522544 ] Yi Pan (Data Infrastructure) commented on SAMZA-1371: - Hi, [~zhjohnzz

[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&focusedCommentId=16503619#comment-16503619 ] Yi Pan (Data Infrastructure) commented on SAMZA-1371: - [~zhjohnzzh] t

[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 secur

[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 Kerberos

[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 > Applic

[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&focusedCommentId=16500545#comment-16500545 ] Yi Pan (Data Infrastructure) commented on SAMZA-929: [~apoorva.sar...@

[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 high-lev

[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&focusedCommentId=16490404#comment-16490404 ] Yi Pan (Data Infrastructure) commented on SAMZA-1665: - >From the above

[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&focusedCommentId=16490386#comment-16490386 ] Yi Pan (Data Infrastructure) commented on SAMZA-1665: - There is anothe

[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 deletedMessagesCalle

[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 Roc

[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 tests

[jira] [Updated] (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) updated SAMZA-1705: Fix Version/s: 0.14.1 > Switch to use snapshot in iterable impl of R

[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 flow

[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 partition,

[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 p

[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 partitio

[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 Pro

[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 i

[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 function

[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&focusedCommentId=16460560#comment-16460560 ] Yi Pan (Data Infrastructure) commented on SAMZA-1371: - [~jagadish1...@

[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&focusedCommentId=16459874#comment-16459874 ] Yi Pan (Data Infrastructure) commented on SAMZA-1371: - Hi, [~zhjohnzzh

[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 te

[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 function

  1   2   3   4   5   6   7   8   9   10   >