mynameborat 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-477643676
I lost access to this account due to 2FC issues.
Will see if I can close it somehow.
mynameborat commented on a change in pull request #905: SAMZA-2055: Async high
level api
URL: https://github.com/apache/samza/pull/905#discussion_r270075454
##
File path:
samza-api/src/main/java/org/apache/samza/operators/functions/AsyncFlatMapFunction.java
##
@@ -0,0 +1,
dnishimura closed 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
This is an automated message from the Apache Git S
dnishimura commented on issue #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#issuecomment-477700203
Closing since incoming API modifications will not require this PR.
FYI - @shanthoosh
-
srinipunuru commented on issue #979: SAMZA-2110 : Support for deleting records
from a table
URL: https://github.com/apache/samza/pull/979#issuecomment-477700449
@atoomula
> * delete events from cc streams. eg: "select * from brooklin.stream",
"select f1, f2 from brooklin.stream"
srinipunuru edited a comment on issue #979: SAMZA-2110 : Support for deleting
records from a table
URL: https://github.com/apache/samza/pull/979#issuecomment-477700449
@atoomula
> * delete events from cc streams. eg: "select * from brooklin.stream",
"select f1, f2 from brooklin.str
mynameborat commented on a change in pull request #905: SAMZA-2055: Async high
level api
URL: https://github.com/apache/samza/pull/905#discussion_r270129948
##
File path:
samza-core/src/main/java/org/apache/samza/operators/impl/AsyncStreamOperatorImpl.java
##
@@ -0,0 +1,7
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-477723517
Since @mynameborat has lost access to his account, I'm closing this PR.
--
shanthoosh closed pull request #39: Sample application to illustrate
side-inputs using stream table join
URL: https://github.com/apache/samza-hello-samza/pull/39
This is an automated message from the Apache Git Service.
To r
+1 (binding)
On Mon, Mar 25, 2019 at 6:09 PM Jagadish Venkatraman
wrote:
> +1 (binding);
>
> thanks Bharath for the proposal and the implementation.
>
> LGTM;
>
> On Monday, March 25, 2019, Bharath Kumara Subramanian <
> codin.mart...@gmail.com> wrote:
>
> > Hi all,
> >
> >
> > This is a call fo
Looks great! +1 (binding).
On Thu, Mar 28, 2019 at 12:03 PM Jake Maes wrote:
> +1 (binding)
>
> On Mon, Mar 25, 2019 at 6:09 PM Jagadish Venkatraman <
> jagadish1...@gmail.com>
> wrote:
>
> > +1 (binding);
> >
> > thanks Bharath for the proposal and the implementation.
> >
> > LGTM;
> >
> > On M
srinipunuru merged pull request #979: SAMZA-2110 : Support for deleting records
from a table
URL: https://github.com/apache/samza/pull/979
This is an automated message from the Apache Git Service.
To respond to the message,
shanthoosh merged pull request #970: SAMZA-2143: Fix NPE in
`CoordinatorStreamMessage#equals` and some clean-up to
CoordinatorStreamSystemConsumer
URL: https://github.com/apache/samza/pull/970
This is an automated message f
shanthoosh commented on issue #970: SAMZA-2143: Fix NPE in
`CoordinatorStreamMessage#equals` and some clean-up to
CoordinatorStreamSystemConsumer
URL: https://github.com/apache/samza/pull/970#issuecomment-477889117
@dnishimura
Thanks for the changes. Merged to trunk.
-
14 matches
Mail list logo
