[
https://issues.apache.org/jira/browse/APEXMALHAR-2011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15217524#comment-15217524
]
ASF GitHub Bot commented on APEXMALHAR-2011:
Github user chinmaykolhatkar
[
https://issues.apache.org/jira/browse/APEXMALHAR-2011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15217522#comment-15217522
]
ASF GitHub Bot commented on APEXMALHAR-2011:
Github user chinmaykolhatkar
Github user chinmaykolhatkar commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57843812
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroToPojo.java ---
@@ -0,0 +1,415 @@
+/**
+ * Licensed to the A
Github user chinmaykolhatkar commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57843723
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroToPojo.java ---
@@ -0,0 +1,415 @@
+/**
+ * Licensed to the A
[
https://issues.apache.org/jira/browse/APEXMALHAR-2011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15217521#comment-15217521
]
ASF GitHub Bot commented on APEXMALHAR-2011:
Github user chinmaykolhatkar
Github user chinmaykolhatkar commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57843629
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroToPojo.java ---
@@ -0,0 +1,415 @@
+/**
+ * Licensed to the A
[
https://issues.apache.org/jira/browse/APEXMALHAR-2011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15217520#comment-15217520
]
ASF GitHub Bot commented on APEXMALHAR-2011:
Github user chinmaykolhatkar
Github user chinmaykolhatkar commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57843644
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroToPojo.java ---
@@ -0,0 +1,415 @@
+/**
+ * Licensed to the A
[
https://issues.apache.org/jira/browse/APEXMALHAR-2011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15217504#comment-15217504
]
ASF GitHub Bot commented on APEXMALHAR-2011:
Github user chinmaykolhatkar
[
https://issues.apache.org/jira/browse/APEXMALHAR-2011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15217503#comment-15217503
]
ASF GitHub Bot commented on APEXMALHAR-2011:
Github user chinmaykolhatkar
Github user chinmaykolhatkar commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57842448
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroFileInputOperator.java
---
@@ -0,0 +1,164 @@
+/**
+ * Licen
Github user chinmaykolhatkar commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57842432
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroFileInputOperator.java
---
@@ -0,0 +1,164 @@
+/**
+ * Licen
[
https://issues.apache.org/jira/browse/APEXMALHAR-2011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15217498#comment-15217498
]
ASF GitHub Bot commented on APEXMALHAR-2011:
Github user chinmaykolhatkar
Github user chinmaykolhatkar commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57842179
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroFileInputOperator.java
---
@@ -0,0 +1,164 @@
+/**
+ * Licen
[
https://issues.apache.org/jira/browse/APEXMALHAR-2011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15217495#comment-15217495
]
ASF GitHub Bot commented on APEXMALHAR-2011:
Github user chinmaykolhatkar
Github user chinmaykolhatkar commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57842065
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroFileInputOperator.java
---
@@ -0,0 +1,164 @@
+/**
+ * Licen
[
https://issues.apache.org/jira/browse/APEXMALHAR-2011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15217492#comment-15217492
]
ASF GitHub Bot commented on APEXMALHAR-2011:
Github user chinmaykolhatkar
Github user chinmaykolhatkar commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57841961
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroFileInputOperator.java
---
@@ -0,0 +1,164 @@
+/**
+ * Licen
[
https://issues.apache.org/jira/browse/APEXMALHAR-2011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15217487#comment-15217487
]
ASF GitHub Bot commented on APEXMALHAR-2011:
Github user chinmaykolhatkar
Github user chinmaykolhatkar commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57841688
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroFileInputOperator.java
---
@@ -0,0 +1,164 @@
+/**
+ * Licen
[
https://issues.apache.org/jira/browse/APEXMALHAR-2011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15217480#comment-15217480
]
ASF GitHub Bot commented on APEXMALHAR-2011:
Github user chinmaykolhatkar
Github user chinmaykolhatkar commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57841449
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroFileInputOperator.java
---
@@ -0,0 +1,164 @@
+/**
+ * Licen
Github user chinmaykolhatkar commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57841319
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroFileInputOperator.java
---
@@ -0,0 +1,164 @@
+/**
+ * Licen
[
https://issues.apache.org/jira/browse/APEXMALHAR-2011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15217476#comment-15217476
]
ASF GitHub Bot commented on APEXMALHAR-2011:
Github user chinmaykolhatkar
Github user chinmaykolhatkar commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57841247
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroFileInputOperator.java
---
@@ -0,0 +1,164 @@
+/**
+ * Licen
[
https://issues.apache.org/jira/browse/APEXMALHAR-2011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15217473#comment-15217473
]
ASF GitHub Bot commented on APEXMALHAR-2011:
Github user chinmaykolhatkar
Ashwin, abstract class isn't suitable.
The basic ingredient is WAL, from which the operator consumes as
appropriate. We already have the WAL implementation.
Incoming tuples are added to the WAL, consumption is async. WAL offset is
checkpointed.
--
sent from mobile
On Mar 29, 2016 2:03 PM, "Ashwi
@Ashwin yes, It's fault tolarant. The variable waitingTuple will get
checkpointed and will hold the tuples that needs to be processed. In case
of failures it re-enqueues any tuples still left in this variable.
On Wed, Mar 30, 2016 at 2:33 AM, Ashwin Chandra Putta <
ashwinchand...@gmail.com> wrote
David,
I am not sure but can we restart the app in same directory as that of
killed app directory. That way copying of whole data for killed app (which
could be huge in some cases) will be avoided.
I know that currently when we restart the app, a new app_id is assigned to
it. Are there any complica
Ashwin,
This is for restarting the application from previous state (configuration
was already applied).
You can change properties on the running app.
Thomas
On Tue, Mar 29, 2016 at 11:51 AM, Ashwin Chandra Putta <
ashwinchand...@gmail.com> wrote:
> +1 for this feature, this is help reduce the
Thanks David.
+1 for adding the feature.
On Wed, Mar 30, 2016 at 12:21 AM, Ashwin Chandra Putta <
ashwinchand...@gmail.com> wrote:
> +1 for this feature, this is help reduce the steps to relaunch an
> application. If we do not have any changes to app package / properties, we
> should be able to
Github user chandnisingh commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/204#discussion_r57832121
--- Diff: library/src/main/java/org/apache/apex/malhar/lib/wal/FSWal.java
---
@@ -0,0 +1,178 @@
+/**
+ * Licensed to the Apache S
[
https://issues.apache.org/jira/browse/APEXMALHAR-1965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15217312#comment-15217312
]
ASF GitHub Bot commented on APEXMALHAR-1965:
Github user chandnisingh com
[
https://issues.apache.org/jira/browse/APEXMALHAR-2036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chandni Singh resolved APEXMALHAR-2036.
---
Resolution: Fixed
Fix Version/s: 3.4.0
> FS operator tests leave stray tes
[
https://issues.apache.org/jira/browse/APEXMALHAR-1965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15217287#comment-15217287
]
ASF GitHub Bot commented on APEXMALHAR-1965:
Github user tweise commented
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/204#discussion_r57830582
--- Diff: library/src/main/java/org/apache/apex/malhar/lib/wal/FSWal.java
---
@@ -0,0 +1,178 @@
+/**
+ * Licensed to the Apache Softwar
[
https://issues.apache.org/jira/browse/APEXMALHAR-2036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15217238#comment-15217238
]
ASF GitHub Bot commented on APEXMALHAR-2036:
Github user asfgit closed th
Github user asfgit closed the pull request at:
https://github.com/apache/incubator-apex-malhar/pull/224
---
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
+1
Thanks,
Chandni
On Sat, Mar 26, 2016 at 8:27 PM, Rajesh Battala <
rajesh.batt...@accelerite.com> wrote:
> +1
>
> Thanks
> Rajesh Battala
>
> -Original Message-
> From: Pramod Immaneni [mailto:pra...@apache.org]
> Sent: Tuesday, March 22, 2016 11:07 PM
> To: dev@apex.incubator.apache.o
Sandesh created APEXCORE-412:
Summary: Javadoc - THREAD_LOCAL - remove "not implemented" line
Key: APEXCORE-412
URL: https://issues.apache.org/jira/browse/APEXCORE-412
Project: Apache Apex Core
I
Github user chandnisingh closed the pull request at:
https://github.com/apache/incubator-apex-malhar/pull/223
---
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 i
[
https://issues.apache.org/jira/browse/APEXMALHAR-2036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15216990#comment-15216990
]
ASF GitHub Bot commented on APEXMALHAR-2036:
GitHub user chandnisingh ope
GitHub user chandnisingh opened a pull request:
https://github.com/apache/incubator-apex-malhar/pull/224
APEXMALHAR-2036 cleanup of intermediate test files
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/chandnisingh/incubator-ap
[
https://issues.apache.org/jira/browse/APEXMALHAR-2036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15216985#comment-15216985
]
ASF GitHub Bot commented on APEXMALHAR-2036:
Github user chandnisingh clo
Github user asfgit closed the pull request at:
https://github.com/apache/incubator-apex-core/pull/288
---
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-409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15216915#comment-15216915
]
ASF GitHub Bot commented on APEXCORE-409:
-
Github user asfgit closed the pull re
Github user asfgit closed the pull request at:
https://github.com/apache/incubator-apex-core/pull/289
---
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-409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15216876#comment-15216876
]
ASF GitHub Bot commented on APEXCORE-409:
-
Github user PramodSSImmaneni commente
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/incubator-apex-core/pull/288#discussion_r57803619
--- Diff: docs/application_development.md ---
@@ -1196,12 +1194,54 @@ public class Application implements
StreamingApplication
}
[
https://issues.apache.org/jira/browse/APEXMALHAR-1965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15216859#comment-15216859
]
ASF GitHub Bot commented on APEXMALHAR-1965:
Github user chandnisingh com
Github user chandnisingh commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/204#discussion_r57802416
--- Diff: library/src/main/java/org/apache/apex/malhar/lib/wal/FSWal.java
---
@@ -0,0 +1,178 @@
+/**
+ * Licensed to the Apache S
[
https://issues.apache.org/jira/browse/APEXMALHAR-1965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15216843#comment-15216843
]
ASF GitHub Bot commented on APEXMALHAR-1965:
Github user ishark commented
Github user ishark commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/204#discussion_r57801373
--- Diff: library/src/main/java/org/apache/apex/malhar/lib/wal/FSWal.java
---
@@ -0,0 +1,178 @@
+/**
+ * Licensed to the Apache Softwar
GitHub user davidyan74 opened a pull request:
https://github.com/apache/incubator-apex-core/pull/289
Added volatile for unit test
@PramodSSImmaneni I missed the second volatile last time. please merge
You can merge this pull request into a Git repository by running:
$ git pull
@Chinmay I went through your code and related comments on pull request. I
was originally thinking of using AbstractReconciler but seems like
AbstractAsyncProcessor will be better because 1. it has multithreaded
output 2. it does not wait for committed window to process queued tuples.
One question t
[
https://issues.apache.org/jira/browse/APEXMALHAR-2033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15216823#comment-15216823
]
devendra tagare commented on APEXMALHAR-2033:
-
Has an apache license for
[
https://issues.apache.org/jira/browse/APEXMALHAR-2011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15216781#comment-15216781
]
ASF GitHub Bot commented on APEXMALHAR-2011:
GitHub user devtagare reopen
[
https://issues.apache.org/jira/browse/APEXMALHAR-2011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15216780#comment-15216780
]
ASF GitHub Bot commented on APEXMALHAR-2011:
Github user devtagare closed
Github user devtagare closed the pull request at:
https://github.com/apache/incubator-apex-malhar/pull/211
---
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 t
GitHub user devtagare reopened a pull request:
https://github.com/apache/incubator-apex-malhar/pull/211
APEXMALHAR-2011-2012 Avro to Pojo & Pojo to Avro converter
Please review changes for Avro to Pojo conversion & back.
Thanks,
Dev
You can merge this pull request into
[
https://issues.apache.org/jira/browse/APEXCORE-409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15216774#comment-15216774
]
ASF GitHub Bot commented on APEXCORE-409:
-
Github user davidyan74 commented on t
Github user davidyan74 commented on the pull request:
https://github.com/apache/incubator-apex-core/pull/288#issuecomment-203084641
@PramodSSImmaneni okay, please review again
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as we
+1 for this feature, this is help reduce the steps to relaunch an
application. If we do not have any changes to app package / properties, we
should be able to launch without providing app package/properties and
automatically picking the previously supplied properties file and
additional properties.
The ability to restart an app without app package will require some changes
in Apex Core.
I created a ticket to track this issue:
https://issues.apache.org/jira/browse/APEXCORE-411
David
On Tue, Mar 29, 2016 at 6:12 AM, Thomas Weise
wrote:
> It is possible to relaunch an application with new
David Yan created APEXCORE-411:
--
Summary: Restart app without specifying app package
Key: APEXCORE-411
URL: https://issues.apache.org/jira/browse/APEXCORE-411
Project: Apache Apex Core
Issue Typ
Can this be solved through a pluggable component of operator, similar to
window data manager?
On Tue, Mar 29, 2016 at 11:18 AM, Siyuan Hua wrote:
> +1 on making it a feature for all output operators that depend on external
> system
>
> On Mon, Mar 28, 2016 at 11:55 PM, Sandeep Deshmukh <
> sand
[
https://issues.apache.org/jira/browse/APEXCORE-409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15216542#comment-15216542
]
ASF GitHub Bot commented on APEXCORE-409:
-
Github user PramodSSImmaneni commente
+1 on making it a feature for all output operators that depend on external
system
On Mon, Mar 28, 2016 at 11:55 PM, Sandeep Deshmukh
wrote:
> +1 on making it apex feature.
> On 29-Mar-2016 12:22 pm, "Tushar Gosavi" wrote:
>
> > +1 for the idea, love to have this feature available for operators
Github user PramodSSImmaneni commented on the pull request:
https://github.com/apache/incubator-apex-core/pull/288#issuecomment-203034681
I think we can keep in app dev guide because we also have the property way
of building apps there (apart from java). You can link from app packages
[
https://issues.apache.org/jira/browse/APEXCORE-409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15216538#comment-15216538
]
ASF GitHub Bot commented on APEXCORE-409:
-
Github user davidyan74 commented on t
Github user davidyan74 commented on the pull request:
https://github.com/apache/incubator-apex-core/pull/288#issuecomment-203033540
@PramodSSImmaneni I thought about that too, but I think it's more useful
for the user to learn about the JSON format in the context of app package. Or
Github user PramodSSImmaneni commented on the pull request:
https://github.com/apache/incubator-apex-core/pull/288#issuecomment-203023100
Shouldn't this be in application developer guide instead of application
packages
---
If your project is set up for it, you can reply to this emai
[
https://issues.apache.org/jira/browse/APEXCORE-409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15216449#comment-15216449
]
ASF GitHub Bot commented on APEXCORE-409:
-
Github user PramodSSImmaneni commente
[
https://issues.apache.org/jira/browse/APEXMALHAR-2011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15216442#comment-15216442
]
ASF GitHub Bot commented on APEXMALHAR-2011:
Github user devtagare commen
[
https://issues.apache.org/jira/browse/APEXMALHAR-2011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15216443#comment-15216443
]
ASF GitHub Bot commented on APEXMALHAR-2011:
Github user devtagare commen
Github user devtagare commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57766719
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroFileInputOperator.java
---
@@ -0,0 +1,159 @@
+/**
+ * Licensed to
Github user devtagare commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57766614
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroFileInputOperator.java
---
@@ -0,0 +1,159 @@
+/**
+ * Licensed to
Github user devtagare commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57766680
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroFileInputOperator.java
---
@@ -0,0 +1,159 @@
+/**
+ * Licensed to
[
https://issues.apache.org/jira/browse/APEXMALHAR-2011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15216440#comment-15216440
]
ASF GitHub Bot commented on APEXMALHAR-2011:
Github user devtagare commen
[
https://issues.apache.org/jira/browse/APEXMALHAR-2011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15216392#comment-15216392
]
ASF GitHub Bot commented on APEXMALHAR-2011:
Github user devtagare commen
Github user devtagare commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57763599
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroFileInputOperator.java
---
@@ -0,0 +1,159 @@
+/**
+ * Licensed to
[
https://issues.apache.org/jira/browse/APEXMALHAR-2011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15216385#comment-15216385
]
ASF GitHub Bot commented on APEXMALHAR-2011:
Github user devtagare commen
[
https://issues.apache.org/jira/browse/APEXMALHAR-2011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15216381#comment-15216381
]
ASF GitHub Bot commented on APEXMALHAR-2011:
Github user devtagare commen
Github user devtagare commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57763061
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroFileInputOperator.java
---
@@ -0,0 +1,159 @@
+/**
+ * Licensed to
Github user devtagare commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57762934
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroFileInputOperator.java
---
@@ -0,0 +1,159 @@
+/**
+ * Licensed to
Failure in reading a record should not cause a failure to read the entire
file.
On Tue, Mar 29, 2016 at 10:18 AM, chinmaykolhatkar
wrote:
> Github user chinmaykolhatkar commented on a diff in the pull request:
>
>
> https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57762245
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15216372#comment-15216372
]
ASF GitHub Bot commented on APEXMALHAR-2011:
Github user chinmaykolhatkar
Github user chinmaykolhatkar commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57762245
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroFileInputOperator.java
---
@@ -0,0 +1,159 @@
+/**
+ * Licen
[
https://issues.apache.org/jira/browse/APEXMALHAR-2011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15216366#comment-15216366
]
ASF GitHub Bot commented on APEXMALHAR-2011:
Github user chinmaykolhatkar
Github user chinmaykolhatkar commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57762011
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroFileInputOperator.java
---
@@ -0,0 +1,159 @@
+/**
+ * Licen
[
https://issues.apache.org/jira/browse/APEXMALHAR-2011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15216355#comment-15216355
]
ASF GitHub Bot commented on APEXMALHAR-2011:
Github user chinmaykolhatkar
Github user chinmaykolhatkar commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57761599
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroFileInputOperator.java
---
@@ -0,0 +1,159 @@
+/**
+ * Licen
Github user chinmaykolhatkar commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57761587
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroFileInputOperator.java
---
@@ -0,0 +1,159 @@
+/**
+ * Licen
Github user chinmaykolhatkar commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57761540
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroFileInputOperator.java
---
@@ -0,0 +1,159 @@
+/**
+ * Licen
[
https://issues.apache.org/jira/browse/APEXMALHAR-2011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15216353#comment-15216353
]
ASF GitHub Bot commented on APEXMALHAR-2011:
Github user chinmaykolhatkar
[
https://issues.apache.org/jira/browse/APEXMALHAR-2011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15216356#comment-15216356
]
ASF GitHub Bot commented on APEXMALHAR-2011:
Github user chinmaykolhatkar
[
https://issues.apache.org/jira/browse/APEXMALHAR-2011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15216349#comment-15216349
]
ASF GitHub Bot commented on APEXMALHAR-2011:
Github user chinmaykolhatkar
Github user chinmaykolhatkar commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57761346
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroFileInputOperator.java
---
@@ -0,0 +1,159 @@
+/**
+ * Licen
[
https://issues.apache.org/jira/browse/APEXMALHAR-2011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15216347#comment-15216347
]
ASF GitHub Bot commented on APEXMALHAR-2011:
Github user chinmaykolhatkar
Github user chinmaykolhatkar commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/211#discussion_r57761130
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/avro/AvroFileInputOperator.java
---
@@ -0,0 +1,159 @@
+/**
+ * Licen
1 - 100 of 113 matches
Mail list logo
