You are viewing a plain text version of this content. The canonical link for it is here.
Posted to github@beam.apache.org by "achang52 (via GitHub)" <gi...@apache.org> on 2023/02/01 19:36:43 UTC

[GitHub] [beam] achang52 opened a new issue, #25046: [Feature Request]: Upgrade Beam Flink Runner to Flink 1.16

achang52 opened a new issue, #25046:
URL: https://github.com/apache/beam/issues/25046

   ### What would you like to happen?
   
   We would like to have Flink 1.16 support for the beam Flink Runner + translators. The current most up to date we can find is for Flink 1.16. 
   
   ### Issue Priority
   
   Priority: 2 (default / most feature requests should be filed as P2)
   
   ### Issue Components
   
   - [ ] Component: Python SDK
   - [ ] Component: Java SDK
   - [ ] Component: Go SDK
   - [ ] Component: Typescript SDK
   - [ ] Component: IO connector
   - [ ] Component: Beam examples
   - [ ] Component: Beam playground
   - [ ] Component: Beam katas
   - [ ] Component: Website
   - [ ] Component: Spark Runner
   - [X] Component: Flink Runner
   - [ ] Component: Samza Runner
   - [ ] Component: Twister2 Runner
   - [ ] Component: Hazelcast Jet Runner
   - [ ] Component: Google Cloud Dataflow Runner


-- 
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.

To unsubscribe, e-mail: github-unsubscribe@beam.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [beam] achang52 closed issue #25046: [Feature Request]: Upgrade Beam Flink Runner to Flink 1.16

Posted by "achang52 (via GitHub)" <gi...@apache.org>.
achang52 closed issue #25046: [Feature Request]: Upgrade Beam Flink Runner to Flink 1.16
URL: https://github.com/apache/beam/issues/25046


-- 
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.

To unsubscribe, e-mail: github-unsubscribe@beam.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [beam] becketqin commented on issue #25046: [Feature Request]: Upgrade Beam Flink Runner to Flink 1.16

Posted by "becketqin (via GitHub)" <gi...@apache.org>.
becketqin commented on issue #25046:
URL: https://github.com/apache/beam/issues/25046#issuecomment-1425042086

   @Abacn Thanks for the comment. Perhaps we don't have to block the Flink 1.16 upgrade for the `DataStream` API migration. If the Flink 1.16 upgrade patch goes in first, by default the Flink batch jobs run with `DataSet` API, but users can always change the config and run batch jobs with `DataStream` API if they want to.


-- 
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.

To unsubscribe, e-mail: github-unsubscribe@beam.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [beam] Abacn commented on issue #25046: [Feature Request]: Upgrade Beam Flink Runner to Flink 1.16

Posted by "Abacn (via GitHub)" <gi...@apache.org>.
Abacn commented on issue #25046:
URL: https://github.com/apache/beam/issues/25046#issuecomment-1425061900

   Sure, this is not a blocker, just something in longer future


-- 
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.

To unsubscribe, e-mail: github-unsubscribe@beam.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [beam] Abacn commented on issue #25046: [Feature Request]: Upgrade Beam Flink Runner to Flink 1.16

Posted by "Abacn (via GitHub)" <gi...@apache.org>.
Abacn commented on issue #25046:
URL: https://github.com/apache/beam/issues/25046#issuecomment-1412535482

   Note that there is a plan to migrate Flink runner to run batch jobs with DataStream API: https://docs.google.com/document/d/1cjUJHOS1eEkH76hMNeBuc-kPhbIIc9w2gvjm8miIFS8/edit#
   
   where it suggested "when new Flink version (e.g. Flink 1.16) is added", set to use DataStream API by default. May mark this issue may be blocked by DataStream API migration.


-- 
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.

To unsubscribe, e-mail: github-unsubscribe@beam.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [beam] Abacn closed issue #25046: [Feature Request]: Upgrade Beam Flink Runner to Flink 1.16

Posted by "Abacn (via GitHub)" <gi...@apache.org>.
Abacn closed issue #25046: [Feature Request]: Upgrade Beam Flink Runner to Flink 1.16
URL: https://github.com/apache/beam/issues/25046


-- 
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.

To unsubscribe, e-mail: github-unsubscribe@beam.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org