commits@samza.apache.org, 2018-03

You are viewing a plain text version of this content. The canonical link for it is here.

- samza git commit: SAMZA-1596: Staging directory name has to be formatted in config - posted by ja...@apache.org on 2018/03/01 18:58:10 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1596) Staging direcroty in HDFS config - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/01 18:59:00 UTC, 0 replies.
- [jira] [Assigned] (SAMZA-1460) StreamAppender does not explicitly create logging topic - posted by "Daniel Nishimura (JIRA)" <ji...@apache.org> on 2018/03/02 05:20:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1598) Cleanup README.md file - posted by "Daniel Nishimura (JIRA)" <ji...@apache.org> on 2018/03/02 05:27:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1598) Cleanup README.md file - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/02 05:32:00 UTC, 1 replies.
- samza git commit: SAMZA-1598: Cleanup README.md file - posted by ja...@apache.org on 2018/03/04 00:29:47 UTC, 0 replies.
- samza git commit: Misc. minor cleanup. - posted by ja...@apache.org on 2018/03/04 00:31:02 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1588) Add random jitter to monitor’s scheduling interval. - posted by "Shanthoosh Venkataraman (JIRA)" <ji...@apache.org> on 2018/03/05 05:27:00 UTC, 0 replies.
- [jira] [Closed] (SAMZA-1588) Add random jitter to monitor’s scheduling interval. - posted by "Shanthoosh Venkataraman (JIRA)" <ji...@apache.org> on 2018/03/05 05:28:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1593) Upgrade gradle nexus plugin. - posted by "Yi Pan (Data Infrastructure) (JIRA)" <ji...@apache.org> on 2018/03/05 18:55:00 UTC, 0 replies.
- [jira] [Assigned] (SAMZA-1596) Staging direcroty in HDFS config - posted by "Yi Pan (Data Infrastructure) (JIRA)" <ji...@apache.org> on 2018/03/05 18:57:01 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1596) Staging direcroty in HDFS config - posted by "Yi Pan (Data Infrastructure) (JIRA)" <ji...@apache.org> on 2018/03/05 18:57:01 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1595) Fix scalacCompileOptions format to build with zinc scala compiler. - posted by "Yi Pan (Data Infrastructure) (JIRA)" <ji...@apache.org> on 2018/03/05 18:58:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1599) AsyncRunLoop Slow When Some Partitions Are Empty - posted by "James Lent (JIRA)" <ji...@apache.org> on 2018/03/05 21:55:00 UTC, 0 replies.
- [jira] [Updated] (SAMZA-1599) AsyncRunLoop Slow When Some Partitions Are Empty - posted by "James Lent (JIRA)" <ji...@apache.org> on 2018/03/05 22:12:00 UTC, 3 replies.
- [jira] [Commented] (SAMZA-1371) Some Samza Containers get stuck at "Starting BrokerProxy for hostname:portnum" while others seem to be fine - posted by "Yi Pan (Data Infrastructure) (JIRA)" <ji...@apache.org> on 2018/03/05 23:37:00 UTC, 2 replies.
- [jira] [Resolved] (SAMZA-1530) Bump up Kafka dependency to 0.11 - posted by "Yi Pan (Data Infrastructure) (JIRA)" <ji...@apache.org> on 2018/03/05 23:38:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1600) Changelog topics for batch jobs should not use combination of delete+compact cleanup policy in Kafka - posted by "Yi Pan (Data Infrastructure) (JIRA)" <ji...@apache.org> on 2018/03/05 23:44:00 UTC, 0 replies.
- samza git commit: SAMZA-1460: StreamAppender does not explicitly create logging topic - posted by ja...@apache.org on 2018/03/06 00:02:54 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1460) StreamAppender does not explicitly create logging topic - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/06 00:04:00 UTC, 0 replies.
- [jira] [Closed] (SAMZA-1460) StreamAppender does not explicitly create logging topic - posted by "Jagadish (JIRA)" <ji...@apache.org> on 2018/03/06 00:06:00 UTC, 0 replies.
- [jira] [Assigned] (SAMZA-1600) Changelog topics for batch jobs should not use combination of delete+compact cleanup policy in Kafka - posted by "Yi Pan (Data Infrastructure) (JIRA)" <ji...@apache.org> on 2018/03/06 00:31:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1600) Changelog topics for batch jobs should not use combination of delete+compact cleanup policy in Kafka - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/06 01:18:00 UTC, 1 replies.
- samza git commit: SAMZA-1600: remove the combination of cleanup policy "compact,delete"… - posted by ja...@apache.org on 2018/03/06 03:40:48 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1600) Changelog topics for batch jobs should not use combination of delete+compact cleanup policy in Kafka - posted by "Jagadish (JIRA)" <ji...@apache.org> on 2018/03/06 03:42:00 UTC, 0 replies.
- [jira] [Closed] (SAMZA-1600) Changelog topics for batch jobs should not use combination of delete+compact cleanup policy in Kafka - posted by "Jagadish (JIRA)" <ji...@apache.org> on 2018/03/06 03:42:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1599) AsyncRunLoop Slow When Some Partitions Are Empty - posted by "James Lent (JIRA)" <ji...@apache.org> on 2018/03/06 16:36:01 UTC, 3 replies.
- [jira] [Resolved] (SAMZA-1594) Fix ScalaCompileOptions errors originating from build.gradle. - posted by "Yi Pan (Data Infrastructure) (JIRA)" <ji...@apache.org> on 2018/03/06 20:23:01 UTC, 0 replies.
- [jira] [Created] (SAMZA-1601) Add stream-table join support for Samza Sql - posted by "Aditya (JIRA)" <ji...@apache.org> on 2018/03/06 23:59:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1602) Samza-Test: Moving StreamAssert from src/test to src/mail - posted by "Sanil Jain (JIRA)" <ji...@apache.org> on 2018/03/07 00:43:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1603) Samza-Sql: Support deep conversion of avro to samza rel message - posted by "Aditya (JIRA)" <ji...@apache.org> on 2018/03/07 00:46:00 UTC, 0 replies.
- [jira] [Updated] (SAMZA-1601) Add stream-table join support for Samza Sql - posted by "Aditya (JIRA)" <ji...@apache.org> on 2018/03/07 00:46:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1604) Samza-Sql: Support constant equality check in stream-table join condition - posted by "Aditya (JIRA)" <ji...@apache.org> on 2018/03/07 00:55:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1605) Samza-Sql: Support stream-table join without join keyword in the sql query - posted by "Aditya (JIRA)" <ji...@apache.org> on 2018/03/07 01:02:00 UTC, 0 replies.
- [jira] [Assigned] (SAMZA-1602) Samza-Test: Moving StreamAssert from src/test to src/mail - posted by "Sanil Jain (JIRA)" <ji...@apache.org> on 2018/03/07 01:17:00 UTC, 0 replies.
- [jira] [Updated] (SAMZA-1602) Samza-Test: Moving StreamAssert from src/test to src/main - posted by "Sanil Jain (JIRA)" <ji...@apache.org> on 2018/03/07 01:18:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1606) Samza-Sql Stream-table join: Add a way to validate the primary key for table - posted by "Aditya (JIRA)" <ji...@apache.org> on 2018/03/07 01:19:00 UTC, 0 replies.
- samza git commit: SAMZA-1498: Support arbitrary system clock timer in operators - posted by xi...@apache.org on 2018/03/07 02:20:26 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1498) Support arbitrary system clock timer in operators - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/07 02:21:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1498) Support arbitrary system clock timer in operators - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2018/03/07 02:31:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1027) InstanceAlreadyExistsException while starting up - posted by "xiezhi (JIRA)" <ji...@apache.org> on 2018/03/07 07:45:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1607) Fix bug in reading the ephemeral processor nodes from zookeeper. - posted by "Shanthoosh Venkataraman (JIRA)" <ji...@apache.org> on 2018/03/07 08:29:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1607) Fix bug in reading the ephemeral processor nodes from zookeeper. - posted by "Shanthoosh Venkataraman (JIRA)" <ji...@apache.org> on 2018/03/07 08:30:00 UTC, 0 replies.
- [jira] [Updated] (SAMZA-1607) Fix bug in reading the ephemeral processor nodes from zookeeper. - posted by "Shanthoosh Venkataraman (JIRA)" <ji...@apache.org> on 2018/03/07 08:32:00 UTC, 2 replies.
- [jira] [Updated] (SAMZA-1607) Handle ZkNodeNotExists exception in zkUtils.readProcessorData - posted by "Shanthoosh Venkataraman (JIRA)" <ji...@apache.org> on 2018/03/07 09:00:09 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1607) Handle ZkNodeNotExists exception in zkUtils.readProcessorData - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/07 09:05:00 UTC, 0 replies.
- [jira] [Updated] (SAMZA-1607) SAMZA-1607: Handle ZkNoNodeExistsException in zkUtils.readProcessorData - posted by "Shanthoosh Venkataraman (JIRA)" <ji...@apache.org> on 2018/03/07 09:07:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1589) Reduce failure retry duration in KafkaCheckpointManager.writeCheckpoint. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/07 09:38:00 UTC, 1 replies.
- [jira] [Commented] (SAMZA-1602) Samza-Test: Moving StreamAssert from src/test to src/main - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/07 18:28:00 UTC, 1 replies.
- samza git commit: SAMZA-1602: Moving class StreamAssert from src/test to src/main - posted by xi...@apache.org on 2018/03/07 21:22:56 UTC, 0 replies.
- samza git commit: SAMZA-1607: Handle ZkNoNodeExistsException in zkUtils.readProcessorData - posted by xi...@apache.org on 2018/03/07 21:25:02 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1607) SAMZA-1607: Handle ZkNoNodeExistsException in zkUtils.readProcessorData - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/07 21:26:00 UTC, 0 replies.
- [jira] [Closed] (SAMZA-1602) Samza-Test: Moving StreamAssert from src/test to src/main - posted by "Sanil Jain (JIRA)" <ji...@apache.org> on 2018/03/07 21:30:00 UTC, 0 replies.
- [jira] [Updated] (SAMZA-1584) StreamProcessor.stop blocks indefinitely. - posted by "Shanthoosh Venkataraman (JIRA)" <ji...@apache.org> on 2018/03/08 00:30:00 UTC, 1 replies.
- [jira] [Updated] (SAMZA-1584) LocalApplicationRunner.waitForFinish blocks indefinitely. - posted by "Shanthoosh Venkataraman (JIRA)" <ji...@apache.org> on 2018/03/08 01:04:00 UTC, 1 replies.
- [jira] [Commented] (SAMZA-1584) LocalApplicationRunner.waitForFinish blocks indefinitely. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/08 23:01:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1608) Disable explicit stream creation in StreamAppender due to bug - posted by "Daniel Nishimura (JIRA)" <ji...@apache.org> on 2018/03/08 23:11:00 UTC, 0 replies.
- [jira] [Assigned] (SAMZA-1608) Disable explicit stream creation in StreamAppender due to bug - posted by "Daniel Nishimura (JIRA)" <ji...@apache.org> on 2018/03/08 23:12:00 UTC, 0 replies.
- samza git commit: SAMZA-1589: Reduce failure retry duration in KafkaCheckpointManager.writeCheckpoint - posted by ja...@apache.org on 2018/03/09 02:00:19 UTC, 0 replies.
- [jira] [Updated] (SAMZA-1584) Improve SamzaContainer shutdown sequence in StreamProcessor. - posted by "Shanthoosh Venkataraman (JIRA)" <ji...@apache.org> on 2018/03/09 03:59:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1584) Improve SamzaContainer shutdown sequence in StreamProcessor. - posted by "Shanthoosh Venkataraman (JIRA)" <ji...@apache.org> on 2018/03/09 04:00:00 UTC, 0 replies.
- [jira] [Updated] (SAMZA-1608) Add hidden config to enable explicit stream creation in StreamAppender due to bug. - posted by "Daniel Nishimura (JIRA)" <ji...@apache.org> on 2018/03/09 17:05:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1608) Add hidden config to enable explicit stream creation in StreamAppender due to bug. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/09 17:06:00 UTC, 1 replies.
- samza git commit: Infinite loop when trying to use SamzaSqlApplicationRunner in yarn mode - posted by xi...@apache.org on 2018/03/09 19:01:16 UTC, 0 replies.
- [jira] [Created] (SAMZA-1609) Refactor SamzaContainer to take in SystemFactories - posted by "Bharath Kumarasubramanian (JIRA)" <ji...@apache.org> on 2018/03/09 19:25:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1610) Implement Remote tables - posted by "Jagadish (JIRA)" <ji...@apache.org> on 2018/03/09 22:56:00 UTC, 0 replies.
- [1/2] samza git commit: SAMZA-1610: Implementation of remote table provider - posted by ja...@apache.org on 2018/03/09 22:58:00 UTC, 0 replies.
- [2/2] samza git commit: SAMZA-1610: Implementation of remote table provider - posted by ja...@apache.org on 2018/03/09 22:58:01 UTC, 0 replies.
- [jira] [Assigned] (SAMZA-1610) Implement Remote tables - posted by "Peng Du (JIRA)" <ji...@apache.org> on 2018/03/09 23:23:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1611) BootstrappingChooser should use systemAdmin offsetComparator API to compare the offsets - posted by "Aditya (JIRA)" <ji...@apache.org> on 2018/03/11 14:41:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1612) Stream-table join: Number of partitions deduced for partitionBy for the stream to be joined does not take into account the partitions in the table - posted by "Aditya (JIRA)" <ji...@apache.org> on 2018/03/11 15:41:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1612) Stream-table join: Number of partitions deduced for partitionBy for the stream to be joined does not take into account the partitions in the table - posted by "Aditya (JIRA)" <ji...@apache.org> on 2018/03/11 15:45:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1613) Stream-table join: Intermediate streams do not inherit bootstrap stream semantic - posted by "Aditya (JIRA)" <ji...@apache.org> on 2018/03/11 15:52:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1614) Stream-table join: While doing a local table join, validate that the number of partitions in stream and table that are joined are equal. - posted by "Aditya (JIRA)" <ji...@apache.org> on 2018/03/11 15:57:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1615) Fix a couple of issues in ControlMessageSender - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2018/03/12 16:27:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1615) Fix a couple of issues in ControlMessageSender - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/12 16:45:00 UTC, 1 replies.
- [jira] [Commented] (SAMZA-1609) Refactor SamzaContainer to take in SystemFactories - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/12 17:04:00 UTC, 0 replies.
- [jira] [Updated] (SAMZA-1395) Add in-memory system consumer & producer - posted by "Sanil Jain (JIRA)" <ji...@apache.org> on 2018/03/12 17:05:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1616) Samza-Sql: Support remote table for stream-table join - posted by "Aditya (JIRA)" <ji...@apache.org> on 2018/03/12 18:32:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1617) Samza-Sql: Support broadcast/global table for stream-table join - posted by "Aditya (JIRA)" <ji...@apache.org> on 2018/03/12 18:33:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1618) fix HdfsFileSystemAdapter to get files recursively - posted by "Hai (JIRA)" <ji...@apache.org> on 2018/03/13 19:09:00 UTC, 0 replies.
- samza git commit: SAMZA-1618: fix HdfsFileSystemAdapter to get files recursively - posted by xi...@apache.org on 2018/03/13 19:28:19 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1618) fix HdfsFileSystemAdapter to get files recursively - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/13 19:29:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1618) fix HdfsFileSystemAdapter to get files recursively - posted by "Hai (JIRA)" <ji...@apache.org> on 2018/03/13 19:30:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1619) Samza-sql: Support deep serialization of samza relational message - posted by "Aditya (JIRA)" <ji...@apache.org> on 2018/03/13 21:00:01 UTC, 0 replies.
- [jira] [Updated] (SAMZA-1619) Samza-sql: Support serialization of nested samza sql relational message - posted by "Aditya (JIRA)" <ji...@apache.org> on 2018/03/13 21:01:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1620) Samza-sql stream-table join: Support UDFs in join condition - posted by "Aditya (JIRA)" <ji...@apache.org> on 2018/03/14 00:00:00 UTC, 0 replies.
- samza git commit: SAMZA-1611: BootstrappingChooser should use systemAdmin offsetComparator API to compare the offsets - posted by ja...@apache.org on 2018/03/14 00:43:44 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1611) BootstrappingChooser should use systemAdmin offsetComparator API to compare the offsets - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/14 00:45:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1611) BootstrappingChooser should use systemAdmin offsetComparator API to compare the offsets - posted by "Aditya (JIRA)" <ji...@apache.org> on 2018/03/14 04:43:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1564) StreamAppender needs to explicitly have a call to SystemAdmin.createStream() - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/14 21:07:00 UTC, 0 replies.
- [jira] [Updated] (SAMZA-1621) Delete the ephemeral processor node in StreamProcessor shutdown phase. - posted by "Shanthoosh Venkataraman (JIRA)" <ji...@apache.org> on 2018/03/15 01:03:00 UTC, 5 replies.
- [jira] [Created] (SAMZA-1621) Delete the ephemeral processor nodes in StreamProcessor shutdown phase. - posted by "Shanthoosh Venkataraman (JIRA)" <ji...@apache.org> on 2018/03/15 01:03:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1621) Delete the ephemeral processor node in StreamProcessor shutdown phase. - posted by "Shanthoosh Venkataraman (JIRA)" <ji...@apache.org> on 2018/03/15 01:06:00 UTC, 1 replies.
- [jira] [Created] (SAMZA-1622) avro writer in hdfs system producer to support generic record - posted by "Hai (JIRA)" <ji...@apache.org> on 2018/03/15 17:56:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1622) avro writer in hdfs system producer to support generic record - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/15 18:29:00 UTC, 1 replies.
- samza git commit: SAMZA-1615: Fix a couple of issues in ControlMessageSender - posted by xi...@apache.org on 2018/03/15 23:47:30 UTC, 0 replies.
- [jira] [Updated] (SAMZA-1155) Allow configuring window.ms to specify trigger duration - posted by "Jagadish (JIRA)" <ji...@apache.org> on 2018/03/16 04:01:00 UTC, 0 replies.
- samza git commit: SAMZA-1622: avro writer to support generic record - posted by xi...@apache.org on 2018/03/16 16:22:09 UTC, 0 replies.
- samza git commit: SAMZA-1608 : Add hidden config to enable explicit stream creation in StreamAppender due to bug. - posted by pm...@apache.org on 2018/03/16 20:11:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1589) Reduce failure retry duration in KafkaCheckpointManager.writeCheckpoint. - posted by "Jake Maes (JIRA)" <ji...@apache.org> on 2018/03/16 21:06:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1561) JobModel upgrade consistency problem. - posted by "Jake Maes (JIRA)" <ji...@apache.org> on 2018/03/16 21:14:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1560) Skip checkpoint validations for Key Serdes - posted by "Jake Maes (JIRA)" <ji...@apache.org> on 2018/03/16 21:15:00 UTC, 0 replies.
- [jira] [Assigned] (SAMZA-1599) AsyncRunLoop Slow When Some Partitions Are Empty - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2018/03/16 21:16:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1552) Host affinity improvements - Improve matching of hosts to allocated resources - posted by "Jake Maes (JIRA)" <ji...@apache.org> on 2018/03/16 21:16:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1550) Doc for 0.14.0 release - posted by "Jake Maes (JIRA)" <ji...@apache.org> on 2018/03/16 21:18:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1547) Fix default value for the grouper-factory configuration in KafkaCheckpointManager - posted by "Jake Maes (JIRA)" <ji...@apache.org> on 2018/03/16 21:19:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1538) Flaky test: TestStreamProcessor testStreamProcessor - posted by "Jake Maes (JIRA)" <ji...@apache.org> on 2018/03/16 21:20:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1535) Support UDFS in where clause - posted by "Jake Maes (JIRA)" <ji...@apache.org> on 2018/03/16 21:21:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1528) Implement async NodeManager interactions - posted by "Jake Maes (JIRA)" <ji...@apache.org> on 2018/03/16 21:22:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1489) TaskInstance should commit offset before it closes() if auto commit is enabled - posted by "Jake Maes (JIRA)" <ji...@apache.org> on 2018/03/16 21:28:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1478) Delete unneeded data from intermediate Kafka topic on offset commit - posted by "Jake Maes (JIRA)" <ji...@apache.org> on 2018/03/16 21:34:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1458) KafkaConfig ignores change logs which use non KafkaSysteAdmin admin class. - posted by "Jake Maes (JIRA)" <ji...@apache.org> on 2018/03/16 21:35:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1447) YarnCliJobStatusProvider cannot handle a high QPS to the JobsResource REST endpoint - posted by "Jake Maes (JIRA)" <ji...@apache.org> on 2018/03/16 21:37:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1407) upgrade junit version to 4.12 - posted by "Jake Maes (JIRA)" <ji...@apache.org> on 2018/03/16 21:38:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1622) avro writer in hdfs system producer to support generic record - posted by "Jake Maes (JIRA)" <ji...@apache.org> on 2018/03/16 21:40:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1615) Fix a couple of issues in ControlMessageSender - posted by "Jake Maes (JIRA)" <ji...@apache.org> on 2018/03/16 21:40:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1607) SAMZA-1607: Handle ZkNoNodeExistsException in zkUtils.readProcessorData - posted by "Jake Maes (JIRA)" <ji...@apache.org> on 2018/03/16 21:41:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1553) Add log4j for latest Kafka build - posted by "Jake Maes (JIRA)" <ji...@apache.org> on 2018/03/16 21:42:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1568) Handle ZkInterruptedException in zkclient.close. - posted by "Jake Maes (JIRA)" <ji...@apache.org> on 2018/03/16 21:42:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1355) Enable standalone integration tests conditionally in build. - posted by "Jake Maes (JIRA)" <ji...@apache.org> on 2018/03/16 21:43:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1334) When host-affinity is turned off, ContainerAllocator should ignore any previous container locality info - posted by "Jake Maes (JIRA)" <ji...@apache.org> on 2018/03/16 21:43:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1232) Log configuration value in RunLoopFactory - posted by "Jake Maes (JIRA)" <ji...@apache.org> on 2018/03/16 21:45:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1105) Upgrade Samza's Kafka client version to 0.10.2.0 - posted by "Jake Maes (JIRA)" <ji...@apache.org> on 2018/03/16 21:47:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1623) AvroDataFileHdfsWriter should include avro as the file suffix - posted by "Hai (JIRA)" <ji...@apache.org> on 2018/03/21 17:39:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1623) AvroDataFileHdfsWriter should include avro as the file suffix - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/21 18:02:00 UTC, 1 replies.
- [jira] [Created] (SAMZA-1624) EventHub system should prefix the configs with senstive for SasKey and SasToken - posted by "Srinivasulu Punuru (JIRA)" <ji...@apache.org> on 2018/03/21 20:00:00 UTC, 0 replies.
- samza git commit: SAMZA-1623: include avro as the file suffix for hdfs producer - posted by xi...@apache.org on 2018/03/21 20:13:25 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1623) AvroDataFileHdfsWriter should include avro as the file suffix - posted by "Hai (JIRA)" <ji...@apache.org> on 2018/03/21 20:16:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1625) EventHub systemAdmin is swallowing exceptions - posted by "Srinivasulu Punuru (JIRA)" <ji...@apache.org> on 2018/03/21 20:33:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1626) EventHub system admin is not returning the metadata for all the ssps requested for - posted by "Srinivasulu Punuru (JIRA)" <ji...@apache.org> on 2018/03/21 20:34:00 UTC, 0 replies.
- [1/3] samza git commit: Add stream-table join support for samza sql - posted by xi...@apache.org on 2018/03/22 00:58:15 UTC, 0 replies.
- [2/3] samza git commit: Add stream-table join support for samza sql - posted by xi...@apache.org on 2018/03/22 00:58:16 UTC, 0 replies.
- [3/3] samza git commit: Add stream-table join support for samza sql - posted by xi...@apache.org on 2018/03/22 00:58:17 UTC, 0 replies.
- [jira] [Created] (SAMZA-1627) Watermark broadcast enhancements - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2018/03/22 17:00:00 UTC, 0 replies.
- [jira] [Updated] (SAMZA-1627) Watermark broadcast enhancements - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2018/03/22 17:02:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1628) LocalityManager should handle null locality values correctly - posted by "Prateek Maheshwari (JIRA)" <ji...@apache.org> on 2018/03/22 20:42:00 UTC, 0 replies.
- samza git commit: Making event hub configs Samza compliant - posted by xi...@apache.org on 2018/03/23 00:08:19 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1571) Make Eventhubs system configs compatible with Samza standalone. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/23 00:09:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1627) Watermark broadcast enhancements - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/26 17:00:03 UTC, 1 replies.
- samza git commit: ScheduleAfterDebounceTime should catch all Throwable to avoid losing unhandled Errors - posted by pm...@apache.org on 2018/03/26 23:08:10 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1293) Enable partition expansion of input streams - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/26 23:21:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1629) Continuous Integration Framework for Samza - posted by "Sanil Jain (JIRA)" <ji...@apache.org> on 2018/03/27 01:05:00 UTC, 0 replies.
- samza git commit: Skipping large messages in the EventHub system producer - posted by xi...@apache.org on 2018/03/27 18:40:00 UTC, 0 replies.
- samza git commit: SAMZA-1627: Watermark broadcast enhancements - posted by xi...@apache.org on 2018/03/28 17:25:25 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1372) Change Latch Interface to Lock Interface for Samza Standalone with ZK - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/28 19:04:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1630) Log a thread dump on timeouts - posted by "Prateek Maheshwari (JIRA)" <ji...@apache.org> on 2018/03/28 21:07:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1630) Log a thread dump on timeouts - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/28 21:09:00 UTC, 3 replies.
- [jira] [Created] (SAMZA-1631) Do not log message contents on Task callback timeouts - posted by "Prateek Maheshwari (JIRA)" <ji...@apache.org> on 2018/03/28 21:11:00 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1631) Do not log message contents on Task callback timeouts - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/28 21:13:00 UTC, 1 replies.
- samza git commit: SAMZA-1631: Improve logging on Task callback timeout - posted by pm...@apache.org on 2018/03/29 00:53:02 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1631) Do not log message contents on Task callback timeouts - posted by "Prateek Maheshwari (JIRA)" <ji...@apache.org> on 2018/03/29 00:54:00 UTC, 0 replies.
- samza git commit: SAMZA-1630: Log a thread dump on timeouts - posted by pm...@apache.org on 2018/03/29 01:14:38 UTC, 0 replies.
- [jira] [Assigned] (SAMZA-1630) Log a thread dump on timeouts - posted by "Prateek Maheshwari (JIRA)" <ji...@apache.org> on 2018/03/29 01:15:00 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1630) Log a thread dump on timeouts - posted by "Prateek Maheshwari (JIRA)" <ji...@apache.org> on 2018/03/29 01:15:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1632) KinesisConfig: Making getProxyHost and getProxyPort APIs protected - posted by "Aditya (JIRA)" <ji...@apache.org> on 2018/03/29 17:58:00 UTC, 0 replies.
- samza git commit: SD-1599: Improve the efficiency of the AsynRunLoop when some partitio… - posted by ni...@apache.org on 2018/03/29 22:26:22 UTC, 0 replies.
- [jira] [Resolved] (SAMZA-1599) AsyncRunLoop Slow When Some Partitions Are Empty - posted by "Yi Pan (Data Infrastructure) (JIRA)" <ji...@apache.org> on 2018/03/29 22:29:00 UTC, 0 replies.
- [jira] [Closed] (SAMZA-1599) AsyncRunLoop Slow When Some Partitions Are Empty - posted by "Yi Pan (Data Infrastructure) (JIRA)" <ji...@apache.org> on 2018/03/29 22:30:00 UTC, 0 replies.
- samza git commit: SAMZA-1632: KinesisConfig: Making getProxyHost and getProxyPort APIs protected - posted by ja...@apache.org on 2018/03/29 22:56:21 UTC, 0 replies.
- [jira] [Commented] (SAMZA-1632) KinesisConfig: Making getProxyHost and getProxyPort APIs protected - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/03/29 22:57:00 UTC, 0 replies.
- [jira] [Updated] (SAMZA-1633) Add more doc about partitionBy operator - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2018/03/30 18:40:00 UTC, 0 replies.
- [jira] [Created] (SAMZA-1633) Add more doc about partitionBy operator - posted by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2018/03/30 18:40:00 UTC, 0 replies.
- samza git commit: SAMZA-1630: Move thread dump from stdout to logs - posted by pm...@apache.org on 2018/03/31 00:11:53 UTC, 0 replies.
- samza git commit: Refactoring the EventHub System Producer into reusable AsyncSystemProducer - posted by xi...@apache.org on 2018/03/31 00:45:48 UTC, 0 replies.