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, ple
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_r267582422
##
File path:
samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemAdmin.scala
##
@@ -257,17 +21
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_r267623921
##
File path:
samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemAdmin.scala
##
@@ -301,12 +26
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_r267623375
##
File path:
samza-kafka/src/test/scala/org/apache/samza/checkpoint/kafka/TestKafkaCheckpointManager.scala
##
@@ -
mynameborat commented on issue #951: SAMZA-2127: Upgrade to Kafka 2.0
URL: https://github.com/apache/samza/pull/951#issuecomment-475113792
Summary of 44d8c97
* Combined StandaloneIntegrationTestHarness and
AbstractIntegrationTestHarness into IntegrationTestHarness.
* Modified some mo
vjagadish1989 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_r267633462
##
File path:
samza-core/src/main/java/org/apache/samza/clustermanager/St
vjagadish1989 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_r267638693
##
File path:
samza-core/src/main/java/org/apache/samza/clustermanager/St
vjagadish1989 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_r267638140
##
File path:
samza-core/src/main/java/org/apache/samza/clustermanager/St
vjagadish1989 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_r267636464
##
File path:
samza-core/src/main/java/org/apache/samza/clustermanager/St
vjagadish1989 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_r267635690
##
File path:
samza-core/src/main/java/org/apache/samza/clustermanager/St
vjagadish1989 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_r267636016
##
File path:
samza-core/src/main/java/org/apache/samza/clustermanager/St
vjagadish1989 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_r267635366
##
File path:
samza-core/src/main/java/org/apache/samza/clustermanager/St
vjagadish1989 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_r267638815
##
File path:
samza-core/src/main/java/org/apache/samza/clustermanager/St
vjagadish1989 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_r267635139
##
File path:
samza-core/src/main/java/org/apache/samza/clustermanager/St
vjagadish1989 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_r267633751
##
File path:
samza-core/src/main/java/org/apache/samza/clustermanager/St
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 i
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 auto
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 +
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 +26
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 +9
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
##
@@ -1
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-475350150
Thanks @shanthoosh. Please merge when you have some time.
--
shanthoosh commented 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 PR:
http
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 PR
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 respond
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:
samza-core/src/main/java/org/apache/
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:
samza-core/src/main/java/org/apach
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:
samza-core/src/main/java/org/apache/samza/clustermanager/Standby
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:
samza-core/src/main/java/org/apache/samza/clustermanager/Standby
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 Git
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_r268352274
##
File path:
samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemAdmin.scala
##
@@ -89,49 +91,
srinipunuru opened a new pull request #966: Moving the Fixes from internal
AvroRelConverter
URL: https://github.com/apache/samza/pull/966
Misc fixes that are made in internal copy of AvroRelConverter.
This is an automated me
dxichen opened a new pull request #967: Add 1.1.0 tools download page
URL: https://github.com/apache/samza/pull/967
@shanthoosh @jagadish-v0 Added tools downloads link
This is an automated message from the Apache Git Service.
shanthoosh merged pull request #967: Add 1.1.0 tools download page
URL: https://github.com/apache/samza/pull/967
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
shanthoosh commented on a change in pull request #960: Update website for 1.1.0
URL: https://github.com/apache/samza/pull/960#discussion_r268372496
##
File path: docs/learn/tutorials/versioned/hello-samza-high-level-yarn.md
##
@@ -63,7 +62,7 @@ Then, you can continue w/ the
dxichen commented on a change in pull request #960: Update website for 1.1.0
URL: https://github.com/apache/samza/pull/960#discussion_r268373360
##
File path: docs/learn/tutorials/versioned/hello-samza-high-level-yarn.md
##
@@ -63,7 +62,7 @@ Then, you can continue w/ the fo
dxichen commented on a change in pull request #960: Update website for 1.1.0
URL: https://github.com/apache/samza/pull/960#discussion_r268373360
##
File path: docs/learn/tutorials/versioned/hello-samza-high-level-yarn.md
##
@@ -63,7 +62,7 @@ Then, you can continue w/ the fo
shanthoosh merged pull request #960: Update website for 1.1.0
URL: https://github.com/apache/samza/pull/960
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
shanthoosh commented on a change in pull request #960: Update website for 1.1.0
URL: https://github.com/apache/samza/pull/960#discussion_r268373402
##
File path: docs/learn/tutorials/versioned/hello-samza-high-level-yarn.md
##
@@ -63,7 +62,7 @@ Then, you can continue w/ the
dxichen opened a new pull request #52: Latest changes for 1.1.0
URL: https://github.com/apache/samza-hello-samza/pull/52
Bumped versions, fixed incompatible changes
This is an automated message from the Apache Git Service.
To
shanthoosh merged pull request #52: Latest changes for 1.1.0
URL: https://github.com/apache/samza-hello-samza/pull/52
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHu
shanthoosh commented on a change in pull request #52: Latest changes for 1.1.0
URL: https://github.com/apache/samza-hello-samza/pull/52#discussion_r268374786
##
File path: pom.xml
##
@@ -206,7 +211,7 @@ under the License.
UTF-8
-1.0.0
+1.1.0
Review
shanthoosh opened a new pull request #968: SAMZA-2141: Adding samza 1.1.0 blog
in markdown format.
URL: https://github.com/apache/samza/pull/968
This is an automated message from the Apache Git Service.
To respond to the mes
shanthoosh commented on issue #968: SAMZA-2141: Adding samza 1.1.0 blog in
markdown format.
URL: https://github.com/apache/samza/pull/968#issuecomment-475828530
@dxichen Please take a look when you have a chance.
This is an a
shanthoosh opened a new pull request #969: SAMZA-2142: Add the samza 1.1
release announce post to the samza blog.
URL: https://github.com/apache/samza/pull/969
This is an automated message from the Apache Git Service.
To res
shanthoosh commented on issue #969: SAMZA-2142: Add the samza 1.1 release
announce post to the samza blog.
URL: https://github.com/apache/samza/pull/969#issuecomment-475830232
![screencapture-127-0-0-1-4000-blog-2019-03-22-announcing-the-release-of-apache-samza-1-1-0-2019-03-22-19_03_06](h
shanthoosh commented on issue #969: SAMZA-2142: Add the samza 1.1 release
announce post to the samza blog.
URL: https://github.com/apache/samza/pull/969#issuecomment-475830266
@dxichen Please take a look when you have a chance.
--
shanthoosh merged pull request #968: SAMZA-2141: Adding samza 1.1.0 blog in
markdown format.
URL: https://github.com/apache/samza/pull/968
This is an automated message from the Apache Git Service.
To respond to the message,
shanthoosh commented on issue #39: Sample application to illustrate side-inputs
using stream table join
URL: https://github.com/apache/samza-hello-samza/pull/39#issuecomment-475833257
Is this pull-request no longer necessary? Can we close if not needed.
shanthoosh merged pull request #969: SAMZA-2142: Add the samza 1.1 release
announce post to the samza blog.
URL: https://github.com/apache/samza/pull/969
This is an automated message from the Apache Git Service.
To respond t
shanthoosh commented on a change in pull request #951: SAMZA-2127: Upgrade to
Kafka 2.0
URL: https://github.com/apache/samza/pull/951#discussion_r268385422
##
File path:
samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemAdmin.java
##
@@ -628,10 +589,12 @@
shanthoosh commented on a change in pull request #951: SAMZA-2127: Upgrade to
Kafka 2.0
URL: https://github.com/apache/samza/pull/951#discussion_r268386149
##
File path:
samza-test/src/test/java/org/apache/samza/test/harness/IntegrationTestHarness.java
##
@@ -0,0 +1,192 @
shanthoosh commented on a change in pull request #951: SAMZA-2127: Upgrade to
Kafka 2.0
URL: https://github.com/apache/samza/pull/951#discussion_r268386358
##
File path: gradle/dependency-versions.gradle
##
@@ -34,7 +34,7 @@
jodaTimeVersion = "2.2"
joptSimpleVersion
shanthoosh commented on a change in pull request #951: SAMZA-2127: Upgrade to
Kafka 2.0
URL: https://github.com/apache/samza/pull/951#discussion_r268386607
##
File path:
samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemAdmin.java
##
@@ -668,22 +631,86 @@
shanthoosh commented on a change in pull request #951: SAMZA-2127: Upgrade to
Kafka 2.0
URL: https://github.com/apache/samza/pull/951#discussion_r268384606
##
File path:
samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemAdmin.java
##
@@ -628,10 +589,12 @@
shanthoosh commented on a change in pull request #951: SAMZA-2127: Upgrade to
Kafka 2.0
URL: https://github.com/apache/samza/pull/951#discussion_r268386258
##
File path:
samza-test/src/test/java/org/apache/samza/test/framework/StreamApplicationIntegrationTestHarness.java
#
shanthoosh commented on a change in pull request #951: SAMZA-2127: Upgrade to
Kafka 2.0
URL: https://github.com/apache/samza/pull/951#discussion_r268386045
##
File path:
samza-test/src/test/java/org/apache/samza/test/harness/IntegrationTestHarness.java
##
@@ -0,0 +1,192 @
shanthoosh commented on a change in pull request #951: SAMZA-2127: Upgrade to
Kafka 2.0
URL: https://github.com/apache/samza/pull/951#discussion_r268386127
##
File path:
samza-test/src/test/java/org/apache/samza/test/harness/IntegrationTestHarness.java
##
@@ -0,0 +1,192 @
shanthoosh commented on a change in pull request #951: SAMZA-2127: Upgrade to
Kafka 2.0
URL: https://github.com/apache/samza/pull/951#discussion_r268386095
##
File path:
samza-test/src/test/java/org/apache/samza/test/harness/IntegrationTestHarness.java
##
@@ -0,0 +1,192 @
shanthoosh commented on a change in pull request #951: SAMZA-2127: Upgrade to
Kafka 2.0
URL: https://github.com/apache/samza/pull/951#discussion_r268386706
##
File path:
samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemAdmin.java
##
@@ -668,22 +631,86 @@
shanthoosh commented on a change in pull request #951: SAMZA-2127: Upgrade to
Kafka 2.0
URL: https://github.com/apache/samza/pull/951#discussion_r268385471
##
File path:
samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemAdmin.java
##
@@ -711,4 +738,29 @@
shanthoosh commented on a change in pull request #951: SAMZA-2127: Upgrade to
Kafka 2.0
URL: https://github.com/apache/samza/pull/951#discussion_r268386258
##
File path:
samza-test/src/test/java/org/apache/samza/test/framework/StreamApplicationIntegrationTestHarness.java
#
shenodaguirguis commented on a change in pull request #966: Moving the Fixes
from internal AvroRelConverter
URL: https://github.com/apache/samza/pull/966#discussion_r268405483
##
File path:
samza-sql/src/main/java/org/apache/samza/sql/avro/AvroRelConverter.java
##
@@ -170
shenodaguirguis commented on a change in pull request #966: Moving the Fixes
from internal AvroRelConverter
URL: https://github.com/apache/samza/pull/966#discussion_r268405596
##
File path:
samza-sql/src/main/java/org/apache/samza/sql/avro/AvroRelConverter.java
##
@@ -271
shenodaguirguis commented on a change in pull request #966: Moving the Fixes
from internal AvroRelConverter
URL: https://github.com/apache/samza/pull/966#discussion_r268405722
##
File path:
samza-sql/src/main/java/org/apache/samza/sql/avro/AvroRelConverter.java
##
@@ -271
dnishimura opened a new pull request #970: SAMZA-2143: Fix NPE in
`CoordinatorStreamMessage#equals` and some clean-up to
CoordinatorStreamSystemConsumer
URL: https://github.com/apache/samza/pull/970
1) NPE exposed in CoordinatorStreamMessage#equals now that the metadata
store allows arbit
dnishimura opened a new pull request #971: SAMZA-2144: In TaskInstance, bypass
"SSP caught-up" check if offset is set by a startpoint
URL: https://github.com/apache/samza/pull/971
TaskInstance maintains a "SSP caught-up map" to ensure that all tasks for
the same SSP have caught up to he sa
shanthoosh 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_r268010269
##
File path: samza-core/src/main/java/org/apache/sa
shanthoosh 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_r268415931
##
File path:
samza-core/src/main/scala/org/apache/
shanthoosh 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_r268481222
##
File path: samza-core/src/main/java/org/apache/sa
shanthoosh 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_r268481956
##
File path:
samza-core/src/main/scala/org/apache/
shanthoosh 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_r268481428
##
File path:
samza-core/src/test/java/org/apache/s
srinipunuru commented on a change in pull request #966: Moving the Fixes from
internal AvroRelConverter
URL: https://github.com/apache/samza/pull/966#discussion_r268728229
##
File path:
samza-sql/src/main/java/org/apache/samza/sql/avro/AvroRelConverter.java
##
@@ -170,22
srinipunuru commented on a change in pull request #966: Moving the Fixes from
internal AvroRelConverter
URL: https://github.com/apache/samza/pull/966#discussion_r268731436
##
File path:
samza-sql/src/main/java/org/apache/samza/sql/avro/AvroRelConverter.java
##
@@ -271,45
srinipunuru commented on a change in pull request #966: Moving the Fixes from
internal AvroRelConverter
URL: https://github.com/apache/samza/pull/966#discussion_r268731436
##
File path:
samza-sql/src/main/java/org/apache/samza/sql/avro/AvroRelConverter.java
##
@@ -271,45
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_r268763050
##
File path: samza-core/src/main/java/org/apache
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_r268764920
##
File path:
samza-test/src/test/java/org/apache/samza/test/framework/StreamApplicationIntegrationTestHarness.java
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_r268772818
##
File path:
samza-test/src/test/scala/org/apache/samza/test/integration/StreamTaskTestUtil.scala
##
@@ -133,43 +1
srinipunuru merged pull request #966: Moving the Fixes from internal
AvroRelConverter
URL: https://github.com/apache/samza/pull/966
This is an automated message from the Apache Git Service.
To respond to the message, please
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_r268788137
##
File path:
samza-core/src/main/java/org/apache/
dengpanyin commented on issue #961: SAMZA-2134:Enable table rate limiter by
default.
URL: https://github.com/apache/samza/pull/961#issuecomment-476328264
Add @sborya to take a look as well.
This is an automated message from
vjagadish1989 commented on a change in pull request #961: SAMZA-2134:Enable
table rate limiter by default.
URL: https://github.com/apache/samza/pull/961#discussion_r268843384
##
File path:
samza-api/src/main/java/org/apache/samza/table/descriptors/RemoteTableDescriptor.java
##
vjagadish1989 commented on a change in pull request #961: SAMZA-2134:Enable
table rate limiter by default.
URL: https://github.com/apache/samza/pull/961#discussion_r268846328
##
File path:
samza-api/src/main/java/org/apache/samza/table/descriptors/RemoteTableDescriptor.java
##
vjagadish1989 commented on a change in pull request #961: SAMZA-2134:Enable
table rate limiter by default.
URL: https://github.com/apache/samza/pull/961#discussion_r268846328
##
File path:
samza-api/src/main/java/org/apache/samza/table/descriptors/RemoteTableDescriptor.java
##
vjagadish1989 commented on a change in pull request #961: SAMZA-2134:Enable
table rate limiter by default.
URL: https://github.com/apache/samza/pull/961#discussion_r268846328
##
File path:
samza-api/src/main/java/org/apache/samza/table/descriptors/RemoteTableDescriptor.java
##
dengpanyin commented on a change in pull request #961: SAMZA-2134:Enable table
rate limiter by default.
URL: https://github.com/apache/samza/pull/961#discussion_r268856771
##
File path:
samza-api/src/main/java/org/apache/samza/table/descriptors/RemoteTableDescriptor.java
#
dengpanyin commented on a change in pull request #961: SAMZA-2134:Enable table
rate limiter by default.
URL: https://github.com/apache/samza/pull/961#discussion_r268860718
##
File path:
samza-api/src/main/java/org/apache/samza/table/descriptors/RemoteTableDescriptor.java
#
mynameborat opened a new pull request #972: [SAMZA-2146] - Expose physical name
in StreamDescriptor
URL: https://github.com/apache/samza/pull/972
Refer to https://issues.apache.org/jira/browse/SAMZA-2146 for more details
This
asfgit closed pull request #972: [SAMZA-2146] - Expose physical name in
StreamDescriptor
URL: https://github.com/apache/samza/pull/972
This is an automated message from the Apache Git Service.
To respond to the message, plea
shanthoosh opened a new pull request #973: Remove semicolon from sub-headings
of 1.1 blog post.
URL: https://github.com/apache/samza/pull/973
This is an automated message from the Apache Git Service.
To respond to the messag
shanthoosh commented on issue #973: Remove semicolon from sub-headings of 1.1
blog post.
URL: https://github.com/apache/samza/pull/973#issuecomment-476411309
Thanks for the quick review Daniel. Since the change involves minor
documentation cleanup, merging it to trunk.
---
shanthoosh merged pull request #973: Remove semicolon from sub-headings of 1.1
blog post.
URL: https://github.com/apache/samza/pull/973
This is an automated message from the Apache Git Service.
To respond to the message, ple
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_r268891069
##
File path:
samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemAdmin.java
##
@@ -628,10 +589,12 @
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_r268861935
##
File path:
samza-test/src/test/java/org/apache/samza/test/harness/IntegrationTestHarness.java
##
@@ -0,0 +1,192
601 - 700 of 969 matches
Mail list logo
