[jira] [Work logged] (BEAM-7730) Add Flink 1.9 build target and Make FlinkRunner compatible with Flink 1.9

["ASF GitHub Bot (Jira)" <ji...@apache.org>]

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

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

                Author: ASF GitHub Bot
            Created on: 03/Sep/19 05:55
            Start Date: 03/Sep/19 05:55
    Worklog Time Spent: 10m 
      Work Description: sunjincheng121 commented on issue #9296: WIP: [BEAM-7730] Introduce Flink 1.9 Runner
URL: https://github.com/apache/beam/pull/9296#issuecomment-527315098
 
 
   Hi @dmvk，I creat a hotfix to address the problem. (see: https://github.com/apache/beam/pull/9464)
   
   Currently, state keys are encoded as NESTED while the keys in keyselector(KvToByteBufferKeySelector)
   are encoded as OUTER. This makes the keyGroupId of the same key are different and  
   lead to the test failure. 
   The newest flink version makes this bug more visible.
   
   I have check it in my local with your patch. Could you please have look at the changes of the hotfix and double check it whether the hotfix is make sense to you. :)
   
   Thank you!
   Jincheng
   
   
 
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to 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: 305407)
    Time Spent: 1h 10m  (was: 1h)

> Add Flink 1.9 build target and Make FlinkRunner compatible with Flink 1.9
> -------------------------------------------------------------------------
>
>                 Key: BEAM-7730
>                 URL: https://issues.apache.org/jira/browse/BEAM-7730
>             Project: Beam
>          Issue Type: New Feature
>          Components: runner-flink
>            Reporter: sunjincheng
>            Assignee: David Moravek
>            Priority: Major
>             Fix For: 2.16.0
>
>          Time Spent: 1h 10m
>  Remaining Estimate: 0h
>
> Apache Flink 1.9 will coming and it's better to add Flink 1.9 build target and make Flink Runner compatible with Flink 1.9.
> I will add the brief changes after the Flink 1.9.0 released. 
> And I appreciate it if you can leave your suggestions or comments!



--
This message was sent by Atlassian Jira
(v8.3.2#803003)