Issues
Enhancing existing JSON Parser | Unassigned | Shubham Pathak | Unresolved | Dec 30, 2015 | Dec 30, 2015 | ||||||
Enhancing existing CSV Parser | Unassigned | Shubham Pathak | Unresolved | Dec 30, 2015 | Dec 30, 2015 | ||||||
Test failure KafkaInputOperatorTest.testRecoveryAndIdempotency | Unassigned | Siyuan Hua | Unresolved | Dec 30, 2015 | Dec 30, 2015 | ||||||
Kafka offset manager properties cannot be set from property files | Unassigned | Pramod Immaneni | Unresolved | Dec 29, 2015 | Dec 29, 2015 | ||||||
Provide access to doneTuple field in AbstractReconciler for derived classes | Unassigned | YogiD | Unresolved | Dec 29, 2015 | Dec 29, 2015 | ||||||
Improve HBasePOJOInputOperator with support for threaded read | Unassigned | Bhupesh Chawda | Unresolved | Dec 29, 2015 | Dec 31, 2015 | ||||||
Concrete generic Implementation of Kafka Output Operator with auto metrics and batch processing | Unassigned | Chaitanya Chebolu | Unresolved | Dec 28, 2015 | Dec 28, 2015 | ||||||
Batch size should be configurable for AbstractBatchTransactionableStoreOutputOperator | Unassigned | PriyankaG | Unresolved | Dec 27, 2015 | Dec 27, 2015 | ||||||
Add Spooled data structures | Unassigned | Chandni Singh | Unresolved | Dec 24, 2015 | Dec 24, 2015 | ||||||
Add generic (insert, update, delete) support to JDBC Output Operator | Unassigned | Bhupesh Chawda | Unresolved | Dec 21, 2015 | Dec 31, 2015 | ||||||
Bring back the Apache Solr unit test cases | Unassigned | Sandesh Hegde | Unresolved | Dec 18, 2015 | Dec 20, 2015 | ||||||
Gracefully Handle Cassandra Down Time In Cassandra Output Operator | Unassigned | Timothy Farkas | Unresolved | Dec 17, 2015 | Dec 17, 2015 | ||||||
Identify and mark Operators and Components as @Stable | Unassigned | Chandni Singh | Unresolved | Dec 16, 2015 | Dec 16, 2015 | ||||||
JDBC Input Operator unnecessarily waits two times when the result is empty | Unassigned | Chandni Singh | Fixed | Dec 16, 2015 | Dec 16, 2015 | ||||||
CassandraStore Should Allow You To Specify Protocol Version. | Unassigned | Timothy Farkas | Unresolved | Dec 15, 2015 | Dec 15, 2015 | ||||||
Ability to restrict number of messages per window by size for kafka input operator | Unassigned | Pramod Immaneni | Unresolved | Dec 15, 2015 | Dec 26, 2015 | ||||||
Mark WindowUtils as Unstable | Unassigned | Timothy Farkas | Won't Fix | Dec 14, 2015 | Dec 19, 2015 | ||||||
Upgrade the version of japicmp to 0.7.0 | Unassigned | Chandni Singh | Unresolved | Dec 14, 2015 | Dec 16, 2015 | ||||||
Add DimensionsConversionContext to Malhar and make it top class | Unassigned | Bright Chen | Fixed | Dec 14, 2015 | Dec 18, 2015 | ||||||
Add Aggregator to Malhar and make it top interface | Unassigned | Bright Chen | Fixed | Dec 14, 2015 | Dec 15, 2015 | ||||||
Apex Operator for Apache Geode. | Unassigned | Prasad Indulkar | Unresolved | Dec 14, 2015 | Dec 29, 2015 | ||||||
Add a default Slice comparator to Malhar/util | Unassigned | Chandni Singh | Fixed | Dec 12, 2015 | Dec 13, 2015 | ||||||
Create Operator Utility Class Which Converts Time To Windows | Unassigned | Timothy Farkas | Fixed | Dec 12, 2015 | Dec 13, 2015 | ||||||
Stream API | Unassigned | Siyuan Hua | Unresolved | Dec 11, 2015 | Dec 29, 2015 | ||||||
Operator checkpointing in distributed in-memory store | Unassigned | Ashish Tadose | Unresolved | Dec 11, 2015 | Dec 29, 2015 | ||||||
Create an implementation of MinHash | Unassigned | Chandni Singh | Unresolved | Dec 10, 2015 | Dec 10, 2015 | ||||||
Apache Nifi Connector | Unassigned | Chandni Singh | Unresolved | Dec 10, 2015 | Dec 15, 2015 | ||||||
Fixes to Cassandra Input/Output Operator | Unassigned | Chandni Singh | Unresolved | Dec 10, 2015 | Dec 10, 2015 | ||||||
When offset is unavailable kafka operator stops reading data | Unassigned | Pramod Immaneni | Fixed | Dec 8, 2015 | Dec 10, 2015 | ||||||
Test please ignore | Unassigned | David Yan | Unresolved | Dec 4, 2015 | Dec 4, 2015 | ||||||
Create a new WindowBoundedService which will execute once every N windows. | Unassigned | Timothy Farkas | Unresolved | Dec 4, 2015 | Dec 21, 2015 | ||||||
Augment FileAccess API | Unassigned | Chandni Singh | Fixed | Dec 4, 2015 | Dec 16, 2015 | ||||||
Create Twilio Output Operator | Unassigned | Timothy Farkas | Unresolved | Dec 2, 2015 | Dec 2, 2015 | ||||||
japicmp plugin fails for malhar samples | Unassigned | Chandni Singh | Fixed | Dec 2, 2015 | Dec 2, 2015 | ||||||
Update checkpointed offsettrack in operator thread instead of consumer thread | Unassigned | Siyuan Hua | Unresolved | Dec 2, 2015 | Dec 8, 2015 | ||||||
Create Rules Operator | Unassigned | Timothy Farkas | Unresolved | Dec 1, 2015 | Dec 3, 2015 | ||||||
Dynamic partitioning of Kafka Input Operator is not working. | Unassigned | Chaitanya Chebolu | Unresolved | Dec 1, 2015 | Dec 1, 2015 | ||||||
The kafka offset manager may not store the offset of processed data in all scenarios | Unassigned | Pramod Immaneni | Unresolved | Nov 30, 2015 | Dec 8, 2015 | ||||||
Incorporate JavaFlow With Malhar | Unassigned | Timothy Farkas | Unresolved | Nov 28, 2015 | Nov 28, 2015 | ||||||
Create HDFS Operator Discovery | Unassigned | Timothy Farkas | Unresolved | Nov 28, 2015 | Dec 13, 2015 | ||||||
[FileStreamContext] Set filterStream variable to transient | Unassigned | PriyankaG | Fixed | Nov 25, 2015 | Dec 28, 2015 | ||||||
Add dimensional HBase Output Operator | Unassigned | Timothy Farkas | Unresolved | Nov 25, 2015 | Nov 25, 2015 | ||||||
Add dimensional JDBC Output Operator | Unassigned | Timothy Farkas | Unresolved | Nov 25, 2015 | Dec 18, 2015 | ||||||
Move Dimensional Schema To Malhar | Unassigned | Timothy Farkas | Unresolved | Nov 25, 2015 | Dec 18, 2015 | ||||||
[FileSplitter] Need stopScanning method in Scanner | Unassigned | PriyankaG | Fixed | Nov 25, 2015 | Dec 8, 2015 | ||||||
Consolidate join operators to one package | Unassigned | Dongming Liang | Unresolved | Nov 24, 2015 | Nov 24, 2015 | ||||||
Add FileAccess API and its DTFileImplementation | Unassigned | Chandni Singh | Fixed | Nov 23, 2015 | Dec 1, 2015 | ||||||
Create functional operators | Unassigned | Brennon York | Unresolved | Nov 20, 2015 | Nov 20, 2015 | ||||||
Add base operators to ease operator API | Unassigned | Brennon York | Unresolved | Nov 20, 2015 | Dec 7, 2015 | ||||||
[FileSplitter] Need access to modifiedTime of ScannedFileInfo class | Unassigned | PriyankaG | Fixed | Nov 19, 2015 | Nov 22, 2015 |
1-50 of 1000+