[GitHub] apex-malhar pull request #633: APEXMALHAR-2506 Added the monitoring to Kafka...

2017-06-09 Thread sandeshh
GitHub user sandeshh opened a pull request: https://github.com/apache/apex-malhar/pull/633 APEXMALHAR-2506 Added the monitoring to Kafka Consumer threads, if on… …e of them dies then the Kafka operator is killed so that it can recover from the proper state

[GitHub] apex-core pull request #543: APEXCORE-743 Added timeout for the Container ki...

2017-06-09 Thread sandeshh
GitHub user sandeshh opened a pull request: https://github.com/apache/apex-core/pull/543 APEXCORE-743 Added timeout for the Container kill request sent to NM. @PramodSSImmaneni @vrozov please review. You can merge this pull request into a Git repository by running: $ git pull

[GitHub] apex-core pull request #465: *Dont Merge/Review yet* APEXCORE-632 BufferServ...

2017-04-17 Thread sandeshh
Github user sandeshh closed the pull request at: https://github.com/apache/apex-core/pull/465 --- 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] apex-core pull request #462: APEXCORE-630 Removing FastDataList as it is not...

2017-04-17 Thread sandeshh
Github user sandeshh closed the pull request at: https://github.com/apache/apex-core/pull/462 --- 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] apex-malhar pull request #582: APEXMALHAR-2445 After recovery no need to wri...

2017-03-15 Thread sandeshh
GitHub user sandeshh opened a pull request: https://github.com/apache/apex-malhar/pull/582 APEXMALHAR-2445 After recovery no need to write to WindowDataManger i… …f window id <= LargestCompleted Window ID @amberarrow please review. You can merge this pull request i

[GitHub] apex-core pull request #430: APEXCORE-584 Exposed the attribute to blacklist...

2017-03-08 Thread sandeshh
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

[GitHub] apex-core pull request #483: APEXCORE-663 During restart fallback to old way...

2017-03-07 Thread sandeshh
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] apex-malhar pull request #560: APEXMALHAR-2422 Flushing the data to HDFS nee...

2017-02-23 Thread sandeshh
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] apex-malhar pull request #560: APEXMALHAR-2422 Flushing the data to HDFS nee...

2017-02-23 Thread sandeshh
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] apex-malhar pull request #560: APEXMALHAR-2422 Flushing the data to HDFS nee...

2017-02-23 Thread sandeshh
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] apex-malhar pull request #560: APEXMALHAR-2422 Flushing the data to HDFS nee...

2017-02-23 Thread sandeshh
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] apex-malhar pull request #560: APEXMALHAR-2422 Flushing the data to HDFS nee...

2017-02-23 Thread sandeshh
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] apex-core pull request #465: APEXCORE-632 BufferServer unit tests moving to ...

2017-02-06 Thread sandeshh
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] apex-core pull request #453: *Review only* APEXCORE-259 Directly write to Da...

2017-02-01 Thread sandeshh
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] apex-core pull request #462: APEXCORE-630 Removing FastDataList as it is not...

2017-02-01 Thread sandeshh
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] apex-core pull request #453: *Review only* APEXCORE-259 Directly write to Da...

2017-01-23 Thread sandeshh
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] apex-core pull request #443: APEXCORE-493 checkpoint purging from Streaming ...

2017-01-23 Thread sandeshh
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] apex-core pull request #443: APEXCORE-493 checkpoint purging from streaming ...

2017-01-05 Thread sandeshh
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] apex-core pull request #437: APEXCORE-471 Reissue of the resource was failin...

2016-12-24 Thread sandeshh
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] apex-core pull request #430: APEXCORE-584 Exposed the attribute to blacklist...

2016-12-07 Thread sandeshh
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] apex-malhar pull request #492: APEXMALHAR-2298 Making the KafkaExactlyOnceOu...

2016-11-10 Thread sandeshh
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] apex-core pull request #416: *Review only* APEXCORE-426 Reuse the running co...

2016-11-04 Thread sandeshh
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] apex-core pull request #407: APEXCORE-476 toString() method was returning wr...

2016-10-05 Thread sandeshh
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] apex-core pull request #406: APEXCORE-475 Making the application type of ape...

2016-10-05 Thread sandeshh
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] apex-core pull request #405: APEXCORE-505 Heartbeat loop was blocked waiting...

2016-10-04 Thread sandeshh
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] apex-core pull request #405: APEXCORE-505 Heartbeat loop was blocked waiting...

2016-10-04 Thread sandeshh
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] apex-core pull request #405: APEXCORE-505 Heartbeat loop was blocked waiting...

2016-10-04 Thread sandeshh
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] apex-core pull request #400: APEXCORE-543 ContainerInfo will contain Map of ...

2016-09-30 Thread sandeshh
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] apex-core pull request #395: [WIP] APEXCORE-474 In M*1 case, deploy the unif...

2016-09-20 Thread sandeshh
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] apex-core pull request #391: APEXCORE-533 layering of the properties in case...

2016-09-14 Thread sandeshh
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] apex-core pull request #369: *Review only* [APEXCORE-498] Savepoint feature

2016-09-13 Thread sandeshh
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] apex-core pull request #378: APEXCORE-474 - Unifier placement during M*1 cas...

2016-08-31 Thread sandeshh
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] apex-core pull request #378: APEXCORE-474

2016-08-31 Thread sandeshh
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] apex-core pull request #373: APEXCORE-475 1st part, as discussed in the jira...

2016-08-24 Thread sandeshh
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] apex-core pull request #358: *Review only* [APEXCORE-482]Make the downstream...

2016-08-23 Thread sandeshh
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] apex-core pull request #372: APEXCORE-513 Reduce the log level

2016-08-22 Thread sandeshh
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] apex-core pull request #371: APEXCORE-512 While processing the "-exactMatch"...

2016-08-22 Thread sandeshh
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] apex-core pull request #371: APEXCORE-512 While processing the "-exactMatch"...

2016-08-22 Thread sandeshh
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] apex-core pull request #371: APEXCORE-512 While processing the "-exactMatch"...

2016-08-22 Thread sandeshh
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] apex-core pull request #369: *Review only* [APEXCORE-498] Savepoint feature

2016-08-15 Thread sandeshh
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] apex-core pull request #361: APEXCORE-496 make operator name available to St...

2016-08-09 Thread sandeshh
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] apex-core pull request #360: APEXCORE-495 supporting apps in config package.

2016-08-04 Thread sandeshh
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] apex-core pull request #360: APEXCORE-495 supporting apps in config package.

2016-08-04 Thread sandeshh
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] apex-core pull request #360: APEXCORE-495 supporting apps in config package.

2016-08-04 Thread sandeshh
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] apex-core pull request #360: APEXCORE-495 supporting apps in config package.

2016-08-04 Thread sandeshh
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] apex-core issue #360: APEXCORE-495 supporting apps in config package.

2016-08-02 Thread sandeshh
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] apex-core pull request #364: APEXCORE-448 Made operator name available in op...

2016-08-01 Thread sandeshh
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] apex-core pull request #360: APEXCORE-495 supporting apps in config package.

2016-07-28 Thread sandeshh
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] apex-core pull request #360: APEXCORE-495 supporting apps in config package.

2016-07-28 Thread sandeshh
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] apex-core pull request #360: APEXCORE-495 supporting apps in config package.

2016-07-28 Thread sandeshh
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] apex-core pull request #360: APEXCORE-495 supporting apps in config package.

2016-07-28 Thread sandeshh
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] apex-core pull request #358: *Review only* [APEXCORE-482]Make the downstream...

2016-07-27 Thread sandeshh
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] apex-core issue #358: *Review only* [APEXCORE-482]Make the downstream operat...

2016-07-22 Thread sandeshh
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] apex-core pull request #360: *review only* APEXCORE-495 supporting apps in c...

2016-07-21 Thread sandeshh
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] apex-core issue #358: *Review only* [APEXCORE-482]Make the downstream operat...

2016-07-20 Thread sandeshh
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] apex-core pull request #350: APEXCORE-222 Purging the stale data present in ...

2016-07-15 Thread sandeshh
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] apex-core pull request #358: *Review only* [APEXCORE-482]Make the downstream...

2016-07-15 Thread sandeshh
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] apex-malhar pull request #298: [APEXMALHAR-2086] Kafka output operator: 0.9....

2016-07-12 Thread sandeshh
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] apex-malhar pull request #298: [APEXMALHAR-2086] Kafka output operator: 0.9....

2016-07-12 Thread sandeshh
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] apex-core pull request #350: APEXCORE-222 Purging the stale data present in ...

2016-07-11 Thread sandeshh
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] apex-core pull request #350: APEXCORE-222 Purging the stale data present in ...

2016-07-11 Thread sandeshh
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] apex-core pull request #357: APEXCORE-488: Issues in SSL communication with ...

2016-07-11 Thread sandeshh
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] apex-core pull request #357: APEXCORE-488: Issues in SSL communication with ...

2016-07-11 Thread sandeshh
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] apex-core pull request #350: APEXCORE-222 Purging the stale data present in ...

2016-07-11 Thread sandeshh
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] apex-core pull request #350: APEXCORE-222 Purging the stale data present in ...

2016-07-11 Thread sandeshh
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] apex-core pull request #350: APEXCORE-222 Purging the stale data present in ...

2016-07-09 Thread sandeshh
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] apex-core pull request #350: APEXCORE-222 Purging the stale data present in ...

2016-07-09 Thread sandeshh
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] apex-malhar pull request #298: [APEXMALHAR-2086] Kafka output operator: 0.9....

2016-07-08 Thread sandeshh
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] apex-malhar pull request #298: [APEXMALHAR-2086] Kafka output operator: 0.9....

2016-07-08 Thread sandeshh
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] apex-core pull request #350: APEXCORE-222 Purging the stale data present in ...

2016-07-07 Thread sandeshh
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] apex-malhar pull request #298: [APEXMALHAR-2086] Kafka output operator: 0.9....

2016-07-07 Thread sandeshh
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] apex-malhar pull request #298: [APEXMALHAR-2086] Kafka output operator: 0.9....

2016-07-07 Thread sandeshh
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] apex-malhar pull request #298: [APEXMALHAR-2086] Kafka output operator: 0.9....

2016-07-07 Thread sandeshh
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] apex-malhar pull request #298: [APEXMALHAR-2086] Kafka output operator: 0.9....

2016-07-07 Thread sandeshh
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] apex-malhar pull request #298: [APEXMALHAR-2086] Kafka output operator: 0.9....

2016-07-07 Thread sandeshh
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] apex-malhar pull request #298: [APEXMALHAR-2086] Kafka output operator: 0.9....

2016-07-07 Thread sandeshh
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] apex-malhar pull request #324: Spillable Datastructures PR for review only

2016-07-05 Thread sandeshh
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] apex-malhar pull request #298: [APEXMALHAR-2086] Kafka output operator: 0.9....

2016-07-05 Thread sandeshh
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] apex-malhar pull request #298: [APEXMALHAR-2086] Kafka output operator: 0.9....

2016-07-05 Thread sandeshh
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] apex-malhar pull request #298: [APEXMALHAR-2086] Kafka output operator: 0.9....

2016-07-01 Thread sandeshh
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] apex-core issue #350: APEXCORE-222 Purging the stale data present in the buf...

2016-07-01 Thread sandeshh
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] apex-malhar pull request #298: [APEXMALHAR-2086] Kafka output: 0.9.1 first c...

2016-06-28 Thread sandeshh
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] apex-malhar pull request #298: [APEXMALHAR-2086] Kafka output: 0.9.1 first c...

2016-06-28 Thread sandeshh
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] apex-malhar pull request #298: [APEXMALHAR-2086] Kafka output: 0.9.1 first c...

2016-06-28 Thread sandeshh
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] apex-malhar pull request #298: [APEXMALHAR-2086] Kafka output: 0.9.1 first c...

2016-06-28 Thread sandeshh
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] apex-core pull request #350: APEXCORE-222 Purging the stale data present in ...

2016-06-27 Thread sandeshh
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] apex-core pull request #350: APEXCORE-222 Purging the stale data present in ...

2016-06-25 Thread sandeshh
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] apex-core pull request #350: APEXCORE-222 Purging the stale data present in ...

2016-06-25 Thread sandeshh
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] apex-core pull request #350: APEXCORE-222 Purging the stale data present in ...

2016-06-25 Thread sandeshh
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] apex-core pull request #350: APEXCORE-222 Purging the stale data present in ...

2016-06-25 Thread sandeshh
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] apex-malhar pull request #298: [APEXMALHAR-2086] Kafka output: 0.9.1 first c...

2016-06-24 Thread sandeshh
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] apex-core pull request #350: APEXCORE-222 Purging the stale data present in ...

2016-06-23 Thread sandeshh
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] apex-core pull request #349: APEXCORE-470 New API in DAG - setOperatorAttrib...

2016-06-15 Thread sandeshh
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] apex-core pull request #350: APEXCORE-222 Purging the stale data present in ...

2016-06-14 Thread sandeshh
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] apex-core pull request #350: APEXCORE-222 Purging the stale data present in ...

2016-06-14 Thread sandeshh
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] apex-core pull request #350: APEXCORE-222 Purging the stale data present in ...

2016-06-14 Thread sandeshh
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] apex-core pull request #350: APEXCORE-222 Purging the stale data present in ...

2016-06-14 Thread sandeshh
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] apex-core pull request #350: APEXCORE-222 Purging the stale data present in ...

2016-06-13 Thread sandeshh
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] apex-core pull request #349: APEXCORE-470

2016-06-07 Thread sandeshh
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] incubator-apex-malhar pull request: *For review only* [APEXMALHAR-...

2016-05-26 Thread sandeshh
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

  1   2   >