You are viewing a plain text version of this content. The canonical link for it is here.
- [jira] [Created] (SAMZA-1478) Delete unneeded data from intermediate Kafka topic on offset commit - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2017/11/01 03:19:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1478) Delete unneeded data from intermediate Kafka topic on offset commit - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/11/01 04:47:00 UTC, 1 replies.
- [jira] [Created] (SAMZA-1479) Kafka checkpoint manager improvements - posted by "Jagadish (JIRA)" <ji...@apache.org> on 2017/11/01 19:58:00 UTC, 0 replies.
- [jira] [Updated] (SAMZA-1479) Proposal Kafka checkpoint manager improvements - posted by "Jagadish (JIRA)" <ji...@apache.org> on 2017/11/01 19:58:00 UTC, 0 replies.
- [jira] [Updated] (SAMZA-1479) Proposal for Kafka checkpoint manager improvements - posted by "Jagadish (JIRA)" <ji...@apache.org> on 2017/11/01 19:58:00 UTC, 3 replies.
- [jira] [Commented] (SAMZA-1479) Proposal for Kafka checkpoint manager improvements - posted by "Jagadish (JIRA)" <ji...@apache.org> on 2017/11/01 20:00:04 UTC, 2 replies.
- [jira] [Created] (SAMZA-1480) TaskStorageManager improperly initializes changelog consumer position when restoring a store from disk - posted by "Jake Maes (JIRA)" <ji...@apache.org> on 2017/11/01 20:13:01 UTC, 0 replies.
- [jira] [Assigned] (SAMZA-1479) Proposal for Kafka checkpoint manager improvements - posted by "Jagadish (JIRA)" <ji...@apache.org> on 2017/11/01 20:25:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1481) KafkaSystemConsumer does not properly track highwatermark in some cases. - posted by "Jake Maes (JIRA)" <ji...@apache.org> on 2017/11/01 20:30:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1480) TaskStorageManager improperly initializes changelog consumer position when restoring a store from disk - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/11/02 16:13:00 UTC, 1 replies.
- [jira] [Commented] (SAMZA-1371) Some Samza Containers get stuck at "Starting BrokerProxy for hostname:portnum" while others seem to be fine - posted by "Hao Song (JIRA)" <ji...@apache.org> on 2017/11/03 17:22:00 UTC, 2 replies.
- samza git commit: SAMZA-1477: Fix issues found by BEAM tests - posted by xi...@apache.org on 2017/11/07 20:16:27 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1477) Fix issues found by BEAM tests - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/11/07 20:17:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1482) Restart or fail Samza jobs in YARN when input topic partition changes - posted by "Yi Pan (Data Infrastructure) (JIRA)" <ji...@apache.org> on 2017/11/07 23:51:00 UTC, 0 replies.
- [jira] [Assigned] (SAMZA-1482) Restart or fail Samza jobs in YARN when input topic partition changes - posted by "Yi Pan (Data Infrastructure) (JIRA)" <ji...@apache.org> on 2017/11/07 23:51:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1483) Restart or fail Samza jobs in Zk-based standalone processors when input topic partition changes - posted by "Yi Pan (Data Infrastructure) (JIRA)" <ji...@apache.org> on 2017/11/07 23:56:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1482) Restart or fail Samza jobs in YARN when input topic partition changes - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/11/08 00:13:00 UTC, 3 replies.
- [jira] [Created] (SAMZA-1484) Host affinity improvements for YARN - posted by "Jagadish (JIRA)" <ji...@apache.org> on 2017/11/08 01:06:00 UTC, 0 replies.
- [jira] [Updated] (SAMZA-1484) Host affinity improvements for YARN - posted by "Jagadish (JIRA)" <ji...@apache.org> on 2017/11/08 01:06:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1485) Make eventData creation extensible. Add interceptor tests - posted by "Jagadish (JIRA)" <ji...@apache.org> on 2017/11/08 01:15:00 UTC, 0 replies.
- samza git commit: SAMZA-1437; Added tests, make eventData creation extensible - posted by ja...@apache.org on 2017/11/08 01:15:32 UTC, 0 replies.
- [jira] [Created] (SAMZA-1486) Implement a Checkpoint Provider for Azure Tables - posted by "Jagadish (JIRA)" <ji...@apache.org> on 2017/11/08 01:17:00 UTC, 0 replies.
- [jira] [Updated] (SAMZA-1486) Implement a Checkpoint Provider for Azure Tables - posted by "Jagadish (JIRA)" <ji...@apache.org> on 2017/11/08 01:18:00 UTC, 0 replies.
- samza git commit: SAMZA-1486; Checkpoint manager implementation with Azure Table - posted by ja...@apache.org on 2017/11/08 01:26:02 UTC, 0 replies.
- samza git commit: Fix test failures caused by PR345 - posted by xi...@apache.org on 2017/11/08 02:02:39 UTC, 0 replies.
- [jira] [Created] (SAMZA-1487) Disable Flaky Zk Integration tests. - posted by "Shanthoosh Venkataraman (JIRA)" <ji...@apache.org> on 2017/11/09 00:09:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1487) Disable Flaky Zk Integration tests. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/11/09 00:29:00 UTC, 3 replies.
- samza git commit: SAMZA-1487: Disable Flaky Zk Integration tests. - posted by pm...@apache.org on 2017/11/09 18:24:54 UTC, 1 replies.
- [jira] [Resolved] (SAMZA-1487) Disable Flaky Zk Integration tests. - posted by "Prateek Maheshwari (JIRA)" <ji...@apache.org> on 2017/11/09 18:29:00 UTC, 0 replies.
- samza git commit: Ignore java fatal error log files from git and rat - posted by pm...@apache.org on 2017/11/09 18:45:08 UTC, 0 replies.
- [jira] [Updated] (SAMZA-1190) Flaky unit tests - posted by "Prateek Maheshwari (JIRA)" <ji...@apache.org> on 2017/11/09 18:49:00 UTC, 0 replies.
- [jira] [Updated] (SAMZA-1476) Flaky test: TestStatefulTask testShouldStartAndRestore - posted by "Prateek Maheshwari (JIRA)" <ji...@apache.org> on 2017/11/09 18:50:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1488) Flaky test: Multiple tests in TestZkBarrierForVersionUpgrade - posted by "Shanthoosh Venkataraman (JIRA)" <ji...@apache.org> on 2017/11/09 18:55:00 UTC, 0 replies.
- [jira] [Updated] (SAMZA-1487) Disable Flaky Zk Integration tests. - posted by "Shanthoosh Venkataraman (JIRA)" <ji...@apache.org> on 2017/11/09 19:36:00 UTC, 0 replies.
- samza git commit: SAMZA-1480: TaskStorageManager improperly initializes changelog consu… - posted by jm...@apache.org on 2017/11/09 19:54:44 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1480) TaskStorageManager improperly initializes changelog consumer position when restoring a store from disk - posted by "Jake Maes (JIRA)" <ji...@apache.org> on 2017/11/09 19:56:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1489) TaskInstance should commit offset before it closes() if auto commit is enabled - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2017/11/09 19:57:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1490) Fix TestRepartitionJoinWindowApp - posted by "Dong Lin (JIRA)" <ji...@apache.org> on 2017/11/09 21:19:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1491) Compress job model used by standalone. - posted by "Sean McCauliff (JIRA)" <ji...@apache.org> on 2017/11/11 00:33:00 UTC, 0 replies.
- [jira] [Assigned] (SAMZA-1438) Implement the SystemProducer, SystemConsumer and SystemAdmin interfaces for EventHubs - posted by "Daniel Chen (JIRA)" <ji...@apache.org> on 2017/11/13 18:13:00 UTC, 0 replies.
- [jira] [Assigned] (SAMZA-1485) Make eventData creation extensible. Add interceptor tests - posted by "Daniel Chen (JIRA)" <ji...@apache.org> on 2017/11/13 18:15:00 UTC, 0 replies.
- [jira] [Assigned] (SAMZA-1486) Implement a Checkpoint Provider for Azure Tables - posted by "Daniel Chen (JIRA)" <ji...@apache.org> on 2017/11/13 18:15:00 UTC, 0 replies.
- [jira] [Assigned] (SAMZA-1437) Samza integration with EventHub - posted by "Daniel Chen (JIRA)" <ji...@apache.org> on 2017/11/13 18:16:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1492) Add exception counter to LocalStoreMonitor. - posted by "Shanthoosh Venkataraman (JIRA)" <ji...@apache.org> on 2017/11/14 00:54:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1492) Add exception counter to LocalStoreMonitor. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/11/14 00:54:00 UTC, 1 replies.
- samza git commit: SAMZA-1492: Add exception counter to LocalStoreMonitor. - posted by jm...@apache.org on 2017/11/14 15:56:23 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1492) Add exception counter to LocalStoreMonitor. - posted by "Jake Maes (JIRA)" <ji...@apache.org> on 2017/11/14 15:57:02 UTC, 0 replies.
- [jira] [Created] (SAMZA-1493) Samza Standalone should create changelog topics - posted by "Prateek Maheshwari (JIRA)" <ji...@apache.org> on 2017/11/14 18:05:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1494) Flush operator state on end of stream - posted by "Prateek Maheshwari (JIRA)" <ji...@apache.org> on 2017/11/14 18:08:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1495) Mark intermediate streams as higher priority than input streams in planner - posted by "Prateek Maheshwari (JIRA)" <ji...@apache.org> on 2017/11/14 18:09:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1496) Update Samza's ApplicationMaster to work with Yarn's host affinity and node labels - posted by "Prateek Maheshwari (JIRA)" <ji...@apache.org> on 2017/11/14 18:12:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1497) Use more descriptive type parameter names in High Level API - posted by "Prateek Maheshwari (JIRA)" <ji...@apache.org> on 2017/11/14 18:12:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1498) Add an onTimer method to operator functions - posted by "Prateek Maheshwari (JIRA)" <ji...@apache.org> on 2017/11/14 18:14:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1499) Make operator storage engine factory configurable - posted by "Prateek Maheshwari (JIRA)" <ji...@apache.org> on 2017/11/14 18:16:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1500) Add metrics for RocksDB state store memory usage - posted by "Prateek Maheshwari (JIRA)" <ji...@apache.org> on 2017/11/14 18:32:00 UTC, 0 replies.
- samza git commit: SAMZA-1490: Fix TestRepartitionJoinWindowApp - posted by pm...@apache.org on 2017/11/14 18:48:53 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1490) Fix TestRepartitionJoinWindowApp - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/11/14 18:50:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1490) Fix TestRepartitionJoinWindowApp - posted by "Prateek Maheshwari (JIRA)" <ji...@apache.org> on 2017/11/14 18:52:02 UTC, 0 replies.
- samza git commit: SAMZA-1474: Bump up rocksdb version to 5.7.3 to include licensing changes - posted by pm...@apache.org on 2017/11/14 19:00:38 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1474) Upgrade RocksDB to include apache licensing changes - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/11/14 19:01:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1474) Upgrade RocksDB to include apache licensing changes - posted by "Prateek Maheshwari (JIRA)" <ji...@apache.org> on 2017/11/14 19:02:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1501) Validate operator IDs so that they don't contain special characters and spaces - posted by "Prateek Maheshwari (JIRA)" <ji...@apache.org> on 2017/11/14 19:56:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1495) Mark intermediate streams as higher priority than input streams in planner - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/11/14 20:08:00 UTC, 1 replies.
- [jira] [Commented] (SAMZA-1501) Validate operator IDs so that they don't contain special characters and spaces - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/11/14 20:45:00 UTC, 1 replies.
- samza git commit: SAMZA-1482: Restart or fail Samza jobs in YARN when detecting changes… - posted by ni...@apache.org on 2017/11/14 20:45:32 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1482) Restart or fail Samza jobs in YARN when input topic partition changes - posted by "Yi Pan (Data Infrastructure) (JIRA)" <ji...@apache.org> on 2017/11/14 20:49:00 UTC, 1 replies.
- [jira] [Reopened] (SAMZA-1482) Restart or fail Samza jobs in YARN when input topic partition changes - posted by "Yi Pan (Data Infrastructure) (JIRA)" <ji...@apache.org> on 2017/11/14 20:50:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1502) Make AllSspToSingleTaskGrouper work with Yarn and ZK JobCoordinator - posted by "Aditya (JIRA)" <ji...@apache.org> on 2017/11/14 22:43:00 UTC, 0 replies.
- samza git commit: SAMZA-1501: Validate operator IDs so that they don't contain special characters and spaces - posted by pm...@apache.org on 2017/11/15 18:27:07 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1501) Validate operator IDs so that they don't contain special characters and spaces - posted by "Prateek Maheshwari (JIRA)" <ji...@apache.org> on 2017/11/15 18:29:00 UTC, 0 replies.
- samza git commit: SAMZA-1495: Set intermediate streams as higher priority by default - posted by pm...@apache.org on 2017/11/15 18:45:06 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1495) Mark intermediate streams as higher priority than input streams in planner - posted by "Prateek Maheshwari (JIRA)" <ji...@apache.org> on 2017/11/15 18:49:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1503) Implement event time support for windowing - posted by "Jagadish (JIRA)" <ji...@apache.org> on 2017/11/16 00:43:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1504) Allow user to register container-level metrics - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2017/11/16 01:17:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1504) Allow user to register container-level metrics - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/11/16 01:25:00 UTC, 1 replies.
- samza git commit: SAMZA-1504: Allow user to register container-level metrics - posted by xi...@apache.org on 2017/11/16 18:46:14 UTC, 0 replies.
- [1/3] samza git commit: Samza SQL implementation for basic projects, filtering and UDFs - posted by xi...@apache.org on 2017/11/16 19:15:00 UTC, 0 replies.
- [2/3] samza git commit: Samza SQL implementation for basic projects, filtering and UDFs - posted by xi...@apache.org on 2017/11/16 19:15:01 UTC, 0 replies.
- [3/3] samza git commit: Samza SQL implementation for basic projects, filtering and UDFs - posted by xi...@apache.org on 2017/11/16 19:15:02 UTC, 0 replies.
- samza git commit: SAMZA-1479; Refactor KafkaCheckpointManager, KafkaCheckpointLogKey and their tests - posted by ja...@apache.org on 2017/11/17 22:41:11 UTC, 0 replies.
- [jira] [Closed] (SAMZA-1479) Proposal for Kafka checkpoint manager improvements - posted by "Jagadish (JIRA)" <ji...@apache.org> on 2017/11/17 22:43:00 UTC, 0 replies.
- [jira] [Closed] (SAMZA-1473) Fix handling of initial values in windows with aggregating functions - posted by "Jagadish (JIRA)" <ji...@apache.org> on 2017/11/20 18:27:00 UTC, 0 replies.
- [jira] [Assigned] (SAMZA-1473) Fix handling of initial values in windows with aggregating functions - posted by "Jagadish (JIRA)" <ji...@apache.org> on 2017/11/20 18:27:00 UTC, 0 replies.
- [jira] [Updated] (SAMZA-1494) Flush operator state on end of stream - posted by "Jagadish (JIRA)" <ji...@apache.org> on 2017/11/20 18:34:00 UTC, 0 replies.
- [jira] [Closed] (SAMZA-1423) Implement a RocksDb backed time-series store for storing and retrieving messages time-ranges - posted by "Jagadish (JIRA)" <ji...@apache.org> on 2017/11/20 18:35:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1426) Wire-up windowed stores in the Operatorgraph - posted by "Jagadish (JIRA)" <ji...@apache.org> on 2017/11/20 18:35:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1425) Implement persistent tumbling and session windows - posted by "Jagadish (JIRA)" <ji...@apache.org> on 2017/11/20 18:35:00 UTC, 0 replies.
- [jira] [Closed] (SAMZA-1426) Wire-up windowed stores in the Operatorgraph - posted by "Jagadish (JIRA)" <ji...@apache.org> on 2017/11/20 18:36:00 UTC, 0 replies.
- samza git commit: SAMZA-1482: add config documentation for auto-restart/fail behavior o… - posted by ni...@apache.org on 2017/11/20 19:48:20 UTC, 0 replies.
- [jira] [Created] (SAMZA-1505) Fix CheckpointTool writing only one ssp per task - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2017/11/20 20:40:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1505) Fix CheckpointTool writing only one ssp per task - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/11/20 21:40:00 UTC, 1 replies.
- [jira] [Resolved] (SAMZA-1409) add the missing parts and make guideline clearer for docs/README.md - posted by "Fred Ji (JIRA)" <ji...@apache.org> on 2017/11/21 00:45:00 UTC, 0 replies.
- [jira] [Updated] (SAMZA-1407) upgrade junit version to 4.12 - posted by "Fred Ji (JIRA)" <ji...@apache.org> on 2017/11/21 00:45:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1408) update the doc for 0.13.1 release - posted by "Fred Ji (JIRA)" <ji...@apache.org> on 2017/11/21 00:45:00 UTC, 0 replies.
- [jira] [Assigned] (SAMZA-1412) remove mockito-all from the dependency - posted by "Fred Ji (JIRA)" <ji...@apache.org> on 2017/11/21 01:56:00 UTC, 0 replies.
- [jira] [Closed] (SAMZA-1353) fritdjidtkbhtdcfhnubicvuuundbetjgndkedgrdfck - posted by "Fred Ji (JIRA)" <ji...@apache.org> on 2017/11/21 01:57:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1412) remove mockito-all from the dependency - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/11/21 02:04:33 UTC, 1 replies.
- [jira] [Commented] (SAMZA-1494) Flush operator state on end of stream - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/11/21 16:47:00 UTC, 1 replies.
- samza git commit: SAMZA-1505: Fix CheckpointTool writing only one ssp per task - posted by xi...@apache.org on 2017/11/21 19:27:05 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1477) Fix issues found by BEAM tests - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2017/11/21 19:29:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1504) Allow user to register container-level metrics - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2017/11/21 19:29:00 UTC, 0 replies.
- [jira] [Updated] (SAMZA-1477) Fix issues found by BEAM tests - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2017/11/21 19:29:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1505) Fix CheckpointTool writing only one ssp per task - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2017/11/21 19:29:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1457) Set retention for internal streams for Batch application - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2017/11/21 19:30:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1386) Inline End-of-stream and Watermark logic inside OperatorImpl - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2017/11/21 19:31:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1434) Fix issues found in Hadoop - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2017/11/21 19:32:00 UTC, 0 replies.
- [jira] [Updated] (SAMZA-1434) Fix issues found in Hadoop - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2017/11/21 19:32:00 UTC, 1 replies.
- [jira] [Updated] (SAMZA-1386) Inline End-of-stream and Watermark logic inside OperatorImpl - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2017/11/21 19:32:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1430) Allow partition count being 0 for hdfs ouput - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2017/11/21 19:33:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1430) Allow partition count being 0 for hdfs ouput - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2017/11/21 19:33:01 UTC, 0 replies.
- [jira] [Updated] (SAMZA-1260) Support Control Messages Across Intermediate Streams - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2017/11/21 19:34:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1352) Detect the upstream tasks when we build the graph - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2017/11/21 19:34:00 UTC, 0 replies.
- [jira] [Updated] (SAMZA-1352) Detect the upstream tasks when we build the graph - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2017/11/21 19:34:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1352) Detect the upstream tasks when we build the graph - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2017/11/21 19:34:00 UTC, 0 replies.
- [jira] [Updated] (SAMZA-1354) Pass in typed control message into EndOfStreamManager.update() and WatermarkManager.update() - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2017/11/21 19:35:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1354) Pass in typed control message into EndOfStreamManager.update() and WatermarkManager.update() - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2017/11/21 19:35:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1260) Support Control Messages Across Intermediate Streams - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2017/11/21 19:35:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1354) Pass in typed control message into EndOfStreamManager.update() and WatermarkManager.update() - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2017/11/21 19:35:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1351) Separate Watermark Implementation from Propagation - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2017/11/21 19:36:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1322) Propagate watermark messages - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2017/11/21 19:36:00 UTC, 0 replies.
- [jira] [Updated] (SAMZA-1351) Separate Watermark Implementation from Propagation - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2017/11/21 19:36:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1351) Separate Watermark Implementation from Propagation - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2017/11/21 19:36:00 UTC, 0 replies.
- [jira] [Updated] (SAMZA-1322) Propagate watermark messages - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2017/11/21 19:36:00 UTC, 1 replies.
- [jira] [Resolved] (SAMZA-1322) Propagate watermark messages - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2017/11/21 19:37:00 UTC, 0 replies.
- [jira] [Updated] (SAMZA-1289) Default id generator if not configured. - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2017/11/21 19:37:00 UTC, 1 replies.
- [jira] [Resolved] (SAMZA-1289) Default id generator if not configured. - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2017/11/21 19:37:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1262) Rename latch in CoordinatorUtil - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2017/11/21 19:38:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1011) Better report event loop utilization metrics in AsyncRunLoop - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2017/11/21 19:39:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1506) Potential orphaned containers in LocalContainerRunner. - posted by "Shanthoosh Venkataraman (JIRA)" <ji...@apache.org> on 2017/11/21 20:04:00 UTC, 0 replies.
- [jira] [Updated] (SAMZA-1506) Potential orphaned containers problem in SamzaContainer. - posted by "Shanthoosh Venkataraman (JIRA)" <ji...@apache.org> on 2017/11/21 20:07:32 UTC, 0 replies.
- samza git commit: SAMZA-1494; Flush operator state at end of stream - posted by ja...@apache.org on 2017/11/21 20:42:24 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1471) No polling for end-of-stream partitions in SystemConsumers - posted by "Bharath Kumarasubramanian (JIRA)" <ji...@apache.org> on 2017/11/21 23:21:00 UTC, 0 replies.
- [jira] [Closed] (SAMZA-1471) No polling for end-of-stream partitions in SystemConsumers - posted by "Bharath Kumarasubramanian (JIRA)" <ji...@apache.org> on 2017/11/21 23:21:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1507) Create changelog streams in ZkJobCoordinator for stateful operators. - posted by "Shanthoosh Venkataraman (JIRA)" <ji...@apache.org> on 2017/11/22 02:15:00 UTC, 0 replies.
- samza git commit: SAMZA-1507; Create changelog streams in Leader(ZkJobCoordinator) for stateful operators. - posted by bo...@apache.org on 2017/11/22 19:54:18 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1507) Create changelog streams in ZkJobCoordinator for stateful operators. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/11/22 19:55:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1508) JobRunner should not return success until the job is healthy - posted by "Jake Maes (JIRA)" <ji...@apache.org> on 2017/11/23 00:30:00 UTC, 0 replies.
- [jira] [Updated] (SAMZA-1508) JobRunner should not return success until the job is healthy - posted by "Jake Maes (JIRA)" <ji...@apache.org> on 2017/11/23 00:37:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1508) JobRunner should not return success until the job is healthy - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/11/23 00:47:09 UTC, 0 replies.
- [jira] [Created] (SAMZA-1509) Upgrade Kafka client version to 0.11 in Samza - posted by "Yi Pan (Data Infrastructure) (JIRA)" <ji...@apache.org> on 2017/11/27 08:00:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1418) Samza version 0.13.x doesn't start with kafka version 0.11.0 - posted by "Yi Pan (Data Infrastructure) (JIRA)" <ji...@apache.org> on 2017/11/27 08:56:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1510) Samza SQL - posted by "Srinivasulu Punuru (JIRA)" <ji...@apache.org> on 2017/11/27 17:30:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1511) Add doc in the config table for bounded stream - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2017/11/27 18:15:01 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1493) Samza Standalone should create changelog topics - posted by "Shanthoosh Venkataraman (JIRA)" <ji...@apache.org> on 2017/11/27 18:15:01 UTC, 0 replies.
- [jira] [Created] (SAMZA-1512) Documentation on the multi-stage batch processing - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2017/11/27 18:27:01 UTC, 0 replies.
- [samza] Git Push Summary - posted by xi...@apache.org on 2017/11/27 19:28:22 UTC, 1 replies.
- [jira] [Commented] (SAMZA-1406) Fix potential orphaned containers problem in stand alone. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/11/27 19:30:00 UTC, 0 replies.
- samza git commit: Change tests and artifacts to use 0.14.0 version - posted by xi...@apache.org on 2017/11/27 21:22:54 UTC, 0 replies.
- samza git commit: Fixing broken link between Yarn Host Affinity and Resource Localizati… - posted by xi...@apache.org on 2017/11/27 21:49:47 UTC, 0 replies.
- [jira] [Closed] (SAMZA-1494) Flush operator state on end of stream - posted by "Jagadish (JIRA)" <ji...@apache.org> on 2017/11/28 04:37:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1513) Doc updates for Windows and joins with durable state - posted by "Jagadish (JIRA)" <ji...@apache.org> on 2017/11/28 04:40:00 UTC, 0 replies.
- [jira] [Updated] (SAMZA-1513) Doc updates for Windows and joins with durable state - posted by "Jagadish (JIRA)" <ji...@apache.org> on 2017/11/28 04:41:00 UTC, 0 replies.
- [jira] [Assigned] (SAMZA-1513) Doc updates for Windows and joins with durable state - posted by "Jagadish (JIRA)" <ji...@apache.org> on 2017/11/28 04:41:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1513) Doc updates for Windows and joins with durable state - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/11/28 17:50:00 UTC, 1 replies.
- [jira] [Created] (SAMZA-1514) Prevent changelog stream names with empty strings. - posted by "Daniel Nishimura (JIRA)" <ji...@apache.org> on 2017/11/28 19:25:00 UTC, 0 replies.
- [jira] [Updated] (SAMZA-1514) Prevent changelog stream names with empty strings. - posted by "Daniel Nishimura (JIRA)" <ji...@apache.org> on 2017/11/28 19:32:00 UTC, 0 replies.
- samza git commit: SAMZA-1513; Doc updates for persistent windows, joins and serdes. - posted by ja...@apache.org on 2017/11/28 20:30:38 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1513) Doc updates for Windows and joins with durable state - posted by "Jagadish (JIRA)" <ji...@apache.org> on 2017/11/28 21:06:01 UTC, 0 replies.
- [jira] [Closed] (SAMZA-1513) Doc updates for Windows and joins with durable state - posted by "Jagadish (JIRA)" <ji...@apache.org> on 2017/11/28 21:06:01 UTC, 0 replies.
- [jira] [Created] (SAMZA-1515) Implement a consumer for Kinesis - posted by "Jagadish (JIRA)" <ji...@apache.org> on 2017/11/28 21:12:09 UTC, 0 replies.
- [1/2] samza git commit: SAMZA-1515; Implement a consumer for Kinesis - posted by ja...@apache.org on 2017/11/28 21:12:14 UTC, 0 replies.
- [2/2] samza git commit: SAMZA-1515; Implement a consumer for Kinesis - posted by ja...@apache.org on 2017/11/28 21:12:15 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1515) Implement a consumer for Kinesis - posted by "Jagadish (JIRA)" <ji...@apache.org> on 2017/11/28 21:13:00 UTC, 0 replies.
- [jira] [Closed] (SAMZA-1515) Implement a consumer for Kinesis - posted by "Jagadish (JIRA)" <ji...@apache.org> on 2017/11/28 21:13:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1516) Another round of issues found by BEAM tests - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2017/11/28 21:43:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1516) Another round of issues found by BEAM tests - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/11/28 22:09:00 UTC, 1 replies.
- [jira] [Updated] (SAMZA-1516) Another round of issues found by BEAM tests - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2017/11/28 22:22:00 UTC, 0 replies.
- samza git commit: SAMZA-1412 replace mockito-all with mockito-core - posted by ni...@apache.org on 2017/11/28 22:36:31 UTC, 0 replies.
- [jira] [Created] (SAMZA-1517) Remove old RunLoop - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2017/11/29 00:04:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1514) Prevent changelog stream names with empty strings. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/11/29 00:07:01 UTC, 1 replies.
- samza git commit: SAMZA-1514: Prevent changelog stream names with empty strings. - posted by jm...@apache.org on 2017/11/29 00:19:59 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1514) Prevent changelog stream names with empty strings. - posted by "Jake Maes (JIRA)" <ji...@apache.org> on 2017/11/29 00:21:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1518) Add CPU utilization and thread count to JVM metrics - posted by "Jake Maes (JIRA)" <ji...@apache.org> on 2017/11/29 00:55:00 UTC, 0 replies.
- [jira] [Updated] (SAMZA-1518) Add CPU utilization and thread count to JVM metrics - posted by "Jake Maes (JIRA)" <ji...@apache.org> on 2017/11/29 00:56:00 UTC, 0 replies.
- [jira] [Assigned] (SAMZA-1518) Add CPU utilization and thread count to JVM metrics - posted by "Jake Maes (JIRA)" <ji...@apache.org> on 2017/11/29 00:57:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1518) Add CPU utilization and thread count to JVM metrics - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/11/29 01:54:00 UTC, 0 replies.
- samza git commit: SAMZA-1516: Another round of issues found by BEAM tests - posted by xi...@apache.org on 2017/11/29 19:34:36 UTC, 0 replies.
- [1/8] samza git commit: Fixing broken link between Yarn Host Affinity and Resource Localizati… - posted by xi...@apache.org on 2017/11/29 19:36:40 UTC, 0 replies.
- [2/8] samza git commit: SAMZA-1513; Doc updates for persistent windows, joins and serdes. - posted by xi...@apache.org on 2017/11/29 19:36:41 UTC, 0 replies.
- [3/8] samza git commit: SAMZA-1515; Implement a consumer for Kinesis - posted by xi...@apache.org on 2017/11/29 19:36:42 UTC, 0 replies.
- [4/8] samza git commit: SAMZA-1515; Implement a consumer for Kinesis - posted by xi...@apache.org on 2017/11/29 19:36:43 UTC, 0 replies.
- [5/8] samza git commit: SAMZA-1412 replace mockito-all with mockito-core - posted by xi...@apache.org on 2017/11/29 19:36:44 UTC, 0 replies.
- [6/8] samza git commit: SAMZA-1514: Prevent changelog stream names with empty strings. - posted by xi...@apache.org on 2017/11/29 19:36:45 UTC, 0 replies.
- [7/8] samza git commit: SAMZA-1516: Another round of issues found by BEAM tests - posted by xi...@apache.org on 2017/11/29 19:36:46 UTC, 0 replies.
- [8/8] samza git commit: Merge branch 'master' into 0.14.0 - posted by xi...@apache.org on 2017/11/29 19:36:47 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1412) remove mockito-all from the dependency - posted by "Fred Ji (JIRA)" <ji...@apache.org> on 2017/11/30 18:38:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1407) upgrade junit version to 4.12 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2017/11/30 23:32:00 UTC, 0 replies.