[jira] [Resolved] (SAMZA-2603) build :rat fails

[ https://issues.apache.org/jira/browse/SAMZA-2603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik resolved SAMZA-2603. --- Resolution: Won't Fix > build :rat fails > > > Key:

[jira] [Commented] (SAMZA-2774) Fix incorrect symlinks used to generate classpath in run-class.sh

[ https://issues.apache.org/jira/browse/SAMZA-2774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17691726#comment-17691726 ] Boris Shkolnik commented on SAMZA-2774: --- [~jonbringhurst] - please add a sp-oncall-action-item

[jira] [Created] (SAMZA-2603) build :rat fails

Boris Shkolnik created SAMZA-2603: - Summary: build :rat fails Key: SAMZA-2603 URL: https://issues.apache.org/jira/browse/SAMZA-2603 Project: Samza Issue Type: Bug Reporter: Boris

[jira] [Created] (SAMZA-2513) Log4j MDC is not getting set in Beam.

Boris Shkolnik created SAMZA-2513: - Summary: Log4j MDC is not getting set in Beam. Key: SAMZA-2513 URL: https://issues.apache.org/jira/browse/SAMZA-2513 Project: Samza Issue Type: Bug

[jira] [Resolved] (SAMZA-2249) create blog for 1.2 reelase

[ https://issues.apache.org/jira/browse/SAMZA-2249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik resolved SAMZA-2249. --- Resolution: Fixed > create blog for 1.2 reelase > --- > >

[jira] [Assigned] (SAMZA-2461) Fix Concurrent Modification Exception in InMemorySystem

[ https://issues.apache.org/jira/browse/SAMZA-2461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik reassigned SAMZA-2461: - Assignee: Yixing Zhang > Fix Concurrent Modification Exception in InMemorySystem >

[jira] [Resolved] (SAMZA-1993) cluster-manager.container.memory.mb is missing from the config doc

[ https://issues.apache.org/jira/browse/SAMZA-1993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik resolved SAMZA-1993. --- Resolution: Fixed > cluster-manager.container.memory.mb is missing from the config doc >

[jira] [Commented] (SAMZA-1993) cluster-manager.container.memory.mb is missing from the config doc

[ https://issues.apache.org/jira/browse/SAMZA-1993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17024757#comment-17024757 ] Boris Shkolnik commented on SAMZA-1993: --- As Prateek mentioned, it is not relevant anymore. Closing

[jira] [Resolved] (SAMZA-2427) add 'strict' keyword to log4j2 configurations

[ https://issues.apache.org/jira/browse/SAMZA-2427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik resolved SAMZA-2427. --- Resolution: Fixed > add 'strict' keyword to log4j2 configurations >

[jira] [Created] (SAMZA-2427) add 'strict' keyword to log4j2 configurations

Boris Shkolnik created SAMZA-2427: - Summary: add 'strict' keyword to log4j2 configurations Key: SAMZA-2427 URL: https://issues.apache.org/jira/browse/SAMZA-2427 Project: Samza Issue Type:

[jira] [Resolved] (SAMZA-2380) Fix a small typo in the docs

[ https://issues.apache.org/jira/browse/SAMZA-2380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik resolved SAMZA-2380. --- Resolution: Fixed > Fix a small typo in the docs > > >

[jira] [Updated] (SAMZA-2380) Fix a small typo in the docs

[ https://issues.apache.org/jira/browse/SAMZA-2380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-2380: -- Summary: Fix a small typo in the docs (was: Fix a small type in the docs) > Fix a small typo

[jira] [Created] (SAMZA-2380) Fix a small type in the docs

Boris Shkolnik created SAMZA-2380: - Summary: Fix a small type in the docs Key: SAMZA-2380 URL: https://issues.apache.org/jira/browse/SAMZA-2380 Project: Samza Issue Type: Bug

[jira] [Assigned] (SAMZA-2380) Fix a small type in the docs

[ https://issues.apache.org/jira/browse/SAMZA-2380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik reassigned SAMZA-2380: - Assignee: Boris Shkolnik > Fix a small type in the docs >

[jira] [Resolved] (SAMZA-1299) update samza configs with StandAlone tutorial link, when it is available.

[ https://issues.apache.org/jira/browse/SAMZA-1299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik resolved SAMZA-1299. --- > update samza configs with StandAlone tutorial link, when it is available. >

[jira] [Resolved] (SAMZA-1201) Zk path setup for leader elector and barrier should be separated

[ https://issues.apache.org/jira/browse/SAMZA-1201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik resolved SAMZA-1201. --- Resolution: Fixed this code has been modified extensively. > Zk path setup for leader

[jira] [Resolved] (SAMZA-1399) TestZkStreamProcessorSession.testTwoStreamProcessors failed in flaky fashion

[ https://issues.apache.org/jira/browse/SAMZA-1399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik resolved SAMZA-1399. --- Resolution: Fixed This part of the tests has been rewritten significantly. >

[jira] [Resolved] (SAMZA-2146) Expose physical name in StreamDescriptor

[ https://issues.apache.org/jira/browse/SAMZA-2146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik resolved SAMZA-2146. --- Resolution: Fixed Resolving (based on git log) > Expose physical name in StreamDescriptor >

[jira] [Resolved] (SAMZA-2117) Container failures due to incorrect AM accounting

[ https://issues.apache.org/jira/browse/SAMZA-2117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik resolved SAMZA-2117. --- Resolution: Fixed Resolving (based on git log) > Container failures due to incorrect AM

[jira] [Resolved] (SAMZA-2124) Add Beam API doc to the website

[ https://issues.apache.org/jira/browse/SAMZA-2124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik resolved SAMZA-2124. --- Resolution: Fixed Resolving (based on git log) > Add Beam API doc to the website >

[jira] [Resolved] (SAMZA-2134) Enable remote table rate limiter by default

[ https://issues.apache.org/jira/browse/SAMZA-2134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik resolved SAMZA-2134. --- Resolution: Fixed Resolving (based on git log) > Enable remote table rate limiter by

[jira] [Resolved] (SAMZA-2165) Account for coordinator restarts in calls to status

[ https://issues.apache.org/jira/browse/SAMZA-2165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik resolved SAMZA-2165. --- Resolution: Fixed Resolving (based on the git log) > Account for coordinator restarts in

[jira] [Resolved] (SAMZA-2241) upgrade docs to version 1.2.0 of samza

[ https://issues.apache.org/jira/browse/SAMZA-2241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik resolved SAMZA-2241. --- Resolution: Fixed > upgrade docs to version 1.2.0 of samza >

[jira] [Created] (SAMZA-2249) create blog for 1.2 reelase

Boris Shkolnik created SAMZA-2249: - Summary: create blog for 1.2 reelase Key: SAMZA-2249 URL: https://issues.apache.org/jira/browse/SAMZA-2249 Project: Samza Issue Type: Bug

[jira] [Resolved] (SAMZA-2228) Release. Samza tools tar should contain LICENCE and NOTICE files

[ https://issues.apache.org/jira/browse/SAMZA-2228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik resolved SAMZA-2228. --- Resolution: Fixed > Release. Samza tools tar should contain LICENCE and NOTICE files >

[jira] [Resolved] (SAMZA-2240) upgrade samza-test to use kafka 0.11

[ https://issues.apache.org/jira/browse/SAMZA-2240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik resolved SAMZA-2240. --- Resolution: Fixed > upgrade samza-test to use kafka 0.11 >

[jira] [Created] (SAMZA-2241) upgrade docs to version 1.2.0 of samza

Boris Shkolnik created SAMZA-2241: - Summary: upgrade docs to version 1.2.0 of samza Key: SAMZA-2241 URL: https://issues.apache.org/jira/browse/SAMZA-2241 Project: Samza Issue Type: Bug

[jira] [Updated] (SAMZA-2241) upgrade docs to version 1.2.0 of samza

[ https://issues.apache.org/jira/browse/SAMZA-2241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-2241: -- Fix Version/s: 1.2 > upgrade docs to version 1.2.0 of samza >

[jira] [Created] (SAMZA-2240) upgrade samza-test to use kafka 0.11

Boris Shkolnik created SAMZA-2240: - Summary: upgrade samza-test to use kafka 0.11 Key: SAMZA-2240 URL: https://issues.apache.org/jira/browse/SAMZA-2240 Project: Samza Issue Type: Bug

[jira] [Updated] (SAMZA-2240) upgrade samza-test to use kafka 0.11

[ https://issues.apache.org/jira/browse/SAMZA-2240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-2240: -- Fix Version/s: 1.2 > upgrade samza-test to use kafka 0.11 >

[jira] [Created] (SAMZA-2228) Release. Samza tools tar should contain LICENCE and NOTICE files

Boris Shkolnik created SAMZA-2228: - Summary: Release. Samza tools tar should contain LICENCE and NOTICE files Key: SAMZA-2228 URL: https://issues.apache.org/jira/browse/SAMZA-2228 Project: Samza

[jira] [Updated] (SAMZA-2193) Fix unit test failures after rate limiter is a required config

[ https://issues.apache.org/jira/browse/SAMZA-2193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-2193: -- Fix Version/s: (was: 1.2) > Fix unit test failures after rate limiter is a required config

[jira] [Updated] (SAMZA-2170) Enabling writing of both new and old format offset files for stores and side-input-stores

[ https://issues.apache.org/jira/browse/SAMZA-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-2170: -- Fix Version/s: 1.2 > Enabling writing of both new and old format offset files for stores and

[jira] [Updated] (SAMZA-2131) [Scala cleanup] Convert FileSystemCheckpointManagerConfig.scala and SystemConfig.scala to Java

[ https://issues.apache.org/jira/browse/SAMZA-2131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-2131: -- Fix Version/s: 1.2 > [Scala cleanup] Convert FileSystemCheckpointManagerConfig.scala and >

[jira] [Updated] (SAMZA-2117) Container failures due to incorrect AM accounting

[ https://issues.apache.org/jira/browse/SAMZA-2117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-2117: -- Fix Version/s: 1.2 > Container failures due to incorrect AM accounting >

[jira] [Updated] (SAMZA-2183) Print Jobmodel when job fails with incorrect container count

[ https://issues.apache.org/jira/browse/SAMZA-2183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-2183: -- Fix Version/s: 1.2 > Print Jobmodel when job fails with incorrect container count >

[jira] [Updated] (SAMZA-2171) Encapsulate creation and loading of metadata streams

[ https://issues.apache.org/jira/browse/SAMZA-2171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-2171: -- Fix Version/s: 1.2 > Encapsulate creation and loading of metadata streams >

[jira] [Updated] (SAMZA-2188) Remove dependency to com.couchbase.client:encryption

[ https://issues.apache.org/jira/browse/SAMZA-2188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-2188: -- Fix Version/s: 1.2 > Remove dependency to com.couchbase.client:encryption >

[jira] [Updated] (SAMZA-2176) Ignore the configurations with serialized null values from coordinator stream.

[ https://issues.apache.org/jira/browse/SAMZA-2176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-2176: -- Fix Version/s: 1.2 > Ignore the configurations with serialized null values from coordinator

[jira] [Updated] (SAMZA-2185) Ability to expose remote data source specific features in remote table

[ https://issues.apache.org/jira/browse/SAMZA-2185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-2185: -- Fix Version/s: 1.2 > Ability to expose remote data source specific features in remote table >

[jira] [Updated] (SAMZA-2146) Expose physical name in StreamDescriptor

[ https://issues.apache.org/jira/browse/SAMZA-2146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-2146: -- Fix Version/s: 1.2 > Expose physical name in StreamDescriptor >

[jira] [Updated] (SAMZA-2192) Add StartpointVisitor implementation for EventHub.

[ https://issues.apache.org/jira/browse/SAMZA-2192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-2192: -- Fix Version/s: 1.2 > Add StartpointVisitor implementation for EventHub. >

[jira] [Updated] (SAMZA-2158) Remove the redunant coordinator stream reads in the ApplicationMaster startup sequence.

[ https://issues.apache.org/jira/browse/SAMZA-2158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-2158: -- Fix Version/s: 1.2 > Remove the redunant coordinator stream reads in the ApplicationMaster

[jira] [Updated] (SAMZA-2165) Account for coordinator restarts in calls to status

[ https://issues.apache.org/jira/browse/SAMZA-2165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-2165: -- Fix Version/s: 1.2 > Account for coordinator restarts in calls to status >

[jira] [Updated] (SAMZA-2091) Update ZkClient in samza-standalone to use string serialization.

[ https://issues.apache.org/jira/browse/SAMZA-2091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-2091: -- Fix Version/s: 1.2 > Update ZkClient in samza-standalone to use string serialization. >

[jira] [Updated] (SAMZA-2135) Provide a way inject ExternalContext to TestRunner

[ https://issues.apache.org/jira/browse/SAMZA-2135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-2135: -- Fix Version/s: 1.2 > Provide a way inject ExternalContext to TestRunner >

[jira] [Updated] (SAMZA-2127) Upgrade to Kafka 2.0

[ https://issues.apache.org/jira/browse/SAMZA-2127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-2127: -- Fix Version/s: 1.2 > Upgrade to Kafka 2.0 > > > Key:

[jira] [Updated] (SAMZA-2156) Couchbase Table Support for Samza Table API

[ https://issues.apache.org/jira/browse/SAMZA-2156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-2156: -- Fix Version/s: 1.2 > Couchbase Table Support for Samza Table API >

[jira] [Updated] (SAMZA-2179) Move the StartpointVisitor abstraction to SystemAdmin interface.

[ https://issues.apache.org/jira/browse/SAMZA-2179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-2179: -- Fix Version/s: 1.2 > Move the StartpointVisitor abstraction to SystemAdmin interface. >

[jira] [Updated] (SAMZA-2166) [Scala cleanup] Convert StorageConfig.scala to Java

[ https://issues.apache.org/jira/browse/SAMZA-2166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-2166: -- Fix Version/s: 1.2 > [Scala cleanup] Convert StorageConfig.scala to Java >

[jira] [Updated] (SAMZA-2148) Fix the rendering of bash and sql scripts in samza-sql release validation page.

[ https://issues.apache.org/jira/browse/SAMZA-2148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-2148: -- Fix Version/s: 1.2 > Fix the rendering of bash and sql scripts in samza-sql release

[jira] [Updated] (SAMZA-2055) Design and Implement async API for high level

[ https://issues.apache.org/jira/browse/SAMZA-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-2055: -- Fix Version/s: 1.2 > Design and Implement async API for high level >

[jira] [Updated] (SAMZA-2132) Startpoint - flatten serialized key

[ https://issues.apache.org/jira/browse/SAMZA-2132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-2132: -- Fix Version/s: 1.2 > Startpoint - flatten serialized key > ---

[jira] [Updated] (SAMZA-2193) Fix unit test failures after rate limiter is a required config

[ https://issues.apache.org/jira/browse/SAMZA-2193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-2193: -- Fix Version/s: 1.2 > Fix unit test failures after rate limiter is a required config >

[jira] [Updated] (SAMZA-2134) Enable remote table rate limiter by default

[ https://issues.apache.org/jira/browse/SAMZA-2134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-2134: -- Fix Version/s: 1.2 > Enable remote table rate limiter by default >

[jira] [Updated] (SAMZA-2046) Startpoints - Fanout of SSP-only keyed Startpoints to SSP+TaskName

[ https://issues.apache.org/jira/browse/SAMZA-2046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-2046: -- Fix Version/s: 1.2 > Startpoints - Fanout of SSP-only keyed Startpoints to SSP+TaskName >

[jira] [Updated] (SAMZA-2181) Ensure consistency of coordinator store creation and initialization

[ https://issues.apache.org/jira/browse/SAMZA-2181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-2181: -- Fix Version/s: 1.2 > Ensure consistency of coordinator store creation and initialization >

[jira] [Updated] (SAMZA-2169) Preventing task-shuffle after task mode addition

[ https://issues.apache.org/jira/browse/SAMZA-2169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-2169: -- Fix Version/s: 1.2 > Preventing task-shuffle after task mode addition >

[jira] [Updated] (SAMZA-2153) Implement to Config for TableRetryPolicy

[ https://issues.apache.org/jira/browse/SAMZA-2153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-2153: -- Fix Version/s: 1.2 > Implement to Config for TableRetryPolicy >

[jira] [Updated] (SAMZA-2116) Make sendTo operators non-terminal

[ https://issues.apache.org/jira/browse/SAMZA-2116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-2116: -- Fix Version/s: 1.2 > Make sendTo operators non-terminal > -- >

[jira] [Updated] (SAMZA-2124) Add Beam API doc to the website

[ https://issues.apache.org/jira/browse/SAMZA-2124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-2124: -- Fix Version/s: 1.2 > Add Beam API doc to the website > --- > >

[jira] [Updated] (SAMZA-2189) Integrate startpoint resolution workflow with SamzaContainer startup sequence.

[ https://issues.apache.org/jira/browse/SAMZA-2189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-2189: -- Fix Version/s: 1.2 > Integrate startpoint resolution workflow with SamzaContainer startup

[jira] [Updated] (SAMZA-2161) Move ChangelogPartitionManager and CoordinatorStream ConfigReader to MetadataStore

[ https://issues.apache.org/jira/browse/SAMZA-2161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-2161: -- Fix Version/s: 1.2 > Move ChangelogPartitionManager and CoordinatorStream ConfigReader to >

[jira] [Updated] (SAMZA-2178) Utils to directly inject custom IME to InMemorySystem streams

[ https://issues.apache.org/jira/browse/SAMZA-2178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-2178: -- Fix Version/s: 1.2 > Utils to directly inject custom IME to InMemorySystem streams >

[jira] [Resolved] (SAMZA-1793) Upgrade to recent API for kafka consumer / producer.

[ https://issues.apache.org/jira/browse/SAMZA-1793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik resolved SAMZA-1793. --- Resolution: Fixed > Upgrade to recent API for kafka consumer / producer. >

[jira] [Resolved] (SAMZA-1869) Refactor KafkaSystemConsumer from using SImpleConsumer

[ https://issues.apache.org/jira/browse/SAMZA-1869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik resolved SAMZA-1869. --- Resolution: Fixed > Refactor KafkaSystemConsumer from using SImpleConsumer >

[jira] [Created] (SAMZA-2030) Fix ScalaMapConfig:getOption to support mocking

Boris Shkolnik created SAMZA-2030: - Summary: Fix ScalaMapConfig:getOption to support mocking Key: SAMZA-2030 URL: https://issues.apache.org/jira/browse/SAMZA-2030 Project: Samza Issue Type:

[jira] [Created] (SAMZA-2019) support per stream broadcast config

Boris Shkolnik created SAMZA-2019: - Summary: support per stream broadcast config Key: SAMZA-2019 URL: https://issues.apache.org/jira/browse/SAMZA-2019 Project: Samza Issue Type: Bug

[jira] [Created] (SAMZA-1993) cluster-manager.container.memory.mb is missing from the config doc

Boris Shkolnik created SAMZA-1993: - Summary: cluster-manager.container.memory.mb is missing from the config doc Key: SAMZA-1993 URL: https://issues.apache.org/jira/browse/SAMZA-1993 Project: Samza

[jira] [Created] (SAMZA-1987) remove old kafka consumer auto.offset.reset values and update docs

Boris Shkolnik created SAMZA-1987: - Summary: remove old kafka consumer auto.offset.reset values and update docs Key: SAMZA-1987 URL: https://issues.apache.org/jira/browse/SAMZA-1987 Project: Samza

[jira] [Created] (SAMZA-1978) Match kafka auto.reset.offset to Samza reset.offset.default

Boris Shkolnik created SAMZA-1978: - Summary: Match kafka auto.reset.offset to Samza reset.offset.default Key: SAMZA-1978 URL: https://issues.apache.org/jira/browse/SAMZA-1978 Project: Samza

[jira] [Resolved] (SAMZA-1922) Create tests for KafkaSystemConsumerMetrics

[ https://issues.apache.org/jira/browse/SAMZA-1922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik resolved SAMZA-1922. --- Resolution: Fixed Committed as part of SAMZA-1868. PR 662. > Create tests for

[jira] [Resolved] (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 ] Boris Shkolnik resolved SAMZA-1371. --- Resolution: Fixed > Some Samza Containers get stuck at "Starting BrokerProxy for >

[jira] [Assigned] (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 ] Boris Shkolnik reassigned SAMZA-1371: - Assignee: Boris Shkolnik > Some Samza Containers get stuck at "Starting BrokerProxy for

[jira] [Resolved] (SAMZA-1868) Refactor KafkaSystemAdmin from using SimpleConsumer

[ https://issues.apache.org/jira/browse/SAMZA-1868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik resolved SAMZA-1868. --- Resolution: Fixed > Refactor KafkaSystemAdmin from using SimpleConsumer >

[jira] [Updated] (SAMZA-1888) minor improvements for the after commit for KafkaSystemAdmin and KafkaSystemConsumer.

[ https://issues.apache.org/jira/browse/SAMZA-1888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-1888: -- Description: consider documents on the following: # usage of zookeeper connect, still needed

[jira] [Updated] (SAMZA-1888) minor improvements for the after commit for KafkaSystemAdmin and KafkaSystemConsumer.

[ https://issues.apache.org/jira/browse/SAMZA-1888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-1888: -- Description: consider documents on the following: # usage of zookeeper connect, still needed

[jira] [Commented] (SAMZA-1888) minor improvements for the after commit for KafkaSystemAdmin and KafkaSystemConsumer.

[ https://issues.apache.org/jira/browse/SAMZA-1888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16648283#comment-16648283 ] Boris Shkolnik commented on SAMZA-1888: --- also fix the following warnings:

[jira] [Assigned] (SAMZA-1934) LocalApplicationRunner fails for LegacyTaskApplication app.class

[ https://issues.apache.org/jira/browse/SAMZA-1934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik reassigned SAMZA-1934: - Assignee: Boris Shkolnik > LocalApplicationRunner fails for LegacyTaskApplication

[jira] [Updated] (SAMZA-1912) improve code style for KafkaSystemConsumer(Proxy) and KafkaAdminClient

[ https://issues.apache.org/jira/browse/SAMZA-1912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-1912: -- Description: These are some code style improvements from PR #624: 1. KafkaSystemConsumer and

[jira] [Updated] (SAMZA-1912) improve code style for KafkaSystemConsumer(Proxy) and KafkaAdminClient

[ https://issues.apache.org/jira/browse/SAMZA-1912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-1912: -- Summary: improve code style for KafkaSystemConsumer(Proxy) and KafkaAdminClient (was: improve

[jira] [Commented] (SAMZA-1921) Upgrade SamzaKafkaSystemAdmin to use latest AdminClient

[ https://issues.apache.org/jira/browse/SAMZA-1921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16644238#comment-16644238 ] Boris Shkolnik commented on SAMZA-1921: --- As per [~yipan] suggestion, consider extracting

[jira] [Updated] (SAMZA-1888) minor improvements for the after commit for KafkaSystemAdmin and KafkaSystemConsumer.

[ https://issues.apache.org/jira/browse/SAMZA-1888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-1888: -- Description: consider documents on the following: # usage of zookeeper connect, still needed

[jira] [Created] (SAMZA-1945) get rid of deleteMessageCalled from KafkaSystemAdmin

Boris Shkolnik created SAMZA-1945: - Summary: get rid of deleteMessageCalled from KafkaSystemAdmin Key: SAMZA-1945 URL: https://issues.apache.org/jira/browse/SAMZA-1945 Project: Samza Issue

[jira] [Created] (SAMZA-1944) refactor KafkaSystemAdmin not to keep Coordinator/Changelog/Intermediate streams info.

Boris Shkolnik created SAMZA-1944: - Summary: refactor KafkaSystemAdmin not to keep Coordinator/Changelog/Intermediate streams info. Key: SAMZA-1944 URL: https://issues.apache.org/jira/browse/SAMZA-1944

[jira] [Created] (SAMZA-1943) get rid of ExtendedSystemAdmin

Boris Shkolnik created SAMZA-1943: - Summary: get rid of ExtendedSystemAdmin Key: SAMZA-1943 URL: https://issues.apache.org/jira/browse/SAMZA-1943 Project: Samza Issue Type: Bug

[jira] [Updated] (SAMZA-1888) minor improvements for the after commit for KafkaSystemAdmin and KafkaSystemConsumer.

[ https://issues.apache.org/jira/browse/SAMZA-1888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-1888: -- Summary: minor improvements for the after commit for KafkaSystemAdmin and KafkaSystemConsumer.

[jira] [Updated] (SAMZA-1888) minor improves for the after commit for KafkaSystemAdmin and KafkaSystemConsumer.

[ https://issues.apache.org/jira/browse/SAMZA-1888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-1888: -- Summary: minor improves for the after commit for KafkaSystemAdmin and KafkaSystemConsumer.

[jira] [Updated] (SAMZA-1888) update documentation for new KafkaSystemConsumer

[ https://issues.apache.org/jira/browse/SAMZA-1888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-1888: -- Description: consider documents on the following: # usage of zookeeper connect, still needed

[jira] [Updated] (SAMZA-1888) update documentation for new KafkaSystemConsumer

[ https://issues.apache.org/jira/browse/SAMZA-1888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-1888: -- Description: consider documents on the following: # usage of zookeeper connect, still needed

[jira] [Commented] (SAMZA-1906) remove ExponentialSleepStrategy from KafkaSystemAdmin code.

[ https://issues.apache.org/jira/browse/SAMZA-1906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16637553#comment-16637553 ] Boris Shkolnik commented on SAMZA-1906: --- There is another reason for the retries. We use

[jira] [Updated] (SAMZA-1906) remove ExponentialSleepStrategy from KafkaSystemAdmin code.

[ https://issues.apache.org/jira/browse/SAMZA-1906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-1906: -- Description: The retry is not needed anymore because the new kafka client should take care of

[jira] [Created] (SAMZA-1936) Investigate if we can get Kafka stream high watermark without using KafkaMetrics

Boris Shkolnik created SAMZA-1936: - Summary: Investigate if we can get Kafka stream high watermark without using KafkaMetrics Key: SAMZA-1936 URL: https://issues.apache.org/jira/browse/SAMZA-1936

[jira] [Created] (SAMZA-1934) LocalApplicationRunner fails for LegacyTaskApplication app.class

Boris Shkolnik created SAMZA-1934: - Summary: LocalApplicationRunner fails for LegacyTaskApplication app.class Key: SAMZA-1934 URL: https://issues.apache.org/jira/browse/SAMZA-1934 Project: Samza

[jira] [Created] (SAMZA-1922) Create tests for KafkaSystemConsumerMetrics

Boris Shkolnik created SAMZA-1922: - Summary: Create tests for KafkaSystemConsumerMetrics Key: SAMZA-1922 URL: https://issues.apache.org/jira/browse/SAMZA-1922 Project: Samza Issue Type: Bug

[jira] [Created] (SAMZA-1921) Upgrade SamzaKafkaSystemAdmin to use latest AdminClient

Boris Shkolnik created SAMZA-1921: - Summary: Upgrade SamzaKafkaSystemAdmin to use latest AdminClient Key: SAMZA-1921 URL: https://issues.apache.org/jira/browse/SAMZA-1921 Project: Samza

[jira] [Created] (SAMZA-1912) improve code style for KafkaSystemConsumer(Proxy)

Boris Shkolnik created SAMZA-1912: - Summary: improve code style for KafkaSystemConsumer(Proxy) Key: SAMZA-1912 URL: https://issues.apache.org/jira/browse/SAMZA-1912 Project: Samza Issue

[jira] [Updated] (SAMZA-1906) remove ExponentialSleepStrategy from KafkaSystemAdmin code.

[ https://issues.apache.org/jira/browse/SAMZA-1906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boris Shkolnik updated SAMZA-1906: -- Description: The retry is not needed anymore because the new kafka client should take care of

[jira] [Created] (SAMZA-1906) remove ExponentialSleepStrategy from KafkaSystemAdmin code.

Boris Shkolnik created SAMZA-1906: - Summary: remove ExponentialSleepStrategy from KafkaSystemAdmin code. Key: SAMZA-1906 URL: https://issues.apache.org/jira/browse/SAMZA-1906 Project: Samza

[jira] [Created] (SAMZA-1899) remove KafkaConfig.getKafkaSystemConsumerConfig

Boris Shkolnik created SAMZA-1899: - Summary: remove KafkaConfig.getKafkaSystemConsumerConfig Key: SAMZA-1899 URL: https://issues.apache.org/jira/browse/SAMZA-1899 Project: Samza Issue Type:

  1   2   3   >