[jira] [Closed] (APEXMALHAR-2397) Malhar demo application PiDemoAppData fails apex get-app-package-info command

[ 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 >

[jira] [Closed] (APEXMALHAR-2516) Fix few dependency issues in malhar-contrib

[ 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 > --- > >

[jira] [Closed] (APEXMALHAR-2471) Upgrade apex-core dependency to 3.6.0

[ 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 > - > >

[jira] [Closed] (APEXMALHAR-2487) Malhar should support outputting data in Snappy compression

[ 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 >

[jira] [Closed] (APEXMALHAR-2366) Apply BloomFilter to Bucket

[ 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 >

[jira] [Closed] (APEXMALHAR-2474) FSLoader only returns value at the beginning

[ 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 > > >

[jira] [Closed] (APEXMALHAR-2426) Add user document for RegexParser operator

[ 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 > -- > >

[jira] [Closed] (APEXMALHAR-2447) No indication from AbstractFileInputOperator when directory is empty

[ 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 >

[jira] [Closed] (APEXMALHAR-2540) Serialization exception with throttle example

[ 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 > - > >

[jira] [Closed] (APEXMALHAR-2492) Correct usage of empty Slice in Malhar Library

[ 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 > -- > >

[jira] [Closed] (APEXMALHAR-2481) High Level Stream API does not support lambda expressions

[ 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 >

[jira] [Closed] (APEXMALHAR-2513) JDBCPollInputOperator issues

[ 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

[jira] [Closed] (APEXMALHAR-2479) Create example for RegexParser operator

[ 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 > --- > >

[jira] [Closed] (APEXMALHAR-2465) Travis build is failing because of excessive logging

[ 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 >

[jira] [Closed] (APEXMALHAR-2459) KafkaInputoperator using 0.10.* Kafka consumer API

[ 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 >

[jira] [Closed] (APEXMALHAR-2384) Add documentation for FixedWIdthParser

[ 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 > -- > >

[jira] [Closed] (APEXMALHAR-2519) Performance Benchmark containers stop repeatedly as they exceed physical memory allocated

[ 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 >

[jira] [Closed] (APEXMALHAR-2475) CacheStore needn't expire data if it read-only data

[ 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 >

[jira] [Closed] (APEXMALHAR-2493) KafkaSinglePortExactlyOnceOutputOperator going to the blocked state during recovery

[ 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 >

[jira] [Closed] (APEXMALHAR-2500) Code comment for FSInputModule mentions "...is abstract class..." but the class is not abstract

[ 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 >

[jira] [Closed] (APEXMALHAR-2535) Timeouts in AbstractEnricher specified as int which limits duration of time which could be specified.

[ 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

[jira] [Closed] (APEXMALHAR-2453) Add sort Accumulation for Windowed operator

[ 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 > --- > >

[jira] [Closed] (APEXMALHAR-2541) Fix travis-ci build

[ 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 >

[jira] [Closed] (APEXMALHAR-2525) YahooFinance example crashes with java.lang.NumberFormatException because YHOO doesn't exist anymore

[ 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

[jira] [Closed] (APEXMALHAR-2472) Implement Kudu Input Operator

[ 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:

[jira] [Closed] (APEXMALHAR-2542) enricher.ApplicationTest access to hard coded /tmp location

[ 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 >

[jira] [Closed] (APEXMALHAR-2532) Transform Application Test flooding CI logs

[ 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 > --- > >

[jira] [Closed] (APEXMALHAR-2505) SnapshotSchema should retain original field order

[ 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 >

[jira] [Closed] (APEXMALHAR-2530) Refactor AbstractAppDataSnapshotServer so that subclasses don't need schemas

[ 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 >

[jira] [Closed] (APEXMALHAR-2460) Redshift output module tuples unable to emit tuples

[ 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 >

[jira] [Closed] (APEXMALHAR-2546) Mocking dependencies should ideally be in the maven parent instead of individual modules

[ 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 >

[jira] [Closed] (APEXMALHAR-2278) Implement Kudu Output Operator for non-transactional streams

[ 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 >

[jira] [Closed] (APEXMALHAR-2506) Kafka Input operator - needs better handling of failure of Kafka reader thread

[ 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 >

[jira] [Closed] (APEXMALHAR-2504) Allow for customization of TwitterSampleInput ConfigurationBuilder

[ 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 >

[jira] [Closed] (APEXMALHAR-2494) Update demo apps with description

[ 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:

[jira] [Closed] (APEXMALHAR-2502) Fix KuduOutput operator for extensibility

[ 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 > - > >

[jira] [Closed] (APEXMALHAR-2544) Flume test leads to Travis timeout

[ 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:

[jira] [Closed] (APEXMALHAR-2463) FTP Input Operator Example app and documentation

[ 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 >

[jira] [Closed] (APEXMALHAR-2514) JDBCPollInputOperator support for offset rebase

[ 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 > --- >

[jira] [Closed] (APEXMALHAR-2434) JMSTransactionableStore uses Session.createQueue() which fails

[ 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 >

[jira] [Closed] (APEXMALHAR-2508) CacheManager throws exception when the operator receives a shutdown request

[ 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 >

[jira] [Closed] (APEXMALHAR-2491) GenericFileOutputOperatorTest : runTestApplication() does not call shutdown() and can continue to run.

[ 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

[jira] [Closed] (APEXMALHAR-2324) Add support for flume

[ 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 >

[jira] [Closed] (APEXMALHAR-2526) FunctionOperator deserialization failure in CLI

[ 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 > --- >

[jira] [Closed] (APEXMALHAR-2435) specify KeyedWindowedOperatorBenchmarkApp application name

[ 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 >

[jira] [Closed] (APEXMALHAR-2476) Unable to override tupleSeparator property of GenericFileOutputOperator using configurations

[ 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 >

[jira] [Closed] (APEXMALHAR-2457) Duplicate entries in navigation panel

[ 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 > - > >

[jira] [Closed] (APEXMALHAR-2518) Kafka input operator stops reading tuples when there is a UNKNOWN_MEMBER_ID error during committed offset processing

[ 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

[jira] [Closed] (APEXMALHAR-2484) BlockWriter for writing the part files into the specified directory

[ 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 >

[jira] [Closed] (APEXMALHAR-2547) Add ride data processing example to Apex Library

[ 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 >

[jira] [Closed] (APEXMALHAR-2489) Change algorithm for average calculation in RunningAverage

[ 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 >

[jira] [Closed] (APEXMALHAR-2455) Create example for Kafka 0.9 API exactly-once output operator

[ 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 >

[jira] [Closed] (APEXMALHAR-2404) Avro file input operator should call beginWindow of AbstractFileInputOperator

[ 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 >

[jira] [Closed] (APEXMALHAR-2480) Move Amazon S3 related examples from datatorrent examples to apex-malhar examples

[ 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 >

[jira] [Closed] (APEXMALHAR-2529) Allow subclass of AbstractFileInputOperator to control when to advance streaming window

[ 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 >

[jira] [Closed] (APEXMALHAR-2515) HBase output operator Multi Table feature.

[ https://issues.apache.org/jira/browse/APEXMALHAR-2515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ananth closed APEXMALHAR-2515. -- > HBase output operator Multi Table feature. > -- > >

[jira] [Closed] (APEXMALHAR-2473) Support for global cache meta information in db CacheManager

[ https://issues.apache.org/jira/browse/APEXMALHAR-2473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ananth closed APEXMALHAR-2473. -- > Support for global cache meta information in db CacheManager >

[jira] [Closed] (APEXMALHAR-2462) Move JDBC related examples from datatorrent examples to apex-malhar examples

[ https://issues.apache.org/jira/browse/APEXMALHAR-2462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ananth closed APEXMALHAR-2462. -- > Move JDBC related examples from datatorrent examples to apex-malhar examples >

[jira] [Closed] (APEXMALHAR-2431) Create Kinesis Input operator which emits byte array as tuple

[ https://issues.apache.org/jira/browse/APEXMALHAR-2431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ananth closed APEXMALHAR-2431. -- > Create Kinesis Input operator which emits byte array as tuple >