+1 for best efforts with warning logs.
Regards,
Mohit
Sent from my iPhone
> On Aug 6, 2017, at 12:42 AM, Vlad Rozov wrote:
>
> I don't see need for the flag either. The output of the command should be
> what applications were stopped/shutdown and which one were not (for any
> reason).
>
>
ange and exchange Type as specified specified. *
> >
> > *Setup:*
> >
> > rabbitMQInputOperator.setQueueName("test");
> > rabbitMQInputOperator.setExchangeType("fanout");
> > rabbitMQInputOperator.setExchange("new_exchange");
> > rabbitMQInputOperator.setRoutingKey("test");
> > rabbitMQInputOperator.setHost("localhost");
> > rabbitMQInputOperator.setPort(5672);
> > *Result:*
> > Worked with no issues. But it demands that it durable queue has to be
> > created with proper exchange and routing key
> >
> > *4) Queuename not specified in an app but exchange and exchangeType
> > specified for Operator *
> >
> > *Setup:*
> > rabbitMQInputOperator.setExchangeType("fanout");
> > rabbitMQInputOperator.setExchange("new_exchange");
> > rabbitMQInputOperator.setHost("localhost");
> > rabbitMQInputOperator.setRoutingKey("test");
> > rabbitMQInputOperator.setPort(5672);
> >
> > *Result:*
> > Operator ended up creating queue with unique names such as
> > “amq.gen-dHDsywLO-8eV8qZM4Q4T_w” which gets auto deleted when last
> > consumer stops consuming from it.
> >
> >
> > Thanks & Regards,
> > Vikram
> >
>
--
Regards,
___
*Mohit Jotwani*
Product Manager
E: mo...@datatorrent.com | M: +91 97699 62740
www.datatorrent.com | apex.apache.org
ds on core 3.4. Custom tuple support has
> > been
> > > > added to core in 3.6. Hence, malhar dependency needs to be updated.
> > > > This is necessary for changing the malhar operators for batch use
> > cases.
> > > >
> > > > Let
+1
Regards,
Mohit
On Tue, Jan 17, 2017 at 12:11 PM, Bhupesh Chawda
wrote:
> +1 for the feature.
>
> ~ Bhupesh
>
> On Mon, Jan 16, 2017 at 5:09 PM, Chinmay Kolhatkar
> wrote:
>
> > Those are not really anonymous POJOs... The definition of POJO will be
> > known to user as based on that only ups
I would agree with Milind.
Regards,
Mohit
On Fri, Dec 2, 2016 at 12:49 PM, Milind Barve wrote:
> Additionally, this would apply to Stram as well i.e. the master should also
> not be deployed on these nodes. Not sure if anti-affinity goes beyond
> operators.
>
> On Fri, Dec 2, 2016 at 12:47 PM,
This is a practical scenario where developers would be required to exclude
certain nodes as they might be required for some mission critical
applications. It would be good to have this feature.
I understand that Stram should not get into resourcing and still rely on
Yarn, however, as the App Maste
+1 for David's approach
Regards,
Mohit
On Tue, Nov 29, 2016 at 11:17 AM, Chinmay Kolhatkar
wrote:
> David,
>
> Your suggestion make sense. This will also help in the idempotency.
> I'll also change the name of interface to WatermarkGenerator.
>
> I had 2 more questions here:
> 1. AbstractWindo
+1
Regards,
Mohit
On Tue, Nov 29, 2016 at 12:30 PM, Aniruddha Thombare <
anirud...@datatorrent.com> wrote:
> +1
> I would also request graphical representation for ease of understanding.
> I could not find any illustrations about Apex internals.
> If someone knows, please point me to it.
> If it
+1 - Approach 2
Regards,
Mohit
On Wed, Nov 23, 2016 at 12:35 PM, AJAY GUPTA wrote:
> +1 for approach 2.
>
>
> Regards,
> Ajay
>
> On Wed, Nov 23, 2016 at 12:16 PM, David Yan wrote:
>
> > The goal of this log4j appender is to provide a log offset and the fixed
> > name of the container log file
+1
Regards,
Mohit
On Thu, Nov 17, 2016 at 11:20 AM, Tushar Gosavi wrote:
> Hi All,
>
> How about adding visitor like API for DAG in Apex, and an api to
> register visitor for the DAG.
> Possible use cases are
> - Validator visitor which could validate the dag
> - Visitor to inject properties/
Finally! Congratulations!!
Very well done
Regards,
Mohit
On Mon, Nov 7, 2016 at 2:55 PM, Bhupesh Chawda
wrote:
> Hi All,
>
> The PR for making Apex a runner for SAMOA has been merged.
>
> Apache SAMOA now has an additional runner with Apache Apex -
> https://github.com/apache/incubator-sam
+1 for Solution 2
Regards,
Mohit
On 27 Oct 2016 2:02 p.m., "Sandeep Deshmukh"
wrote:
> +1
>
> Regards,
> Sandeep
>
> On Thu, Oct 27, 2016 at 1:53 PM, Chaitanya Chebolu <
> chaita...@datatorrent.com> wrote:
>
> > Hi All,
> >
> > I am planning to implement the approach (2) of S3 Output Module wh
+1
Regards,
Mohit
On Fri, Oct 28, 2016 at 5:17 AM, Sandesh Hegde
wrote:
> Here is a one more jira for 3.6, I need few more days to open the PR.
> https://issues.apache.org/jira/browse/APEXMALHAR-2298?filter=-1
>
> Thanks
>
>
> On Thu, Oct 27, 2016 at 10:28 AM Vlad Rozov
> wrote:
>
> +1. It wil
+1
Regards,
Mohit
On Mon, Oct 3, 2016 at 8:42 AM, Chaitanya Chebolu wrote:
> +1
>
> Regards,
> Chaitanya
>
> On Mon, Oct 3, 2016 at 6:01 PM, Sanjay Pujare
> wrote:
>
> > +1
> >
> > On Oct 3, 2016 5:33 PM, "Sandeep Deshmukh"
> > wrote:
> >
> > > +1
> > >
> > > Regards,
> > > Sandeep
> > >
> >
Hi Kartavya,
This is a good initiative.
+1
Regards,
Mohit
On Wed, Aug 10, 2016 at 5:22 AM, Kartavya Jain
wrote:
> Hi Pramod,
>
> +1 for "Initiatives". And yes, I would appreciate some help to make these
> changes on the website.
>
> Thanks,
> Kartavya
>
> On Tue, Aug 9, 2016 at 4:48 PM, Pramo
Dear Community,
+1 to Bhupesh's suggestion.
I would suggest to go ahead with the Managed State and once we have proper
analysis on the windowed operator + large storage backed windowed operator
- we should implement operators such as dedup with it.
Regards,
Mohit
On Mon, Jul 18, 2016 at 12:35 P
16 matches
Mail list logo
