[jira] [Resolved] (SAMZA-2108) Check for host affinity config before resolving preferred host matching

[ https://issues.apache.org/jira/browse/SAMZA-2108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen resolved SAMZA-2108. - Resolution: Fixed > Check for host affinity config before resolving preferred host matching > ---

[jira] [Updated] (SAMZA-2108) Check for host affinity config before resolving preferred host matching

[ https://issues.apache.org/jira/browse/SAMZA-2108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Chen updated SAMZA-2108: Fix Version/s: 1.0.1 > Check for host affinity config before resolving preferred host matching > --

[samza] branch master updated: SAMZA-2108: Check for host affinity config before resolving preferred host matching

This is an automated email from the ASF dual-hosted git repository. jagadish pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/samza.git The following commit(s) were added to refs/heads/master by this push: new 8052463 SAMZA-2108: Check for host affinity co

[samza] branch master updated: [CLEANUP] Rename scalaVersion to scalaSuffix and scalaLibVersion to scalaVersion

This is an automated email from the ASF dual-hosted git repository. pmaheshwari pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/samza.git The following commit(s) were added to refs/heads/master by this push: new 725e973 [CLEANUP] Rename scalaVersion to sc

[jira] [Created] (SAMZA-2114) SamzaSQL Diagnostics: SamzaSqlInputTransformer should check if event and arrival time are set or not

Shenoda Guirguis created SAMZA-2114: --- Summary: SamzaSQL Diagnostics: SamzaSqlInputTransformer should check if event and arrival time are set or not Key: SAMZA-2114 URL: https://issues.apache.org/jira/browse/SAMZ

[jira] [Created] (SAMZA-2113) Relay exceptions in side-inputs read/flush from CSM to main SamzaContainer thread

Rayman created SAMZA-2113: - Summary: Relay exceptions in side-inputs read/flush from CSM to main SamzaContainer thread Key: SAMZA-2113 URL: https://issues.apache.org/jira/browse/SAMZA-2113 Project: Samza

[jira] [Updated] (SAMZA-2106) Samza App & Job Config Refactor

[ https://issues.apache.org/jira/browse/SAMZA-2106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sanil Jain updated SAMZA-2106: -- Affects Version/s: 1.0.1 > Samza App & Job Config Refactor > --- > >

[jira] [Created] (SAMZA-2112) Add SideInputs to JobModel to streamline side-input consumption once refactored into CSM

Rayman created SAMZA-2112: - Summary: Add SideInputs to JobModel to streamline side-input consumption once refactored into CSM Key: SAMZA-2112 URL: https://issues.apache.org/jira/browse/SAMZA-2112 Project: Sam

[jira] [Updated] (SAMZA-2076) RocksDbTableDescriptor should use Long type for TTL

[ https://issues.apache.org/jira/browse/SAMZA-2076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes updated SAMZA-2076: - Fix Version/s: (was: 1.1) 1.0.1 1.0.1 > RocksDbTableDescriptor

[jira] [Updated] (SAMZA-2072) Update guava to 23.0

[ https://issues.apache.org/jira/browse/SAMZA-2072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes updated SAMZA-2072: - Fix Version/s: 1.0.1 1.0.1 > Update guava to 23.0 > > >

[jira] [Updated] (SAMZA-2071) Skip StartpointManager instantiation for PassThroughCoordinator.

[ https://issues.apache.org/jira/browse/SAMZA-2071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes updated SAMZA-2071: - Fix Version/s: 1.0.1 1.0.1 > Skip StartpointManager instantiation for PassThroughCoord

[jira] [Updated] (SAMZA-1714) Creating shared context factory for shared context objects

[ https://issues.apache.org/jira/browse/SAMZA-1714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes updated SAMZA-1714: - Fix Version/s: 1.0.1 1.0.1 > Creating shared context factory for shared context object

[jira] [Updated] (SAMZA-2070) Upgrade calcite and add support for Arrays and maps

[ https://issues.apache.org/jira/browse/SAMZA-2070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes updated SAMZA-2070: - Fix Version/s: 1.0.1 > Upgrade calcite and add support for Arrays and maps >

[jira] [Updated] (SAMZA-2004) Add ability to disable table metrics

[ https://issues.apache.org/jira/browse/SAMZA-2004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes updated SAMZA-2004: - Fix Version/s: (was: 1.1) 1.0.1 1.0.1 > Add ability to disable

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

[ https://issues.apache.org/jira/browse/SAMZA-1835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes updated SAMZA-1835: - Fix Version/s: (was: 1.1) 1.0.1 1.0.1 > Consolidate all process

[jira] [Updated] (SAMZA-1629) Integration Framework for Samza

[ https://issues.apache.org/jira/browse/SAMZA-1629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes updated SAMZA-1629: - Fix Version/s: 1.0.1 1.0.1 > Integration Framework for Samza > ---

[jira] [Updated] (SAMZA-1950) SAMZA 1.0 DOCUMENTATION Fixing styling and cleanup

[ https://issues.apache.org/jira/browse/SAMZA-1950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes updated SAMZA-1950: - Fix Version/s: 1.0.1 1.0.1 > SAMZA 1.0 DOCUMENTATION Fixing styling and cleanup >

[jira] [Updated] (SAMZA-1946) Problem with Race between TimerListenener initialization and timers fired from init()

[ https://issues.apache.org/jira/browse/SAMZA-1946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes updated SAMZA-1946: - Fix Version/s: 1.0.1 1.0.1 > Problem with Race between TimerListenener initialization

[jira] [Updated] (SAMZA-1965) SAMZA 1.0 DOCUMENTATION FOR TEST FW

[ https://issues.apache.org/jira/browse/SAMZA-1965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes updated SAMZA-1965: - Fix Version/s: 1.0.1 1.0.1 > SAMZA 1.0 DOCUMENTATION FOR TEST FW > ---

[jira] [Updated] (SAMZA-2090) Fix flush behavior for remote and hybrid tables

[ https://issues.apache.org/jira/browse/SAMZA-2090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes updated SAMZA-2090: - Fix Version/s: (was: 1.1) 1.0.1 1.0.1 > Fix flush behavior for

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

[ https://issues.apache.org/jira/browse/SAMZA-1924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes updated SAMZA-1924: - Fix Version/s: (was: 1.0) 1.0.1 1.0.1 > Documentation for case-

[jira] [Updated] (SAMZA-2068) Separating container launch logic into util class

[ https://issues.apache.org/jira/browse/SAMZA-2068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes updated SAMZA-2068: - Fix Version/s: 1.0.1 1.0.1 > Separating container launch logic into util class > -

[jira] [Updated] (SAMZA-2066) Refactor remote tables to separate various concerns

[ https://issues.apache.org/jira/browse/SAMZA-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes updated SAMZA-2066: - Fix Version/s: (was: 1.1) 1.0.1 1.0.1 > Refactor remote tables

[jira] [Updated] (SAMZA-1967) Samza 1.0 TestRunner not generating serde configs to take precedence over ApplicationDescriptor configs

[ https://issues.apache.org/jira/browse/SAMZA-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes updated SAMZA-1967: - Fix Version/s: 1.0.1 1.0.1 > Samza 1.0 TestRunner not generating serde configs to take

[jira] [Updated] (SAMZA-2036) MessageStreamAssert.containsInAnyOrder does not fail if there is an error

[ https://issues.apache.org/jira/browse/SAMZA-2036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes updated SAMZA-2036: - Fix Version/s: 1.0.1 1.0.1 > MessageStreamAssert.containsInAnyOrder does not fail if t

[jira] [Updated] (SAMZA-1638) Recreate SystemProducer on KafkaCheckpointManager.writeCheckpoint failure.

[ https://issues.apache.org/jira/browse/SAMZA-1638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes updated SAMZA-1638: - Fix Version/s: 1.0.1 1.0.1 > Recreate SystemProducer on KafkaCheckpointManager.writeCh

[jira] [Updated] (SAMZA-1970) Support InMemoryStreamDescriptors with PhysicalName

[ https://issues.apache.org/jira/browse/SAMZA-1970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes updated SAMZA-1970: - Fix Version/s: 1.0.1 1.0.1 > Support InMemoryStreamDescriptors with PhysicalName > ---

[jira] [Updated] (SAMZA-1861) Create HDFS System and Stream Descriptors

[ https://issues.apache.org/jira/browse/SAMZA-1861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes updated SAMZA-1861: - Fix Version/s: 1.0.1 1.0.1 > Create HDFS System and Stream Descriptors > -

[jira] [Updated] (SAMZA-2026) Refactor remote table API to separate retry policy settings

[ https://issues.apache.org/jira/browse/SAMZA-2026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes updated SAMZA-2026: - Fix Version/s: (was: 1.1) 1.0.1 1.0.1 > Refactor remote table A

[jira] [Updated] (SAMZA-2097) Allow table parts configuration generation

[ https://issues.apache.org/jira/browse/SAMZA-2097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes updated SAMZA-2097: - Fix Version/s: (was: 1.1) 1.0.1 1.0.1 > Allow table parts confi

[jira] [Updated] (SAMZA-2015) Refactor timer handling in tables to be consistent with stores

[ https://issues.apache.org/jira/browse/SAMZA-2015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes updated SAMZA-2015: - Fix Version/s: (was: 1.1) 1.0.1 1.0.1 > Refactor timer handling

[jira] [Updated] (SAMZA-2061) Make fixes in Samza 1.0 documentation

[ https://issues.apache.org/jira/browse/SAMZA-2061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes updated SAMZA-2061: - Fix Version/s: 1.0.1 1.0.1 > Make fixes in Samza 1.0 documentation >

[jira] [Updated] (SAMZA-2059) Create the configuration in coordinator stream for standalone.

[ https://issues.apache.org/jira/browse/SAMZA-2059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes updated SAMZA-2059: - Fix Version/s: 1.0.1 1.0.1 > Create the configuration in coordinator stream for standa

[jira] [Updated] (SAMZA-2043) Consolidate ReadableTable and ReadWriteTable

[ https://issues.apache.org/jira/browse/SAMZA-2043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes updated SAMZA-2043: - Fix Version/s: (was: 1.1) 1.0.1 1.0.1 > Consolidate ReadableTab

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

[ https://issues.apache.org/jira/browse/SAMZA-1961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes updated SAMZA-1961: - Fix Version/s: 1.0.1 1.0.1 > Samza 1.0 Doc cleanup > - > >

[jira] [Updated] (SAMZA-1858) Public APIs for shared context

[ https://issues.apache.org/jira/browse/SAMZA-1858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes updated SAMZA-1858: - Fix Version/s: 1.0.1 1.0.1 > Public APIs for shared context >

[jira] [Updated] (SAMZA-1969) Cleanup the ApplicationDescriptorImpl to use descriptors wired from LocalApplicationRunner for Test Framework

[ https://issues.apache.org/jira/browse/SAMZA-1969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes updated SAMZA-1969: - Fix Version/s: 1.0.1 1.0.1 > Cleanup the ApplicationDescriptorImpl to use descriptors

[jira] [Updated] (SAMZA-2081) Samza SQL : Type system for Samza SQL

[ https://issues.apache.org/jira/browse/SAMZA-2081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes updated SAMZA-2081: - Fix Version/s: 1.0.1 1.0.1 > Samza SQL : Type system for Samza SQL >

[jira] [Updated] (SAMZA-1857) Implement System Descriptors for Kinesis

[ https://issues.apache.org/jira/browse/SAMZA-1857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes updated SAMZA-1857: - Fix Version/s: 1.0.1 1.0.1 > Implement System Descriptors for Kinesis > --

[jira] [Updated] (SAMZA-2041) Add system descriptors for HDFS and Kinesis

[ https://issues.apache.org/jira/browse/SAMZA-2041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes updated SAMZA-2041: - Fix Version/s: 1.0.1 1.0.1 > Add system descriptors for HDFS and Kinesis > ---

[jira] [Updated] (SAMZA-2013) Account for cycles in graph traversal within Execution Planner

[ https://issues.apache.org/jira/browse/SAMZA-2013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes updated SAMZA-2013: - Fix Version/s: 1.0.1 1.0.1 > Account for cycles in graph traversal within Execution Pl

[jira] [Updated] (SAMZA-2012) Add API for wiring an external context through to application processing code

[ https://issues.apache.org/jira/browse/SAMZA-2012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes updated SAMZA-2012: - Fix Version/s: 1.0.1 1.0.1 > Add API for wiring an external context through to applica

[jira] [Updated] (SAMZA-2010) Handle null value in LocalReadWriteTable.putAll()

[ https://issues.apache.org/jira/browse/SAMZA-2010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes updated SAMZA-2010: - Fix Version/s: (was: 1.1) 1.0.1 1.0.1 > Handle null value in Lo

[jira] [Updated] (SAMZA-2033) Inconsistency in the inmemory offsets managed by the TaskSideInputStorageManager.

[ https://issues.apache.org/jira/browse/SAMZA-2033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jake Maes updated SAMZA-2033: - Fix Version/s: 1.0.1 1.0.1 > Inconsistency in the inmemory offsets managed by the > T

[samza] branch master updated: Ignoring standby tasks when grouping

This is an automated email from the ASF dual-hosted git repository. atoomula pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/samza.git The following commit(s) were added to refs/heads/master by this push: new 2c86eed Ignoring standby tasks when grouping 2