GitHub user PramodSSImmaneni opened a pull request:
https://github.com/apache/apex-malhar/pull/644
APEXMALHAR-2518 Terminating operator when there is a server error in
processing commit offsets
You can merge this pull request into a Git repository by running:
$ git pull
GitHub user PramodSSImmaneni reopened a pull request:
https://github.com/apache/apex-malhar/pull/631
APEXMALHAR-2366 #resolve #comment Apply BloomFilter to Bucket, use internal
BloomFilter
@bhupeshchawda please see, this is to finish up the work started in
https://github.com
GitHub user PramodSSImmaneni opened a pull request:
https://github.com/apache/apex-core/pull/539
APEXCORE-742 Fix for creation of yarn client instances
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/PramodSSImmaneni/apex-core
GitHub user PramodSSImmaneni opened a pull request:
https://github.com/apache/apex-core/pull/538
APEXCORE-736 Using YARN client api to fetch the application master
container report
This is a continuation of the PR
https://github.com/apache/apex-core/pull/534 and merging
GitHub user PramodSSImmaneni opened a pull request:
https://github.com/apache/apex-malhar/pull/631
APEXMALHAR-2366 #resolve #comment Apply BloomFilter to Bucket, use internal
BloomFilter
@bhupeshchawda please see, this is to finish up the work started in
https://github.com/apache
GitHub user PramodSSImmaneni opened a pull request:
https://github.com/apache/apex-core/pull/531
APEXCORE-732 Handling serialization and other exceptions while recording
tuples, preventing the container from failing
You can merge this pull request into a Git repository by running
GitHub user PramodSSImmaneni opened a pull request:
https://github.com/apache/apex-core/pull/530
APEXCORE-726 Setup up acls for impersonation
@devtagare @amberarrow please see
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user PramodSSImmaneni opened a pull request:
https://github.com/apache/apex-site/pull/75
APEXCORE-721 Updated announcements to malhar 3.7.0 and core 3.6.0
@tweise @tushargosavi please see
You can merge this pull request into a Git repository by running:
$ git pull https
GitHub user PramodSSImmaneni opened a pull request:
https://github.com/apache/apex-core/pull/523
APEXCORE-716 Javadoc for engine api packages warning of no backwards
compatibility guarantees
@vrozov @tweise please see
You can merge this pull request into a Git repository
GitHub user PramodSSImmaneni opened a pull request:
https://github.com/apache/apex-core/pull/522
APEXCORE-714 Adding a new recovery mode where the operator instance before
a failure event can be reused when recovering from an upstream operator failure
[Review Only]
You can merge
GitHub user PramodSSImmaneni opened a pull request:
https://github.com/apache/apex-core/pull/518
APEXCORE-700 Uniform interface between setup and runtime plugins
@tushargosavi please see
Better to merge after https://github.com/apache/apex-core/pull/503/
You can merge
GitHub user PramodSSImmaneni opened a pull request:
https://github.com/apache/apex-core/pull/507
APEXCORE-609 Backpressure when spooling is disabled.
The publisher is suspended if ahead of subscriber by maximum number of
blocks. This doesn't yet address the issue of blocks being
Github user PramodSSImmaneni closed the pull request at:
https://github.com/apache/apex-malhar/pull/475
---
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 PramodSSImmaneni opened a pull request:
https://github.com/apache/apex-malhar/pull/598
Flume operator and agent
This PR adds support for flume. It contains flume input operator and an
agent to use on the flume side.
You can merge this pull request into a Git repository
GitHub user PramodSSImmaneni opened a pull request:
https://github.com/apache/apex-core/pull/488
APEXCORE-641 Preventing a scenario where more than one the subscribe
notification task can be scheduled simultaneously
@vrozov please see. I missed this, something didnt feel right
GitHub user PramodSSImmaneni opened a pull request:
https://github.com/apache/apex-core/pull/487
APEXCORE-671 ValueEntry reverted back to public
@ajaygit158 @vrozov @sandeshh please see. A more permanent solution can be
done later but this currently breaks dependencies.
You can
GitHub user PramodSSImmaneni opened a pull request:
https://github.com/apache/apex-malhar/pull/571
Solace input operators
Solace input operators to read data from solace messaging system.
This was built as a team effort between Solace and DataTorrent, hence the
multiple
GitHub user PramodSSImmaneni opened a pull request:
https://github.com/apache/apex-core/pull/450
APEXCORE-616 Added back http client handler that was removed and affects
running in kerberized cluster
@venkateshkottapalli @davidyan74 please see
You can merge this pull request
GitHub user PramodSSImmaneni opened a pull request:
https://github.com/apache/apex-core/pull/445
APEXCORE-570 Back pressure support in buffer server when subscribers are
slower than publisher
@vrozov please see
You can merge this pull request into a Git repository by running
GitHub user PramodSSImmaneni opened a pull request:
https://github.com/apache/apex-core/pull/425
Example application showing how to use the launcher API in a project
@tweise this is an example showing launcher API usage (which I had earlier
in my repo). I felt that the best place
GitHub user PramodSSImmaneni opened a pull request:
https://github.com/apache/apex-malhar/pull/509
APEXMALHAR-2355 Added schema annotation
@yogidevendra @pradeepdalvi please see
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
Github user PramodSSImmaneni closed the pull request at:
https://github.com/apache/apex-malhar/pull/475
---
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 PramodSSImmaneni reopened a pull request:
https://github.com/apache/apex-malhar/pull/475
APEXMALHAR-2324 Megh flume
Flume support from megh project. Preserved attribution for individual
commits, filtered flume related commits only from the megh project. Applied
GitHub user PramodSSImmaneni opened a pull request:
https://github.com/apache/apex-malhar/pull/475
Megh flume
Flume support from megh project. Preserved attribution for individual
commits, filtered flume related commits only from the megh project. Applied
formatting and licensing
GitHub user PramodSSImmaneni opened a pull request:
https://github.com/apache/apex-core/pull/394
Upgraded beanutils version
@tweise @vrozov please see
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/PramodSSImmaneni/apex-core
GitHub user PramodSSImmaneni opened a pull request:
https://github.com/apache/apex-core/pull/390
APEXCORE-519 Added DIGEST authentication
@vrozov please see
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/PramodSSImmaneni/apex
GitHub user PramodSSImmaneni opened a pull request:
https://github.com/apache/apex-core/pull/383
APEXCORE-517 Added BASIC authentication support
This adds support to authenticate with Hadoop web services with BASIC
authentication enabled.
@pradeepdalvi @vrozov please see
GitHub user PramodSSImmaneni opened a pull request:
https://github.com/apache/apex-core/pull/382
Added best practices for application and operator development
This was originally submitted to Malhar, pull request mentioned below. This
is a more appropriate repository because
GitHub user PramodSSImmaneni opened a pull request:
https://github.com/apache/apex-core/pull/374
APEXCORE-515 Providing principal for token refresh
@gauravgopi123 please see
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/347#discussion_r73784652
--- Diff: library/src/main/java/com/datatorrent/lib/io/jms/JMSBase.java ---
@@ -76,18 +79,59 @@
private transient Session session
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/347#discussion_r73784565
--- Diff: library/src/main/java/com/datatorrent/lib/io/jms/JMSBase.java ---
@@ -129,12 +173,20 @@ public void setConnectionFactoryClass(String
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/347#discussion_r73784544
--- Diff: library/src/main/java/com/datatorrent/lib/io/jms/JMSBase.java ---
@@ -76,18 +79,59 @@
private transient Session session
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/347#discussion_r73784474
--- Diff: library/src/main/java/com/datatorrent/lib/io/jms/JMSBase.java ---
@@ -76,18 +76,52 @@
private transient Session session
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/347#discussion_r73784425
--- Diff: library/src/main/java/com/datatorrent/lib/io/jms/JMSBase.java ---
@@ -112,14 +156,14 @@ public Destination getDestination
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/347#discussion_r73784288
--- Diff: library/src/main/java/com/datatorrent/lib/io/jms/JMSBase.java ---
@@ -129,12 +173,20 @@ public void setConnectionFactoryClass(String
Github user PramodSSImmaneni commented on the issue:
https://github.com/apache/apex-core/pull/364
I second it, please reopen this PR and I will merge it. I think we have
spent enough time on the tests and everyone's inputs have been valuable. There
will be other opportunities
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/364#discussion_r73430475
--- Diff:
engine/src/test/java/com/datatorrent/stram/engine/OperatorContextTest.java ---
@@ -0,0 +1,98 @@
+/**
+ * Licensed to the Apache
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/364#discussion_r73429227
--- Diff:
engine/src/main/java/com/datatorrent/stram/engine/OperatorContext.java ---
@@ -84,12 +87,13 @@ public void setIdleTimeout(long
Github user PramodSSImmaneni commented on the issue:
https://github.com/apache/apex-site/pull/44
@tweise anything else, otherwise can you 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
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/347#discussion_r72995064
--- Diff:
stream/src/test/java/org/apache/apex/malhar/stream/FunctionOperator/FunctionOperatorTest.java
---
@@ -1,332 +0,0
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/347#discussion_r72994883
--- Diff: library/src/main/java/com/datatorrent/lib/io/jms/JMSBase.java ---
@@ -76,18 +76,52 @@
private transient Session session
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/347#discussion_r72994523
--- Diff: library/src/main/java/com/datatorrent/lib/io/jms/JMSBase.java ---
@@ -143,7 +172,7 @@ public void setConnectionFactoryProperties(Map
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/347#discussion_r72993901
--- Diff: library/src/main/java/com/datatorrent/lib/io/jms/JMSBase.java ---
@@ -76,18 +76,52 @@
private transient Session session
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/347#discussion_r72991746
--- Diff: library/src/main/java/com/datatorrent/lib/io/jms/JMSBase.java ---
@@ -76,18 +76,52 @@
private transient Session session
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/347#discussion_r72991276
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/kafka/AbstractKafkaInputOperator.java
---
@@ -250,12 +250,7 @@ public void setup
Github user PramodSSImmaneni commented on the issue:
https://github.com/apache/apex-site/pull/42
Updated and squashed.
---
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
GitHub user PramodSSImmaneni opened a pull request:
https://github.com/apache/apex-core/pull/363
Documentation for secure impersonation
@davidyan74 please see
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/PramodSSImmaneni/apex
Github user PramodSSImmaneni commented on the issue:
https://github.com/apache/apex-site/pull/42
@tweise made the changes
---
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
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/347#discussion_r72343723
--- Diff: library/src/main/java/com/datatorrent/lib/io/jms/JMSBase.java ---
@@ -355,10 +366,13 @@ public void createConnection() throws
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/347#discussion_r72343606
--- Diff: library/src/main/java/com/datatorrent/lib/io/jms/JMSBase.java ---
@@ -355,10 +366,13 @@ public void createConnection() throws
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-site/pull/42#discussion_r72343142
--- Diff: src/md/release.md ---
@@ -201,6 +252,27 @@ git push apache
```
Merge `@since` tag and change log changes to `master
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-site/pull/42#discussion_r72340598
--- Diff: src/md/release.md ---
@@ -150,6 +150,57 @@ mkdir svn-dist && cp *-source-* svn-dist/
svn import svn-dist
https://dist.ap
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-site/pull/42#discussion_r72340572
--- Diff: src/md/release.md ---
@@ -201,6 +252,27 @@ git push apache
```
Merge `@since` tag and change log changes to `master
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-site/pull/45#discussion_r72340210
--- Diff: src/md/powered-by-apex.md ---
@@ -5,7 +5,7 @@ This page lists organizations and software projects which
work with Apache Apex
GitHub user PramodSSImmaneni opened a pull request:
https://github.com/apache/apex-site/pull/45
Added new Apex companies, university and minor content changes
@amolhkekre please see
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/347#discussion_r72279473
--- Diff: library/src/main/java/com/datatorrent/lib/io/jms/JMSBase.java ---
@@ -76,18 +76,24 @@
private transient Session session
Github user PramodSSImmaneni commented on the issue:
https://github.com/apache/apex-site/pull/44
This is from the discussion
https://www.mail-archive.com/dev%40apex.apache.org/msg00289.html
Also, take a look at the accompanying pull request that has the best
practices
GitHub user PramodSSImmaneni opened a pull request:
https://github.com/apache/apex-malhar/pull/350
Added development best practices
@sashadt please review and merge
This is from the discussion in the mailing list below. The document was
available for review by everyone
GitHub user PramodSSImmaneni opened a pull request:
https://github.com/apache/apex-site/pull/44
Added malhar contribution guidelines
Based on the discussion in the dev list. @sashadt please review
You can merge this pull request into a Git repository by running:
$ git pull
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-site/pull/42#discussion_r71972984
--- Diff: src/md/release.md ---
@@ -150,6 +150,47 @@ mkdir svn-dist && cp *-source-* svn-dist/
svn import svn-dist
https://dist.ap
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-site/pull/42#discussion_r71929670
--- Diff: src/md/release.md ---
@@ -150,6 +150,47 @@ mkdir svn-dist && cp *-source-* svn-dist/
svn import svn-dist
https://dist.ap
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-site/pull/42#discussion_r71923101
--- Diff: src/md/release.md ---
@@ -150,6 +150,47 @@ mkdir svn-dist && cp *-source-* svn-dist/
svn import svn-dist
https://dist.ap
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-site/pull/42#discussion_r71800574
--- Diff: src/md/release.md ---
@@ -150,6 +150,47 @@ mkdir svn-dist && cp *-source-* svn-dist/
svn import svn-dist
https://dist.ap
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-site/pull/42#discussion_r71714416
--- Diff: src/md/release.md ---
@@ -150,6 +150,47 @@ mkdir svn-dist && cp *-source-* svn-dist/
svn import svn-dist
https://dist.ap
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-site/pull/42#discussion_r71652914
--- Diff: src/md/release.md ---
@@ -150,6 +150,47 @@ mkdir svn-dist && cp *-source-* svn-dist/
svn import svn-dist
https://dist.ap
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-site/pull/42#discussion_r71226364
--- Diff: src/md/release.md ---
@@ -150,6 +150,47 @@ mkdir svn-dist && cp *-source-* svn-dist/
svn import svn-dist
https://dist.ap
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/357#discussion_r70850997
--- Diff: engine/src/main/java/com/datatorrent/stram/util/ConfigUtils.java
---
@@ -68,15 +68,30 @@ public static String getRMUsername
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/357#discussion_r70630193
--- Diff: engine/src/main/java/com/datatorrent/stram/util/ConfigUtils.java
---
@@ -68,15 +68,30 @@ public static String getRMUsername
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/357#discussion_r70553112
--- Diff:
engine/src/main/java/com/datatorrent/stram/StreamingAppMasterService.java ---
@@ -607,14 +608,15 @@ protected void serviceStart
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-site/pull/42#discussion_r70510870
--- Diff: src/md/release.md ---
@@ -150,6 +150,47 @@ mkdir svn-dist && cp *-source-* svn-dist/
svn import svn-dist
https://dist.ap
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-site/pull/42#discussion_r70510813
--- Diff: src/md/release.md ---
@@ -150,6 +150,47 @@ mkdir svn-dist && cp *-source-* svn-dist/
svn import svn-dist
https://dist.ap
GitHub user PramodSSImmaneni opened a pull request:
https://github.com/apache/apex-core/pull/353
Removed deployment documentation as it is included in the release
documentation
A pull request has been submitted to apex-site to deploy documentation as
part of the release process
GitHub user PramodSSImmaneni opened a pull request:
https://github.com/apache/apex-site/pull/42
Added updating documentation to release process
I had some updates to docs and had noticed that we don't include building
and staging documentation as part of the release process even
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/351#discussion_r70020461
--- Diff: api/src/main/java/com/datatorrent/api/ClusterMode.java ---
@@ -0,0 +1,67 @@
+/**
+ * Licensed to the Apache Software Foundation
Github user PramodSSImmaneni commented on the issue:
https://github.com/apache/apex-core/pull/351
@gauravgopi123 sorry the link is this one
http://mail-archives.apache.org/mod_mbox/apex-dev/201604.mbox/%3CCAA7LveFWbGiONNWrAeJE8-H8rkGSg2e-nwGNojN%2BXQm4hG%3DEXg%40mail.gmail.com%3E
Github user PramodSSImmaneni commented on the issue:
https://github.com/apache/apex-core/pull/351
@tweise I will show a simple driver code on how to use it and a maven
sample on how to launch it and may be it will become clearer on how it can be
used. User needs to include apex
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/351#discussion_r70010184
--- Diff: api/src/main/java/com/datatorrent/api/ClusterMode.java ---
@@ -0,0 +1,67 @@
+/**
+ * Licensed to the Apache Software Foundation
Github user PramodSSImmaneni commented on the issue:
https://github.com/apache/apex-core/pull/351
Hey @tweise the API is in parity with how the app is launched in embedded
mode. So it expects the user to set all the configuration in the configuration
object and pass it along
Github user PramodSSImmaneni commented on the issue:
https://github.com/apache/apex-core/pull/351
@davidyan74 please see as well
---
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 PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/351#discussion_r69362973
--- Diff: engine/src/main/java/com/datatorrent/stram/LocalModeImpl.java ---
@@ -54,6 +55,53 @@ public DAG cloneDAG() throws Exception
Github user PramodSSImmaneni commented on the issue:
https://github.com/apache/apex-core/pull/351
@siyuanh @tushargosavi please see as you have expressed interest in JIRA
---
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 PramodSSImmaneni opened a pull request:
https://github.com/apache/apex-core/pull/351
APEXCORE-405 Common API to launch on local mode or cluster
@tweise please take a look.
Common API to launch on local mode or cluster. No functionality lost in
local mode
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/349#discussion_r67067938
--- Diff: api/src/main/java/com/datatorrent/api/DAG.java ---
@@ -236,11 +236,22 @@
public abstract void setAttribute(Attribute key, T
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/349#discussion_r67067785
--- Diff: api/src/main/java/com/datatorrent/api/DAG.java ---
@@ -236,11 +236,22 @@
public abstract void setAttribute(Attribute key, T
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/350#discussion_r67067166
--- Diff:
engine/src/main/java/com/datatorrent/stram/engine/StreamingContainer.java ---
@@ -769,7 +769,11 @@ public void
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/350#discussion_r67063171
--- Diff:
engine/src/main/java/com/datatorrent/stram/engine/StreamingContainer.java ---
@@ -769,7 +769,11 @@ public void
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/350#discussion_r67060191
--- Diff:
engine/src/main/java/com/datatorrent/stram/engine/StreamingContainer.java ---
@@ -769,7 +769,11 @@ public void
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/349#discussion_r66172343
--- Diff: api/src/main/java/com/datatorrent/api/DAG.java ---
@@ -238,9 +238,15 @@
/**
* setAttribute.
*/
+ @Deprecated
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/incubator-apex-core/pull/338#discussion_r65550916
--- Diff: engine/src/main/java/com/datatorrent/stram/webapp/TypeGraph.java
---
@@ -355,7 +356,8 @@ public int size
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/282#discussion_r65274816
--- Diff:
library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcPollInputOperator.java
---
@@ -0,0 +1,652
90 matches
Mail list logo
