dxichen commented on a change in pull request #2: Update scripts and docs based
on Beam 2.11.0 release
URL: https://github.com/apache/samza-beam-examples/pull/2#discussion_r264896844
##
File path: pom.xml
##
@@ -27,7 +27,7 @@
jar
-2.9.0
+2.11.0
0.14.1
xinyuiscool merged pull request #51: Fix build issues on master, update versions
URL: https://github.com/apache/samza-hello-samza/pull/51
This is an automated message from the Apache Git Service.
To respond to the message, pl
dxichen commented on a change in pull request #2: Update scripts and docs based
on Beam 2.11.0 release
URL: https://github.com/apache/samza-beam-examples/pull/2#discussion_r264905811
##
File path: pom.xml
##
@@ -27,7 +27,7 @@
jar
-2.9.0
+2.11.0
0.14.1
mynameborat 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_r264802046
##
File path:
samza-core/src/main/java/org/apache/samza/execution/LocalJobPlanner.java
###
mynameborat 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_r264797657
##
File path:
samza-core/src/main/java/org/apache/samza/execution/LocalJobPlanner.java
###
mynameborat 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_r264802724
##
File path:
samza-core/src/main/java/org/apache/samza/execution/LocalJobPlanner.java
###
mynameborat 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_r264798931
##
File path:
samza-core/src/main/java/org/apache/samza/coordinator/CoordinationConstants.java
mynameborat 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_r264811329
##
File path:
samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java
##
mynameborat 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_r264938259
##
File path:
samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java
##
mynameborat 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_r264843464
##
File path:
samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java
##
mynameborat 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_r264937250
##
File path:
samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java
##
mynameborat 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_r264937342
##
File path:
samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java
##
mynameborat 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_r264938632
##
File path:
samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java
##
mynameborat 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_r264944248
##
File path:
samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java
##
shanthoosh commented on a change in pull request #944: Release version updates
URL: https://github.com/apache/samza/pull/944#discussion_r265230217
##
File path: docs/learn/tutorials/versioned/samza-rest-getting-started.md
##
@@ -48,7 +48,7 @@ Run the following commands:
{%
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_r265687641
##
File path:
samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.jav
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_r265687938
##
File path:
samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.jav
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_r265688291
##
File path:
samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.jav
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_r265688252
##
File path:
samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.jav
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_r265688397
##
File path:
samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.jav
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_r265688437
##
File path:
samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.jav
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_r265688837
##
File path:
samza-core/src/main/java/org/apache/samza/execution/LocalJobPlanner.java
##
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_r265688760
##
File path:
samza-core/src/main/java/org/apache/samza/execution/LocalJobPlanner.java
##
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_r265688805
##
File path:
samza-core/src/main/java/org/apache/samza/coordinator/CoordinationConstants.
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_r265688727
##
File path:
samza-core/src/main/java/org/apache/samza/execution/LocalJobPlanner.java
##
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_r265689058
##
File path:
samza-core/src/main/java/org/apache/samza/coordinator/CoordinationUtils.java
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_r265689098
##
File path:
samza-azure/src/main/java/org/apache/samza/coordinator/AzureCoordinationUtil
mynameborat opened a new pull request #951: SAMZA-2127: Upgrade to Kafka 2.0
URL: https://github.com/apache/samza/pull/951
Initial PR for Kafka 2.0 upgrade
This is an automated message from the Apache Git Service.
To respond t
rmatharu opened a new pull request #952: Improved standby-aware container
allocation for active-containers on job redeploys
URL: https://github.com/apache/samza/pull/952
This is an automated message from the Apache Git Servi
shanthoosh opened a new pull request #953: Set job coordinator replication
factor configuration for standalone.
URL: https://github.com/apache/samza/pull/953
This is an automated message from the Apache Git Service.
To respo
shanthoosh commented on issue #953: Set job coordinator replication factor
configuration for standalone.
URL: https://github.com/apache/samza/pull/953#issuecomment-473483420
@vjagadish1989
Can you take a look.
This is an a
shanthoosh merged pull request #953: Set job coordinator replication factor
configuration for standalone.
URL: https://github.com/apache/samza/pull/953
This is an automated message from the Apache Git Service.
To respond to
shanthoosh opened a new pull request #954: SAMZA-2129: Move the offset
comparison check to choose the lowest offset to SystemConsumers.
URL: https://github.com/apache/samza/pull/954
This patch is comprised of the following changes:
* Moves the offset comparison check to SystemConsume
shanthoosh commented on issue #954: SAMZA-2129: Move the offset comparison
check to choose the lowest offset to SystemConsumers.
URL: https://github.com/apache/samza/pull/954#issuecomment-473711732
@dnishimura Please take a look when you have a chance.
-
shanthoosh edited a comment on issue #954: SAMZA-2129: Move the offset
comparison check to choose the lowest offset to SystemConsumers.
URL: https://github.com/apache/samza/pull/954#issuecomment-473711732
@dnishimura @cameronlee314
Please take a look when you have a chance.
---
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_r266258426
##
File path:
samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemConsu
cameronlee314 opened a new pull request #955: SAMZA-2131: [Scala cleanup]
Convert FileSystemCheckpointManagerConfig.scala and SystemConfig.scala to Java
URL: https://github.com/apache/samza/pull/955
This is an automated mess
cameronlee314 commented on a change in pull request #954: SAMZA-2129: Move the
offset comparison check to choose the lowest offset to SystemConsumers.
URL: https://github.com/apache/samza/pull/954#discussion_r266562517
##
File path: samza-core/src/main/java/org/apache/samza/system/S
shanthoosh commented on a change in pull request #954: SAMZA-2129: Move the
offset comparison check to choose the lowest offset to SystemConsumers.
URL: https://github.com/apache/samza/pull/954#discussion_r266635932
##
File path: samza-core/src/main/java/org/apache/samza/system/Syst
dnishimura opened a new pull request #956: SAMZA-2132: Flatten startpoint key
when serialized.
URL: https://github.com/apache/samza/pull/956
StartpointKey has unnecessary redundancies when serialized. Example:
```
"{\"systemStreamPartition\":{\"system\":\"test\",\"stream\":\"test\",
shanthoosh merged pull request #954: SAMZA-2129: Move the offset comparison
check to choose the lowest offset to SystemConsumers.
URL: https://github.com/apache/samza/pull/954
This is an automated message from the Apache Git
cameronlee314 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_r266682416
##
File path:
samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemCo
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_r266697388
##
File path:
samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemConsu
shanthoosh commented on a change in pull request #956: SAMZA-2132: Flatten
startpoint key when serialized.
URL: https://github.com/apache/samza/pull/956#discussion_r266721395
##
File path:
samza-core/src/main/java/org/apache/samza/startpoint/StartpointKey.java
##
@@ -41,1
shanthoosh commented on a change in pull request #956: SAMZA-2132: Flatten
startpoint key when serialized.
URL: https://github.com/apache/samza/pull/956#discussion_r266721395
##
File path:
samza-core/src/main/java/org/apache/samza/startpoint/StartpointKey.java
##
@@ -41,1
vjagadish1989 opened a new pull request #957: Link Video tutorials from the
Apache Samza homepage
URL: https://github.com/apache/samza/pull/957
- link video tutorials
- adjust default button-sizes for prettier display
Thi
asfgit closed pull request #957: Link Video tutorials from the Apache Samza
homepage
URL: https://github.com/apache/samza/pull/957
This is an automated message from the Apache Git Service.
To respond to the message, please l
vjagadish1989 opened a new pull request #958: SAMZA-2117: Handle race condition
in container launch due to incorrect AM accounting
URL: https://github.com/apache/samza/pull/958
Steps involved when starting a Samza container:
1. Issue a request to YARN to launch a container
2. Record t
dnishimura commented on issue #918: SAMZA-2094: Implement the StartpointVisitor
for the KafkaSystemConsumer.
URL: https://github.com/apache/samza/pull/918#issuecomment-474414111
Is the timeout error shown in Travis-CI just a transient thing and not
reproducible locally?
```testShouldCre
shanthoosh commented on issue #918: SAMZA-2094: Implement the StartpointVisitor
for the KafkaSystemConsumer.
URL: https://github.com/apache/samza/pull/918#issuecomment-474441844
@dnishimura No, I tried it locally multiple times but was not able to
reproduce it. But that failure is orthogon
dnishimura commented on a change in pull request #956: SAMZA-2132: Flatten
startpoint key when serialized.
URL: https://github.com/apache/samza/pull/956#discussion_r266984446
##
File path:
samza-core/src/main/java/org/apache/samza/startpoint/StartpointKey.java
##
@@ -41,1
prateekm commented on issue #899: SAMZA-2091: Update ZkClient in
samza-standalone to use string serializer
URL: https://github.com/apache/samza/pull/899#issuecomment-474469431
@shanthoosh Please merge if you don't need anything else for this PR.
---
cameronlee314 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_r267010766
##
File path:
samza-kafka/src/test/java/org/apache/samza/system/kafka/TestKafkaSyst
cameronlee314 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_r267009293
##
File path:
samza-kafka/src/test/java/org/apache/samza/system/kafka/TestKafkaSyst
cameronlee314 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_r267010415
##
File path:
samza-kafka/src/test/java/org/apache/samza/system/kafka/TestKafkaSyst
cameronlee314 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_r266996590
##
File path:
samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemCo
cameronlee314 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_r266999014
##
File path:
samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemCo
cameronlee314 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_r267009407
##
File path:
samza-kafka/src/test/java/org/apache/samza/system/kafka/TestKafkaSyst
cameronlee314 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_r267009990
##
File path:
samza-kafka/src/test/java/org/apache/samza/system/kafka/TestKafkaSyst
cameronlee314 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_r267001831
##
File path:
samza-kafka/src/test/java/org/apache/samza/system/kafka/TestKafkaSyst
cameronlee314 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_r267008613
##
File path:
samza-kafka/src/test/java/org/apache/samza/system/kafka/TestKafkaSyst
asfgit closed pull request #958: SAMZA-2117: Handle race condition in container
launch due to incorrect AM accounting
URL: https://github.com/apache/samza/pull/958
This is an automated message from the Apache Git Service.
To
xinyuiscool merged pull request #2: Update scripts and docs based on Beam
2.11.0 release
URL: https://github.com/apache/samza-beam-examples/pull/2
This is an automated message from the Apache Git Service.
To respond to the m
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_r267056681
##
File path:
samza-kafka/src/test/java/org/apache/samza/system/kafka/TestKafkaSystemC
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_r267053676
##
File path:
samza-kafka/src/test/java/org/apache/samza/system/kafka/TestKafkaSystemC
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_r267022260
##
File path:
samza-kafka/src/test/java/org/apache/samza/system/kafka/TestKafkaSystemC
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_r267054141
##
File path:
samza-kafka/src/test/java/org/apache/samza/system/kafka/TestKafkaSystemC
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_r267052376
##
File path:
samza-kafka/src/test/java/org/apache/samza/system/kafka/TestKafkaSystemC
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_r267053644
##
File path:
samza-kafka/src/test/java/org/apache/samza/system/kafka/TestKafkaSystemC
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_r267054111
##
File path:
samza-kafka/src/test/java/org/apache/samza/system/kafka/TestKafkaSystemC
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_r267081142
##
File path:
samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemConsu
cameronlee314 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_r267081332
##
File path:
samza-kafka/src/test/java/org/apache/samza/system/kafka/TestKafkaSyst
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_r267091668
##
File path:
samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemAdmin.scala
##
@@ -257,17 +
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_r267087682
##
File path:
samza-kafka/src/test/scala/org/apache/samza/checkpoint/kafka/TestKafkaCheckpointManager.scala
##
@@
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_r267095405
##
File path:
samza-test/src/test/scala/org/apache/samza/test/integration/StreamTaskTestUtil.scala
##
@@ -257,23
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_r267086592
##
File path:
samza-kafka/src/test/java/org/apache/samza/system/kafka/TestKafkaSystemAdminJava.java
##
@@ -275,11
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_r267093231
##
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_r267059448
##
File path:
samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemAdmin.java
##
@@ -717,4 +744,21
shanthoosh opened a new pull request #959: SAMZA-2133: Fix the
TestKeyValuePerformance test.
URL: https://github.com/apache/samza/pull/959
Running the TestJeyValuePerformance test results in the following failure:
```
2019-03-19 11:16:36.713 [main] TestKeyValuePerformance$ [INFO]
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_r267088346
##
File path:
samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemAdmin.scala
##
@@ -93,48 +9
shanthoosh commented on issue #959: SAMZA-2133: Fix the TestKeyValuePerformance
test.
URL: https://github.com/apache/samza/pull/959#issuecomment-474583030
Ran the test-case locally after this fix to verify this failure does not
happen again.
@sborya @dnishimura
Please take a look.
shanthoosh merged pull request #959: SAMZA-2133: Fix the
TestKeyValuePerformance test.
URL: https://github.com/apache/samza/pull/959
This is an automated message from the Apache Git Service.
To respond to the message, please
shanthoosh merged pull request #956: SAMZA-2132: Flatten startpoint key when
serialized.
URL: https://github.com/apache/samza/pull/956
This is an automated message from the Apache Git Service.
To respond to the message, plea
shanthoosh merged pull request #918: SAMZA-2094: Implement the
StartpointVisitor for the KafkaSystemConsumer.
URL: https://github.com/apache/samza/pull/918
This is an automated message from the Apache Git Service.
To respond
dxichen opened a new pull request #960: Update website for 1.1.0
URL: https://github.com/apache/samza/pull/960
@vjagadish @shanthoosh Followed the instructions as per
https://github.com/apache/samza/blob/master/docs/README.md#release-new-version-website-checklist
Please let me know
dengpanyin opened a new pull request #961: SAMZA-2134:Enable table rate limiter
by default.
URL: https://github.com/apache/samza/pull/961
By default rate limiter will be enabled. The user need to provide a rate
limiter for the
table descriptor or disable read/write rate limiter explicit
dengpanyin commented on issue #961: SAMZA-2134:Enable table rate limiter by
default.
URL: https://github.com/apache/samza/pull/961#issuecomment-474618197
@weisong44 Can you help view this RB? Thanks
This is an automated mes
dxichen commented on issue #944: Release version updates
URL: https://github.com/apache/samza/pull/944#issuecomment-474626523
@shanthoosh @jagadish-v0 @prateekm Please take a look
This is an automated message from the Apache
dxichen commented on a change in pull request #944: Release version updates
URL: https://github.com/apache/samza/pull/944#discussion_r267139268
##
File path: docs/learn/tutorials/versioned/samza-rest-getting-started.md
##
@@ -48,7 +48,7 @@ Run the following commands:
{% hi
Sanil15 opened a new pull request #962: SAMZA-2135: Provide a way inject
ExternalContext to TestRunner
URL: https://github.com/apache/samza/pull/962
- Added a public API to pass ExternalContext to TestRunner
- Refactored existing tests to test it
---
Sanil15 commented on issue #962: SAMZA-2135: Provide a way inject
ExternalContext to TestRunner
URL: https://github.com/apache/samza/pull/962#issuecomment-474632748
@cameronlee314 please have a look!
This is an automated mess
cameronlee314 commented on a change in pull request #962: SAMZA-2135: Provide a
way inject ExternalContext to TestRunner
URL: https://github.com/apache/samza/pull/962#discussion_r267146513
##
File path:
samza-test/src/test/java/org/apache/samza/test/framework/StreamTaskIntegrationT
xinyuiscool merged pull request #944: Release version updates
URL: https://github.com/apache/samza/pull/944
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
Sanil15 commented on a change in pull request #962: SAMZA-2135: Provide a way
inject ExternalContext to TestRunner
URL: https://github.com/apache/samza/pull/962#discussion_r267147519
##
File path:
samza-test/src/test/java/org/apache/samza/test/framework/StreamTaskIntegrationTest.ja
cameronlee314 commented on a change in pull request #962: SAMZA-2135: Provide a
way inject ExternalContext to TestRunner
URL: https://github.com/apache/samza/pull/962#discussion_r267149842
##
File path:
samza-test/src/test/java/org/apache/samza/test/framework/StreamTaskIntegrationT
Sanil15 commented on a change in pull request #962: SAMZA-2135: Provide a way
inject ExternalContext to TestRunner
URL: https://github.com/apache/samza/pull/962#discussion_r267150940
##
File path:
samza-test/src/test/java/org/apache/samza/test/framework/StreamTaskIntegrationTest.ja
asfgit closed pull request #962: SAMZA-2135: Provide a way inject
ExternalContext to TestRunner
URL: https://github.com/apache/samza/pull/962
This is an automated message from the Apache Git Service.
To respond to the messag
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 the
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 respon
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
501 - 600 of 969 matches
Mail list logo
