Ananth created APEXCORE-472:
---
Summary: Enhance Kafka 0.9 input operator to support starting from
custom offsets in multiple partitions
Key: APEXCORE-472
URL: https://issues.apache.org/jira/browse/APEXCORE-472
Ananth created APEXMALHAR-2181:
--
Summary: Non-Transactional Prepared Statement Based Cassandra
Output Operator
Key: APEXMALHAR-2181
URL: https://issues.apache.org/jira/browse/APEXMALHAR-2181
Project:
[
https://issues.apache.org/jira/browse/APEXMALHAR-2278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth updated APEXMALHAR-2278:
---
Summary: Implement Kudu Operator for non-transactional streams (was:
Implement Kudud Operator
[
https://issues.apache.org/jira/browse/APEXMALHAR-2278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth updated APEXMALHAR-2278:
---
Summary: Implement Kudu Output Operator for non-transactional streams
(was: Implement Kudu
[
https://issues.apache.org/jira/browse/APEXMALHAR-2181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth updated APEXMALHAR-2181:
---
Summary: Non-Transactional Prepared Statement Based Cassandra Upsert
(Update + Insert ) output
[
https://issues.apache.org/jira/browse/APEXMALHAR-2181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15599194#comment-15599194
]
Ananth commented on APEXMALHAR-2181:
Functionality ready for review at
[
https://issues.apache.org/jira/browse/APEXMALHAR-2181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth updated APEXMALHAR-2181:
---
Description:
An abstract operator that is used to mutate cassandra rows using
[
https://issues.apache.org/jira/browse/APEXMALHAR-2181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth reassigned APEXMALHAR-2181:
--
Assignee: Ananth
> Non-Transactional Prepared Statement Based Cassandra Output Operator
>
[
https://issues.apache.org/jira/browse/APEXCORE-576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15703364#comment-15703364
]
Ananth commented on APEXCORE-576:
-
If we were to model something along the lines of "Spark packages", I
[
https://issues.apache.org/jira/browse/APEXMALHAR-2278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth updated APEXMALHAR-2278:
---
Description:
Here are some benefits of integrating Kudu and Apex:
Kudu is just declared 1.0
[
https://issues.apache.org/jira/browse/APEXMALHAR-2278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth updated APEXMALHAR-2278:
---
Description:
Here are some benefits of integrating Kudu and Apex:
Kudu is just declared 1.0
[
https://issues.apache.org/jira/browse/APEXMALHAR-2278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth updated APEXMALHAR-2278:
---
Description:
Here are some benefits of integrating Kudu and Apex:
Kudu is just declared 1.0
Ananth created APEXMALHAR-2472:
--
Summary: Implement Kudu Input Operator
Key: APEXMALHAR-2472
URL: https://issues.apache.org/jira/browse/APEXMALHAR-2472
Project: Apache Apex Malhar
Issue Type:
[
https://issues.apache.org/jira/browse/APEXMALHAR-2472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth updated APEXMALHAR-2472:
---
Issue Type: New Feature (was: Bug)
> Implement Kudu Input Operator
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth updated APEXMALHAR-2278:
---
Fix Version/s: 3.8.0
> Implement Kudu Output Operator for non-transactional streams
>
Ananth created APEXMALHAR-2432:
--
Summary: javadoc for cassandra operator is improperly formatted
Key: APEXMALHAR-2432
URL: https://issues.apache.org/jira/browse/APEXMALHAR-2432
Project: Apache Apex
[
https://issues.apache.org/jira/browse/APEXMALHAR-2472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16128171#comment-16128171
]
Ananth commented on APEXMALHAR-2472:
The following are the main features that would be supported
[
https://issues.apache.org/jira/browse/APEXMALHAR-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16129795#comment-16129795
]
Ananth commented on APEXMALHAR-2260:
Hello [~thomasWeise] - Can I work on this if no one else is
[
https://issues.apache.org/jira/browse/APEXMALHAR-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16129959#comment-16129959
]
Ananth commented on APEXMALHAR-2260:
Thanks for the comment [~vikram] . My understanding of the
Ananth created APEXMALHAR-2502:
--
Summary: Fix KuduOutput operator for extensibility
Key: APEXMALHAR-2502
URL: https://issues.apache.org/jira/browse/APEXMALHAR-2502
Project: Apache Apex Malhar
[
https://issues.apache.org/jira/browse/APEXMALHAR-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204841#comment-16204841
]
Ananth commented on APEXMALHAR-2260:
*Tensorflow integration with Keras* as the wrapper gave the
[
https://issues.apache.org/jira/browse/APEXMALHAR-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204841#comment-16204841
]
Ananth edited comment on APEXMALHAR-2260 at 10/14/17 10:29 PM:
---
[
https://issues.apache.org/jira/browse/APEXMALHAR-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204841#comment-16204841
]
Ananth edited comment on APEXMALHAR-2260 at 10/14/17 10:28 PM:
---
[
https://issues.apache.org/jira/browse/APEXMALHAR-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204844#comment-16204844
]
Ananth commented on APEXMALHAR-2260:
Integration with xgboost python package gives the following
[
https://issues.apache.org/jira/browse/APEXMALHAR-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204629#comment-16204629
]
Ananth edited comment on APEXMALHAR-2260 at 10/14/17 10:23 PM:
---
Scoring
[
https://issues.apache.org/jira/browse/APEXMALHAR-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204629#comment-16204629
]
Ananth edited comment on APEXMALHAR-2260 at 10/14/17 10:24 PM:
---
Scoring
[
https://issues.apache.org/jira/browse/APEXMALHAR-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204629#comment-16204629
]
Ananth edited comment on APEXMALHAR-2260 at 10/14/17 10:24 PM:
---
Scoring
[
https://issues.apache.org/jira/browse/APEXMALHAR-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204841#comment-16204841
]
Ananth edited comment on APEXMALHAR-2260 at 10/14/17 10:30 PM:
---
[
https://issues.apache.org/jira/browse/APEXMALHAR-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204608#comment-16204608
]
Ananth edited comment on APEXMALHAR-2260 at 10/14/17 12:39 PM:
---
There
[
https://issues.apache.org/jira/browse/APEXMALHAR-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204629#comment-16204629
]
Ananth commented on APEXMALHAR-2260:
Scoring a scikit learn SVM model on a 2012 macbook pro gave
[
https://issues.apache.org/jira/browse/APEXMALHAR-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204608#comment-16204608
]
Ananth edited comment on APEXMALHAR-2260 at 10/14/17 1:36 PM:
--
A design
[
https://issues.apache.org/jira/browse/APEXMALHAR-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204608#comment-16204608
]
Ananth commented on APEXMALHAR-2260:
There is a design discussion thread that will follow in the
[
https://issues.apache.org/jira/browse/APEXMALHAR-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16204608#comment-16204608
]
Ananth edited comment on APEXMALHAR-2260 at 10/14/17 12:40 PM:
---
There
[
https://issues.apache.org/jira/browse/APEXMALHAR-2545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth updated APEXMALHAR-2545:
---
Summary: Implement few improvements in the Kudu Implementation (was:
Implement a few
Ananth created APEXMALHAR-2546:
--
Summary: Mocking dependencies should ideally be in the maven
parent instead of individual modules
Key: APEXMALHAR-2546
URL: https://issues.apache.org/jira/browse/APEXMALHAR-2546
Ananth created APEXMALHAR-2545:
--
Summary: Implement a few improvements in the Kudu Implementation
Key: APEXMALHAR-2545
URL: https://issues.apache.org/jira/browse/APEXMALHAR-2545
Project: Apache Apex
[
https://issues.apache.org/jira/browse/APEXMALHAR-2542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181473#comment-16181473
]
Ananth commented on APEXMALHAR-2542:
The root cause is that the application is expecting a file
[
https://issues.apache.org/jira/browse/APEXMALHAR-2544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth reassigned APEXMALHAR-2544:
--
Assignee: Ananth
> Flume test leads to Travis timeout
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth reassigned APEXMALHAR-2544:
--
Assignee: (was: Ananth)
> Flume test leads to Travis timeout
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth reassigned APEXMALHAR-2542:
--
Assignee: Ananth
> enricher.ApplicationTest access to hard coded /tmp location
>
Ananth created APEXMALHAR-2538:
--
Summary: Enhance Apex Kudu Support for Streaming SQL API
Key: APEXMALHAR-2538
URL: https://issues.apache.org/jira/browse/APEXMALHAR-2538
Project: Apache Apex Malhar
[
https://issues.apache.org/jira/browse/APEXMALHAR-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth reassigned APEXMALHAR-2260:
--
Assignee: Ananth
> Python execution for operator logic
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16182329#comment-16182329
]
Ananth commented on APEXMALHAR-2542:
The out location was also fixed as part of the fix by using
Ananth created APEXCORE-799:
---
Summary: Fix documentation for release process instructions
Key: APEXCORE-799
URL: https://issues.apache.org/jira/browse/APEXCORE-799
Project: Apache Apex Core
Issue
[
https://issues.apache.org/jira/browse/APEXMALHAR-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth updated APEXMALHAR-2260:
---
Summary: Operator that can execute python code (was: Python execution for
operator logic )
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2397.
--
> Malhar demo application PiDemoAppData fails apex get-app-package-info command
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2516.
--
> Fix few dependency issues in malhar-contrib
> ---
>
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2471.
--
> Upgrade apex-core dependency to 3.6.0
> -
>
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2487.
--
> Malhar should support outputting data in Snappy compression
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2366.
--
> Apply BloomFilter to Bucket
> ---
>
> Key: APEXMALHAR-2366
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2474.
--
> FSLoader only returns value at the beginning
>
>
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2426.
--
> Add user document for RegexParser operator
> --
>
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2447.
--
> No indication from AbstractFileInputOperator when directory is empty
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2540.
--
> Serialization exception with throttle example
> -
>
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2492.
--
> Correct usage of empty Slice in Malhar Library
> --
>
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2481.
--
> High Level Stream API does not support lambda expressions
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2513.
--
> JDBCPollInputOperator issues
>
>
> Key: APEXMALHAR-2513
[
https://issues.apache.org/jira/browse/APEXMALHAR-2479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2479.
--
> Create example for RegexParser operator
> ---
>
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2465.
--
> Travis build is failing because of excessive logging
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2459.
--
> KafkaInputoperator using 0.10.* Kafka consumer API
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2384.
--
> Add documentation for FixedWIdthParser
> --
>
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2519.
--
> Performance Benchmark containers stop repeatedly as they exceed physical
> memory allocated
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2475.
--
> CacheStore needn't expire data if it read-only data
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2493.
--
> KafkaSinglePortExactlyOnceOutputOperator going to the blocked state during
> recovery
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2500.
--
> Code comment for FSInputModule mentions "...is abstract class..." but the
> class is not abstract
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2535.
--
> Timeouts in AbstractEnricher specified as int which limits duration of time
> which could be
[
https://issues.apache.org/jira/browse/APEXMALHAR-2453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2453.
--
> Add sort Accumulation for Windowed operator
> ---
>
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2541.
--
> Fix travis-ci build
> ---
>
> Key: APEXMALHAR-2541
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2525.
--
> YahooFinance example crashes with java.lang.NumberFormatException because
> YHOO doesn't exist
[
https://issues.apache.org/jira/browse/APEXMALHAR-2472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2472.
--
> Implement Kudu Input Operator
> --
>
> Key:
[
https://issues.apache.org/jira/browse/APEXMALHAR-2542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2542.
--
> enricher.ApplicationTest access to hard coded /tmp location
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2532.
--
> Transform Application Test flooding CI logs
> ---
>
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2505.
--
> SnapshotSchema should retain original field order
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2530.
--
> Refactor AbstractAppDataSnapshotServer so that subclasses don't need schemas
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2460.
--
> Redshift output module tuples unable to emit tuples
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2546.
--
> Mocking dependencies should ideally be in the maven parent instead of
> individual modules
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2278.
--
> Implement Kudu Output Operator for non-transactional streams
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2506.
--
> Kafka Input operator - needs better handling of failure of Kafka reader thread
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2504.
--
> Allow for customization of TwitterSampleInput ConfigurationBuilder
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2494.
--
> Update demo apps with description
> -
>
> Key:
[
https://issues.apache.org/jira/browse/APEXMALHAR-2502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2502.
--
> Fix KuduOutput operator for extensibility
> -
>
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2544.
--
> Flume test leads to Travis timeout
> --
>
> Key:
[
https://issues.apache.org/jira/browse/APEXMALHAR-2463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2463.
--
> FTP Input Operator Example app and documentation
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2514.
--
> JDBCPollInputOperator support for offset rebase
> ---
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2434.
--
> JMSTransactionableStore uses Session.createQueue() which fails
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2508.
--
> CacheManager throws exception when the operator receives a shutdown request
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2491.
--
> GenericFileOutputOperatorTest : runTestApplication() does not call shutdown()
> and can continue to
[
https://issues.apache.org/jira/browse/APEXMALHAR-2324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2324.
--
> Add support for flume
> -
>
> Key: APEXMALHAR-2324
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2526.
--
> FunctionOperator deserialization failure in CLI
> ---
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2435.
--
> specify KeyedWindowedOperatorBenchmarkApp application name
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2476.
--
> Unable to override tupleSeparator property of GenericFileOutputOperator using
> configurations
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2457.
--
> Duplicate entries in navigation panel
> -
>
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2518.
--
> Kafka input operator stops reading tuples when there is a UNKNOWN_MEMBER_ID
> error during
[
https://issues.apache.org/jira/browse/APEXMALHAR-2484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2484.
--
> BlockWriter for writing the part files into the specified directory
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2547.
--
> Add ride data processing example to Apex Library
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2489.
--
> Change algorithm for average calculation in RunningAverage
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2455.
--
> Create example for Kafka 0.9 API exactly-once output operator
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2404.
--
> Avro file input operator should call beginWindow of AbstractFileInputOperator
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2480.
--
> Move Amazon S3 related examples from datatorrent examples to apex-malhar
> examples
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ananth closed APEXMALHAR-2529.
--
> Allow subclass of AbstractFileInputOperator to control when to advance
> streaming window
>
1 - 100 of 110 matches
Mail list logo
