GitHub user siyuanh opened a pull request:
https://github.com/apache/incubator-apex-malhar/pull/205
Add Idempotent support the new kafka input operator
@chaithu14 @tweise Please review
You can merge this pull request into a Git repository by running:
$ git pull https://github
Github user tweise commented on the pull request:
https://github.com/apache/incubator-apex-core/pull/245#issuecomment-190072705
How will the deployment work with multiple versions?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
[
https://issues.apache.org/jira/browse/APEXCORE-293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15171508#comment-15171508
]
ASF GitHub Bot commented on APEXCORE-293:
-
Github user tweise commented on the p
Github user tweise commented on the pull request:
https://github.com/apache/incubator-apex-core/pull/245#issuecomment-190071158
Sasha, I have cleaned up this import and moved it to the following branch:
https://github.com/tweise/incubator-apex-core/tree/APEXCORE-293
P
Hi Chinmay,
Please find my replies inline..
Thanks,
Isha
On Sun, Feb 28, 2016 at 10:04 PM, Chinmay Kolhatkar
wrote:
> Hi Isha,
>
> Couple of points:
> 1. Do the first curly brackets required? They seem to add another level of
> hierarchy.
>
[ISHA] Yes, for serialization to and from Json,
[
https://issues.apache.org/jira/browse/APEXCORE-354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15171463#comment-15171463
]
ASF GitHub Bot commented on APEXCORE-354:
-
Github user chinmaykolhatkar commente
Github user chinmaykolhatkar commented on the pull request:
https://github.com/apache/incubator-apex-site/pull/14#issuecomment-190060348
Apologies for another comment.
@sashadt @sandeepdeshmukh Can one of you guys please review and merge?
Thanks,
Chinmay.
---
If
Hi Isha,
Couple of points:
1. Do the first curly brackets required? They seem to add another level of
hierarchy.
2. operatorRegex, operators, operatorList all seem to mention list list of
operators. Do you think we can come up with a simpler rather than providing
more options?
3. Having JSON innsi
+1
Checked following:
1. mvn rat check and unit tests passed
2. Launched pi demo.
On Mon, Feb 29, 2016 at 9:39 AM, Bright Chen wrote:
> +1
>
> - maven build and unit test
>
> thanks
> Bright
>
> > On Feb 27, 2016, at 10:39 PM, Isha Arkatkar
> wrote:
> >
> > +1
> >
> > Checked following on sou
+1
- maven build and unit test
thanks
Bright
> On Feb 27, 2016, at 10:39 PM, Isha Arkatkar wrote:
>
> +1
>
> Checked following on source tarball:
> - Maven build and unit tests
> - Rat check
> - Launched Pi demo
>
> Thanks,
> Isha
>
> On Sat, Feb 27, 2016 at 2:58 PM, Hitesh Shah wrote:
[
https://issues.apache.org/jira/browse/APEXCORE-10?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15171283#comment-15171283
]
ASF GitHub Bot commented on APEXCORE-10:
Github user ishark closed the pull reque
Github user ishark closed the pull request at:
https://github.com/apache/incubator-apex-core/pull/234
---
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 fe
[
https://issues.apache.org/jira/browse/APEXCORE-358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise resolved APEXCORE-358.
---
Resolution: Fixed
> Make RPC timeout configurable
> -
>
>
Vlad Rozov created APEXCORE-366:
---
Summary: Review CircularBuffer usage in the OperatorContext
Key: APEXCORE-366
URL: https://issues.apache.org/jira/browse/APEXCORE-366
Project: Apache Apex Core
[
https://issues.apache.org/jira/browse/APEXCORE-358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated APEXCORE-358:
--
Fix Version/s: 3.3.1
3.4.0
3.2.1
> Make RPC timeout conf
Github user asfgit closed the pull request at:
https://github.com/apache/incubator-apex-core/pull/248
---
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 fe
[
https://issues.apache.org/jira/browse/APEXCORE-358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15171249#comment-15171249
]
ASF GitHub Bot commented on APEXCORE-358:
-
Github user asfgit closed the pull re
[
https://issues.apache.org/jira/browse/APEXCORE-363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15171247#comment-15171247
]
ASF GitHub Bot commented on APEXCORE-363:
-
Github user vrozov commented on a dif
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/incubator-apex-core/pull/247#discussion_r54359261
--- Diff:
engine/src/main/java/com/datatorrent/stram/StreamingContainerManager.java ---
@@ -1558,6 +1558,10 @@ public void run()
en
Vlad Rozov created APEXCORE-365:
---
Summary: Raise exception when buffer server receives a tuple that
it can not handle
Key: APEXCORE-365
URL: https://issues.apache.org/jira/browse/APEXCORE-365
Project: A
[
https://issues.apache.org/jira/browse/APEXCORE-363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated APEXCORE-363:
--
Fix Version/s: 3.3.1
3.4.0
3.2.1
> NPE in StreamingConta
Vlad Rozov created APEXCORE-364:
---
Summary: Remove limit on the size of a tuple that buffer server
can handle
Key: APEXCORE-364
URL: https://issues.apache.org/jira/browse/APEXCORE-364
Project: Apache Ape
[
https://issues.apache.org/jira/browse/APEXCORE-363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15171241#comment-15171241
]
ASF GitHub Bot commented on APEXCORE-363:
-
Github user asfgit closed the pull re
Github user asfgit closed the pull request at:
https://github.com/apache/incubator-apex-core/pull/247
---
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 fe
[
https://issues.apache.org/jira/browse/APEXCORE-363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15171237#comment-15171237
]
ASF GitHub Bot commented on APEXCORE-363:
-
Github user tweise commented on a dif
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-core/pull/247#discussion_r54358885
--- Diff:
engine/src/main/java/com/datatorrent/stram/StreamingContainerManager.java ---
@@ -1558,6 +1558,10 @@ public void run()
en
Regarding the file name: It is probably not urgent but some time ago I had
filed the following to make the local file name configurable in the Apache
organization POM:
https://issues.apache.org/jira/browse/MPOM-90
Note that we could also rename the file before copying to SVN, but that
won't chang
[
https://issues.apache.org/jira/browse/APEXCORE-358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15171202#comment-15171202
]
ASF GitHub Bot commented on APEXCORE-358:
-
GitHub user vrozov opened a pull requ
GitHub user vrozov opened a pull request:
https://github.com/apache/incubator-apex-core/pull/248
APEXCORE-358 - Make RPC timeout configurable.
Introduced "com.datatorrent.stram.rpc.*" system properties that may be used
to set RPC timeouts.
@tweise Please merge
You can mer
GitHub user vrozov opened a pull request:
https://github.com/apache/incubator-apex-core/pull/247
APEXCORE-363 - NPE in StreamingContainerManager.
Skip null in the statistics list in case it was inserted as a result of
incorrect CircularBuffer usage in the OperatorContext.
@
[
https://issues.apache.org/jira/browse/APEXCORE-363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15171150#comment-15171150
]
ASF GitHub Bot commented on APEXCORE-363:
-
GitHub user vrozov opened a pull requ
[
https://issues.apache.org/jira/browse/APEXCORE-363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vlad Rozov updated APEXCORE-363:
Remaining Estimate: 4h
Original Estimate: 4h
> NPE in StreamingContainerManager
> ---
[
https://issues.apache.org/jira/browse/APEXCORE-362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vlad Rozov updated APEXCORE-362:
Remaining Estimate: 4h
Original Estimate: 4h
> NPE in StreamingContainerManager
> ---
[
https://issues.apache.org/jira/browse/APEXCORE-362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15171108#comment-15171108
]
ASF GitHub Bot commented on APEXCORE-362:
-
GitHub user vrozov opened a pull requ
GitHub user vrozov opened a pull request:
https://github.com/apache/incubator-apex-core/pull/246
APEXCORE-362 - NPE in StreamingContainerManager.
Fixed race condition between the thread that insert into
endWindowStatsOperatorMap and the thread that removes entries when
endWindowS
[
https://issues.apache.org/jira/browse/APEXCORE-31?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15171097#comment-15171097
]
Tushar Gosavi commented on APEXCORE-31:
---
Can we also evaluate akka, few projects ar
[
https://issues.apache.org/jira/browse/APEXCORE-362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vlad Rozov updated APEXCORE-362:
Description:
There is a possible race condition while end window statistics is calculated by
appl
[
https://issues.apache.org/jira/browse/APEXCORE-362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vlad Rozov updated APEXCORE-362:
Description:
There is a possible race condition while end window statistics is calculated by
appl
[
https://issues.apache.org/jira/browse/APEXCORE-353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vlad Rozov updated APEXCORE-353:
Affects Version/s: 3.2.1
> Buffer server may stop processing data
> --
Vlad Rozov created APEXCORE-363:
---
Summary: NPE in StreamingContainerManager
Key: APEXCORE-363
URL: https://issues.apache.org/jira/browse/APEXCORE-363
Project: Apache Apex Core
Issue Type: Bug
[
https://issues.apache.org/jira/browse/APEXCORE-31?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15171072#comment-15171072
]
Vlad Rozov commented on APEXCORE-31:
I'd suggest to evaluate both netlet and netty as
The vote is concluded and passes. Thanks everyone for voting and verifying
the release.
binding +1 (4)
David Yan
Thomas Weise
Chris Nauroth
Hitesh Shah
non-binding +1 (3)
Sandeep Deshmukh
Pradeep Kumbhar
Isha Arkatkar
No other votes.
Will forward for vote with the IPMC.
Thanks,
Bhupesh
On S
42 matches
Mail list logo
