Re: ExecutionConfig.enableTimestamps() in 1.0.0

Posted by Zach Cox on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/ExecutionConfig-enableTimestamps-in-1-0-0-tp5410p5426.html

I see the new Event Time docs page, thanks for fixing that! I like the additional explanation of event time and watermarks.

I also updated our TimestampExtractors to AssignerWithPeriodicWatermarks as described in [1]. I like the separation between periodic and punctuated watermark assigners in the new API - it's definitely more clear how each one operates.

Thanks,
Zach

[1] https://ci.apache.org/projects/flink/flink-docs-release-1.0/apis/streaming/event_timestamps_watermarks.html


On Thu, Mar 10, 2016 at 3:33 AM Ufuk Celebi <[hidden email]> wrote:
Just removed the page. Triggering a new docs build...

On Thu, Mar 10, 2016 at 10:22 AM, Aljoscha Krettek <[hidden email]> wrote:
> Then Stephan should have removed the old doc when adding the new one… :-)
>> On 10 Mar 2016, at 10:20, Ufuk Celebi <[hidden email]> wrote:
>>
>> Just talked with Stephan: the document you are referring to is stale.
>> Can you check out this one here:
>> https://ci.apache.org/projects/flink/flink-docs-release-1.0/apis/streaming/event_time.html
>>
>> – Ufuk
>>
>>
>> On Thu, Mar 10, 2016 at 10:17 AM, Ufuk Celebi <[hidden email]> wrote:
>>> I've added this to the migration guide here:
>>> https://cwiki.apache.org/confluence/display/FLINK/Migration+Guide%3A+0.10.x+to+1.0.x
>>>
>>> Feel free to add any other API changes that are missing there.
>>>
>>> – Ufuk
>>>
>>>
>>> On Thu, Mar 10, 2016 at 10:13 AM, Aljoscha Krettek <[hidden email]> wrote:
>>>> Hi,
>>>> you’re right, this should be changed to “setStreamTimeCharacteristic(EventTime)” in the doc.
>>>>
>>>> Cheers,
>>>> Aljoscha
>>>>> On 09 Mar 2016, at 23:21, Zach Cox <[hidden email]> wrote:
>>>>>
>>>>> Hi - I'm upgrading our app to 1.0.0 and noticed ExecutionConfig no longer has an enableTimestamps() method. Do we just not need to call that at all now?
>>>>>
>>>>> The docs still say to call it [1] - do they just need to be updated?
>>>>>
>>>>> Thanks,
>>>>> Zach
>>>>>
>>>>> [1] https://ci.apache.org/projects/flink/flink-docs-release-1.0/apis/streaming/time.html
>>>>>
>>>>
>