Prateek Maheshwari created SAMZA-1017:
-
Summary: Disk Quotas - Add throttler for AsyncRunLoop
Key: SAMZA-1017
URL: https://issues.apache.org/jira/browse/SAMZA-1017
Project: Samza
Issue Ty
[
https://issues.apache.org/jira/browse/SAMZA-1017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1017:
--
Attachment: throttling-scheduler.patch
Added disk quota based throttling to AsyncRunLoop
[
https://issues.apache.org/jira/browse/SAMZA-1017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1017:
--
Summary: Disk Quotas - Add throttling support for AsyncRunLoop (was: Disk
Quotas - Add
[
https://issues.apache.org/jira/browse/SAMZA-1017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1017:
--
Attachment: throttling-scheduler-2.patch
Removed uses of Java 8 features.
Added licenses
[
https://issues.apache.org/jira/browse/SAMZA-1017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15589382#comment-15589382
]
Prateek Maheshwari commented on SAMZA-1017:
---
RB: https://reviews.apache.org/r/53
[
https://issues.apache.org/jira/browse/SAMZA-1017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1017:
--
Attachment: throttling-scheduler-3.patch
Rebased from HEAD.
> Disk Quotas - Add throttl
Prateek Maheshwari created SAMZA-1054:
-
Summary: Refactor public Operator APIs
Key: SAMZA-1054
URL: https://issues.apache.org/jira/browse/SAMZA-1054
Project: Samza
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/SAMZA-1054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari resolved SAMZA-1054.
---
Resolution: Fixed
> Refactor public Operator APIs
> -
>
>
Prateek Maheshwari created SAMZA-1056:
-
Summary: Provide Operator implementations access to
KeyValueStorageEngines
Key: SAMZA-1056
URL: https://issues.apache.org/jira/browse/SAMZA-1056
Project: Sa
Prateek Maheshwari created SAMZA-1057:
-
Summary: Window documentation refers to single-threaded-only
execution model
Key: SAMZA-1057
URL: https://issues.apache.org/jira/browse/SAMZA-1057
Project:
Prateek Maheshwari created SAMZA-1065:
-
Summary: Change the commit order to support at least once
processing when deduping with local state store
Key: SAMZA-1065
URL: https://issues.apache.org/jira/browse/SAMZ
[
https://issues.apache.org/jira/browse/SAMZA-1065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1065:
--
Description:
The current commit order for a task instance is
(https://github.com/apache
[
https://issues.apache.org/jira/browse/SAMZA-1054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari closed SAMZA-1054.
-
> Refactor public Operator APIs
> -
>
> Key: SAMZA
[
https://issues.apache.org/jira/browse/SAMZA-1065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1065:
--
Description:
The current commit order for a task instance is
(https://github.com/apache
[
https://issues.apache.org/jira/browse/SAMZA-1065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15771030#comment-15771030
]
Prateek Maheshwari commented on SAMZA-1065:
---
Re: 3.1, 3.2 and 3.3:
I think the
Prateek Maheshwari created SAMZA-1070:
-
Summary: Use a separate SystemProducer for changelog
Key: SAMZA-1070
URL: https://issues.apache.org/jira/browse/SAMZA-1070
Project: Samza
Issue Typ
Title: Message Title
Prateek Maheshwari commented on SAMZA-984
Prateek Maheshwari created SAMZA-1091:
-
Summary: Implement key-based inner join operator with no time
constraints
Key: SAMZA-1091
URL: https://issues.apache.org/jira/browse/SAMZA-1091
Project: Sam
Prateek Maheshwari created SAMZA-1121:
-
Summary: StreamAppender should not propagate exceptions to caller
Key: SAMZA-1121
URL: https://issues.apache.org/jira/browse/SAMZA-1121
Project: Samza
Prateek Maheshwari created SAMZA-1148:
-
Summary: Wire up fluent API input/output stream serdes
Key: SAMZA-1148
URL: https://issues.apache.org/jira/browse/SAMZA-1148
Project: Samza
Issue T
Prateek Maheshwari created SAMZA-1159:
-
Summary: Move StreamSpec from a public API to an ApplicationRunner
internal API
Key: SAMZA-1159
URL: https://issues.apache.org/jira/browse/SAMZA-1159
Projec
[
https://issues.apache.org/jira/browse/SAMZA-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934964#comment-15934964
]
Prateek Maheshwari commented on SAMZA-1159:
---
We're currently using the StreamSpe
Prateek Maheshwari created SAMZA-1176:
-
Summary: Make TestJoinOperator unit tests safe for concurrent
execution
Key: SAMZA-1176
URL: https://issues.apache.org/jira/browse/SAMZA-1176
Project: Samza
Prateek Maheshwari created SAMZA-1190:
-
Summary: Flaky unit tests
Key: SAMZA-1190
URL: https://issues.apache.org/jira/browse/SAMZA-1190
Project: Samza
Issue Type: Bug
Affects Versions
Prateek Maheshwari created SAMZA-1191:
-
Summary: Flaky test: TestExponentialSleepStrategy
testThreadInterruptInRetryLoop
Key: SAMZA-1191
URL: https://issues.apache.org/jira/browse/SAMZA-1191
Proje
[
https://issues.apache.org/jira/browse/SAMZA-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari resolved SAMZA-1159.
---
Resolution: Fixed
Resolved in https://github.com/apache/samza/pull/92.
> Move StreamS
[
https://issues.apache.org/jira/browse/SAMZA-1159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari closed SAMZA-1159.
-
> Move StreamSpec from a public API to an ApplicationRunner internal API
> ---
Prateek Maheshwari created SAMZA-1192:
-
Summary: TestJoinOperator tests fail on JDK 1.8.0_05
Key: SAMZA-1192
URL: https://issues.apache.org/jira/browse/SAMZA-1192
Project: Samza
Issue Typ
[
https://issues.apache.org/jira/browse/SAMZA-1192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1192:
--
Description:
TestJoinOperator tests fail on JDK 1.8.0_05 due to a JDK bug:
https://bugs
[
https://issues.apache.org/jira/browse/SAMZA-1191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari resolved SAMZA-1191.
---
Resolution: Fixed
Assignee: Prateek Maheshwari
> Flaky test: TestExponentialSlee
[
https://issues.apache.org/jira/browse/SAMZA-1191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari closed SAMZA-1191.
-
> Flaky test: TestExponentialSleepStrategy testThreadInterruptInRetryLoop
> --
[
https://issues.apache.org/jira/browse/SAMZA-1196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari reassigned SAMZA-1196:
-
Assignee: Prateek Maheshwari
> Fix TestJmxReporter flaky tests
>
Prateek Maheshwari created SAMZA-1199:
-
Summary: ClassCastException in partitionBy if input type M does
not equal msg.serde type
Key: SAMZA-1199
URL: https://issues.apache.org/jira/browse/SAMZA-1199
Prateek Maheshwari created SAMZA-1200:
-
Summary: Scala compile for samza-core occassionally fails with
ambiguous reference error
Key: SAMZA-1200
URL: https://issues.apache.org/jira/browse/SAMZA-1200
Prateek Maheshwari created SAMZA-1211:
-
Summary: Remove Thread.sleep() from TestJoinOperator tests
Key: SAMZA-1211
URL: https://issues.apache.org/jira/browse/SAMZA-1211
Project: Samza
Iss
[
https://issues.apache.org/jira/browse/SAMZA-1026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari reopened SAMZA-1026:
---
Assignee: (was: Eli Reisman)
We should still do this to avoid the dependency fro
[
https://issues.apache.org/jira/browse/SAMZA-1026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1026:
--
Fix Version/s: 0.13.0
> HDFS System Producer should not have Kafka dependency
>
[
https://issues.apache.org/jira/browse/SAMZA-1173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1173:
--
Fix Version/s: 0.13.0
> Evaluate CoordinationService design and resolve unresolved quest
[
https://issues.apache.org/jira/browse/SAMZA-1175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari closed SAMZA-1175.
-
> Removing CoordinationUtils from JobCoordinationFactory interface
> -
[
https://issues.apache.org/jira/browse/SAMZA-1176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari resolved SAMZA-1176.
---
Resolution: Fixed
> Make TestJoinOperator unit tests safe for concurrent execution
> -
[
https://issues.apache.org/jira/browse/SAMZA-1110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari resolved SAMZA-1110.
---
Resolution: Fixed
Fix Version/s: 0.13.0
Not necessary anymore.
> Use "equals"
[
https://issues.apache.org/jira/browse/SAMZA-272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari resolved SAMZA-272.
--
Resolution: Fixed
Assignee: Prateek Maheshwari
Fix Version/s: 0.13.0
> Te
[
https://issues.apache.org/jira/browse/SAMZA-1147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1147:
--
Fix Version/s: 0.13.0
> ZkJobCoordinator does not honor the interface contract of JobCoo
[
https://issues.apache.org/jira/browse/SAMZA-1210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1210:
--
Summary: Fix ZK path issues + container IDs generation. (was: fix ZK path
issues + cont
[
https://issues.apache.org/jira/browse/SAMZA-1162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1162:
--
Summary: Review tryBecomeLeader implementation to see if it can be
simplified. (was: re
[
https://issues.apache.org/jira/browse/SAMZA-1106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari resolved SAMZA-1106.
---
Resolution: Fixed
> Create test utils for Zk based Standalone testing
> --
[
https://issues.apache.org/jira/browse/SAMZA-1106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1106:
--
Summary: Create test utils for Zk based Standalone testing (was: create
test utils for
[
https://issues.apache.org/jira/browse/SAMZA-1150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1150:
--
Fix Version/s: 0.13.0
> Handling Error propagation between ZkJobCoordinator & DebounceTi
[
https://issues.apache.org/jira/browse/SAMZA-1181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1181:
--
Fix Version/s: 0.13.0
> Fix AppMaster hang after submitting jobs to Yarn
> -
[
https://issues.apache.org/jira/browse/SAMZA-1109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1109:
--
Fix Version/s: 0.13.0
> Creating Serde regristry to support typed data serdes in samza-a
[
https://issues.apache.org/jira/browse/SAMZA-1203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1203:
--
Fix Version/s: 0.13.0
> Use ProcessorId instead of Zk node Id in JobModel generation
> -
[
https://issues.apache.org/jira/browse/SAMZA-1209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1209:
--
Fix Version/s: 0.13.0
> Improve error handling in LocalStoreMonitor
> -
[
https://issues.apache.org/jira/browse/SAMZA-1202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1202:
--
Fix Version/s: 0.13.0
> Multiple calls to `graph.getInputStream()` with the same streamI
[
https://issues.apache.org/jira/browse/SAMZA-1212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1212:
--
Fix Version/s: 0.13.0
> Refactor interaction between StreamProcessor, JobCoordinator and
[
https://issues.apache.org/jira/browse/SAMZA-1204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1204:
--
Fix Version/s: 0.13.0
> Visualize StreamGraph and ExecutionPlan
> --
[
https://issues.apache.org/jira/browse/SAMZA-1205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1205:
--
Fix Version/s: 0.13.0
> Disable Flaky test : TestJmxServer#serverStartsUp
>
[
https://issues.apache.org/jira/browse/SAMZA-1207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1207:
--
Fix Version/s: 0.13.0
> Samza should publish test utilities in a test artifact
> ---
[
https://issues.apache.org/jira/browse/SAMZA-1201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1201:
--
Fix Version/s: 0.13.0
> Zk path setup for leader elector and barrier should be separated
[
https://issues.apache.org/jira/browse/SAMZA-1183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1183:
--
Fix Version/s: 0.13.0
> Fix TestAsyncRunLoop flaky tests
> -
[
https://issues.apache.org/jira/browse/SAMZA-1188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1188:
--
Fix Version/s: 0.13.0
> Document local store monitor support in configuration table unde
[
https://issues.apache.org/jira/browse/SAMZA-1183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari resolved SAMZA-1183.
---
Resolution: Fixed
> Fix TestAsyncRunLoop flaky tests
> ---
[
https://issues.apache.org/jira/browse/SAMZA-1184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1184:
--
Fix Version/s: 0.13.0
> Improvements to Merge Script
>
>
>
[
https://issues.apache.org/jira/browse/SAMZA-1193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1193:
--
Fix Version/s: 0.13.0
> Fix the flaky test
> TestZkBarrierForVersionUpgrade.testZkBarri
[
https://issues.apache.org/jira/browse/SAMZA-1177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1177:
--
Fix Version/s: 0.13.0
> Improve upgrade documentation for open source releases
> ---
[
https://issues.apache.org/jira/browse/SAMZA-1170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1170:
--
Fix Version/s: 0.13.0
> Integration testing harness for StreamApplications
> ---
[
https://issues.apache.org/jira/browse/SAMZA-1174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1174:
--
Fix Version/s: 0.13.0
> Profiling State Perfromance
> ---
>
>
[
https://issues.apache.org/jira/browse/SAMZA-1170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari resolved SAMZA-1170.
---
Resolution: Fixed
> Integration testing harness for StreamApplications
> -
[
https://issues.apache.org/jira/browse/SAMZA-1179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1179:
--
Fix Version/s: 0.13.0
> Documentation of ApplicationRunner
> ---
[
https://issues.apache.org/jira/browse/SAMZA-1164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1164:
--
Fix Version/s: 0.13.0
> Add capability to cancel in LeaderElection
> ---
[
https://issues.apache.org/jira/browse/SAMZA-1166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1166:
--
Fix Version/s: 0.13.0
> Leader should hold a lock to avoid failures on long GC pause/tim
[
https://issues.apache.org/jira/browse/SAMZA-1168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1168:
--
Fix Version/s: 0.13.0
> Migrate yarn local runner to use StreamProcessor
> -
[
https://issues.apache.org/jira/browse/SAMZA-1163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1163:
--
Fix Version/s: 0.13.0
> Samza 0.12 build with scala 2.10
> -
[
https://issues.apache.org/jira/browse/SAMZA-1157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1157:
--
Fix Version/s: 0.13.0
> When throwable is caught in serialization/deserialzation, Samza
[
https://issues.apache.org/jira/browse/SAMZA-1160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1160:
--
Fix Version/s: 0.13.0
> Migrate MapConfig inherited Java classes to use composition over
[
https://issues.apache.org/jira/browse/SAMZA-1149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1149:
--
Fix Version/s: 0.13.0
> upgrade mockito from 1.8.4 to 1.10.19
>
[
https://issues.apache.org/jira/browse/SAMZA-1143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1143:
--
Fix Version/s: 0.13.0
> Universal config support for localized resource
> --
[
https://issues.apache.org/jira/browse/SAMZA-1149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari resolved SAMZA-1149.
---
Resolution: Fixed
Assignee: Fred Ji
> upgrade mockito from 1.8.4 to 1.10.19
> --
[
https://issues.apache.org/jira/browse/SAMZA-1142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1142:
--
Fix Version/s: 0.13.0
> Create documentation for non blocking commit in AsyncRunLoop.
>
[
https://issues.apache.org/jira/browse/SAMZA-1143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari resolved SAMZA-1143.
---
Resolution: Fixed
Assignee: Fred Ji
> Universal config support for localized res
[
https://issues.apache.org/jira/browse/SAMZA-1144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1144:
--
Fix Version/s: 0.13.0
> Deprecate yarn.package.path and change package localizer to use
[
https://issues.apache.org/jira/browse/SAMZA-1130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1130:
--
Fix Version/s: 0.13.0
> ApplicationRunner for running StreamApplication
> --
[
https://issues.apache.org/jira/browse/SAMZA-984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-984:
-
Fix Version/s: 0.13.0
> Upgrade to RocksDB to 4.8.0
> ---
>
>
[
https://issues.apache.org/jira/browse/SAMZA-860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari reassigned SAMZA-860:
Assignee: Prateek Maheshwari
> Expose RocksDB log options via Samza configuration
>
[
https://issues.apache.org/jira/browse/SAMZA-860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari resolved SAMZA-860.
--
Resolution: Fixed
Fix Version/s: 0.13.0
> Expose RocksDB log options via Samza con
[
https://issues.apache.org/jira/browse/SAMZA-984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari resolved SAMZA-984.
--
Resolution: Fixed
> Upgrade to RocksDB to 4.8.0
> ---
>
>
[
https://issues.apache.org/jira/browse/SAMZA-955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari reassigned SAMZA-955:
Assignee: Prateek Maheshwari
> Upgrade RocksDB JNI to 4.5.1
> --
[
https://issues.apache.org/jira/browse/SAMZA-955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari resolved SAMZA-955.
--
Resolution: Fixed
> Upgrade RocksDB JNI to 4.5.1
>
>
>
[
https://issues.apache.org/jira/browse/SAMZA-1074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari resolved SAMZA-1074.
---
Resolution: Fixed
> Cannot build hello-samza on various CDH version
>
[
https://issues.apache.org/jira/browse/SAMZA-1076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari resolved SAMZA-1076.
---
Resolution: Fixed
> getKafkaChangelogEnabledStores() should use StorageConfig.getChang
[
https://issues.apache.org/jira/browse/SAMZA-1076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1076:
--
Fix Version/s: 0.13.0
> getKafkaChangelogEnabledStores() should use StorageConfig.getCha
[
https://issues.apache.org/jira/browse/SAMZA-1074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1074:
--
Fix Version/s: 0.13.0
> Cannot build hello-samza on various CDH version
> --
[
https://issues.apache.org/jira/browse/SAMZA-1132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1132:
--
Fix Version/s: 0.13.0
> LocalApplicationRunner for local exeuction of Samza StreamApplic
[
https://issues.apache.org/jira/browse/SAMZA-1155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1155:
--
Fix Version/s: 0.13.0
> Allow configuring window.ms to specify trigger duration
> --
[
https://issues.apache.org/jira/browse/SAMZA-1133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1133:
--
Fix Version/s: 0.13.0
> TestApplicationRunner for executing Samza StreamApplication in t
[
https://issues.apache.org/jira/browse/SAMZA-1132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari resolved SAMZA-1132.
---
Resolution: Fixed
> LocalApplicationRunner for local exeuction of Samza StreamApplicat
[
https://issues.apache.org/jira/browse/SAMZA-1120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1120:
--
Fix Version/s: 0.13.0
> Config scope changes for multi-stage
> -
[
https://issues.apache.org/jira/browse/SAMZA-1117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari resolved SAMZA-1117.
---
Resolution: Fixed
> set up certificate signing request in the context for resource loc
[
https://issues.apache.org/jira/browse/SAMZA-1117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1117:
--
Fix Version/s: 0.13.0
> set up certificate signing request in the context for resource l
[
https://issues.apache.org/jira/browse/SAMZA-1118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1118:
--
Fix Version/s: 0.13.0
> Deprecate the SystemStream configurations in favor of StreamId
>
[
https://issues.apache.org/jira/browse/SAMZA-1119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prateek Maheshwari updated SAMZA-1119:
--
Fix Version/s: 0.13.0
> Introduce a common job.metadata.system config to specify the sys
1 - 100 of 564 matches
Mail list logo