GitHub user chaithu14 opened a pull request:
https://github.com/apache/incubator-apex-malhar/pull/300
APEXMALHAR-2103 Fixed the scanner issue in FileSplitterInput Class
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/chaithu14
GitHub user chaithu14 opened a pull request:
https://github.com/apache/incubator-apex-malhar/pull/299
APEXMALHAR-2103 Fixed the scanner issue in FileSplitterInput Class
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/chaithu14
Github user chaithu14 closed the pull request at:
https://github.com/apache/incubator-apex-malhar/pull/299
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/300#discussion_r65475558
--- Diff:
library/src/main/java/com/datatorrent/lib/io/fs/FileSplitterInput.java ---
@@ -375,11 +375,14 @@ public void run
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/300#discussion_r65303185
--- Diff:
library/src/main/java/com/datatorrent/lib/io/fs/FileSplitterInput.java ---
@@ -375,11 +374,18 @@ public void run
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/300#discussion_r65023539
--- Diff:
library/src/main/java/com/datatorrent/lib/io/fs/FileSplitterInput.java ---
@@ -375,11 +374,11 @@ public void run
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/300#discussion_r65023670
--- Diff:
library/src/main/java/com/datatorrent/lib/io/fs/FileSplitterInput.java ---
@@ -375,11 +374,11 @@ public void run
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/330#discussion_r70789750
--- Diff:
library/src/main/java/com/datatorrent/lib/join/AbstractManagedStateInnerJoinOperator.java
---
@@ -0,0 +1,259 @@
+/**
+ * Licensed
Github user chaithu14 commented on the issue:
https://github.com/apache/apex-core/pull/359
Thanks @vrozov @amberarrow . I will into the JIRA and will update this PR.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well
Github user chaithu14 commented on the issue:
https://github.com/apache/apex-core/pull/359
@vrozov Can the definePartitions() return the current partition ? If yes,
then there might be an issue in redoPartition().
From the above example, for the logical operator C, current
Github user chaithu14 commented on the issue:
https://github.com/apache/apex-core/pull/362
This fix is related to dynamic partitioning and logic related to
re-partitioning is in redoPartitions().
Thanks Thomas, its a good suggestion. I will re-look in to it and will
discuss
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/362#discussion_r72926469
--- Diff:
engine/src/main/java/com/datatorrent/stram/plan/physical/PhysicalPlan.java ---
@@ -962,8 +963,11 @@ private void redoPartitions(PMapping
Github user chaithu14 commented on the issue:
https://github.com/apache/apex-core/pull/362
@vrozov Please review and merge.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
GitHub user chaithu14 opened a pull request:
https://github.com/apache/apex-core/pull/362
APEXCORE-494 Fixed the dynamic partition issue in case of initial partition
size is 1
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/330#discussion_r73141485
--- Diff:
library/src/main/java/com/datatorrent/lib/join/AbstractInnerJoinOperator.java
---
@@ -0,0 +1,331 @@
+/**
+ * Licensed to the Apache
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/330#discussion_r73141506
--- Diff:
library/src/main/java/com/datatorrent/lib/join/AbstractInnerJoinOperator.java
---
@@ -0,0 +1,331 @@
+/**
+ * Licensed to the Apache
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/330#discussion_r73141502
--- Diff:
library/src/main/java/com/datatorrent/lib/join/AbstractInnerJoinOperator.java
---
@@ -0,0 +1,331 @@
+/**
+ * Licensed to the Apache
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/330#discussion_r73141529
--- Diff:
library/src/main/java/com/datatorrent/lib/join/AbstractInnerJoinOperator.java
---
@@ -0,0 +1,331 @@
+/**
+ * Licensed to the Apache
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/330#discussion_r73145124
--- Diff:
library/src/main/java/com/datatorrent/lib/join/AbstractInnerJoinOperator.java
---
@@ -0,0 +1,331 @@
+/**
+ * Licensed to the Apache
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/330#discussion_r73281797
--- Diff:
library/src/main/java/com/datatorrent/lib/join/AbstractManagedStateInnerJoinOperator.java
---
@@ -0,0 +1,265 @@
+/**
+ * Licensed
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/330#discussion_r73281761
--- Diff:
library/src/main/java/com/datatorrent/lib/join/POJOInnerJoinOperator.java ---
@@ -0,0 +1,247 @@
+/**
+ * Licensed to the Apache
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/330#discussion_r73282003
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/state/managed/ManagedTimeStateMultiValue.java
---
@@ -0,0 +1,357
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/330#discussion_r73282037
--- Diff:
library/src/main/java/com/datatorrent/lib/join/POJOInnerJoinOperator.java ---
@@ -0,0 +1,247 @@
+/**
+ * Licensed to the Apache
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/330#discussion_r73289857
--- Diff:
library/src/main/java/com/datatorrent/lib/join/AbstractManagedStateInnerJoinOperator.java
---
@@ -0,0 +1,265 @@
+/**
+ * Licensed
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/330#discussion_r73289845
--- Diff:
library/src/main/java/com/datatorrent/lib/join/AbstractManagedStateInnerJoinOperator.java
---
@@ -0,0 +1,265 @@
+/**
+ * Licensed
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/330#discussion_r73289826
--- Diff:
library/src/main/java/com/datatorrent/lib/join/AbstractInnerJoinOperator.java
---
@@ -0,0 +1,331 @@
+/**
+ * Licensed to the Apache
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/330#discussion_r73289926
--- Diff:
library/src/main/java/com/datatorrent/lib/join/POJOInnerJoinOperator.java ---
@@ -0,0 +1,247 @@
+/**
+ * Licensed to the Apache
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/330#discussion_r73290027
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/state/managed/ManagedTimeStateMultiValue.java
---
@@ -0,0 +1,357
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/330#discussion_r73289947
--- Diff:
library/src/main/java/com/datatorrent/lib/join/POJOInnerJoinOperator.java ---
@@ -0,0 +1,247 @@
+/**
+ * Licensed to the Apache
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/330#discussion_r73289992
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/state/managed/ManagedTimeStateMultiValue.java
---
@@ -0,0 +1,357
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/330#discussion_r73289943
--- Diff:
library/src/main/java/com/datatorrent/lib/join/POJOInnerJoinOperator.java ---
@@ -0,0 +1,247 @@
+/**
+ * Licensed to the Apache
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/330#discussion_r73289869
--- Diff:
library/src/main/java/com/datatorrent/lib/join/ManagedSpillableComplexComponent.java
---
@@ -0,0 +1,122 @@
+/**
+ * Licensed
GitHub user chaithu14 opened a pull request:
https://github.com/apache/apex-malhar/pull/360
APEXMALHAR-2174-S3-ReaderIssue Fixed the S3 reader issue
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/chaithu14/incubator-apex-malhar
GitHub user chaithu14 reopened a pull request:
https://github.com/apache/apex-malhar/pull/330
APEXMALHAR-2100 Implementation of Inner Join operator
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/chaithu14/incubator-apex-malhar
Github user chaithu14 closed the pull request at:
https://github.com/apache/apex-malhar/pull/330
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/359#discussion_r71739128
--- Diff:
engine/src/main/java/com/datatorrent/stram/plan/physical/PhysicalPlan.java ---
@@ -895,8 +895,10 @@ private void redoPartitions(PMapping
GitHub user chaithu14 opened a pull request:
https://github.com/apache/apex-core/pull/359
APEXCORE-494 Fixed the dynamic partition issue in case of initial partition
size is 1
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user chaithu14 opened a pull request:
https://github.com/apache/apex-malhar/pull/346
APEXMALHAR-2158 Fixed the duplication of messages emitted issue when the
Kafka Input operator redeployed
You can merge this pull request into a Git repository by running:
$ git pull
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r68559266
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/state/spillable/SpillableByteMapImpl.java
---
@@ -0,0 +1,191 @@
+package
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r68559252
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/state/spillable/SpillableByteArrayListMultimapImpl.java
---
@@ -0,0 +1,241 @@
+package
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r68559313
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/utils/serde/SliceUtils.java ---
@@ -0,0 +1,52 @@
+package
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r68560022
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/state/spillable/SpillableByteArrayListMultimapImpl.java
---
@@ -0,0 +1,241 @@
+package
GitHub user chaithu14 opened a pull request:
https://github.com/apache/apex-malhar/pull/330
Initial cut of Inner Join operator for REVIEW only
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/chaithu14/incubator-apex-malhar
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/334#discussion_r69947853
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/state/managed/AbstractManagedStateImpl.java
---
@@ -536,6 +538,16 @@ public void
GitHub user chaithu14 opened a pull request:
https://github.com/apache/apex-malhar/pull/334
APEXMALHAR-2136 1) Fixed the null pointer exception issue. 2) Added getter
and setter for IncrementalCheckpointManager
You can merge this pull request into a Git repository by running
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/334#discussion_r69860038
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/state/managed/AbstractManagedStateImpl.java
---
@@ -203,7 +203,12 @@ public void setup
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/351#discussion_r73824988
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/kafka/AbstractKafkaInputOperator.java
---
@@ -188,6 +188,8 @@
@Min(1)
private
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/351#discussion_r73824992
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/kafka/AbstractKafkaInputOperator.java
---
@@ -834,17 +840,16 @@ private boolean
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/330#discussion_r73844379
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/state/managed/ManagedTimeStateMultiValue.java
---
@@ -0,0 +1,363
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/330#discussion_r73844300
--- Diff:
library/src/main/java/com/datatorrent/lib/join/POJOInnerJoinOperator.java ---
@@ -0,0 +1,248 @@
+/**
+ * Licensed to the Apache
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/330#discussion_r73844285
--- Diff:
library/src/main/java/com/datatorrent/lib/join/POJOInnerJoinOperator.java ---
@@ -0,0 +1,248 @@
+/**
+ * Licensed to the Apache
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/330#discussion_r73844252
--- Diff:
library/src/main/java/com/datatorrent/lib/join/AbstractManagedStateInnerJoinOperator.java
---
@@ -0,0 +1,354 @@
+/**
+ * Licensed
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/330#discussion_r73844275
--- Diff:
library/src/main/java/com/datatorrent/lib/join/InnerJoinStreamCodec.java ---
@@ -0,0 +1,48 @@
+/**
+ * Licensed to the Apache
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/330#discussion_r73844228
--- Diff:
library/src/main/java/com/datatorrent/lib/join/AbstractManagedStateInnerJoinOperator.java
---
@@ -0,0 +1,354 @@
+/**
+ * Licensed
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/330#discussion_r73844212
--- Diff:
library/src/main/java/com/datatorrent/lib/join/AbstractInnerJoinOperator.java
---
@@ -0,0 +1,331 @@
+/**
+ * Licensed to the Apache
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/330#discussion_r73844311
--- Diff:
library/src/main/java/com/datatorrent/lib/join/POJOInnerJoinOperator.java ---
@@ -0,0 +1,248 @@
+/**
+ * Licensed to the Apache
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/330#discussion_r73844328
--- Diff:
library/src/main/java/com/datatorrent/lib/join/POJOInnerJoinOperator.java ---
@@ -0,0 +1,248 @@
+/**
+ * Licensed to the Apache
Github user chaithu14 closed the pull request at:
https://github.com/apache/apex-malhar/pull/360
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
GitHub user chaithu14 reopened a pull request:
https://github.com/apache/apex-malhar/pull/360
APEXMALHAR-2174-S3-ReaderIssue Fixed the S3 reader issue
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/chaithu14/incubator-apex
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r68926798
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/state/spillable/SpillableByteArrayListMultimapImpl.java
---
@@ -0,0 +1,241 @@
+package
Github user chaithu14 commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r68926769
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/state/spillable/SpillableByteArrayListMultimapImpl.java
---
@@ -0,0 +1,241 @@
+package
GitHub user chaithu14 opened a pull request:
https://github.com/apache/apex-malhar/pull/401
APEXMALHAR-2226 Fixed the Not supported exception while re-deploying the
AbstractFileOutput Operator
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user chaithu14 opened a pull request:
https://github.com/apache/apex-malhar/pull/420
APEXMALHAR-2242 Added user documentation for 0.9 version of Kafka Input
Operator
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user chaithu14 reopened a pull request:
https://github.com/apache/apex-malhar/pull/330
APEXMALHAR-2100 Implementation of Inner Join operator
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/chaithu14/incubator-apex-malhar
Github user chaithu14 closed the pull request at:
https://github.com/apache/apex-malhar/pull/330
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
GitHub user chaithu14 reopened a pull request:
https://github.com/apache/apex-malhar/pull/330
APEXMALHAR-2100 Implementation of Inner Join operator
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/chaithu14/incubator-apex-malhar
GitHub user chaithu14 opened a pull request:
https://github.com/apache/apex-malhar/pull/373
APEXMALHAR-2154 Update the Kafka Input Operator to use
CheckpointNotificationListener
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user chaithu14 opened a pull request:
https://github.com/apache/apex-malhar/pull/379
APEXMALHAR-2134 Fix the NullPointerException, if the kafka partition has no
leader broker
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user chaithu14 opened a pull request:
https://github.com/apache/apex-malhar/pull/380
APEXMALHAR-2199 Added the support chroot zookeeper path in Kafka Input
Operator
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user chaithu14 reopened a pull request:
https://github.com/apache/apex-malhar/pull/379
APEXMALHAR-2134 Fix the NullPointerException, if the kafka partition has no
leader broker
You can merge this pull request into a Git repository by running:
$ git pull https
Github user chaithu14 closed the pull request at:
https://github.com/apache/apex-malhar/pull/379
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
GitHub user chaithu14 opened a pull request:
https://github.com/apache/apex-malhar/pull/485
APEXMALHAR-2284 *Review Only*
1) Implemented SpillableMap, SpillableArrayList, SpillableArrayListMultiMap
over TimeSlicedBucketState 2) Integrated Spillable data structure into Inner
Join
GitHub user chaithu14 opened a pull request:
https://github.com/apache/apex-malhar/pull/467
APEXMALHAR-2257 Added documentation of Transform Operator
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/chaithu14/incubator-apex
Github user chaithu14 closed the pull request at:
https://github.com/apache/apex-malhar/pull/483
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
GitHub user chaithu14 reopened a pull request:
https://github.com/apache/apex-malhar/pull/483
APEXMALHAR-2022 Developed S3 Output Module
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/chaithu14/incubator-apex-malhar
APEXMALHAR
GitHub user chaithu14 opened a pull request:
https://github.com/apache/apex-malhar/pull/483
APEXMALHAR-2022 Developed S3 Output Module
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/chaithu14/incubator-apex-malhar
APEXMALHAR
GitHub user chaithu14 opened a pull request:
https://github.com/apache/apex-malhar/pull/479
APEXMALHAR-2325 1) Set the file system default block size to the reader. 2)
Set the block size to the reader context
You can merge this pull request into a Git repository by running
GitHub user chaithu14 opened a pull request:
https://github.com/apache/apex-malhar/pull/453
APEXMALHAR-2284 Disabled the POJOInnerJoinOperatorTest
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/chaithu14/incubator-apex-malhar
GitHub user chaithu14 reopened a pull request:
https://github.com/apache/apex-malhar/pull/483
APEXMALHAR-2022 Developed S3 Output Module
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/chaithu14/incubator-apex-malhar
APEXMALHAR
Github user chaithu14 closed the pull request at:
https://github.com/apache/apex-malhar/pull/483
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
Github user chaithu14 closed the pull request at:
https://github.com/apache/apex-malhar/pull/483
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
GitHub user chaithu14 reopened a pull request:
https://github.com/apache/apex-malhar/pull/483
APEXMALHAR-2022 Developed S3 Output Module
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/chaithu14/incubator-apex-malhar
APEXMALHAR
GitHub user chaithu14 opened a pull request:
https://github.com/apache/apex-malhar/pull/529
APEXMALHAR-2364 Added Documetation for S3Output Module
@amberarrow Please review and merge.
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user chaithu14 opened a pull request:
https://github.com/apache/apex-malhar/pull/600
APEXMALHAR-2459 1)Refactor the existing Kafka Input Operator. 2)Added the
support of KafkaInputOperator using 0.10 consumer API
You can merge this pull request into a Git repository
GitHub user chaithu14 opened a pull request:
https://github.com/apache/apex-malhar/pull/642
APEXMALHAR-2497 APEXMALHAR-2162 1) Refactor the Exactly Once output
operator. 2) Refactor and fix the issues of unit tests.
@tushargosavi @tweise Please review and merge.
You can merge
GitHub user chaithu14 opened a pull request:
https://github.com/apache/apex-malhar/pull/611
APEXMALHAR-2484 Support of PartFileWriter for writing the part files
@shubham-pathak22 @yogidevendra Please review and merge.
You can merge this pull request into a Git repository by running
Github user chaithu14 closed the pull request at:
https://github.com/apache/apex-malhar/pull/611
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
GitHub user chaithu14 opened a pull request:
https://github.com/apache/apex-malhar/pull/614
APEXMALHAR-2484 Support of PartFileWriter for writing the part files
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/chaithu14/incubator
GitHub user chaithu14 opened a pull request:
https://github.com/apache/apex-malhar/pull/622
APEXMALHAR-2493 Fixed the issue of KafkaSinglePortExactlyOnceOutputOperator
going to the blocked state during recovery
@sandeshh @tushargosavi Please review and merge.
You can merge
GitHub user chaithu14 opened a pull request:
https://github.com/apache/apex-malhar/pull/623
APEXMALHAR-2494 Added description for the demo apps
@yogidevendra Please review and merge.
You can merge this pull request into a Git repository by running:
$ git pull https
Github user chaithu14 closed the pull request at:
https://github.com/apache/apex-malhar/pull/614
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
91 matches
Mail list logo
