mynameborat commented on issue #981: Bugfix: Making KafkaSytemAdmin's
metadataConsumer accesses thread-safe, enabling StreamRegexMonitors only when
required
URL: https://github.com/apache/samza/pull/981#issuecomment-478844338
Can you create a JIRA and add explanation around the bug and
rmatharu commented on a change in pull request #980: Cleaned up AM logs and
naming convention
URL: https://github.com/apache/samza/pull/980#discussion_r270498446
##
File path:
samza-core/src/main/java/org/apache/samza/clustermanager/AbstractContainerAllocator.java
##
@@
prateekm opened a new pull request #980: Cleaned up AM logs and naming
convention
URL: https://github.com/apache/samza/pull/980
1. To disambiguate between YARN containers and Samza Processor.
2. Use consistent logging format. Now can search logs with strings
"Container ID: ",
rmatharu commented on a change in pull request #980: Cleaned up AM logs and
naming convention
URL: https://github.com/apache/samza/pull/980#discussion_r270496794
##
File path:
samza-core/src/main/java/org/apache/samza/clustermanager/AbstractContainerAllocator.java
##
@@
prateekm commented on issue #980: Cleaned up AM logs and naming convention
URL: https://github.com/apache/samza/pull/980#issuecomment-478070467
@vjagadish1989 @rmatharu Please take a look.
This is an automated message from
mynameborat commented on issue #905: SAMZA-2055: Async high level api
URL: https://github.com/apache/samza/pull/905#issuecomment-479058100
`testSinkEndToEndWithKeyWithNullRecords` seems to be flaky. I have a 60%
pass rate locally.
prateekm commented on a change in pull request #981: SAMZA-2152 : Bugfix:
Making KafkaSytemAdmin's metadataConsumer accesses thread-safe, enabling
StreamRegexMonitors only when required
URL: https://github.com/apache/samza/pull/981#discussion_r271393999
##
File path:
prateekm commented on a change in pull request #981: SAMZA-2152 : Bugfix:
Making KafkaSytemAdmin's metadataConsumer accesses thread-safe, enabling
StreamRegexMonitors only when required
URL: https://github.com/apache/samza/pull/981#discussion_r271392441
##
File path:
rmatharu commented on issue #981: SAMZA-2152 : Bugfix: Making KafkaSytemAdmin's
metadataConsumer accesses thread-safe, enabling StreamRegexMonitors only when
required
URL: https://github.com/apache/samza/pull/981#issuecomment-479104652
addressed your comments.
adminClient accesses seem
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
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:
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:
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:
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:
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:
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:
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:
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:
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:
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:
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
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 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
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
shanthoosh commented on issue #974: SAMZA-2147: Improve the documentation of
the samza release process.
URL: https://github.com/apache/samza/pull/974#issuecomment-476433492
@dxichen Please take a look when you have a chance.
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_r268930336
##
File path:
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_r268902437
##
File path:
samza-test/src/test/java/org/apache/samza/test/framework/StreamApplicationIntegrationTestHarness.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_r268901338
##
File path:
samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemAdmin.java
##
@@ -594,7 +593,13
shanthoosh merged pull request #974: SAMZA-2147: Improve the documentation of
the samza release process.
URL: https://github.com/apache/samza/pull/974
This is an automated message from the Apache Git Service.
To respond to
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
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
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_r268900710
##
File path:
samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemAdmin.java
##
@@ -594,7 +593,13
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,
shanthoosh edited a comment on issue #975: SAMZA-2148: Fix the rendering of
bash and sql scripts in samza-sql release validation page.
URL: https://github.com/apache/samza/pull/975#issuecomment-476437090
@srinipunuru @atoomula
Please take a look when you have a chance. I've
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
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_r268893914
##
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_r268890341
##
File path: gradle/dependency-versions.gradle
##
@@ -34,7 +34,7 @@
jodaTimeVersion = "2.2"
shanthoosh opened a new pull request #975: SAMZA-2148: Fix the rendering of
bash and sql scripts in samza-sql release validation page.
URL: https://github.com/apache/samza/pull/975
Currently, the bash/sql scripts available in samza-sql release validation
page were not using the proper
shanthoosh commented on issue #975: SAMZA-2148: Fix the rendering of bash and
sql scripts in samza-sql release validation page.
URL: https://github.com/apache/samza/pull/975#issuecomment-476437090
@srinipunuru Please take a look when you have a chance. I've attached the
screenshot of the
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,
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
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
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_r268899597
##
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_r268961813
##
File path:
samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemAdmin.java
##
@@ -594,7 +593,13 @@
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_r268959127
##
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_r268902597
##
File path:
samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemAdmin.java
##
@@ -668,22 +631,86
weisong44 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_r269080557
##
File path:
samza-api/src/main/java/org/apache/samza/table/descriptors/RemoteTableDescriptor.java
weisong44 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_r269080884
##
File path:
samza-api/src/main/java/org/apache/samza/table/descriptors/RemoteTableDescriptor.java
srinipunuru opened a new pull request #979: SAMZA-2110 : Support for deleting
records from a table
URL: https://github.com/apache/samza/pull/979
1. Commit adds support for deleting records from table by adding a special
__op__ field. SQL users can use this field to say whether the row
shanthoosh commented on a change in pull request #978: SAMZA-1733 : Making
MetricsSnapshotReporter look for appclass then taskclass
URL: https://github.com/apache/samza/pull/978#discussion_r269649574
##
File path:
prateekm commented on a change in pull request #978: SAMZA-1733 : Making
MetricsSnapshotReporter look for appclass then taskclass
URL: https://github.com/apache/samza/pull/978#discussion_r269637384
##
File path:
rmatharu commented on a change in pull request #978: SAMZA-1733 : Making
MetricsSnapshotReporter look for appclass then taskclass
URL: https://github.com/apache/samza/pull/978#discussion_r269684095
##
File path:
rmatharu commented on a change in pull request #978: SAMZA-1733 : Making
MetricsSnapshotReporter look for appclass then taskclass
URL: https://github.com/apache/samza/pull/978#discussion_r269684095
##
File path:
shanthoosh commented on a change in pull request #978: SAMZA-1733 : Making
MetricsSnapshotReporter look for appclass then taskclass
URL: https://github.com/apache/samza/pull/978#discussion_r269704869
##
File path:
atoomula merged pull request #978: SAMZA-1733 : Making MetricsSnapshotReporter
look for appclass then taskclass
URL: https://github.com/apache/samza/pull/978
This is an automated message from the Apache Git Service.
To
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_r269749949
##
File path:
samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemAdmin.scala
##
@@ -169,59
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_r269750016
##
File path: gradle/dependency-versions.gradle
##
@@ -34,7 +34,7 @@
jodaTimeVersion = "2.2"
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_r269747800
##
File path:
samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemAdmin.java
##
@@ -594,7 +593,13
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_r269747886
##
File path:
samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemAdmin.java
##
@@ -594,7 +593,13
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_r269750805
##
File path:
samza-test/src/test/java/org/apache/samza/test/harness/IntegrationTestHarness.java
##
@@ -0,0 +1,192
shanthoosh commented on issue #955: SAMZA-2131: [Scala cleanup] Convert
FileSystemCheckpointManagerConfig.scala and SystemConfig.scala to Java
URL: https://github.com/apache/samza/pull/955#issuecomment-476785179
@cameronlee314 Thanks for the changes. Merged to trunk.
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
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
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
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:
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:
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:
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:
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:
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_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 #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/
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 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/
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
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 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
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
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 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
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
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
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
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
asfgit closed pull request #905: SAMZA-2055: Async high level api
URL: https://github.com/apache/samza/pull/905
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
srinipunuru merged pull request #983: Samza-2154: Fixing the
testSinkEndToEndWithKeyWithNullRecords test case
URL: https://github.com/apache/samza/pull/983
This is an automated message from the Apache Git Service.
To
Zhangyx39 opened a new pull request #982: SAMZA-2153: Implement to Config for
TableRetryPolicy
URL: https://github.com/apache/samza/pull/982
Added setTableId and getTableId to TablePart interface.
Implemented toConfig method in TableRetryPolicy to serialize the class to
json format so
srinipunuru opened a new pull request #983: Fixing the
testSinkEndToEndWithKeyWithNullRecords test case
URL: https://github.com/apache/samza/pull/983
This is an automated message from the Apache Git Service.
To respond to
1 - 100 of 921 matches
Mail list logo