[
https://issues.apache.org/jira/browse/SAMZA-1028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish resolved SAMZA-1028.
-
Resolution: Fixed
> Moving logline in callback thread and making exception thrown AtomicRefere
[
https://issues.apache.org/jira/browse/SAMZA-1020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish updated SAMZA-1020:
Assignee: Xinyu Liu
> Remove some deprecated interfaces from 0.10 vers
[
https://issues.apache.org/jira/browse/SAMZA-1020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish resolved SAMZA-1020.
-
Resolution: Fixed
> Remove some deprecated interfaces from 0.10 vers
[
https://issues.apache.org/jira/browse/SAMZA-995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15533729#comment-15533729
]
Jagadish commented on SAMZA-995:
Thanks Xinyu for the patch, merged and submitted.
> Remove conf
[
https://issues.apache.org/jira/browse/SAMZA-995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15533726#comment-15533726
]
Jagadish commented on SAMZA-995:
RB: https://reviews.apache.org/r/52401/ .
> Remove configs depreca
[
https://issues.apache.org/jira/browse/SAMZA-998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15505131#comment-15505131
]
Jagadish commented on SAMZA-998:
https://reviews.apache.org/r/51126/
> Documentation upda
[
https://issues.apache.org/jira/browse/SAMZA-974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15538018#comment-15538018
]
Jagadish commented on SAMZA-974:
Merged and submitted! This is a first step towards enabling bounded
[
https://issues.apache.org/jira/browse/SAMZA-1015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15536914#comment-15536914
]
Jagadish commented on SAMZA-1015:
-
Merged and submitted.
> Support lambdas, streams in checkStyle che
[
https://issues.apache.org/jira/browse/SAMZA-1016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15536915#comment-15536915
]
Jagadish commented on SAMZA-1016:
-
Merged and submitted.
> Fix gradle settings for joint compilat
[
https://issues.apache.org/jira/browse/SAMZA-1046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15688156#comment-15688156
]
Jagadish commented on SAMZA-1046:
-
Thanks alot Boris for the patch! Merged and submitted.
> Docum
Jagadish created SAMZA-1045:
---
Summary: Refactor classes from samza-operator/api into samza-api.
Key: SAMZA-1045
URL: https://issues.apache.org/jira/browse/SAMZA-1045
Project: Samza
Issue Type
[
https://issues.apache.org/jira/browse/SAMZA-1045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15626868#comment-15626868
]
Jagadish commented on SAMZA-1045:
-
Thanks guys for the reviews. Submitted to samza-operator branch. We
[
https://issues.apache.org/jira/browse/SAMZA-1041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15746352#comment-15746352
]
Jagadish commented on SAMZA-1041:
-
[~jagadish1...@gmail.com]
> Multi-stage feature for Sa
[
https://issues.apache.org/jira/browse/SAMZA-1065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish updated SAMZA-1065:
Fix Version/s: 0.12.0
> Change the commit order to support at least once processing when dedup
Jagadish created SAMZA-1077:
---
Summary: SamzaContainer should catch all Throwables instead of
only exceptions
Key: SAMZA-1077
URL: https://issues.apache.org/jira/browse/SAMZA-1077
Project: Samza
[
https://issues.apache.org/jira/browse/SAMZA-1077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish updated SAMZA-1077:
Description:
Here's the startup sequence of the SamzaContainer.
{code:title=Bar.java|borderStyle=solid
[
https://issues.apache.org/jira/browse/SAMZA-1077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish updated SAMZA-1077:
Description:
Here's the snippet from the startup sequence of the SamzaContainer.
{code:title
[
https://issues.apache.org/jira/browse/SAMZA-1077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish updated SAMZA-1077:
Description:
Here's the snippet from the startup sequence of the SamzaContainer.
{code:title
[
https://issues.apache.org/jira/browse/SAMZA-1077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish updated SAMZA-1077:
Description:
Here's the snippet from the startup sequence of the SamzaContainer.
{code:title
Jagadish created SAMZA-1177:
---
Summary: Improve upgrade documentation for open source releases
Key: SAMZA-1177
URL: https://issues.apache.org/jira/browse/SAMZA-1177
Project: Samza
Issue Type: Bug
Jagadish created SAMZA-1170:
---
Summary: Integration testing harness for StreamApplications
Key: SAMZA-1170
URL: https://issues.apache.org/jira/browse/SAMZA-1170
Project: Samza
Issue Type: Bug
Jagadish created SAMZA-1155:
---
Summary: Allow configuring window.ms to specify trigger duration
Key: SAMZA-1155
URL: https://issues.apache.org/jira/browse/SAMZA-1155
Project: Samza
Issue Type: Bug
[
https://issues.apache.org/jira/browse/SAMZA-1155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish updated SAMZA-1155:
Description: When a user writes a `StreamTask` (low level API), the
property `task.window.ms` specifies
Jagadish created SAMZA-1202:
---
Summary: Multiple calls to `graph.getInputStream()` with the same
streamId results in non-deterministic behavior
Key: SAMZA-1202
URL: https://issues.apache.org/jira/browse/SAMZA-1202
[
https://issues.apache.org/jira/browse/SAMZA-1202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish updated SAMZA-1202:
Description:
Consider the following code-snippet that invokes graph.getInputStream multiple
times
[
https://issues.apache.org/jira/browse/SAMZA-1202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish updated SAMZA-1202:
Description:
Consider the following code-snippet that invokes graph.getInputStream multiple
times
[
https://issues.apache.org/jira/browse/SAMZA-1202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish reassigned SAMZA-1202:
---
Assignee: Jagadish
> Multiple calls to `graph.getInputStream()` with the same streamId resu
[
https://issues.apache.org/jira/browse/SAMZA-1202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish updated SAMZA-1202:
Description:
Consider the following code-snippet that invokes graph.getInputStream multiple
times
[
https://issues.apache.org/jira/browse/SAMZA-1202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish updated SAMZA-1202:
Description:
Consider the following code-snippet that invokes graph.getInputStream multiple
times
[
https://issues.apache.org/jira/browse/SAMZA-1202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish updated SAMZA-1202:
Description:
Consider the following code-snippet that invokes graph.getInputStream multiple
times
[
https://issues.apache.org/jira/browse/SAMZA-1202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish updated SAMZA-1202:
Description:
Consider the following code-snippet that invokes graph.getInputStream multiple
times
[
https://issues.apache.org/jira/browse/SAMZA-1202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish updated SAMZA-1202:
Description:
Consider the following code-snippet that invokes graph.getInputStream multiple
times
[
https://issues.apache.org/jira/browse/SAMZA-1202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish updated SAMZA-1202:
Description:
Consider the following code-snippet that invokes graph.getInputStream multiple
times
[
https://issues.apache.org/jira/browse/SAMZA-1202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish updated SAMZA-1202:
Description:
Consider the following code-snippet that invokes graph.getInputStream multiple
times
[
https://issues.apache.org/jira/browse/SAMZA-1220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish updated SAMZA-1220:
Description:
[~jagadish1...@gmail.com] and I were recently looking at a thread dump for a
SamzaContainer
Jagadish created SAMZA-1225:
---
Summary: Add demo examples for programming with the fluent API
Key: SAMZA-1225
URL: https://issues.apache.org/jira/browse/SAMZA-1225
Project: Samza
Issue Type: Bug
[
https://issues.apache.org/jira/browse/SAMZA-1112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish updated SAMZA-1112:
Fix Version/s: 0.13.0
Thanks for the contribution. Merged, and submitted. Fix version: 0.13.0
Jagadish created SAMZA-1108:
---
Summary: Implement core windowing and triggering logic
Key: SAMZA-1108
URL: https://issues.apache.org/jira/browse/SAMZA-1108
Project: Samza
Issue Type: Bug
[
https://issues.apache.org/jira/browse/SAMZA-1121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish resolved SAMZA-1121.
-
Resolution: Fixed
Thanks for the timely patch [~pmaheshwari]. merged and submitted to master
[
https://issues.apache.org/jira/browse/SAMZA-1121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish updated SAMZA-1121:
Fix Version/s: 0.13.0
> StreamAppender should not propagate exceptions to cal
[
https://issues.apache.org/jira/browse/SAMZA-1362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish reassigned SAMZA-1362:
---
Assignee: Jagadish
> Revisit window APIs in Sa
Jagadish created SAMZA-1362:
---
Summary: Revisit window APIs in Samza
Key: SAMZA-1362
URL: https://issues.apache.org/jira/browse/SAMZA-1362
Project: Samza
Issue Type: Bug
Reporter
[
https://issues.apache.org/jira/browse/SAMZA-1359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16087682#comment-16087682
]
Jagadish commented on SAMZA-1359:
-
The fix looks as follows:
1. Improve our container handling logic
[
https://issues.apache.org/jira/browse/SAMZA-1359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish updated SAMZA-1359:
Description:
At LinkedIn, we have observed that there are phantom notifications
corresponding
[
https://issues.apache.org/jira/browse/SAMZA-1359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish updated SAMZA-1359:
Description:
At LinkedIn, we have observed that there are phantom notifications
corresponding
[
https://issues.apache.org/jira/browse/SAMZA-1359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish updated SAMZA-1359:
Description:
At LinkedIn, we have observed that there are phantom notifications
corresponding
[
https://issues.apache.org/jira/browse/SAMZA-1359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish updated SAMZA-1359:
Description:
At LinkedIn, we have observed that there are phantom notifications
corresponding
[
https://issues.apache.org/jira/browse/SAMZA-1359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish updated SAMZA-1359:
Description:
At LinkedIn, we have observed that there are phantom notifications
corresponding
[
https://issues.apache.org/jira/browse/SAMZA-1359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish updated SAMZA-1359:
Description:
At LinkedIn, we have observed that there are phantom notifications
corresponding
[
https://issues.apache.org/jira/browse/SAMZA-1359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16087686#comment-16087686
]
Jagadish commented on SAMZA-1359:
-
[~jmakes] [~nickpan47][~navina] thoughts and suggestions welcome
[
https://issues.apache.org/jira/browse/SAMZA-1359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish updated SAMZA-1359:
Description:
At LinkedIn, we have observed that there are phantom notifications
corresponding
[
https://issues.apache.org/jira/browse/SAMZA-1359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish reassigned SAMZA-1359:
---
Assignee: Jagadish
> Handle phantom container notifications cleanly during RM fail-o
[
https://issues.apache.org/jira/browse/SAMZA-1368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish updated SAMZA-1368:
Fix Version/s: 0.13.1
> make sure that a new job model will be generated if zk barrier times
[
https://issues.apache.org/jira/browse/SAMZA-1368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish closed SAMZA-1368.
---
> make sure that a new job model will be generated if zk barrier times
[
https://issues.apache.org/jira/browse/SAMZA-1368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish resolved SAMZA-1368.
-
Resolution: Fixed
> make sure that a new job model will be generated if zk barrier times
[
https://issues.apache.org/jira/browse/SAMZA-1359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish closed SAMZA-1359.
---
> Handle phantom container notifications cleanly during RM fail-o
[
https://issues.apache.org/jira/browse/SAMZA-1359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish resolved SAMZA-1359.
-
Resolution: Fixed
> Handle phantom container notifications cleanly during RM fail-o
Jagadish created SAMZA-1359:
---
Summary: Handle phantom container notifications cleanly during RM
fail-over
Key: SAMZA-1359
URL: https://issues.apache.org/jira/browse/SAMZA-1359
Project: Samza
[
https://issues.apache.org/jira/browse/SAMZA-1370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish closed SAMZA-1370.
---
> Memory leak in CachedStore when using ByteBufferSerde as key se
[
https://issues.apache.org/jira/browse/SAMZA-1361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish resolved SAMZA-1361.
-
Resolution: Fixed
> OperatorImplGraph used wrong keys to store/retrieve OperatorImpl in the
[
https://issues.apache.org/jira/browse/SAMZA-1361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish closed SAMZA-1361.
---
> OperatorImplGraph used wrong keys to store/retrieve OperatorImpl in the
[
https://issues.apache.org/jira/browse/SAMZA-1174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish closed SAMZA-1174.
---
> Profiling State Perfromance
> ---
>
> Key
[
https://issues.apache.org/jira/browse/SAMZA-1174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish resolved SAMZA-1174.
-
Resolution: Fixed
> Profiling State Perfromance
> ---
>
>
[
https://issues.apache.org/jira/browse/SAMZA-1298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish closed SAMZA-1298.
---
> if ZkConnect string contains extra path, it needs to be created on the
[
https://issues.apache.org/jira/browse/SAMZA-1298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish resolved SAMZA-1298.
-
Resolution: Fixed
> if ZkConnect string contains extra path, it needs to be created on the
[
https://issues.apache.org/jira/browse/SAMZA-1271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish reassigned SAMZA-1271:
---
Assignee: Jagadish (was: Prateek Maheshwari)
> Guarantee deterministic and predictable or
[
https://issues.apache.org/jira/browse/SAMZA-1271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish resolved SAMZA-1271.
-
Resolution: Fixed
> Guarantee deterministic and predictable order for operator function
> initiali
[
https://issues.apache.org/jira/browse/SAMZA-1271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish closed SAMZA-1271.
---
> Guarantee deterministic and predictable order for operator function
> initiali
[
https://issues.apache.org/jira/browse/SAMZA-1264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish reassigned SAMZA-1264:
---
Assignee: Jagadish (was: Prateek Maheshwari)
> Operator functions should allow closing/finalizat
[
https://issues.apache.org/jira/browse/SAMZA-1264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish resolved SAMZA-1264.
-
Resolution: Fixed
> Operator functions should allow closing/finalizat
[
https://issues.apache.org/jira/browse/SAMZA-1264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish closed SAMZA-1264.
---
> Operator functions should allow closing/finalizat
Jagadish created SAMZA-1249:
---
Summary: Fix equality for WindowKey for Non-keyed tumbling windows
Key: SAMZA-1249
URL: https://issues.apache.org/jira/browse/SAMZA-1249
Project: Samza
Issue Type
[
https://issues.apache.org/jira/browse/SAMZA-1249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish updated SAMZA-1249:
Description:
The following exception results when we check equality between the `WindowKey`
in the message
[
https://issues.apache.org/jira/browse/SAMZA-1249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish reassigned SAMZA-1249:
---
Assignee: Jagadish
> Fix equality for WindowKey for Non-keyed tumbling wind
[
https://issues.apache.org/jira/browse/SAMZA-1249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish updated SAMZA-1249:
Description:
The following exception results when we attempt to check equality for WindowKey
Jagadish created SAMZA-1419:
---
Summary: Refactor StreamProcessor tests to remove Thread.sleep()
Key: SAMZA-1419
URL: https://issues.apache.org/jira/browse/SAMZA-1419
Project: Samza
Issue Type: Bug
[
https://issues.apache.org/jira/browse/SAMZA-1419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16170366#comment-16170366
]
Jagadish commented on SAMZA-1419:
-
Resolved by https://github.com/apache/samza/pull/291/files
> Refac
[
https://issues.apache.org/jira/browse/SAMZA-1419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish resolved SAMZA-1419.
-
Resolution: Fixed
> Refactor StreamProcessor tests to remove Thread.sl
[
https://issues.apache.org/jira/browse/SAMZA-1419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish closed SAMZA-1419.
---
> Refactor StreamProcessor tests to remove Thread.sl
Jagadish created SAMZA-1421:
---
Summary: Re-think Samza's Window APIs
Key: SAMZA-1421
URL: https://issues.apache.org/jira/browse/SAMZA-1421
Project: Samza
Issue Type: Bug
Reporter
Jagadish created SAMZA-1422:
---
Summary: Refactor APIs for Keyed vs Non-Keyed Windows
Key: SAMZA-1422
URL: https://issues.apache.org/jira/browse/SAMZA-1422
Project: Samza
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/SAMZA-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish updated SAMZA-1421:
Description:
Currently, Windows can either be Keyed or Non-Keyed , session or tumbling ,
event time
Jagadish created SAMZA-1423:
---
Summary: Implement a RocksDb backed time-series store for storing
and retrieving messages time-ranges
Key: SAMZA-1423
URL: https://issues.apache.org/jira/browse/SAMZA-1423
Jagadish created SAMZA-1424:
---
Summary: Extend Samza's StorageEngine APIs to support Windowed
stores
Key: SAMZA-1424
URL: https://issues.apache.org/jira/browse/SAMZA-1424
Project: Samza
Issue Type
[
https://issues.apache.org/jira/browse/SAMZA-1425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish updated SAMZA-1425:
Summary: Implement persistent tumbling and session windows (was: Implement
persistent tumbling and sliding
Jagadish created SAMZA-1425:
---
Summary: Implement persistent tumbling and sliding windows
Key: SAMZA-1425
URL: https://issues.apache.org/jira/browse/SAMZA-1425
Project: Samza
Issue Type: Sub-task
Jagadish created SAMZA-1426:
---
Summary: Wire-up windowed stores in the Operatorgraph
Key: SAMZA-1426
URL: https://issues.apache.org/jira/browse/SAMZA-1426
Project: Samza
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/SAMZA-1426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish reassigned SAMZA-1426:
---
Assignee: (was: Jagadish)
> Wire-up windowed stores in the Operatorgr
[
https://issues.apache.org/jira/browse/SAMZA-1423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish reassigned SAMZA-1423:
---
Assignee: Jagadish
> Implement a RocksDb backed time-series store for storing and retriev
[
https://issues.apache.org/jira/browse/SAMZA-1423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish updated SAMZA-1423:
Description:
I'm thinking of the following API for the time-series store:
{code}
/**
* A key-value store
[
https://issues.apache.org/jira/browse/SAMZA-1423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish updated SAMZA-1423:
Description:
I'm thinking of the following API for the time-series store:
{code}
/**
* A key-value store
Title: Message Title
jagadish created a page
SEP-8 Add a Kinesis SystemConsumer and SystemProducer
Status Current state: [ UNDER DISCUSSION | ACCEPTED | REJECTED ] Discussion thread: <link to mail
Title: Message Title
jagadish edited a page
SEP-9 Add a Kinesis SystemConsumer and SystemProducer
Status Current state: [ UNDER DISCUSSION | ACCEPTED | REJECTED ] ... JIRA: SAMZA-TBD Released
[
https://issues.apache.org/jira/browse/SAMZA-1425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish closed SAMZA-1425.
---
> Implement persistent tumbling and session wind
[
https://issues.apache.org/jira/browse/SAMZA-1426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish reassigned SAMZA-1426:
---
Assignee: Jagadish
> Wire-up windowed stores in the Operatorgr
[
https://issues.apache.org/jira/browse/SAMZA-1425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish resolved SAMZA-1425.
-
Resolution: Fixed
Assignee: Jagadish
> Implement persistent tumbling and session wind
[
https://issues.apache.org/jira/browse/SAMZA-1424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish resolved SAMZA-1424.
-
Resolution: Fixed
Assignee: Jagadish
> Extend Samza's StorageEngine APIs to support Windowed sto
[
https://issues.apache.org/jira/browse/SAMZA-1424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish closed SAMZA-1424.
---
> Extend Samza's StorageEngine APIs to support Windowed sto
Jagadish created SAMZA-1435:
---
Summary: Remove Scala from Samza-API classes
Key: SAMZA-1435
URL: https://issues.apache.org/jira/browse/SAMZA-1435
Project: Samza
Issue Type: Bug
Reporter
[
https://issues.apache.org/jira/browse/SAMZA-1435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jagadish updated SAMZA-1435:
Fix Version/s: 0.14.0
> Remove Scala from Samza-API clas
801 - 900 of 1058 matches
Mail list logo
