[samza] branch master updated: SAMZA-2262: Change container-startup-time to a gauge from a timer and to ms instead of ns (#1092)

This is an automated email from the ASF dual-hosted git repository. pmaheshwari pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/samza.git The following commit(s) were added to refs/heads/master by this push: new 816313e SAMZA-2262: Change container-startu

[GitHub] [samza] prateekm merged pull request #1092: SAMZA-2262: Change container-startup-time to a gauge from a timer and to ms instead of ns

prateekm merged pull request #1092: SAMZA-2262: Change container-startup-time to a gauge from a timer and to ms instead of ns URL: https://github.com/apache/samza/pull/1092 This is an automated message from the Apache Git Se

[samza] branch master updated: SAMZA-2213: Fixing accidental change to config key (#1093)

This is an automated email from the ASF dual-hosted git repository. pmaheshwari pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/samza.git The following commit(s) were added to refs/heads/master by this push: new 2a401b0 SAMZA-2213: Fixing accidental chang

[GitHub] [samza] prateekm merged pull request #1093: SAMZA-2213: Fixing accidental change to config key

prateekm merged pull request #1093: SAMZA-2213: Fixing accidental change to config key URL: https://github.com/apache/samza/pull/1093 This is an automated message from the Apache Git Service. To respond to the message, pleas

[GitHub] [samza] vjagadish1989 commented on issue #1092: Samza-2262: Making container-startup-time a gauge. It is currently a timer.

vjagadish1989 commented on issue #1092: Samza-2262: Making container-startup-time a gauge. It is currently a timer. URL: https://github.com/apache/samza/pull/1092#issuecomment-506101003 nit-nit-pick: s/samza/SAMZA This is an

[GitHub] [samza] rmatharu commented on issue #1092: Samza-2262: Making container-startup-time a gauge. It is currently a timer.

rmatharu commented on issue #1092: Samza-2262: Making container-startup-time a gauge. It is currently a timer. URL: https://github.com/apache/samza/pull/1092#issuecomment-506090314 Done This is an automated message from the A

[jira] [Created] (SAMZA-2262) Making container-startup-time a gauge. It is currently a timer

Rayman created SAMZA-2262: - Summary: Making container-startup-time a gauge. It is currently a timer Key: SAMZA-2262 URL: https://issues.apache.org/jira/browse/SAMZA-2262 Project: Samza Issue Type: B

[GitHub] [samza] rmatharu commented on a change in pull request #1092: Making container-startup-time a gauge. It is currently a timer.

rmatharu commented on a change in pull request #1092: Making container-startup-time a gauge. It is currently a timer. URL: https://github.com/apache/samza/pull/1092#discussion_r297914260 ## File path: samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala #

[GitHub] [samza] rmatharu opened a new pull request #1093: Samza-2213: Fixing accidental change to config key

rmatharu opened a new pull request #1093: Samza-2213: Fixing accidental change to config key URL: https://github.com/apache/samza/pull/1093 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [samza] vjagadish1989 commented on issue #1092: Making container-startup-time a gauge. It is currently a timer.

vjagadish1989 commented on issue #1092: Making container-startup-time a gauge. It is currently a timer. URL: https://github.com/apache/samza/pull/1092#issuecomment-506076495 nit-pick: fix PR title either: "SAMZA-1234: ..." or "Minor: ..." ---

[GitHub] [samza] prateekm commented on a change in pull request #1092: Making container-startup-time a gauge. It is currently a timer.

prateekm commented on a change in pull request #1092: Making container-startup-time a gauge. It is currently a timer. URL: https://github.com/apache/samza/pull/1092#discussion_r297899061 ## File path: samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala #

[GitHub] [samza] rmatharu opened a new pull request #1092: Making container-startup-time a gauge. It is currently a timer.

rmatharu opened a new pull request #1092: Making container-startup-time a gauge. It is currently a timer. URL: https://github.com/apache/samza/pull/1092 This metric is the diff of System.nanoTime() which is a positive long (since the number of nano seconds for which a JVM a running should

[GitHub] [samza] prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog

prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog URL: https://github.com/apache/samza/pull/1008#discussion_r297896194 ## File path: samza-kv/src/main/java/org/apache/samza/storage/kv/LargeMessage

[GitHub] [samza] cameronlee314 commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog

cameronlee314 commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog URL: https://github.com/apache/samza/pull/1008#discussion_r297893534 ## File path: samza-kv/src/main/scala/org/apache/samza/storage/kv/BaseKe

[GitHub] [samza] prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog

prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog URL: https://github.com/apache/samza/pull/1008#discussion_r297890721 ## File path: samza-kv/src/main/scala/org/apache/samza/storage/kv/BaseKeyValu

[GitHub] [samza] cameronlee314 commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog

cameronlee314 commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog URL: https://github.com/apache/samza/pull/1008#discussion_r297888348 ## File path: samza-kv/src/main/scala/org/apache/samza/storage/kv/BaseKe

[GitHub] [samza] prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog

prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog URL: https://github.com/apache/samza/pull/1008#discussion_r297875021 ## File path: samza-kv/src/main/scala/org/apache/samza/storage/kv/BaseKeyValu

[GitHub] [samza] prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog

prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog URL: https://github.com/apache/samza/pull/1008#discussion_r297859339 ## File path: docs/learn/documentation/versioned/jobs/configuration-table.html

[GitHub] [samza] prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog

prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog URL: https://github.com/apache/samza/pull/1008#discussion_r297885083 ## File path: samza-kv/src/main/scala/org/apache/samza/storage/kv/BaseKeyValu

[GitHub] [samza] prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog

prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog URL: https://github.com/apache/samza/pull/1008#discussion_r297861567 ## File path: samza-kv/src/main/java/org/apache/samza/storage/kv/LargeMessage

[GitHub] [samza] prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog

prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog URL: https://github.com/apache/samza/pull/1008#discussion_r297861818 ## File path: samza-kv/src/main/java/org/apache/samza/storage/kv/LargeMessage

[GitHub] [samza] prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog

prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog URL: https://github.com/apache/samza/pull/1008#discussion_r297885117 ## File path: samza-kv/src/main/scala/org/apache/samza/storage/kv/BaseKeyValu

[GitHub] [samza] prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog

prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog URL: https://github.com/apache/samza/pull/1008#discussion_r297884963 ## File path: samza-kv/src/main/scala/org/apache/samza/storage/kv/BaseKeyValu

[GitHub] [samza] prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog

prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog URL: https://github.com/apache/samza/pull/1008#discussion_r297855998 ## File path: docs/learn/documentation/versioned/jobs/configuration-table.html

[GitHub] [samza] prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog

prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog URL: https://github.com/apache/samza/pull/1008#discussion_r297857929 ## File path: docs/learn/documentation/versioned/jobs/configuration-table.html

[GitHub] [samza] prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog

prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog URL: https://github.com/apache/samza/pull/1008#discussion_r297861352 ## File path: samza-kv/src/main/java/org/apache/samza/storage/kv/LargeMessage

[GitHub] [samza] prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog

prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog URL: https://github.com/apache/samza/pull/1008#discussion_r297885294 ## File path: samza-kv/src/main/scala/org/apache/samza/storage/kv/LoggedStore

[GitHub] [samza] prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog

prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog URL: https://github.com/apache/samza/pull/1008#discussion_r297871746 ## File path: samza-kv/src/main/java/org/apache/samza/storage/kv/LargeMessage

[GitHub] [samza] prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog

prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog URL: https://github.com/apache/samza/pull/1008#discussion_r297856834 ## File path: docs/learn/documentation/versioned/jobs/configuration-table.html

[GitHub] [samza] prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog

prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog URL: https://github.com/apache/samza/pull/1008#discussion_r297859883 ## File path: docs/learn/documentation/versioned/jobs/configuration-table.html

[GitHub] [samza] prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog

prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog URL: https://github.com/apache/samza/pull/1008#discussion_r297857367 ## File path: docs/learn/documentation/versioned/jobs/configuration-table.html

[GitHub] [samza] prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog

prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog URL: https://github.com/apache/samza/pull/1008#discussion_r297885381 ## File path: samza-kv/src/main/scala/org/apache/samza/storage/kv/LoggedStore

[GitHub] [samza] prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog

prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog URL: https://github.com/apache/samza/pull/1008#discussion_r297860764 ## File path: samza-kv/src/main/java/org/apache/samza/storage/kv/LargeMessage

[GitHub] [samza] prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog

prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog URL: https://github.com/apache/samza/pull/1008#discussion_r297857652 ## File path: docs/learn/documentation/versioned/jobs/configuration-table.html

[GitHub] [samza] prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog

prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog URL: https://github.com/apache/samza/pull/1008#discussion_r297856464 ## File path: docs/learn/documentation/versioned/jobs/configuration-table.html

[GitHub] [samza] prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog

prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog URL: https://github.com/apache/samza/pull/1008#discussion_r297861197 ## File path: samza-kv/src/main/java/org/apache/samza/storage/kv/LargeMessage

[GitHub] [samza] prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog

prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog URL: https://github.com/apache/samza/pull/1008#discussion_r297860586 ## File path: samza-kv/src/main/java/org/apache/samza/storage/kv/LargeMessage

[GitHub] [samza] prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog

prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog URL: https://github.com/apache/samza/pull/1008#discussion_r297874975 ## File path: samza-kv/src/main/scala/org/apache/samza/storage/kv/BaseKeyValu

[GitHub] [samza] prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog

prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog URL: https://github.com/apache/samza/pull/1008#discussion_r297873143 ## File path: samza-kv/src/main/scala/org/apache/samza/storage/kv/BaseKeyValu

[GitHub] [samza] prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog

prateekm commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog URL: https://github.com/apache/samza/pull/1008#discussion_r297860457 ## File path: samza-kv/src/main/java/org/apache/samza/storage/kv/LargeMessage

[GitHub] [samza] mynameborat commented on issue #1066: SAMZA-2235: Move the merging of side inputs with task inputs from the ExecutionPlanner to the JobModelManager

mynameborat commented on issue #1066: SAMZA-2235: Move the merging of side inputs with task inputs from the ExecutionPlanner to the JobModelManager URL: https://github.com/apache/samza/pull/1066#issuecomment-505974549 > @bharathkk > Since the CSM creates a separate SystemConsumers with a

[GitHub] [samza] prateekm commented on issue #1066: SAMZA-2235: Move the merging of side inputs with task inputs from the ExecutionPlanner to the JobModelManager

prateekm commented on issue #1066: SAMZA-2235: Move the merging of side inputs with task inputs from the ExecutionPlanner to the JobModelManager URL: https://github.com/apache/samza/pull/1066#issuecomment-505972692 @shanthoosh had a question about whether side inputs are part of the job mo

[GitHub] [samza] dnishimura commented on issue #1091: Minor: Increase Travis-CI timeout to 40 min.

dnishimura commented on issue #1091: Minor: Increase Travis-CI timeout to 40 min. URL: https://github.com/apache/samza/pull/1091#issuecomment-505968317 If we had admin access to the apache/samza org in travis-CI, we could probably move the integration tests (which take up majority of the b

[GitHub] [samza] dnishimura commented on issue #1091: Minor: Increase Travis-CI timeout to 40 min.

dnishimura commented on issue #1091: Minor: Increase Travis-CI timeout to 40 min. URL: https://github.com/apache/samza/pull/1091#issuecomment-505967259 > Has there been a recent test addition/change that requires the increased timeout? @rmatharu I think just the slow accumulation of

[GitHub] [samza] rmatharu commented on a change in pull request #1064: SAMZA-1949: Add java docs and configuration documentation for side inputs

rmatharu commented on a change in pull request #1064: SAMZA-1949: Add java docs and configuration documentation for side inputs URL: https://github.com/apache/samza/pull/1064#discussion_r297778577 ## File path: docs/learn/documentation/versioned/jobs/samza-configurations.md ###

[GitHub] [samza] rmatharu commented on a change in pull request #1064: SAMZA-1949: Add java docs and configuration documentation for side inputs

rmatharu commented on a change in pull request #1064: SAMZA-1949: Add java docs and configuration documentation for side inputs URL: https://github.com/apache/samza/pull/1064#discussion_r29940 ## File path: docs/learn/documentation/versioned/jobs/samza-configurations.md ###

[GitHub] [samza] rmatharu commented on a change in pull request #1064: SAMZA-1949: Add java docs and configuration documentation for side inputs

rmatharu commented on a change in pull request #1064: SAMZA-1949: Add java docs and configuration documentation for side inputs URL: https://github.com/apache/samza/pull/1064#discussion_r29416 ## File path: docs/learn/documentation/versioned/jobs/samza-configurations.md ###

[GitHub] [samza] rmatharu edited a comment on issue #1066: SAMZA-2235: Move the merging of side inputs with task inputs from the ExecutionPlanner to the JobModelManager

rmatharu edited a comment on issue #1066: SAMZA-2235: Move the merging of side inputs with task inputs from the ExecutionPlanner to the JobModelManager URL: https://github.com/apache/samza/pull/1066#issuecomment-505964695 @bharathkk Since the CSM creates a separate SystemConsumers with

[GitHub] [samza] rmatharu edited a comment on issue #1066: SAMZA-2235: Move the merging of side inputs with task inputs from the ExecutionPlanner to the JobModelManager

rmatharu edited a comment on issue #1066: SAMZA-2235: Move the merging of side inputs with task inputs from the ExecutionPlanner to the JobModelManager URL: https://github.com/apache/samza/pull/1066#issuecomment-505964695 @bharathkk Since the CSM creates a separate SystemConsumers with

[GitHub] [samza] rmatharu commented on issue #1066: SAMZA-2235: Move the merging of side inputs with task inputs from the ExecutionPlanner to the JobModelManager

rmatharu commented on issue #1066: SAMZA-2235: Move the merging of side inputs with task inputs from the ExecutionPlanner to the JobModelManager URL: https://github.com/apache/samza/pull/1066#issuecomment-505964695 @bharathkk Since the CSM creates a separate SystemConsumers with a defau

[GitHub] [samza] cameronlee314 commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog

cameronlee314 commented on a change in pull request #1008: SAMZA-2174: Throw a record too large exception for oversized records in changelog URL: https://github.com/apache/samza/pull/1008#discussion_r297773073 ## File path: samza-kv/src/main/scala/org/apache/samza/storage/kv/BaseKe

[GitHub] [samza] rmatharu commented on a change in pull request #1078: SAMZA-2248: Fix AM bookkeeping on receiving dead container notifications

rmatharu commented on a change in pull request #1078: SAMZA-2248: Fix AM bookkeeping on receiving dead container notifications URL: https://github.com/apache/samza/pull/1078#discussion_r297771297 ## File path: samza-core/src/test/java/org/apache/samza/clustermanager/TestContainerRe

[GitHub] [samza] rmatharu commented on issue #1091: Minor: Increase Travis-CI timeout to 40 min.

rmatharu commented on issue #1091: Minor: Increase Travis-CI timeout to 40 min. URL: https://github.com/apache/samza/pull/1091#issuecomment-505958878 Has there been a recent test addition/change that requires the increased timeout? --

[GitHub] [samza] dnishimura opened a new pull request #1091: Minor: Increase Travis-CI timeout to 40 min.

dnishimura opened a new pull request #1091: Minor: Increase Travis-CI timeout to 40 min. URL: https://github.com/apache/samza/pull/1091 The builds are close to hitting the 30 min timeout limit. This increases the limit to 40 min. ---

[jira] [Updated] (SAMZA-2260) Standalone: Share metadata store between StreamProcessor and JobCoordinator

[ https://issues.apache.org/jira/browse/SAMZA-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Nishimura updated SAMZA-2260: Description: Currently the coordinator stream metadata store init() method is expensive and

[GitHub] [samza] dnishimura opened a new pull request #1090: SAMZA-2260: Standalone - coordinator stream metadata store lifecycle

dnishimura opened a new pull request #1090: SAMZA-2260: Standalone - coordinator stream metadata store lifecycle URL: https://github.com/apache/samza/pull/1090 **Motivation** The current implementation of the coordinator stream metadata store's `init()` method is an expensive call as it