Github user Shubham0411 closed the pull request at:
https://github.com/apache/apex-malhar/pull/557
---
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
[
https://issues.apache.org/jira/browse/APEXCORE-652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated APEXCORE-652:
--
Labels: newbie (was: )
> Error in document for PI example
>
[
https://issues.apache.org/jira/browse/APEXCORE-652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise moved APEXMALHAR-2423 to APEXCORE-652:
---
Workflow: jira (was: Default workflow, editable Closed
[
https://issues.apache.org/jira/browse/APEXMALHAR-2420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise deleted APEXMALHAR-2420:
-
> Error in document for PI example
> -
>
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise moved APEXCORE-651 to APEXMALHAR-2423:
---
Component/s: (was: Documentation)
Workflow:
[
https://issues.apache.org/jira/browse/APEXMALHAR-2422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sandesh updated APEXMALHAR-2422:
Description:
In WindowDataManager getLargestWindow during recovery is not reflecting the
Sandesh created APEXMALHAR-2422:
---
Summary: WindowDataManager not recovering as expected on HDFS
Key: APEXMALHAR-2422
URL: https://issues.apache.org/jira/browse/APEXMALHAR-2422
Project: Apache Apex
[
https://issues.apache.org/jira/browse/APEXMALHAR-2420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongming Liang closed APEXMALHAR-2420.
--
Resolution: Duplicate
> Error in document for PI example
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15879556#comment-15879556
]
Dongming Liang commented on APEXMALHAR-2420:
Moved to
Dongming Liang created APEXCORE-651:
---
Summary: Error in document for PI example
Key: APEXCORE-651
URL: https://issues.apache.org/jira/browse/APEXCORE-651
Project: Apache Apex Core
Issue
[
https://issues.apache.org/jira/browse/APEXMALHAR-2421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongming Liang closed APEXMALHAR-2421.
--
Resolution: Duplicate
> Error in document for PI example
>
[
https://issues.apache.org/jira/browse/APEXCORE-650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sandesh updated APEXCORE-650:
-
Description: ResetWindowTuple raises the complexity of the engine and
development, without much
Dongming Liang created APEXMALHAR-2421:
--
Summary: Error in document for PI example
Key: APEXMALHAR-2421
URL: https://issues.apache.org/jira/browse/APEXMALHAR-2421
Project: Apache Apex Malhar
Sandesh created APEXCORE-650:
Summary: Remove ResetWindowTuple
Key: APEXCORE-650
URL: https://issues.apache.org/jira/browse/APEXCORE-650
Project: Apache Apex Core
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/APEXMALHAR-2420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15879541#comment-15879541
]
Dongming Liang commented on APEXMALHAR-2420:
This should be filed under apex-core. Will
Dongming Liang created APEXMALHAR-2420:
--
Summary: Error in document for PI example
Key: APEXMALHAR-2420
URL: https://issues.apache.org/jira/browse/APEXMALHAR-2420
Project: Apache Apex Malhar
[
https://issues.apache.org/jira/browse/APEXMALHAR-2373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongming Liang reassigned APEXMALHAR-2373:
--
Assignee: Dongming Liang
> JdbcOutputOperator does not handle NUMERIC
[
https://issues.apache.org/jira/browse/APEXMALHAR-2419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sandesh updated APEXMALHAR-2419:
Comment: was deleted
(was: Fix is here, until it is merged.
[
https://issues.apache.org/jira/browse/APEXMALHAR-2419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15879182#comment-15879182
]
Thomas Weise commented on APEXMALHAR-2419:
--
Completed windows (endWindow) are supposed to be
[
https://issues.apache.org/jira/browse/APEXMALHAR-2419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15878951#comment-15878951
]
Sandesh edited comment on APEXMALHAR-2419 at 2/22/17 6:46 PM:
--
Largest
[
https://issues.apache.org/jira/browse/APEXMALHAR-2419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15878951#comment-15878951
]
Sandesh commented on APEXMALHAR-2419:
-
Largest completed window is moving only after a committed
[
https://issues.apache.org/jira/browse/APEXMALHAR-2414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15878926#comment-15878926
]
ASF GitHub Bot commented on APEXMALHAR-2414:
GitHub user Hitesh-Scorpio opened a pull
[
https://issues.apache.org/jira/browse/APEXMALHAR-2239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15878743#comment-15878743
]
Dongming Liang commented on APEXMALHAR-2239:
[~Hitesh_]I'll work on the comments today.
Hi Bhupesh,
This looks great. You use the watermark as measure of completeness and the
window to isolate the state, which is how it should work.
Questions/comments:
Why does the count operator have a 2ms window when this should be driven by
the watermark from the input operator?
I don't think
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/477
APEXCORE-648 Unnecessary byte array copy in
DefaultStatefulStreamCodec.toDataStatePair()
@sandeshh Please review and merge
You can merge this pull request into a Git repository by running:
[
https://issues.apache.org/jira/browse/APEXCORE-648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15878618#comment-15878618
]
ASF GitHub Bot commented on APEXCORE-648:
-
GitHub user vrozov opened a pull request:
[
https://issues.apache.org/jira/browse/APEXMALHAR-2419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15878506#comment-15878506
]
Munagala V. Ramanath commented on APEXMALHAR-2419:
--
To clarify, the point of the
[
https://issues.apache.org/jira/browse/APEXMALHAR-2419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15878463#comment-15878463
]
Munagala V. Ramanath commented on APEXMALHAR-2419:
--
[~sandesh] Does "recovery is not
I think this could be a good way to improve readability of code in Malhar
operators as well.
This one however is MIT license. Any alternatives?
~ Bhupesh
___
Bhupesh Chawda
Software Engineer
E: bhup...@datatorrent.com | Twitter: @bhupeshsc
Yes Amol,
Watermarks, in general solve a different issue and we should not mix it
with data association. If needed, the data association can be solved by the
user on the operator/ application layer. The engine should not worry about
it.
Regarding your point on event time based watermarks, I think
Hi Thomas,
Sorry for the delay.
I agree that the watermark concept is general and is understood by
intermediate transformations. File name is some additional information in
the watermark which helps the start and end operators do stuff related to
batch.
As suggested, I have created a wordcount
[
https://issues.apache.org/jira/browse/APEXMALHAR-2380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chaitanya resolved APEXMALHAR-2380.
---
Resolution: Fixed
Fix Version/s: 3.7.0
> Add MutablePair for Kinensis Operator
[
https://issues.apache.org/jira/browse/APEXCORE-634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tushar Gosavi resolved APEXCORE-634.
Resolution: Fixed
Fix Version/s: 3.6.0
> Apex Platform unable to set unifier
[
https://issues.apache.org/jira/browse/APEXCORE-634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15878031#comment-15878031
]
ASF GitHub Bot commented on APEXCORE-634:
-
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/apex-core/pull/466
---
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 is
Certainly good and convenient for application/operator developers to use.
But could someone include this dependency in apex application project and
use it?
If yes, then I would prefer to keep this outside of Apex in general and let
the user use it for convenience.
-Chinmay.
On Wed, Feb 22,
The Java operators we write have a lot of code which is less related to the
business logic of the operator, eg. getters, setters, constructors, log
variables, etc.
Lombok library can be used to greatly avoid such code by using annotations,
eg. @Getter, @Setter. The library generates this code
[
https://issues.apache.org/jira/browse/APEXMALHAR-2239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1585#comment-1585
]
Hitesh Kapoor commented on APEXMALHAR-2239:
---
[~d9liang] Have you had a chance to go over
38 matches
Mail list logo