GitHub user sandeshh opened a pull request:
https://github.com/apache/incubator-apex-core/pull/340
*Review only* Prototype of running java utils to get information from
containers
I am using Jstack to get the container stack. But the idea is to run
various commands ( jcmd, jinfo
Github user sandeshh commented on the pull request:
https://github.com/apache/incubator-apex-core/pull/340#issuecomment-221046944
@tweise It is at the idea phase, I have started the discussion on the
mailing thread. If this idea is fine then I will create a jira.
---
If your
Github user sandeshh closed the pull request at:
https://github.com/apache/incubator-apex-core/pull/340
---
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, or if the
Github user sandeshh commented on a diff in the pull request:
https://github.com/apache/incubator-apex-core/pull/340#discussion_r64491259
--- Diff: engine/src/main/java/com/datatorrent/stram/StramUtils.java ---
@@ -133,4 +135,37 @@ public static JSONObject getStackTrace
Github user sandeshh commented on the pull request:
https://github.com/apache/incubator-apex-core/pull/344#issuecomment-221940571
Usually, the interface and one default implementation live in core.
Different implementations should go to Malhar.
This belongs to Malhar
GitHub user sandeshh opened a pull request:
https://github.com/apache/incubator-apex-malhar/pull/298
*For review only* [APEXMALHAR-2086] Kafka output: 0.9.1 first cut
Kafka output exactly once operator and the regular output operator.
You can merge this pull request into a
GitHub user sandeshh opened a pull request:
https://github.com/apache/apex-core/pull/349
APEXCORE-470
1. Added the new API - setOperatorAttribute
2. updated the unit tests,
3. marked "setAttribute(Operator..." as deprecated
@PramodSSImmaneni please re
GitHub user sandeshh opened a pull request:
https://github.com/apache/apex-core/pull/350
APEXCORE-222 Purging the stale data present in the bufferserver, direâ¦
â¦ctly from the streaming container.
You can merge this pull request into a Git repository by running:
$ git pull
Github user sandeshh closed the pull request at:
https://github.com/apache/apex-core/pull/350
---
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, or if the feature
GitHub user sandeshh reopened a pull request:
https://github.com/apache/apex-core/pull/350
APEXCORE-222 Purging the stale data present in the bufferserver, direâ¦
â¦ctly from the streaming container.
You can merge this pull request into a Git repository by running:
$ git
Github user sandeshh commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/350#discussion_r67062269
--- Diff:
engine/src/main/java/com/datatorrent/stram/engine/StreamingContainer.java ---
@@ -769,7 +769,11 @@ public void
processHeartbeatResponse
Github user sandeshh commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/350#discussion_r67065992
--- Diff:
engine/src/main/java/com/datatorrent/stram/engine/StreamingContainer.java ---
@@ -769,7 +769,11 @@ public void
processHeartbeatResponse
Github user sandeshh commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/349#discussion_r67238893
--- Diff: api/src/main/java/com/datatorrent/api/DAG.java ---
@@ -236,11 +236,22 @@
public abstract void setAttribute(Attribute key, T value
Github user sandeshh commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/350#discussion_r68184470
--- Diff:
engine/src/main/java/com/datatorrent/stram/engine/StreamingContainer.java ---
@@ -769,7 +769,11 @@ public void
processHeartbeatResponse
Github user sandeshh commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/298#discussion_r68441681
--- Diff:
kafka/src/main/java/org/apache/apex/malhar/kafka/KafkaSinglePortExactlyOnceOutputOperator.java
---
@@ -0,0 +1,369
Github user sandeshh commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/350#discussion_r68493761
--- Diff: engine/src/main/java/com/datatorrent/stram/StramLocalCluster.java
---
@@ -72,7 +72,7 @@
protected final StreamingContainerManager dnmgr
Github user sandeshh commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/350#discussion_r68493801
--- Diff:
bufferserver/src/main/java/com/datatorrent/bufferserver/internal/DataList.java
---
@@ -176,21 +176,20 @@ public void reset
Github user sandeshh commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/350#discussion_r68493910
--- Diff:
engine/src/main/java/com/datatorrent/stram/engine/StreamingContainer.java ---
@@ -769,7 +769,11 @@ public void
processHeartbeatResponse
Github user sandeshh commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/350#discussion_r68496137
--- Diff:
engine/src/main/java/com/datatorrent/stram/engine/StreamingContainer.java ---
@@ -769,7 +769,11 @@ public void
processHeartbeatResponse
Github user sandeshh commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/350#discussion_r68643226
--- Diff:
engine/src/main/java/com/datatorrent/stram/engine/StreamingContainer.java ---
@@ -769,7 +769,11 @@ public void
processHeartbeatResponse
Github user sandeshh commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/298#discussion_r68860997
--- Diff:
kafka/src/main/java/org/apache/apex/malhar/kafka/KafkaSinglePortExactlyOnceOutputOperator.java
---
@@ -0,0 +1,369
Github user sandeshh commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/298#discussion_r68862254
--- Diff:
kafka/src/main/java/org/apache/apex/malhar/kafka/KafkaSinglePortExactlyOnceOutputOperator.java
---
@@ -0,0 +1,369
Github user sandeshh commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/298#discussion_r68862518
--- Diff:
kafka/src/main/java/org/apache/apex/malhar/kafka/KafkaSinglePortExactlyOnceOutputOperator.java
---
@@ -0,0 +1,369
Github user sandeshh commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/298#discussion_r68862611
--- Diff:
kafka/src/main/java/org/apache/apex/malhar/kafka/KafkaSinglePortExactlyOnceOutputOperator.java
---
@@ -0,0 +1,369
Github user sandeshh commented on the issue:
https://github.com/apache/apex-core/pull/350
All the review comments has been addressed.
---
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
Github user sandeshh commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/298#discussion_r69347651
--- Diff:
kafka/src/main/java/org/apache/apex/malhar/kafka/KafkaSinglePortExactlyOnceOutputOperator.java
---
@@ -0,0 +1,401
Github user sandeshh closed the pull request at:
https://github.com/apache/apex-malhar/pull/298
---
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, or if the feature
GitHub user sandeshh reopened a pull request:
https://github.com/apache/apex-malhar/pull/298
[APEXMALHAR-2086] Kafka output operator: 0.9.0
Kafka output exactly once operator and the regular output operator.
You can merge this pull request into a Git repository by running
Github user sandeshh commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/324#discussion_r69600767
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/state/spillable/TimeBasedPriorityQueue.java
---
@@ -0,0 +1,128 @@
+package
GitHub user sandeshh reopened a pull request:
https://github.com/apache/apex-malhar/pull/298
[APEXMALHAR-2086] Kafka output operator: 0.9.0
Kafka output exactly once operator and the regular output operator.
You can merge this pull request into a Git repository by running
Github user sandeshh closed the pull request at:
https://github.com/apache/apex-malhar/pull/298
---
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, or if the feature
Github user sandeshh closed the pull request at:
https://github.com/apache/apex-malhar/pull/298
---
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, or if the feature
GitHub user sandeshh reopened a pull request:
https://github.com/apache/apex-malhar/pull/298
[APEXMALHAR-2086] Kafka output operator: 0.9.0
Kafka output exactly once operator and the regular output operator.
You can merge this pull request into a Git repository by running
Github user sandeshh closed the pull request at:
https://github.com/apache/apex-malhar/pull/298
---
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, or if the feature
GitHub user sandeshh reopened a pull request:
https://github.com/apache/apex-malhar/pull/298
[APEXMALHAR-2086] Kafka output operator: 0.9.0
Kafka output exactly once operator and the regular output operator.
You can merge this pull request into a Git repository by running
Github user sandeshh commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/350#discussion_r70022763
--- Diff:
bufferserver/src/main/java/com/datatorrent/bufferserver/server/Server.java ---
@@ -199,6 +199,13 @@ private void handlePurgeRequest
GitHub user sandeshh reopened a pull request:
https://github.com/apache/apex-malhar/pull/298
[APEXMALHAR-2086] Kafka output operator: 0.9.0
Kafka output exactly once operator and the regular output operator.
You can merge this pull request into a Git repository by running
Github user sandeshh closed the pull request at:
https://github.com/apache/apex-malhar/pull/298
---
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, or if the feature
Github user sandeshh closed the pull request at:
https://github.com/apache/apex-core/pull/350
---
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, or if the feature
GitHub user sandeshh reopened a pull request:
https://github.com/apache/apex-core/pull/350
APEXCORE-222 Purging the stale data present in the bufferserver, direâ¦
â¦ctly from the streaming container.
You can merge this pull request into a Git repository by running:
$ git
GitHub user sandeshh reopened a pull request:
https://github.com/apache/apex-core/pull/350
APEXCORE-222 Purging the stale data present in the bufferserver, direâ¦
â¦ctly from the streaming container.
You can merge this pull request into a Git repository by running:
$ git
Github user sandeshh closed the pull request at:
https://github.com/apache/apex-core/pull/350
---
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, or if the feature
Github user sandeshh commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/357#discussion_r70355340
--- Diff: engine/src/main/java/com/datatorrent/stram/client/StramAgent.java
---
@@ -204,7 +204,14 @@ private UriBuilder
getStramWebURIBuilder
Github user sandeshh commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/357#discussion_r70355804
--- Diff: engine/src/main/java/com/datatorrent/stram/client/StramAgent.java
---
@@ -204,7 +204,14 @@ private UriBuilder
getStramWebURIBuilder
GitHub user sandeshh reopened a pull request:
https://github.com/apache/apex-core/pull/350
APEXCORE-222 Purging the stale data present in the bufferserver, direâ¦
â¦ctly from the streaming container.
You can merge this pull request into a Git repository by running:
$ git
Github user sandeshh closed the pull request at:
https://github.com/apache/apex-core/pull/350
---
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, or if the feature
GitHub user sandeshh reopened a pull request:
https://github.com/apache/apex-malhar/pull/298
[APEXMALHAR-2086] Kafka output operator: 0.9.0
Kafka output exactly once operator and the regular output operator.
You can merge this pull request into a Git repository by running
Github user sandeshh closed the pull request at:
https://github.com/apache/apex-malhar/pull/298
---
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, or if the feature
GitHub user sandeshh opened a pull request:
https://github.com/apache/apex-core/pull/358
*Review only* [APEXCORE-482]Make the downstream operator & unifier in the
same container as THREAâ¦
â¦D_LOCAL
Opening it early, to get the feedback on the approach.
Github user sandeshh commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/350#discussion_r71008939
--- Diff:
bufferserver/src/main/java/com/datatorrent/bufferserver/internal/DataList.java
---
@@ -176,21 +176,20 @@ public void reset
Github user sandeshh commented on the issue:
https://github.com/apache/apex-core/pull/358
@vrozov StreamMeta constructors are private. I will add a "clone" method to
that and assign a separate StreamMeta for the unifiers.
Also, I have seen some cases where un
GitHub user sandeshh opened a pull request:
https://github.com/apache/apex-core/pull/360
*review only* APEXCORE-495 supporting apps in config package.
1. Added support to store apps in the config file
2. By default apps from the config and app package gets merged (During
Github user sandeshh commented on the issue:
https://github.com/apache/apex-core/pull/358
@tweise I will do the benchmarking. But at the outset, It skips the queue
between default unifier and the downstream, that should improve performance.
---
If your project is set up for it, you
Github user sandeshh commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/358#discussion_r72490943
--- Diff:
engine/src/main/java/com/datatorrent/stram/plan/physical/PTOperator.java ---
@@ -85,6 +85,7 @@
private static final long
Github user sandeshh commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/360#discussion_r72670234
--- Diff: engine/src/main/java/com/datatorrent/stram/cli/ApexCli.java ---
@@ -3850,6 +3908,9 @@ private Option add(Option opt)
final Option
Github user sandeshh commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/360#discussion_r72670717
--- Diff:
engine/src/main/java/com/datatorrent/stram/client/ConfigPackage.java ---
@@ -71,6 +72,7 @@
private final Map properties = new
Github user sandeshh commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/360#discussion_r72670932
--- Diff:
engine/src/test/java/com/datatorrent/stram/support/StramTestSupport.java ---
@@ -157,21 +160,42 @@ public static void
waitForWindowComplete
Github user sandeshh commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/360#discussion_r72671495
--- Diff:
engine/src/test/resources/testOperators/src/main/java/org/apache/apex/test/RandomGen.java
---
@@ -16,24 +16,44 @@
* specific language
Github user sandeshh commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/364#discussion_r73067721
--- Diff: api/src/main/java/com/datatorrent/api/Context.java ---
@@ -328,6 +328,8 @@
*/
int getWindowsFromCheckpoint
Github user sandeshh commented on the issue:
https://github.com/apache/apex-core/pull/360
@davidyan74 Please review.
---
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
Github user sandeshh commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/360#discussion_r73582926
--- Diff: engine/src/test/java/com/datatorrent/stram/cli/ApexCliTest.java
---
@@ -180,4 +188,40 @@ public void
Github user sandeshh commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/360#discussion_r73584686
--- Diff: engine/src/test/java/com/datatorrent/stram/cli/ApexCliTest.java
---
@@ -180,4 +188,40 @@ public void
Github user sandeshh commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/360#discussion_r73586551
--- Diff: engine/src/test/java/com/datatorrent/stram/cli/ApexCliTest.java
---
@@ -53,16 +56,16 @@
private static File configFile
Github user sandeshh commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/360#discussion_r73610135
--- Diff: engine/src/test/java/com/datatorrent/stram/cli/ApexCliTest.java
---
@@ -180,4 +188,40 @@ public void
Github user sandeshh commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/361#discussion_r74098254
--- Diff: api/src/main/java/com/datatorrent/api/StatsListener.java ---
@@ -115,6 +115,28 @@
List getOperatorResponse
GitHub user sandeshh opened a pull request:
https://github.com/apache/apex-core/pull/369
*Review only* [APEXCORE-498] Savepoint feature
This enables the following feature,
a. Store the savepoint of the running app in the location provided
apexCli> savepo
GitHub user sandeshh opened a pull request:
https://github.com/apache/apex-core/pull/371
APEXCORE-512 While processing the "-exactMatch" flag, immutable list â¦
â¦was required. Made the changes to unit test as well.
You can merge this pull request into a Git repository
GitHub user sandeshh reopened a pull request:
https://github.com/apache/apex-core/pull/371
APEXCORE-512 While processing the "-exactMatch" flag, immutable list â¦
â¦was required. Made the changes to unit test as well.
You can merge this pull request into a Git rep
Github user sandeshh closed the pull request at:
https://github.com/apache/apex-core/pull/371
---
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, or if the feature
GitHub user sandeshh opened a pull request:
https://github.com/apache/apex-core/pull/372
APEXCORE-513 Reduce the log level
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/sandeshh/apex-core APEXCORE-513
Alternatively you can
Github user sandeshh closed the pull request at:
https://github.com/apache/apex-core/pull/358
---
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, or if the feature
GitHub user sandeshh opened a pull request:
https://github.com/apache/apex-core/pull/373
APEXCORE-475 1st part, as discussed in the jira. This will make the câ¦
â¦lient the forward compatible, then in the next release we can change the
type to of the applicationt to ApacheApex
GitHub user sandeshh opened a pull request:
https://github.com/apache/apex-core/pull/378
APEXCORE-474
https://issues.apache.org/jira/browse/APEXCORE-474
Creating a separate container for the last unifier is not required. It only
changes the default behavior, users can
Github user sandeshh closed the pull request at:
https://github.com/apache/apex-core/pull/378
---
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, or if the feature
Github user sandeshh closed the pull request at:
https://github.com/apache/apex-core/pull/369
---
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, or if the feature
GitHub user sandeshh opened a pull request:
https://github.com/apache/apex-core/pull/391
APEXCORE-533 layering of the properties in case of config apps where â¦
â¦failing, because of the order in which they are processed, now fixed
@davidyan74 please review.
You can
GitHub user sandeshh opened a pull request:
https://github.com/apache/apex-core/pull/395
[WIP] APEXCORE-474 In M*1 case, deploy the unifier in the same container
asâ¦
⦠downstream
Opening this, work in progress, PR to get early feedback. Only changes I am
doing is for
GitHub user sandeshh opened a pull request:
https://github.com/apache/apex-core/pull/400
APEXCORE-543 ContainerInfo will contain Map of operators, with Key reâ¦
â¦presenting Id and Value representing name.
@davidyan74 please review.
You can merge this pull request into a
GitHub user sandeshh opened a pull request:
https://github.com/apache/apex-core/pull/405
APEXCORE-505 Heartbeat loop was blocked waiting for operator activatiâ¦
â¦on, the reason for this is that Stream activation(Only
BufferServerSubscriber and WindowGenerator) waits for operator
GitHub user sandeshh reopened a pull request:
https://github.com/apache/apex-core/pull/405
APEXCORE-505 Heartbeat loop was blocked waiting for operator activatiâ¦
â¦on, the reason for this is that Stream activation(Only
BufferServerSubscriber and WindowGenerator) waits for
Github user sandeshh closed the pull request at:
https://github.com/apache/apex-core/pull/405
---
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, or if the feature
GitHub user sandeshh opened a pull request:
https://github.com/apache/apex-core/pull/406
APEXCORE-475 Making the application type of apex applications as Apacâ¦
â¦heApex and we will still keep DataTorrent as the deprecated tag.
@tweise please review.
You can merge this
GitHub user sandeshh opened a pull request:
https://github.com/apache/apex-core/pull/407
APEXCORE-476 toString() method was returning wrong window ids, fixingâ¦
⦠this, as the correct information is useful during debugging
@vrozov please review.
You can merge this pull
GitHub user sandeshh opened a pull request:
https://github.com/apache/apex-core/pull/416
*Review only* APEXCORE-426 Reuse the running container, when the Stram
restarts.
@tweise & @vrozov please review
If you guys are fine with the approach, I will work on unit t
GitHub user sandeshh opened a pull request:
https://github.com/apache/apex-malhar/pull/492
APEXMALHAR-2298 Making the KafkaExactlyOnceOutputOperator take generiâ¦
â¦c object as input.
@siyuanh please review.
You can merge this pull request into a Git repository by
GitHub user sandeshh opened a pull request:
https://github.com/apache/apex-core/pull/430
APEXCORE-584 Exposed the attribute to blacklist the nodes for the resâ¦
â¦ource allocation purpose
@PramodSSImmaneni please review.
You can merge this pull request into a Git
GitHub user sandeshh opened a pull request:
https://github.com/apache/apex-core/pull/437
APEXCORE-471 Reissue of the resource was failing for the BlackListBasâ¦
â¦ed scheduler, it happened because RequestedResource was never empty.
Issue is fixed after making the operation
GitHub user sandeshh opened a pull request:
https://github.com/apache/apex-core/pull/443
APEXCORE-493 checkpoint purging from streaming container
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/sandeshh/apex-core APEXCORE-493
Github user sandeshh closed the pull request at:
https://github.com/apache/apex-core/pull/443
---
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, or if the feature
GitHub user sandeshh opened a pull request:
https://github.com/apache/apex-core/pull/453
*Review only* APEXCORE-259 Directly write to DataList
Instead of the loop back between the Output port and the buffer server,
tuples are directly written to DataList. This improves the tuples
GitHub user sandeshh opened a pull request:
https://github.com/apache/apex-core/pull/462
APEXCORE-630 Removing FastDataList as it is not complete and not deveâ¦
â¦loped, so no reason to keep it
@vrozov please review.
You can merge this pull request into a Git repository
Github user sandeshh closed the pull request at:
https://github.com/apache/apex-core/pull/453
---
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, or if the feature
GitHub user sandeshh opened a pull request:
https://github.com/apache/apex-core/pull/465
APEXCORE-632 BufferServer unit tests moving to Junit
1. Move the unit tests to Junit from testNg
2. Fix the failing test cases
3. Enable the test cases
You can merge this pull request
GitHub user sandeshh opened a pull request:
https://github.com/apache/apex-malhar/pull/560
APEXMALHAR-2422 Flushing the data to HDFS needs a separate flag for iâ¦
â¦t to work.
@otterc , @tushargosavi please review.
You can merge this pull request into a Git repository by
GitHub user sandeshh reopened a pull request:
https://github.com/apache/apex-malhar/pull/560
APEXMALHAR-2422 Flushing the data to HDFS needs a separate flag for iâ¦
â¦t to work.
@otterc , @tushargosavi please review.
You can merge this pull request into a Git repository
Github user sandeshh closed the pull request at:
https://github.com/apache/apex-malhar/pull/560
---
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, or if the feature
GitHub user sandeshh reopened a pull request:
https://github.com/apache/apex-malhar/pull/560
APEXMALHAR-2422 Flushing the data to HDFS needs a separate flag for iâ¦
â¦t to work.
@otterc , @tushargosavi please review.
You can merge this pull request into a Git repository
Github user sandeshh closed the pull request at:
https://github.com/apache/apex-malhar/pull/560
---
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, or if the feature
GitHub user sandeshh opened a pull request:
https://github.com/apache/apex-core/pull/483
APEXCORE-663 During restart fallback to old way of constructing the lâ¦
â¦ist of containers as YARN return empty list of containers
@vrozov @tweise please review
You can merge this
Github user sandeshh closed the pull request at:
https://github.com/apache/apex-core/pull/430
---
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, or if the feature
1 - 100 of 105 matches
Mail list logo
