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
>>
>>
2016 5:21 PM
> *To:* users@apex.incubator.apache.org
> *Subject:* Re: Kinesis Operator Help
>
>
>
> Why use the application id ? Could you generate and use a java.util.UUID
> for example and save it in HDFS ?
>
>
>
> Ram
>
>
>
> On Tue, Feb 16, 2016 at 11:4
