Re: [ANNOUNCE] Apache Flink Table Store 0.2.0 released
Congrats! Thanks Jingsong for driving this release, and thanks to all contributors! Best, Jane On Mon, Aug 29, 2022 at 11:35 AM Jingsong Li wrote: > The Apache Flink community is very happy to announce the release of > Apache Flink Table Store 0.2.0. > > Apache Flink Table Store is a unified storage to build dynamic tables > for both streaming and batch processing in Flink, supporting > high-speed data ingestion and timely data query. > > Please check out the release blog post for an overview of the release: > https://flink.apache.org/news/2022/08/29/release-table-store-0.2.0.html > > The release is available for download at: > https://flink.apache.org/downloads.html > > Maven artifacts for Flink Table Store can be found at: > https://search.maven.org/search?q=g:org.apache.flink%20table-store > > The full release notes are available in Jira: > > https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522=12351570 > > We would like to thank all contributors of the Apache Flink community > who made this release possible! > > Regards, > Jingsong Lee >
[ANNOUNCE] Apache Flink Table Store 0.2.0 released
The Apache Flink community is very happy to announce the release of Apache Flink Table Store 0.2.0. Apache Flink Table Store is a unified storage to build dynamic tables for both streaming and batch processing in Flink, supporting high-speed data ingestion and timely data query. Please check out the release blog post for an overview of the release: https://flink.apache.org/news/2022/08/29/release-table-store-0.2.0.html The release is available for download at: https://flink.apache.org/downloads.html Maven artifacts for Flink Table Store can be found at: https://search.maven.org/search?q=g:org.apache.flink%20table-store The full release notes are available in Jira: https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522=12351570 We would like to thank all contributors of the Apache Flink community who made this release possible! Regards, Jingsong Lee
Re:Flink Native Kubernetes Resources Requests and Limits
看了下关于资源比例的参数是1.15版本才有的，1.13是没有的 内存的配置参数是 kubernetes.taskmanager.memory.limit-factor https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/deployment/config/#kubernetes-taskmanager-memory-limit-factor On 08/28/2022 11:55，casel.chen wrote： 内存有相应的requests和limits参数吗？找了一圈没有发现，都设的是requests=limits，是为了作业高可靠保障么？如果要能够调整内存使用大小的话应该要如何实现呢？实际业务朝夕现象很鲜明，希望作业在低峰期能空出一些内存资源来 在 2022-08-05 10:42:48，"spoon_lz" 写道： 可以尝试使用个参数： kubernetes.taskmanager.cpu.limit-factor https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/deployment/config/#kubernetes-taskmanager-cpu-limit-factor On 08/5/2022 09:24，casel.chen wrote： 我通过flink native kubernetes部署flink 1.13.2作业到k8s上发现资源实际使用量远小于请求量，特别是CPU，启动的时候CPU消耗多一些，运行一段时间后CPU消耗显著降低，如果设置CPU值较小的话又会造成作业启动慢的问题，查了一下当前实现中将资源requests恒等于limits，请问该如何分别设置cpu和内存的requests和limits以提高资源使用效率呢？谢谢！
??????k8s??????application????flink????HA??????????????
1.K8s??HAconfigMap. configMap??: cluster-id--config-map.jobgraph??checkpointhigh-availability.storageDir?? 2.??Application??Id????checkpoint,??HA?? 3.flink cancel.stopdeployment??configMap??checkpoint [1].https://flink.apache.org/2021/02/10/native-k8s-with-ha.html [2].https://cwiki.apache.org/confluence/display/FLINK/FLIP-144%3A+Native+Kubernetes+HA+for+Flink [3].https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/deployment/ha/kubernetes_ha/#high-availability-data-clean-up Best, Hjw ---- ??: "user-zh"
