[jira] [Commented] (SAMZA-1647) Fix NPE in JobModelExpired event handler.

[ https://issues.apache.org/jira/browse/SAMZA-1647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444966#comment-16444966 ] Jagadish commented on SAMZA-1647: - Thanks for identifying this - There's still a period of race-conditions

[jira] [Commented] (SAMZA-1656) EventHubSystemAdmin does not fetch metadata for valid streams.

[ https://issues.apache.org/jira/browse/SAMZA-1656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16444817#comment-16444817 ] Jagadish commented on SAMZA-1656: - Thanks for this fix, looks good! > EventHubSystemAdmin does not fe

[jira] [Created] (SAMZA-1669) Prioritize preferred host requests over ANY-HOST requests

Jagadish created SAMZA-1669: --- Summary: Prioritize preferred host requests over ANY-HOST requests Key: SAMZA-1669 URL: https://issues.apache.org/jira/browse/SAMZA-1669 Project: Samza Issue Type

samza git commit: SAMZA-1651: Samza-sql - Implement GROUP BY SQL operator

47a5af62860ff0f Parents: d7a071b Author: Aditya Toomula <atoom...@linkedin.com> Authored: Tue Apr 17 16:02:49 2018 -0700 Committer: Jagadish <jvenkatra...@linkedin.com> Committed: Tue Apr 17 16:02:49 2018 -0700 ---

samza git commit: SAMZA-1666: Benchmark SystemProducer and SystemConsumer

sts are being run. Author: Srinivasulu Punuru <spun...@linkedin.com> Reviewers: Jagadish <jagad...@apache.org>, Wei Song<ws...@linkedin.com> Closes #473 from srinipunuru/benchmark.1 Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apach

samza-hello-samza git commit: SAMZA-1592: Fix Hello-Samza latest after Kafka 0.11 upgrade in Samza

ken. Users who follow the tutorial will see a `NoSuchMethodError` when starting their job due to a mismatch of Kafka versions. This PR makes both Kafka versions consistent by updating the hello-samza tutorial to use Kafka-0.11 Author: Jagadish <jvenkatra...@linkedin.com> Reviewers: Pratee

[1/2] samza git commit: SAMZA-1619: Samza-sql: Support serialization of nested samza sql relational message

Repository: samza Updated Branches: refs/heads/master bf2a2f76d -> 58c39e371 http://git-wip-us.apache.org/repos/asf/samza/blob/58c39e37/samza-sql/src/test/java/org/apache/samza/sql/system/TestAvroSystemFactory.java -- diff

[2/2] samza git commit: SAMZA-1619: Samza-sql: Support serialization of nested samza sql relational message

f6560ac6c9 Parents: bf2a2f7 Author: Aditya Toomula <atoom...@linkedin.com> Authored: Mon Apr 16 10:26:51 2018 -0700 Committer: Jagadish <jvenkatra...@linkedin.com> Committed: Mon Apr 16 10:26:51 2018 -0700 ---

samza git commit: SAMZA-1643: StreamPartitionCountMonitor should only restart/shut down the job if partition count increases

nce that's what its name indicates. Author: Prateek Maheshwari <pmahe...@linkedin.com> Reviewers: Jagadish V <jagad...@apache.org> Closes #468 from prateekm/partition-monitor-fixes Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/a

samza git commit: SAMZA-1649: Improve host-aware allocation to account for strict locality

ion to the above change, this PR also modifies the allocator algorithm to fallback to "ANY_HOST" requests so that we make progress when the node is unavailable. Author: Jagadish <jvenkatra...@linkedin.com> Reviewers: Prateek Maheshwari <pmahe...@linkedin.com> Closes #471 from vja

samza git commit: SAMZA-1650: Fix for firing trigger at the end of trigger interval for tumbling window

Repository: samza Updated Branches: refs/heads/master 76de840c7 -> 96c333469 SAMZA-1650: Fix for firing trigger at the end of trigger interval for tumbling window Author: Aditya Toomula <atoom...@linkedin.com> Reviewers: Jagadish <jagad...@apache.org> Closes #472 from

samza git commit: minor fix on eventhubs size limit for event body and partition key

Repository: samza Updated Branches: refs/heads/master bbcf14eba -> 3895a9070 minor fix on eventhubs size limit for event body and partition key Author: Hai Lu <h...@linkedin.com> Reviewers: Jagadish <jagad...@apache.org>, Srinivasulu Punuru<spun...@linkedin.com> Clo

[jira] [Created] (SAMZA-1649) Improve host-aware allocation to account for strict locality

Jagadish created SAMZA-1649: --- Summary: Improve host-aware allocation to account for strict locality Key: SAMZA-1649 URL: https://issues.apache.org/jira/browse/SAMZA-1649 Project: Samza Issue Type

[jira] [Created] (SAMZA-1635) Usage of AsyncRunLoop with threadpool size = 1 results in slowness

Jagadish created SAMZA-1635: --- Summary: Usage of AsyncRunLoop with threadpool size = 1 results in slowness Key: SAMZA-1635 URL: https://issues.apache.org/jira/browse/SAMZA-1635 Project: Samza

[jira] [Created] (SAMZA-1634) Update javadocs for SystemConsumer implementors

Jagadish created SAMZA-1634: --- Summary: Update javadocs for SystemConsumer implementors Key: SAMZA-1634 URL: https://issues.apache.org/jira/browse/SAMZA-1634 Project: Samza Issue Type: Bug

samza git commit: SAMZA-1632: KinesisConfig: Making getProxyHost and getProxyPort APIs protected

Repository: samza Updated Branches: refs/heads/master 57fea260a -> e58e3cadc SAMZA-1632: KinesisConfig: Making getProxyHost and getProxyPort APIs protected Author: Aditya Toomula <atoom...@linkedin.com> Reviewers: Jagadish<jagad...@apache.org> Closes #457 from atoomula/kc

[CONF] Apache Samza > Powered By

Title: Message Title jagadish edited a page   Powered By ... Company Description LinkedIn Samza was originally developed at LinkedIn. It's currently used to process tracking data, service log

[CONF] Apache Samza > Powered By

Title: Message Title jagadish edited a page   Powered By ... Company Description LinkedIn Samza was originally developed at LinkedIn. It's currently used to process tracking data, service log

[CONF] Apache Samza > Powered By

Title: Message Title jagadish edited a page   Powered By ... Company Description LinkedIn Samza was originally developed at LinkedIn. It's currently used to process tracking data, service log

[jira] [Updated] (SAMZA-1155) Allow configuring window.ms to specify trigger duration

[ https://issues.apache.org/jira/browse/SAMZA-1155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1155: Description: When a user writes a `StreamTask` (low level API), the property `task.window.ms` specifies

[CONF] Apache Samza > Powered By

Title: Message Title jagadish edited a page   Powered By ... Company Description LinkedIn Samza was originally developed at LinkedIn. It's currently used to process tracking data, service log

samza git commit: SAMZA-1611: BootstrappingChooser should use systemAdmin offsetComparator API to compare the offsets

Repository: samza Updated Branches: refs/heads/master 49e5073c3 -> 3f9b96704 SAMZA-1611: BootstrappingChooser should use systemAdmin offsetComparator API to compare the offsets Author: Aditya Toomula <atoom...@linkedin.com> Reviewers: Jagadish <jagad...@apache.org> C

[1/2] samza git commit: SAMZA-1610: Implementation of remote table provider

Repository: samza Updated Branches: refs/heads/master 1971d596c -> 2be7061d4 http://git-wip-us.apache.org/repos/asf/samza/blob/2be7061d/samza-core/src/test/java/org/apache/samza/util/TestEmbeddedTaggedRateLimiter.java -- diff

[2/2] samza git commit: SAMZA-1610: Implementation of remote table provider

SAMZA-1610: Implementation of remote table provider Please see commit messages for detailed descriptions. Author: Peng Du <p...@linkedin.com> Reviewers: Jagadish <jagad...@apache.org>, Wei Song <ws...@linkedin.com> Closes #432 from pdu-mn1/remote-table-0222 Proje

[jira] [Created] (SAMZA-1610) Implement Remote tables

Jagadish created SAMZA-1610: --- Summary: Implement Remote tables Key: SAMZA-1610 URL: https://issues.apache.org/jira/browse/SAMZA-1610 Project: Samza Issue Type: Bug Reporter: Jagadish

samza git commit: SAMZA-1589: Reduce failure retry duration in KafkaCheckpointManager.writeCheckpoint

Repository: samza Updated Branches: refs/heads/master 89dc18e96 -> 6492826e1 SAMZA-1589: Reduce failure retry duration in KafkaCheckpointManager.writeCheckpoint Author: Shanthoosh Venkataraman <svenkatara...@linkedin.com> Reviewers: Jagadish <jagad...@apache.org> C

[jira] [Commented] (SAMZA-1599) AsyncRunLoop Slow When Some Partitions Are Empty

[ https://issues.apache.org/jira/browse/SAMZA-1599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16388851#comment-16388851 ] Jagadish commented on SAMZA-1599: - Heya [~jwlent55], this is extremely thorough. Impressive work

[jira] [Closed] (SAMZA-1600) Changelog topics for batch jobs should not use combination of delete+compact cleanup policy in Kafka

[ https://issues.apache.org/jira/browse/SAMZA-1600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish closed SAMZA-1600. --- > Changelog topics for batch jobs should not use combination of delete+compact > cleanup policy in

[jira] [Resolved] (SAMZA-1600) Changelog topics for batch jobs should not use combination of delete+compact cleanup policy in Kafka

[ https://issues.apache.org/jira/browse/SAMZA-1600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish resolved SAMZA-1600. - Resolution: Fixed > Changelog topics for batch jobs should not use combination of delete+comp

samza git commit: SAMZA-1600: remove the combination of cleanup policy "compact,delete"…

Repository: samza Updated Branches: refs/heads/master 810d8bd80 -> 78ee98261 SAMZA-1600: remove the combination of cleanup policy "compact,delete"… … in changelog topic properties Author: Yi Pan (Data Infrastructure) <nickpa...@gmail.com> Reviewers: Jagadish &

[jira] [Closed] (SAMZA-1460) StreamAppender does not explicitly create logging topic

[ https://issues.apache.org/jira/browse/SAMZA-1460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish closed SAMZA-1460. --- > StreamAppender does not explicitly create logging to

samza git commit: SAMZA-1460: StreamAppender does not explicitly create logging topic

/asf/samza/tree/810d8bd8 Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/810d8bd8 Branch: refs/heads/master Commit: 810d8bd805f386f79ce73efdee0d2ef341a65e83 Parents: 1dfc5ce Author: Daniel Nishimura <dnishim...@gmail.com> Authored: Mon Mar 5 16:02:49 2018 -0800 Committer: Jagadish <j

samza git commit: Misc. minor cleanup.

few checkstyle warning about missing param/throws documentation. Author: Prateek Maheshwari <pmahe...@linkedin.com> Reviewers: Jagadish <jagad...@apache.org>, Jacob M <jma...@apache.org> Closes #433 from prateekm/container-thread-pool-name Project: http://git-wip-us.apache.org

samza git commit: SAMZA-1598: Cleanup README.md file

c0a47b7 Branch: refs/heads/master Commit: bc0a47b7ca0f3f2ff506673224ec7da4880429fd Parents: ed7e4af Author: Daniel Nishimura <dnishim...@gmail.com> Authored: Sat Mar 3 16:29:44 2018 -0800 Committer: Jagadish <jvenkatra...@linkedin.com> Committed: Sa

samza git commit: SAMZA-1596: Staging directory name has to be formatted in config

oes not parse from config, but only systems.%s.stagingDirectory only parses instead. Solution is to add formatter to getStagingDirectory method. Author: Akim Akimov <zed...@gmail.com> Reviewers: Jagadish <jagad...@apache.org>, Hai L<h...@linkedin.com> Closes #431 from Zed

samza git commit: SAMZA-1597: Expose an interface for throttling

pos/asf/samza/tree/963bd308 Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/963bd308 Branch: refs/heads/master Commit: 963bd3085e0284b40917c3ddfd02e70f882d1a19 Parents: 6af104e Author: Wei Song <ws...@linkedin.com> Authored: Tue Feb 27 11:47:51 2018 -0800 Committer: Jagadish &

[jira] [Created] (SAMZA-1597) Expose an Interface for throttling

Jagadish created SAMZA-1597: --- Summary: Expose an Interface for throttling Key: SAMZA-1597 URL: https://issues.apache.org/jira/browse/SAMZA-1597 Project: Samza Issue Type: Bug Reporter

[jira] [Commented] (SAMZA-1592) Hello-Samza latest branch is broken after Kafka 0.11 upgrade in Samza

[ https://issues.apache.org/jira/browse/SAMZA-1592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16375737#comment-16375737 ] Jagadish commented on SAMZA-1592: - [~xinyu] Here's the PR for this: https://github.com/apache/samza-hello

[jira] [Updated] (SAMZA-1592) Hello-Samza latest branch is broken after Kafka 0.11 upgrade in Samza

[ https://issues.apache.org/jira/browse/SAMZA-1592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1592: Description: After the 0.11 upgrade, the latest branch in hello-samza (and hence all our open-source

samza git commit: Fixes to get the build working with Scala 2.10 build

Repository: samza Updated Branches: refs/heads/master 6dc89e100 -> 6270e40b2 Fixes to get the build working with Scala 2.10 build The fixes needed to get the build working with the Scala 2.10. Author: Srinivasulu Punuru <spun...@linkedin.com> Reviewers: Jagadish <jagad...@apache

[jira] [Created] (SAMZA-1592) Hello-Samza latest branch is broken after Kafka 0.11 upgrade in Samza

Jagadish created SAMZA-1592: --- Summary: Hello-Samza latest branch is broken after Kafka 0.11 upgrade in Samza Key: SAMZA-1592 URL: https://issues.apache.org/jira/browse/SAMZA-1592 Project: Samza

samza git commit: SAMZA-1568: Handle ZkInterruptedException in zkclient.close.

: Shanthoosh Venkataraman <svenkatara...@linkedin.com> Reviewers: Jagadish <jagad...@apache.org> Closes #416 from shanthoosh/zk_utils_close Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/4123b160 Tree: http://git-wip

samza git commit: SAMZA-1572: Add fixed retries on failure in KafkaCheckpointManager.

7 Branch: refs/heads/master Commit: 002e131784d52e02f6d4b46453b31d47f20cad31 Parents: c51693b Author: Shanthoosh Venkataraman <svenkatara...@linkedin.com> Authored: Tue Feb 13 11:22:34 2018 -0800 Committer: Jagadish <jvenkatra...@linkedin.com> Committed: Tue

samza git commit: SAMZA-1489: TaskInstance should commit offset before it closes() if auto commit is enabled

Repository: samza Updated Branches: refs/heads/master 03e5026cf -> c51693bcd SAMZA-1489: TaskInstance should commit offset before it closes() if auto commit is enabled Author: Dong Lin <lindon...@gmail.com> Reviewers: Jagadish<jagad...@apache.org> Closes #417 from lindo

samza git commit: SAMZA-1552: Host affinity improvements - Improve matching of hosts to allocated resources

Repository: samza Updated Branches: refs/heads/master 7e68e4b10 -> 03e5026cf SAMZA-1552: Host affinity improvements - Improve matching of hosts to allocated resources Author: Jagadish <jvenkatra...@linkedin.com> Reviewers: Prateek <prate...@cs.utexas.edu> Closes #401 fro

samza git commit: Added some logging to stdout for easier parsing by tools.

Repository: samza Updated Branches: refs/heads/master 75e70e569 -> 9674836f6 Added some logging to stdout for easier parsing by tools. Author: Prateek Maheshwari <pmahe...@linkedin.com> Reviewers: Jagadish<jagad...@apache.org> Closes #414 from prateekm/print-container-info

samza git commit: fix the bug containsValue method

Repository: samza Updated Branches: refs/heads/master d6686b0f0 -> 1756b0597 fix the bug containsValue method containsValue method should invoke map.containsValue not map.containsKey Author: michaelwong <michaelwon...@users.noreply.github.com> Reviewers: Jagadish <jagad..

samza git commit: Typo fix in web-ui-rest-api.md

42f27e5 Parents: 2bd7f69 Author: David Dumenil <david.dume...@moneysupermarket.com> Authored: Mon Jan 22 14:08:29 2018 -0800 Committer: Jagadish <jvenkatra...@linkedin.com> Committed: Mon Jan 22 14:08:29 2018 -0800 -

samza git commit: upTime should be field not method

Repository: samza Updated Branches: refs/heads/master 24d22bb80 -> d6686b0f0 upTime should be field not method Author: zhangyijun <joa.zh...@gmail.com> Reviewers: Jagadish <jagad...@apache.org> Closes #9 from zhangyijun/patch-1 Project: http://git-wip-us.apache.org/repos

samza git commit: SAMZA-1561: Fix inconsistency problem in JobModel publish.

Repository: samza Updated Branches: refs/heads/master e075e956f -> 24d22bb80 SAMZA-1561: Fix inconsistency problem in JobModel publish. Author: Shanthoosh Venkataraman <svenkatara...@linkedin.com> Reviewers: Jagadish V<jagad...@apache.org>, Xinyu Liu<xi...@apache.org&

samza git commit: SAMZA-1560: Handle key-serde errors in KafkaCheckpointManager

Repository: samza Updated Branches: refs/heads/master b38e6622f -> b7805df10 SAMZA-1560: Handle key-serde errors in KafkaCheckpointManager Author: Jagadish <jvenkatra...@linkedin.com> Reviewers: Xinyu Liu<xinyuisc...@gmail.com> Closes #408 from vjagadish1989/kcm-fix Proj

[jira] [Created] (SAMZA-1560) Skip checkpoint validations for Key Serdes

Jagadish created SAMZA-1560: --- Summary: Skip checkpoint validations for Key Serdes Key: SAMZA-1560 URL: https://issues.apache.org/jira/browse/SAMZA-1560 Project: Samza Issue Type: Bug

[jira] [Updated] (SAMZA-1560) Skip checkpoint validations for Key Serdes

[ https://issues.apache.org/jira/browse/SAMZA-1560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1560: Description: Currently, when "validateCheckpoints" is set to false, we ignore validat

[jira] [Closed] (SAMZA-1523) Cleanup table entries before shutting down the processor

[ https://issues.apache.org/jira/browse/SAMZA-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish closed SAMZA-1523. --- > Cleanup table entries before shutting down the proces

[jira] [Resolved] (SAMZA-1523) Cleanup table entries before shutting down the processor

[ https://issues.apache.org/jira/browse/SAMZA-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish resolved SAMZA-1523. - Resolution: Fixed > Cleanup table entries before shutting down the proces

samza git commit: SAMZA-1523: Cleanup table entries before shutting down the processor

...@apache.org> Authored: Wed Jan 17 10:11:40 2018 -0800 Committer: Jagadish <jvenkatra...@linkedin.com> Committed: Wed Jan 17 10:11:40 2018 -0800 -- .../samza/coordinator/AzureJobCoordinator.java | 75 ++-

[jira] [Closed] (SAMZA-1556) Samza SQL: Add support for multi level sources in SQL query

[ https://issues.apache.org/jira/browse/SAMZA-1556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish closed SAMZA-1556. --- > Samza SQL: Add support for multi level sources in SQL qu

[jira] [Updated] (SAMZA-1556) Samza SQL: Add support for multi level sources in SQL query

[ https://issues.apache.org/jira/browse/SAMZA-1556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1556: Fix Version/s: 0.15.0 > Samza SQL: Add support for multi level sources in SQL qu

[jira] [Resolved] (SAMZA-1556) Samza SQL: Add support for multi level sources in SQL query

[ https://issues.apache.org/jira/browse/SAMZA-1556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish resolved SAMZA-1556. - Resolution: Fixed > Samza SQL: Add support for multi level sources in SQL qu

samza git commit: SAMZA-1556: Adding support for multi level sources in queries

cd2b9a5 Branch: refs/heads/master Commit: fcd2b9a53367c2e0b53df7a1fb7eedc8086b285c Parents: 3a9e806 Author: Srinivasulu Punuru <spun...@linkedin.com> Authored: Wed Jan 17 10:06:50 2018 -0800 Committer: Jagadish <jvenkatra...@linkedin.com> Committe

[jira] [Closed] (SAMZA-1500) Add metrics for RocksDB state store memory usage

[ https://issues.apache.org/jira/browse/SAMZA-1500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish closed SAMZA-1500. --- > Add metrics for RocksDB state store memory us

samza git commit: SAMZA-1500: Added metrics for RocksDB state store memory usage

ize + rocksdb.size-all-mem-tables + rocksdb.estimate-table-readers-mem Author: Prateek Maheshwari <pmahe...@linkedin.com> Reviewers: Jagadish <jagad...@apache.org> Closes #404 from prateekm/rocksdb-memory Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apach

[jira] [Updated] (SAMZA-1552) Host affinity improvements - Improve matching of hosts to allocated resources

[ https://issues.apache.org/jira/browse/SAMZA-1552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1552: Description: Kudos to [~abkshvn] for observing this! We have observed host-affinity not being honored

[jira] [Created] (SAMZA-1552) Host affinity improvements - Improve matching of hosts to allocated resources

Jagadish created SAMZA-1552: --- Summary: Host affinity improvements - Improve matching of hosts to allocated resources Key: SAMZA-1552 URL: https://issues.apache.org/jira/browse/SAMZA-1552 Project: Samza

[jira] [Updated] (SAMZA-1552) Host affinity improvements - Improve matching of hosts to allocated resources

[ https://issues.apache.org/jira/browse/SAMZA-1552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1552: Description: Kudos to [~abkshvn] for observing this! We have observed host-affinity not being honored

samza git commit: SAMZA-1528: Change ClusterResourceManager to use the async NMClient

job. Author: Jagadish <jvenkatra...@linkedin.com> Author: Fred Ji <haifeng...@gmail.com> Author: Srinivasulu Punuru <spun...@linkedin.com> Reviewers: Jacob Maes<jma...@linkedin.com>, Xinyu Liu<xinyuisc...@gmail.com> Closes #380 from vjagadish1989/cluster-mgr-refactor1 Proj

samza git commit: SAMZA-1547; Parse default value grouper-factory config in KafkaCheckpointMgr

Repository: samza Updated Branches: refs/heads/0.14.0 804aea2b9 -> 7b42474d3 SAMZA-1547; Parse default value grouper-factory config in KafkaCheckpointMgr - Additionally, updated all unit-tests. Author: Jagadish <jvenkatra...@linkedin.com> Reviewers: Prateek M <prmahe...@

samza git commit: SAMZA-1547; Parse default value grouper-factory config in KafkaCheckpointMgr

Repository: samza Updated Branches: refs/heads/master 9a8099cda -> 93219c78d SAMZA-1547; Parse default value grouper-factory config in KafkaCheckpointMgr - Additionally, updated all unit-tests. Author: Jagadish <jvenkatra...@linkedin.com> Reviewers: Prateek M <prmahe...@

[jira] [Created] (SAMZA-1547) Fix default value for the grouper-factory configuration in KafkaCheckpointManager

Jagadish created SAMZA-1547: --- Summary: Fix default value for the grouper-factory configuration in KafkaCheckpointManager Key: SAMZA-1547 URL: https://issues.apache.org/jira/browse/SAMZA-1547 Project: Samza

samza git commit: SAMZA-1536; Adding docs for Kinesis consumer

Repository: samza Updated Branches: refs/heads/0.14.0 c7150cf2d -> ef506a3c5 SAMZA-1536; Adding docs for Kinesis consumer Author: Aditya Toomula <atoom...@atoomula-ld1.linkedin.biz> Reviewers: Jagadish <jagad...@apache.org> Closes #384 from atoomula/kinesis-docs (cherry pic

samza git commit: SAMZA-1536; Adding docs for Kinesis consumer

Repository: samza Updated Branches: refs/heads/master 54dc4a03e -> ed8dad54b SAMZA-1536; Adding docs for Kinesis consumer Author: Aditya Toomula <atoom...@atoomula-ld1.linkedin.biz> Reviewers: Jagadish <jagad...@apache.org> Closes #384 from atoomula/kinesis-docs Project:

samza-hello-samza git commit: Adding hello-samza example for kinesis

Repository: samza-hello-samza Updated Branches: refs/heads/master 5fa742ac4 -> 90bbe75f2 Adding hello-samza example for kinesis Author: Aditya Toomula <atoom...@atoomula-ld1.linkedin.biz> Reviewers: Jagadish<jagad...@apache.org> Closes #30 from atoomula/kinesis Project:

samza git commit: SAMZA-1437; Added Eventhub producer and consumer docs

ub.com> Reviewers: Jagadish <jagad...@apache.org> Closes #382 from dxichen/eventhub-docs Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/2e5ceec1 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/2e5ceec1 Diff:

samza git commit: SAMZA-1502; Make AllSspToSingleTaskGrouper work with Yarn and ZK JobCoordinator

093d9abf9) Signed-off-by: Jagadish <jvenkatra...@linkedin.com> Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/736fe252 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/736fe252 Diff: http://git-wip-us.apache.org/repos/asf/

samza git commit: SAMZA-1502; Make AllSspToSingleTaskGrouper work with Yarn and ZK JobCoordinator

Aditya Toomula <atoom...@atoomula-ld1.linkedin.biz> Authored: Tue Dec 12 21:41:37 2017 -0800 Committer: Jagadish <jvenkatra...@linkedin.com> Committed: Tue Dec 12 21:41:37 2017 -0800 -- .../AllSspToSingleTa

[2/2] samza git commit: Documentation for Samza SQL

-1526 Author: Srinivasulu Punuru <spun...@linkedin.com> Reviewers: Yi Pan<nickpa...@gmail.com>, Jagadish<jagad...@apachehe.org> Closes #374 from srinipunuru/docs.1 Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/sam

[1/2] samza git commit: Documentation for Samza SQL

Repository: samza Updated Branches: refs/heads/master 1d420e750 -> 42bac30ad http://git-wip-us.apache.org/repos/asf/samza/blob/42bac30a/samza-tools/src/main/java/org/apache/samza/tools/schemas/ProfileChangeEvent.avsc -- diff

samza-hello-samza git commit: Change Kafka Version used in bin/grid

mre Nagi <imre.nagi2...@gmail.com> Reviewers: Jagadish<jagad...@apache.org> Closes #26 from imrenagi/master Project: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/commit/5fa742ac Tree: http://git-wip-us.a

samza-hello-samza git commit: Fix the Kafka download link

0.2, and 1.0.0. Changed the repo to the main apache repo. Author: Sardana <sardana...@mail.ru> Reviewers: Jagadish<jagad...@apache.org> Closes #28 from capdaha/patch-1 Project: http://git-wip-us.apache.org/repos/asf/samza-hello-samza/repo Commit: http://git-wip-us.apache.org/repos/

samza-hello-samza git commit: Fixed stateful operator name

Repository: samza-hello-samza Updated Branches: refs/heads/latest f48c7f9f3 -> 004e03fad Fixed stateful operator name Author: Prateek Maheshwari <pmahe...@linkedin.com> Reviewers: Jagadish<jagad...@apache.org> Closes #25 from prateekm/latest Project: http://git-wip-us.apach

samza-hello-samza git commit: SAMZA-1524: Azure checkpoint and eventhubs fluent api standalone example

Repository: samza-hello-samza Updated Branches: refs/heads/latest e7811dbf7 -> f48c7f9f3 SAMZA-1524: Azure checkpoint and eventhubs fluent api standalone example Tutorial and docs coming soon Author: Daniel Chen <29577458+dxic...@users.noreply.github.com> Reviewers: Jagad

samza git commit: SAMZA-1532; Eventhub connector fix

8+dxic...@users.noreply.github.com> Reviewers: Jagadish<jagad...@apache.org> Closes #377 from dxichen/eventhub-connector-fix Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/1d420e75 Tree: http://git-wip-us.apache.org/repos/asf/samz

[jira] [Created] (SAMZA-1528) Implement async NodeManager interactions

Jagadish created SAMZA-1528: --- Summary: Implement async NodeManager interactions Key: SAMZA-1528 URL: https://issues.apache.org/jira/browse/SAMZA-1528 Project: Samza Issue Type: Bug

[jira] [Resolved] (SAMZA-1515) Implement a consumer for Kinesis

[ https://issues.apache.org/jira/browse/SAMZA-1515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish resolved SAMZA-1515. - Resolution: Fixed > Implement a consumer for Kine

[jira] [Closed] (SAMZA-1515) Implement a consumer for Kinesis

[ https://issues.apache.org/jira/browse/SAMZA-1515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish closed SAMZA-1515. --- > Implement a consumer for Kinesis > > > Key

[jira] [Created] (SAMZA-1515) Implement a consumer for Kinesis

Jagadish created SAMZA-1515: --- Summary: Implement a consumer for Kinesis Key: SAMZA-1515 URL: https://issues.apache.org/jira/browse/SAMZA-1515 Project: Samza Issue Type: Sub-task

[2/2] samza git commit: SAMZA-1515; Implement a consumer for Kinesis

SAMZA-1515; Implement a consumer for Kinesis Author: Aditya Toomula <atoom...@atoomula-ld1.linkedin.biz> Reviewers: Jagadish<jagad...@apache.org> Closes #368 from atoomula/kinesis Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/rep

[1/2] samza git commit: SAMZA-1515; Implement a consumer for Kinesis

Repository: samza Updated Branches: refs/heads/master 5e68d621a -> 9961023f7 http://git-wip-us.apache.org/repos/asf/samza/blob/9961023f/samza-aws/src/test/java/org/apache/samza/system/kinesis/TestKinesisSystemFactory.java --

[jira] [Closed] (SAMZA-1513) Doc updates for Windows and joins with durable state

[ https://issues.apache.org/jira/browse/SAMZA-1513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish closed SAMZA-1513. --- > Doc updates for Windows and joins with durable st

[jira] [Resolved] (SAMZA-1513) Doc updates for Windows and joins with durable state

[ https://issues.apache.org/jira/browse/SAMZA-1513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish resolved SAMZA-1513. - Resolution: Fixed > Doc updates for Windows and joins with durable st

samza git commit: SAMZA-1513; Doc updates for persistent windows, joins and serdes.

Repository: samza Updated Branches: refs/heads/master a5a69c4df -> 5e68d621a SAMZA-1513; Doc updates for persistent windows, joins and serdes. jmakes prateekm nickpan47 for review. Author: Jagadish <jvenkatra...@linkedin.com> Reviewers: Jake Maes<jm...@linkedin.com> C

[jira] [Assigned] (SAMZA-1513) Doc updates for Windows and joins with durable state

[ https://issues.apache.org/jira/browse/SAMZA-1513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish reassigned SAMZA-1513: --- Assignee: Jagadish > Doc updates for Windows and joins with durable st

[jira] [Updated] (SAMZA-1513) Doc updates for Windows and joins with durable state

[ https://issues.apache.org/jira/browse/SAMZA-1513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish updated SAMZA-1513: Description: - The website needs to be updated with examples for using Windows and Joins with durable

[jira] [Created] (SAMZA-1513) Doc updates for Windows and joins with durable state

Jagadish created SAMZA-1513: --- Summary: Doc updates for Windows and joins with durable state Key: SAMZA-1513 URL: https://issues.apache.org/jira/browse/SAMZA-1513 Project: Samza Issue Type: Sub

[jira] [Closed] (SAMZA-1494) Flush operator state on end of stream

[ https://issues.apache.org/jira/browse/SAMZA-1494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish closed SAMZA-1494. --- > Flush operator state on end of stream > - > >

samza git commit: SAMZA-1494; Flush operator state at end of stream

eam irrespective of auto-commit behavior. Author: Jagadish <jvenkatra...@linkedin.com> Reviewers: Xinyu Liu <xi...@linkedin.com> Closes #366 from vjagadish1989/eos-flush Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/

[jira] [Closed] (SAMZA-1426) Wire-up windowed stores in the Operatorgraph

[ https://issues.apache.org/jira/browse/SAMZA-1426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish closed SAMZA-1426. --- > Wire-up windowed stores in the Operatorgr

[jira] [Commented] (SAMZA-1425) Implement persistent tumbling and session windows

[ https://issues.apache.org/jira/browse/SAMZA-1425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16259616#comment-16259616 ] Jagadish commented on SAMZA-1425: - https://github.com/apache/samza/pull/321 > Implement persist

[jira] [Closed] (SAMZA-1423) Implement a RocksDb backed time-series store for storing and retrieving messages time-ranges

[ https://issues.apache.org/jira/browse/SAMZA-1423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jagadish closed SAMZA-1423. --- > Implement a RocksDb backed time-series store for storing and retrieving > messages time-

[jira] [Commented] (SAMZA-1426) Wire-up windowed stores in the Operatorgraph

[ https://issues.apache.org/jira/browse/SAMZA-1426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16259615#comment-16259615 ] Jagadish commented on SAMZA-1426: - Resolved by https://github.com/apache/samza/pull/321 > Wire

<    2   3   4   5   6   7   8   9   10   11   >