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
+ Xinyu. I think he's still working on merging the remaining 1.0 changes to
the Beam runner.
On Tue, Mar 26, 2019 at 3:35 PM LeVeck, Matt wrote:
> Thanks Prateek. I think I’ve switched all of the relevant libraries to
> Beam Runner 2.12-SNAPSHOTl, and Samza 1.1.0. But for some reason it’s
>
13 matches
Mail list logo