cameronlee314 commented on a change in pull request #947: SAMZA-2120: Enable
custom handling of ConsumerRecords consumed by Kafka
URL: https://github.com/apache/samza/pull/947#discussion_r264368204
##
File path:
shanthoosh opened a new pull request #949: Remove scala 2.10 version from
documentation.
URL: https://github.com/apache/samza/pull/949
Post 1.0, samza does not support scala 2.10 version. This patch removes the
references of the scala 2.10 version from the documentation.
rmatharu commented on a change in pull request #941: SAMZA-2120: Enable custom
handling of ConsumerRecords consumed by Kafka
URL: https://github.com/apache/samza/pull/941#discussion_r263553107
##
File path:
rmatharu commented on a change in pull request #941: SAMZA-2120: Enable custom
handling of ConsumerRecords consumed by Kafka
URL: https://github.com/apache/samza/pull/941#discussion_r263554894
##
File path: samza-core/src/main/java/org/apache/samza/task/AsyncRunLoop.java
dxichen opened a new pull request #944: Release version updates
URL: https://github.com/apache/samza/pull/944
Updated hard coded version for the upcoming release
This is an automated message from the Apache Git Service.
To
xinyuiscool merged pull request #943: Update Samza version for 1.1.0 release
branch
URL: https://github.com/apache/samza/pull/943
This is an automated message from the Apache Git Service.
To respond to the message, please
mynameborat commented on a change in pull request #942: Bugfix: Recent CSM
refactor was causing some metrics to not be emitted. Fixed -restore-time
metric.
URL: https://github.com/apache/samza/pull/942#discussion_r263637333
##
File path:
cameronlee314 commented on a change in pull request #940: SAMZA-2121: Add
checkpoint offset field to IncomingMessageEnvelope
URL: https://github.com/apache/samza/pull/940#discussion_r263639549
##
File path:
vjagadish1989 edited a comment on issue #905: SAMZA-2055: [WIP] Async high
level api
URL: https://github.com/apache/samza/pull/905#issuecomment-470775503
also adding @xinyuiscool in case he has additional feedback on the async-api
dxichen opened a new pull request #943: Update Samza version for 1.1.0 release
branch
URL: https://github.com/apache/samza/pull/943
Change versions as per RELEASE.md
This is an automated message from the Apache Git Service.
shanthoosh commented on a change in pull request #940: SAMZA-2121: Add
checkpoint offset field to IncomingMessageEnvelope
URL: https://github.com/apache/samza/pull/940#discussion_r263628931
##
File path:
samza-api/src/main/java/org/apache/samza/system/IncomingMessageEnvelope.java
shanthoosh commented on a change in pull request #940: SAMZA-2121: Add
checkpoint offset field to IncomingMessageEnvelope
URL: https://github.com/apache/samza/pull/940#discussion_r263628931
##
File path:
samza-api/src/main/java/org/apache/samza/system/IncomingMessageEnvelope.java
shanthoosh commented on a change in pull request #940: SAMZA-2121: Add
checkpoint offset field to IncomingMessageEnvelope
URL: https://github.com/apache/samza/pull/940#discussion_r263628931
##
File path:
samza-api/src/main/java/org/apache/samza/system/IncomingMessageEnvelope.java
shanthoosh commented on a change in pull request #942: Bugfix: Recent CSM
refactor was causing some metrics to not be emitted. Fixed -restore-time
metric.
URL: https://github.com/apache/samza/pull/942#discussion_r263647669
##
File path:
lakshmi-manasa-g commented on a change in pull request #938: SAMZA-1531:
Support run.id in standalone for batch processing.
URL: https://github.com/apache/samza/pull/938#discussion_r263661119
##
File path:
lakshmi-manasa-g commented on a change in pull request #938: SAMZA-1531:
Support run.id in standalone for batch processing.
URL: https://github.com/apache/samza/pull/938#discussion_r263661134
##
File path:
lakshmi-manasa-g commented on a change in pull request #938: SAMZA-1531:
Support run.id in standalone for batch processing.
URL: https://github.com/apache/samza/pull/938#discussion_r26366
##
File path:
lakshmi-manasa-g commented on a change in pull request #938: SAMZA-1531:
Support run.id in standalone for batch processing.
URL: https://github.com/apache/samza/pull/938#discussion_r263661126
##
File path:
lakshmi-manasa-g commented on a change in pull request #938: SAMZA-1531:
Support run.id in standalone for batch processing.
URL: https://github.com/apache/samza/pull/938#discussion_r263661144
##
File path:
rmatharu commented on a change in pull request #942: Bugfix: Recent CSM
refactor was causing some metrics to not be emitted. Fixed -restore-time
metric.
URL: https://github.com/apache/samza/pull/942#discussion_r263657205
##
File path:
sborya commented on a change in pull request #938: SAMZA-1531: Support run.id
in standalone for batch processing.
URL: https://github.com/apache/samza/pull/938#discussion_r264387433
##
File path:
samza-azure/src/main/java/org/apache/samza/coordinator/AzureCoordinationUtils.java
sborya commented on a change in pull request #938: SAMZA-1531: Support run.id
in standalone for batch processing.
URL: https://github.com/apache/samza/pull/938#discussion_r264475902
##
File path:
samza-core/src/main/java/org/apache/samza/zk/ZkDistributedReadWriteLock.java
sborya commented on a change in pull request #938: SAMZA-1531: Support run.id
in standalone for batch processing.
URL: https://github.com/apache/samza/pull/938#discussion_r264387509
##
File path:
samza-azure/src/main/java/org/apache/samza/coordinator/AzureCoordinationUtils.java
sborya commented on a change in pull request #938: SAMZA-1531: Support run.id
in standalone for batch processing.
URL: https://github.com/apache/samza/pull/938#discussion_r264473744
##
File path:
samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java
sborya commented on a change in pull request #938: SAMZA-1531: Support run.id
in standalone for batch processing.
URL: https://github.com/apache/samza/pull/938#discussion_r264468919
##
File path:
samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java
sborya commented on a change in pull request #938: SAMZA-1531: Support run.id
in standalone for batch processing.
URL: https://github.com/apache/samza/pull/938#discussion_r264474066
##
File path:
samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java
sborya commented on a change in pull request #938: SAMZA-1531: Support run.id
in standalone for batch processing.
URL: https://github.com/apache/samza/pull/938#discussion_r264469347
##
File path:
samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java
sborya commented on a change in pull request #938: SAMZA-1531: Support run.id
in standalone for batch processing.
URL: https://github.com/apache/samza/pull/938#discussion_r264474872
##
File path:
samza-core/src/main/java/org/apache/samza/zk/ZkDistributedDataAccess.java
##
sborya commented on a change in pull request #938: SAMZA-1531: Support run.id
in standalone for batch processing.
URL: https://github.com/apache/samza/pull/938#discussion_r264474987
##
File path:
samza-core/src/main/java/org/apache/samza/zk/ZkDistributedReadWriteLock.java
sborya commented on a change in pull request #938: SAMZA-1531: Support run.id
in standalone for batch processing.
URL: https://github.com/apache/samza/pull/938#discussion_r264414547
##
File path:
samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java
sborya commented on a change in pull request #938: SAMZA-1531: Support run.id
in standalone for batch processing.
URL: https://github.com/apache/samza/pull/938#discussion_r264474790
##
File path:
samza-core/src/main/java/org/apache/samza/zk/ZkDistributedDataAccess.java
##
sborya commented on a change in pull request #938: SAMZA-1531: Support run.id
in standalone for batch processing.
URL: https://github.com/apache/samza/pull/938#discussion_r264472956
##
File path:
samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java
sborya commented on a change in pull request #938: SAMZA-1531: Support run.id
in standalone for batch processing.
URL: https://github.com/apache/samza/pull/938#discussion_r264469001
##
File path:
samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java
sborya commented on a change in pull request #938: SAMZA-1531: Support run.id
in standalone for batch processing.
URL: https://github.com/apache/samza/pull/938#discussion_r264388397
##
File path:
sborya commented on a change in pull request #938: SAMZA-1531: Support run.id
in standalone for batch processing.
URL: https://github.com/apache/samza/pull/938#discussion_r264470992
##
File path:
samza-core/src/main/java/org/apache/samza/zk/ZkDistributedReadWriteLock.java
sborya commented on a change in pull request #938: SAMZA-1531: Support run.id
in standalone for batch processing.
URL: https://github.com/apache/samza/pull/938#discussion_r264467907
##
File path:
samza-core/src/main/java/org/apache/samza/execution/LocalJobPlanner.java
##
dnishimura opened a new pull request #964: SAMZA-2138: Incorrect logging when
task to container mapping is written.
URL: https://github.com/apache/samza/pull/964
Example before this fix:
```
2019-03-21 08:36:34.810 [main] JobModelManager$ [INFO] Storing ssp:
Partition 1 and task: 0
dnishimura commented on issue #964: SAMZA-2138: Incorrect logging when task to
container mapping is written.
URL: https://github.com/apache/samza/pull/964#issuecomment-475287206
@shanthoosh please take a look.
This is an
mynameborat commented on a change in pull request #951: SAMZA-2127: Upgrade to
Kafka 2.0
URL: https://github.com/apache/samza/pull/951#discussion_r267873046
##
File path:
samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemAdmin.scala
##
@@ -301,12
cameronlee314 commented on a change in pull request #951: SAMZA-2127: Upgrade
to Kafka 2.0
URL: https://github.com/apache/samza/pull/951#discussion_r267885428
##
File path:
samza-test/src/test/scala/org/apache/samza/test/integration/StreamTaskTestUtil.scala
##
@@ -133,43
cameronlee314 commented on a change in pull request #951: SAMZA-2127: Upgrade
to Kafka 2.0
URL: https://github.com/apache/samza/pull/951#discussion_r267876940
##
File path:
samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemAdmin.scala
##
@@ -89,49
cameronlee314 commented on a change in pull request #951: SAMZA-2127: Upgrade
to Kafka 2.0
URL: https://github.com/apache/samza/pull/951#discussion_r267882631
##
File path:
samza-test/src/test/java/org/apache/samza/test/processor/TestZkLocalApplicationRunner.java
##
@@
cameronlee314 commented on a change in pull request #951: SAMZA-2127: Upgrade
to Kafka 2.0
URL: https://github.com/apache/samza/pull/951#discussion_r267881671
##
File path:
samza-test/src/test/java/org/apache/samza/test/framework/StreamApplicationIntegrationTestHarness.java
dnishimura commented on issue #964: SAMZA-2138: Incorrect logging when task to
container mapping is written.
URL: https://github.com/apache/samza/pull/964#issuecomment-475401665
It happened to me before. Not sure why. Thanks for merging it.
shanthoosh merged pull request #964: SAMZA-2138: Incorrect logging when task to
container mapping is written.
URL: https://github.com/apache/samza/pull/964
This is an automated message from the Apache Git Service.
To
shanthoosh edited a comment on issue #964: SAMZA-2138: Incorrect logging when
task to container mapping is written.
URL: https://github.com/apache/samza/pull/964#issuecomment-475401240
@dnishimura
This build is green in travis. Here's the successful travis build associated
with this
rmatharu commented on issue #952: Improved standby-aware container allocation
for active-containers on job redeploys
URL: https://github.com/apache/samza/pull/952#issuecomment-475692992
Addressed all comments.
thumbsup => comment addressed.
vjagadish1989 opened a new pull request #965: Fix a typo in LinkedIn case-study
URL: https://github.com/apache/samza/pull/965
This is an automated message from the Apache Git Service.
To respond to the message, please log on
asfgit closed pull request #965: Minor: Fix a typo in LinkedIn case-study
URL: https://github.com/apache/samza/pull/965
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
cameronlee314 commented on a change in pull request #951: SAMZA-2127: Upgrade
to Kafka 2.0
URL: https://github.com/apache/samza/pull/951#discussion_r267871144
##
File path:
samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemAdmin.scala
##
@@ -301,12
dnishimura commented on issue #964: SAMZA-2138: Incorrect logging when task to
container mapping is written.
URL: https://github.com/apache/samza/pull/964#issuecomment-475350150
Thanks @shanthoosh. Please merge when you have some time.
rmatharu commented on a change in pull request #952: Improved standby-aware
container allocation for active-containers on job redeploys
URL: https://github.com/apache/samza/pull/952#discussion_r268030497
##
File path:
rmatharu commented on a change in pull request #952: Improved standby-aware
container allocation for active-containers on job redeploys
URL: https://github.com/apache/samza/pull/952#discussion_r268030578
##
File path:
mynameborat commented on a change in pull request #955: SAMZA-2131: [Scala
cleanup] Convert FileSystemCheckpointManagerConfig.scala and SystemConfig.scala
to Java
URL: https://github.com/apache/samza/pull/955#discussion_r267968434
##
File path:
cameronlee314 commented on a change in pull request #955: SAMZA-2131: [Scala
cleanup] Convert FileSystemCheckpointManagerConfig.scala and SystemConfig.scala
to Java
URL: https://github.com/apache/samza/pull/955#discussion_r268000138
##
File path:
shanthoosh merged pull request #899: SAMZA-2091: Update ZkClient in
samza-standalone to use string serializer
URL: https://github.com/apache/samza/pull/899
This is an automated message from the Apache Git Service.
To
shanthoosh commented on issue #899: SAMZA-2091: Update ZkClient in
samza-standalone to use string serializer
URL: https://github.com/apache/samza/pull/899#issuecomment-475051108
@prateekm Apologies for the delay in merging this in. I was side-tracked
with save-points and standalone -prod
dxichen opened a new pull request #963: SAMZA-2137: Update blog pages, remove
unreleased version
URL: https://github.com/apache/samza/pull/963
@prateekm @jagadish-v0 please take a look.
Would be nice to deploy this before the meetup talking about Samza 1.0
asfgit closed pull request #963: SAMZA-2137: Update blog pages, remove
unreleased version
URL: https://github.com/apache/samza/pull/963
This is an automated message from the Apache Git Service.
To respond to the message,
asfgit closed pull request #921: SAMZA-2105: [elasticsearch, hdfs, kafka] code
cleanup and refactoring
URL: https://github.com/apache/samza/pull/921
This is an automated message from the Apache Git Service.
To respond to
srinipunuru merged pull request #909: Support for empty records
URL: https://github.com/apache/samza/pull/909
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use
srinipunuru opened a new pull request #911: Support for types in Samza SQL UDF
URL: https://github.com/apache/samza/pull/911
This PR adds following capabilities to UDF
1. Adds typed UDFS : Previously samza sql udfs were un-typed all the params
used to be Objects, Although this
shenodaguirguis commented on a change in pull request #911: Support for types
in Samza SQL UDF
URL: https://github.com/apache/samza/pull/911#discussion_r254915133
##
File path:
samza-sql/src/main/java/org/apache/samza/sql/data/SamzaSqlExecutionContext.java
##
@@ -52,16
srinipunuru commented on a change in pull request #911: Support for types in
Samza SQL UDF
URL: https://github.com/apache/samza/pull/911#discussion_r254886952
##
File path:
samza-sql/src/main/java/org/apache/samza/sql/data/SamzaSqlExecutionContext.java
##
@@ -38,7 +40,7
srinipunuru commented on a change in pull request #911: Support for types in
Samza SQL UDF
URL: https://github.com/apache/samza/pull/911#discussion_r254888242
##
File path:
samza-sql/src/main/java/org/apache/samza/sql/data/SamzaSqlExecutionContext.java
##
@@ -52,16
rmatharu opened a new pull request #912: Test sideinputrefactor
URL: https://github.com/apache/samza/pull/912
DO NOT REVIEW
This is an automated message from the Apache Git Service.
To respond to the message, please log on
strkkk opened a new pull request #913: SAMZA-2102: [samza-azure] code cleanup
and refactoring
URL: https://github.com/apache/samza/pull/913
1. Removed deprecated junit.framework.Assert
2. Add final modifiers
3. Remove redundant things (L literal, modifiers, local variables)
4.
strkkk opened a new pull request #914: SAMZA-2103: [samza-aws] code cleanup and
refactoring
URL: https://github.com/apache/samza/pull/914
1. Redundant things removed
2. Several methods simplified
3. Condition ``if (numRecordsPerShard > 0)`` in
``TestKinesisSystemConsumer.java`` was
rmatharu commented on issue #876: SEP-19 : Basic Standby task/container
implementation
URL: https://github.com/apache/samza/pull/876#issuecomment-461914315
Closing this in lieu of https://github.com/apache/samza/pull/912 and a
follow on to that.
rmatharu closed pull request #876: SEP-19 : Basic Standby task/container
implementation
URL: https://github.com/apache/samza/pull/876
This is an automated message from the Apache Git Service.
To respond to the message,
shanthoosh commented on a change in pull request #918: SAMZA-2094: Implement
the StartpointVisitor for the KafkaSystemConsumer.
URL: https://github.com/apache/samza/pull/918#discussion_r257074119
##
File path:
shanthoosh commented on a change in pull request #918: SAMZA-2094: Implement
the StartpointVisitor for the KafkaSystemConsumer.
URL: https://github.com/apache/samza/pull/918#discussion_r257522508
##
File path:
shanthoosh commented on a change in pull request #918: SAMZA-2094: Implement
the StartpointVisitor for the KafkaSystemConsumer.
URL: https://github.com/apache/samza/pull/918#discussion_r257523191
##
File path:
shanthoosh commented on a change in pull request #918: SAMZA-2094: Implement
the StartpointVisitor for the KafkaSystemConsumer.
URL: https://github.com/apache/samza/pull/918#discussion_r257523873
##
File path:
shanthoosh commented on a change in pull request #918: SAMZA-2094: Implement
the StartpointVisitor for the KafkaSystemConsumer.
URL: https://github.com/apache/samza/pull/918#discussion_r257524023
##
File path:
shanthoosh commented on a change in pull request #918: SAMZA-2094: Implement
the StartpointVisitor for the KafkaSystemConsumer.
URL: https://github.com/apache/samza/pull/918#discussion_r257072998
##
File path:
shanthoosh commented on a change in pull request #918: SAMZA-2094: Implement
the StartpointVisitor for the KafkaSystemConsumer.
URL: https://github.com/apache/samza/pull/918#discussion_r257523115
##
File path:
shanthoosh commented on a change in pull request #918: SAMZA-2094: Implement
the StartpointVisitor for the KafkaSystemConsumer.
URL: https://github.com/apache/samza/pull/918#discussion_r257523065
##
File path:
atoomula commented on a change in pull request #911: Support for types in Samza
SQL UDF
URL: https://github.com/apache/samza/pull/911#discussion_r255300421
##
File path:
samza-sql/src/main/java/org/apache/samza/sql/planner/SamzaSqlScalarFunctionImpl.java
##
@@ -61,17
atoomula commented on a change in pull request #911: Support for types in Samza
SQL UDF
URL: https://github.com/apache/samza/pull/911#discussion_r255300436
##
File path:
samza-sql/src/main/java/org/apache/samza/sql/data/SamzaSqlExecutionContext.java
##
@@ -38,7 +40,10 @@
atoomula commented on a change in pull request #911: Support for types in Samza
SQL UDF
URL: https://github.com/apache/samza/pull/911#discussion_r255300768
##
File path: samza-sql/src/main/java/org/apache/samza/sql/fn/GetSqlFieldUdf.java
##
@@ -51,22 +52,21 @@
*
atoomula commented on a change in pull request #911: Support for types in Samza
SQL UDF
URL: https://github.com/apache/samza/pull/911#discussion_r255299964
##
File path:
samza-sql/src/main/java/org/apache/samza/sql/fn/BuildOutputRecordUdf.java
##
@@ -61,13 +61,13 @@
*
atoomula commented on a change in pull request #911: Support for types in Samza
SQL UDF
URL: https://github.com/apache/samza/pull/911#discussion_r255277549
##
File path: samza-api/src/main/java/org/apache/samza/sql/udfs/ScalarUdf.java
##
@@ -36,5 +36,4 @@
* @param
rmatharu commented on issue #915: Consolidating offset read and write for
store-offsets and side-inputs, maintaining backward compatbility
URL: https://github.com/apache/samza/pull/915#issuecomment-462886896
Addressed all comments.
vjagadish1989 commented on a change in pull request #903: SEP-19: Allocator
changes for standby-aware container allocation, and active container failover
URL: https://github.com/apache/samza/pull/903#discussion_r256082808
##
File path:
vjagadish1989 commented on a change in pull request #903: SEP-19: Allocator
changes for standby-aware container allocation, and active container failover
URL: https://github.com/apache/samza/pull/903#discussion_r255777131
##
File path:
vjagadish1989 commented on a change in pull request #903: SEP-19: Allocator
changes for standby-aware container allocation, and active container failover
URL: https://github.com/apache/samza/pull/903#discussion_r255771228
##
File path:
vjagadish1989 commented on a change in pull request #903: SEP-19: Allocator
changes for standby-aware container allocation, and active container failover
URL: https://github.com/apache/samza/pull/903#discussion_r256070415
##
File path:
vjagadish1989 commented on a change in pull request #903: SEP-19: Allocator
changes for standby-aware container allocation, and active container failover
URL: https://github.com/apache/samza/pull/903#discussion_r256081802
##
File path:
vjagadish1989 commented on a change in pull request #903: SEP-19: Allocator
changes for standby-aware container allocation, and active container failover
URL: https://github.com/apache/samza/pull/903#discussion_r256084515
##
File path:
vjagadish1989 commented on a change in pull request #903: SEP-19: Allocator
changes for standby-aware container allocation, and active container failover
URL: https://github.com/apache/samza/pull/903#discussion_r255766345
##
File path:
mynameborat commented on a change in pull request #915: Consolidating offset
read and write for store-offsets and side-inputs, maintaining backward
compatbility
URL: https://github.com/apache/samza/pull/915#discussion_r256068006
##
File path:
mynameborat commented on a change in pull request #915: Consolidating offset
read and write for store-offsets and side-inputs, maintaining backward
compatbility
URL: https://github.com/apache/samza/pull/915#discussion_r256068006
##
File path:
rmatharu commented on a change in pull request #915: Consolidating offset read
and write for store-offsets and side-inputs, maintaining backward compatbility
URL: https://github.com/apache/samza/pull/915#discussion_r256096861
##
File path:
vjagadish1989 commented on a change in pull request #903: SEP-19: Allocator
changes for standby-aware container allocation, and active container failover
URL: https://github.com/apache/samza/pull/903#discussion_r256072645
##
File path:
vjagadish1989 commented on a change in pull request #903: SEP-19: Allocator
changes for standby-aware container allocation, and active container failover
URL: https://github.com/apache/samza/pull/903#discussion_r255769800
##
File path:
vjagadish1989 commented on a change in pull request #903: SEP-19: Allocator
changes for standby-aware container allocation, and active container failover
URL: https://github.com/apache/samza/pull/903#discussion_r256083123
##
File path:
vjagadish1989 commented on a change in pull request #903: SEP-19: Allocator
changes for standby-aware container allocation, and active container failover
URL: https://github.com/apache/samza/pull/903#discussion_r254810012
##
File path:
shanthoosh merged pull request #874: SAMZA-2058: Integrate the input stream
expansion aware SystemStreamGrouper to JobModel generation flow.
URL: https://github.com/apache/samza/pull/874
This is an automated message from
rmatharu commented on a change in pull request #915: Consolidating offset read
and write for store-offsets and side-inputs, maintaining backward compatbility
URL: https://github.com/apache/samza/pull/915#discussion_r256213346
##
File path:
601 - 700 of 921 matches
Mail list logo
