You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/08/02 22:18:00 UTC

[jira] [Work logged] (BEAM-867) Support set/delete of timers by ID in Flink runner

     [ https://issues.apache.org/jira/browse/BEAM-867?focusedWorklogId=130657&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-130657 ]

ASF GitHub Bot logged work on BEAM-867:
---------------------------------------

                Author: ASF GitHub Bot
            Created on: 02/Aug/18 22:17
            Start Date: 02/Aug/18 22:17
    Worklog Time Spent: 10m 
      Work Description: reuvenlax commented on issue #4119: [BEAM-867] Add schema update options to BigQueryIO
URL: https://github.com/apache/beam/pull/4119#issuecomment-410085422
 
 
   Has not been implemented. However there's a workaround - use
   withFailedInsertRetryPolicy to detect when inserts fail due to invalid
   schema, and update the schema in response to that.
   
   On Wed, Jul 25, 2018 at 1:42 AM Oleg Skovpen <no...@github.com>
   wrote:
   
   > @aaltay <https://github.com/aaltay> @reuvenlax
   > <https://github.com/reuvenlax> what's the status of this issue BEAM-876 (
   > https://issues.apache.org/jira/browse/BEAM-876)? Does anyone do it?
   >
   > —
   > You are receiving this because you were mentioned.
   > Reply to this email directly, view it on GitHub
   > <https://github.com/apache/beam/pull/4119#issuecomment-407680150>, or mute
   > the thread
   > <https://github.com/notifications/unsubscribe-auth/AUGE1VyYl9srCeNJK09xg8C1PePbZbOgks5uKC-CgaJpZM4Qbfma>
   > .
   >
   

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


Issue Time Tracking
-------------------

    Worklog Id:     (was: 130657)
    Time Spent: 0.5h  (was: 20m)

> Support set/delete of timers by ID in Flink runner
> --------------------------------------------------
>
>                 Key: BEAM-867
>                 URL: https://issues.apache.org/jira/browse/BEAM-867
>             Project: Beam
>          Issue Type: New Feature
>          Components: runner-flink
>            Reporter: Kenneth Knowles
>            Assignee: Aljoscha Krettek
>            Priority: Major
>          Time Spent: 0.5h
>  Remaining Estimate: 0h
>
> This is a prerequisite for full support of BEAM-27, and related to BEAM-35.
> My current understanding is that this might be actually removed from Flink itself, and needs implementation in terms of state. It might be reasonable to just remove deletion from Beam; it is just a nice-to-have for user experience IMO, and perhaps a performance help for certain runners.
> (Since I am filing individual tickets for each runner, generalized discussion should probably be on the dev list directly on or BEAM-35)



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)