Jim,
Is there state in the rest of the operators in your application? If that
cases storing the offsets only the input operator(s) is not sufficient as
you will lose the state from the other operators in your DAG. Second
modifying idempotent storage manager to store in an external location,
while
@apex.incubator.apache.org
Subject: Re: Kinesis Operator Help
Jim,
You can put the following line in a shell script,
dtcli - e "launch -originalAppId apppid apa_path"
Even you can shutdown the app from the shell script.
On Tue, Feb 16, 2016, 10:22 PM Munagala Ramanath
<r...@datatorrent
d!
>>
>>
>>
>> Jim
>>
>>
>>
>> *From:* Munagala Ramanath [mailto:r...@datatorrent.com]
>> *Sent:* Tuesday, February 16, 2016 5:21 PM
>> *To:* users@apex.incubator.apache.org
>> *Subject:* Re: Kinesis Operator Help
>>
>>
he cli to do some
> commands (because at some point some operator will forget and then we will
> reprocess a bunch of transactions; that would not be good!
>
>
>
> Jim
>
>
>
> *From:* Munagala Ramanath [mailto:r...@datatorrent.com]
> *Sent:* Tuesday, February 16,
