[jira] [Created] (FLINK-23756) Release FRocksDB-6.20.3 binaries

2021-08-13 Thread Yun Tang (Jira)
Yun Tang created FLINK-23756: Summary: Release FRocksDB-6.20.3 binaries Key: FLINK-23756 URL: https://issues.apache.org/jira/browse/FLINK-23756 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-23737) Ensure publish-to-dockerhub.sh only publish specific flink versions

2021-08-12 Thread Yun Tang (Jira)
Yun Tang created FLINK-23737: Summary: Ensure publish-to-dockerhub.sh only publish specific flink versions Key: FLINK-23737 URL: https://issues.apache.org/jira/browse/FLINK-23737 Project: Flink

[ANNOUNCE] Apache Flink 1.13.2 released

2021-08-05 Thread Yun Tang
are available in Jira: https://issues.apache.org/jira/secure/ReleaseNote.jspa?version=12350218==12315522 We would like to thank all contributors of the Apache Flink community who made this release possible! Regards, Yun Tang

Re: [ANNOUNCE] RocksDB Version Upgrade and Performance

2021-08-05 Thread Yun Tang
] https://github.com/facebook/rocksdb/tree/master/java/jmh Best, Yun Tang From: Piotr Nowojski Sent: Thursday, August 5, 2021 2:01 To: Yuval Itzchakov Cc: Yun Tang ; Nico Kruber ; u...@flink.apache.org ; dev Subject: Re: [ANNOUNCE] RocksDB Version Upgrade

Re: [ANNOUNCE] RocksDB Version Upgrade and Performance

2021-08-04 Thread Yun Tang
/frocksdb/pull/19 [13] https://github.com/facebook/rocksdb/pull/5441/ [14] https://github.com/facebook/rocksdb/pull/2283 Best, Yun Tang On Wed, Aug 4, 2021 at 2:36 PM Yuval Itzchakov mailto:yuva...@gmail.com>> wrote: We are heavy users of RocksDB and have had several issues with memory m

[RESULT] [VOTE] Release 1.13.2, release candidate #3

2021-08-01 Thread Yun Tang
Fu (binding) There are no disapproving votes. Thanks everyone! Best, Yun Tang

Re: [VOTE] Release 1.11.4, release candidate #1

2021-07-29 Thread Yun Tang
+1 (non-binding) Checked the jars with signature of 4A978875E56AA2100EB0CF12A244D52CF0A40279. Reviewed the PR of release notes. Download the pre-built package to run a standalone application mode job successfully. Best Yun Tang On 2021/07/26 15:25:27, godfrey he wrote: > Hi every

Re: [VOTE] Release 1.12.5, release candidate #3

2021-07-29 Thread Yun Tang
+1 (non-binding) Checked the signature. Reviewed the PR of flink-web. Download the pre-built tar package and launched an application mode standalone job successfully. Best Yun Tang From: Jingsong Li Sent: Tuesday, July 27, 2021 11:54 To: dev Subject: [VOTE

Re: [DISCUSS] Change Default Jira Priority from "Major" to "Minor"

2021-07-27 Thread Yun Tang
Hi Konstantin, How about rename "Major" to "Normal"? We already have higher critical and blocker priorities, and I personally usually treat current "major" as "normal" priority. Best, Yun Tang From: Konstantin Knauf Se

[VOTE] Release 1.13.2, release candidate #3

2021-07-23 Thread Yun Tang
lease-1.13.2-rc3" [5], * website pull request listing the new release and adding announcement blog post [6]. The vote will be open for at least 72 hours. It is adopted by majority approval, with at least 3 PMC affirmative votes. Best, Yun Tang [1] https://issues.apache.org/j

[jira] [Created] (FLINK-23471) Try best to ensure all operators and state manager handle the checkpoint notification

2021-07-22 Thread Yun Tang (Jira)
Yun Tang created FLINK-23471: Summary: Try best to ensure all operators and state manager handle the checkpoint notification Key: FLINK-23471 URL: https://issues.apache.org/jira/browse/FLINK-23471

[VOTE] Release 1.13.2, release candidate #2

2021-07-14 Thread Yun Tang
lease-1.13.2-rc2" [5], * website pull request listing the new release and adding announcement blog post [6]. The vote will be open for at least 72 hours. It is adopted by majority approval, with at least 3 PMC affirmative votes. Best, Yun Tang [1] https://issues.apache.org/j

Re: [NOTICE] flink-runtime now scala-free

2021-07-14 Thread Yun Tang
Great news, thanks for Chesnay's work! Best Yun Tang From: Martijn Visser Sent: Wednesday, July 14, 2021 16:05 To: dev@flink.apache.org Subject: Re: [NOTICE] flink-runtime now scala-free This is a great achievement, thank you for driving this! On Tue, 13 Jul

[jira] [Created] (FLINK-23352) Collect Sink Operator Factory does not support to configure max bytes per batch

2021-07-11 Thread Yun Tang (Jira)
Yun Tang created FLINK-23352: Summary: Collect Sink Operator Factory does not support to configure max bytes per batch Key: FLINK-23352 URL: https://issues.apache.org/jira/browse/FLINK-23352 Project

Re: [ANNOUNCE] New Apache Flink Committer - Yuan Mei

2021-07-07 Thread Yun Tang
Congratulations, Yuan Best Yun Tang From: Yu Li Sent: Thursday, July 8, 2021 1:21 To: dev ; Yuan Mei ; yuan...@apache.org Subject: [ANNOUNCE] New Apache Flink Committer - Yuan Mei Hi all, On behalf of the PMC, I’m very happy to announce Yuan Mei as a new

Re: [VOTE] Release 1.13.2, release candidate #1

2021-07-07 Thread Yun Tang
Since FLINK-23233 brings concerns to many guys, and this release candidate #1 had not received enough binding +1 from PMCs, I think we could cancel this RC and wait for that problem resolved. Best Yun Tang From: Till Rohrmann Sent: Wednesday, July 7, 2021 17:21

Re: Re: [ANNOUNCE] New Apache Flink Committer - Yang Wang

2021-07-06 Thread Yun Tang
Congratulations, Yang! Best Yun Tang From: Yu Li Sent: Wednesday, July 7, 2021 11:18 To: dev Subject: Re: Re: [ANNOUNCE] New Apache Flink Committer - Yang Wang Congrats and welcome, Yang! Best Regards, Yu On Wed, 7 Jul 2021 at 10:57, Yuan Mei wrote

Re: Re: [ANNOUNCE] New PMC member: Guowei Ma

2021-07-06 Thread Yun Tang
Congratulations, Guowei! Best Yun Tang From: Jary Zhen Sent: Wednesday, July 7, 2021 10:48 To: dev Cc: JING ZHANG Subject: Re: Re: [ANNOUNCE] New PMC member: Guowei Ma Congratulations Guowei! Best, Jary Yun Gao 于2021年7月7日周三 上午10:38写道: > Congratulati

Re: [VOTE] Release 1.13.2, release candidate #1

2021-07-04 Thread Yun Tang
@JING ZHANG , thanks for your reminder and you could comment on my PR for further discussion. Best Yun Tang From: Xintong Song Sent: Monday, July 5, 2021 10:09 To: dev Subject: Re: [VOTE] Release 1.13.2, release candidate #1 +1 (binding) - verified checksums

[VOTE] Release 1.13.2, release candidate #1

2021-07-01 Thread Yun Tang
lease-1.13.2-rc1" [5], * website pull request listing the new release and adding announcement blog post [6]. The vote will be open for at least 72 hours. It is adopted by majority approval, with at least 3 PMC affirmative votes. Best, Yun Tang [1] https://issues.apache.org/j

Re: [DISCUSS] Releasing Flink 1.11.4, 1.12.5, 1.13.2

2021-06-24 Thread Yun Tang
u want to include some very important tickets in 1.13.2, please reply in this thread. And I will build a release candidate on next Monday (Jun 28th 00:00 AM CST) if nothing unexpected happen. Best Yun Tang From: Till Rohrmann Sent: Tuesday, June 22, 2021 17:52 T

Re: [DISCUSS] Releasing Flink 1.11.4, 1.12.5, 1.13.2

2021-06-21 Thread Yun Tang
Hi Dawid, Thanks for driving this discussion, I am willing to volunteer as the release manager for these versions. Best Yun Tang From: Konstantin Knauf Sent: Friday, June 18, 2021 22:35 To: dev Subject: Re: [DISCUSS] Releasing Flink 1.11.4, 1.12.5, 1.13.2 Hi

[jira] [Created] (FLINK-23050) Add Chinese version of documentation of unaligned checkpoint

2021-06-20 Thread Yun Tang (Jira)
Yun Tang created FLINK-23050: Summary: Add Chinese version of documentation of unaligned checkpoint Key: FLINK-23050 URL: https://issues.apache.org/jira/browse/FLINK-23050 Project: Flink Issue

[jira] [Created] (FLINK-23018) TTL state factory should handle extended state descriptors

2021-06-17 Thread Yun Tang (Jira)
Yun Tang created FLINK-23018: Summary: TTL state factory should handle extended state descriptors Key: FLINK-23018 URL: https://issues.apache.org/jira/browse/FLINK-23018 Project: Flink Issue

Re: Re: [ANNOUNCE] New PMC member: Arvid Heise

2021-06-16 Thread Yun Tang
Congratulations, Arvid Best Yun Tang From: Yun Gao Sent: Thursday, June 17, 2021 10:46 To: Jingsong Li ; dev Subject: Re: Re: [ANNOUNCE] New PMC member: Arvid Heise Congratulations, Arvid! Best, Yun

Re: [ANNOUNCE] New PMC member: Xintong Song

2021-06-16 Thread Yun Tang
Congratulations, Xintong! Best Yun Tang From: Leonard Xu Sent: Wednesday, June 16, 2021 21:05 To: dev (dev@flink.apache.org) Subject: Re: [ANNOUNCE] New PMC member: Xintong Song Congratulations, Xintong! Best, Leonard > 在 2021年6月16日,20:07,Till Rohrmann

Re: State migration scenario's

2021-06-09 Thread Yun Tang
job. Best Yun Tang From: Marlo Ploemen Sent: Wednesday, June 9, 2021 15:57 To: dev@flink.apache.org Subject: State migration scenario's Hi community, I am looking into the data migration and schema evolution process for stateful streaming jobs. Currently

Re: Request to open the contributor permission!

2021-06-09 Thread Yun Tang
-to-contribute.html Best Yun Tang From: w.gh123 Sent: Wednesday, June 9, 2021 0:53 To: dev Subject: Request to open the contributor permission! Hi, I want to contribute to Apache Flink. Would you please give me the contributor permission? My JIRA ID is hapihu

Re: [DISCUSS][Statebackend][Runtime] Changelog Statebackend Configuration Proposal

2021-06-01 Thread Yun Tang
Hi Yuan, thanks for launching this discussion. I prefer option-3 as this is the easiest to understand for users. Best Yun Tang From: Roman Khachatryan Sent: Monday, May 31, 2021 16:53 To: dev Subject: Re: [DISCUSS][Statebackend][Runtime] Changelog Statebackend

[jira] [Created] (FLINK-22759) Correct the applicability of RocksDB related options as per operator

2021-05-24 Thread Yun Tang (Jira)
Yun Tang created FLINK-22759: Summary: Correct the applicability of RocksDB related options as per operator Key: FLINK-22759 URL: https://issues.apache.org/jira/browse/FLINK-22759 Project: Flink

Re: [ANNOUNCE] Apache Flink 1.13.0 released

2021-05-06 Thread Yun Tang
Thanks for Dawid and Guowei's great work, and thanks for everyone involved for this release. Best Yun Tang From: Xintong Song Sent: Thursday, May 6, 2021 12:08 To: user ; dev Subject: Re: [ANNOUNCE] Apache Flink 1.13.0 released Thanks Dawid & Gu

[jira] [Created] (FLINK-22535) Resource leak would happen if exception thrown during AbstractInvokable#restore of task life

2021-04-29 Thread Yun Tang (Jira)
Yun Tang created FLINK-22535: Summary: Resource leak would happen if exception thrown during AbstractInvokable#restore of task life Key: FLINK-22535 URL: https://issues.apache.org/jira/browse/FLINK-22535

[jira] [Created] (FLINK-22527) Give friendly hint when click FlameGraph without rest.flamegraph.enabled

2021-04-29 Thread Yun Tang (Jira)
Yun Tang created FLINK-22527: Summary: Give friendly hint when click FlameGraph without rest.flamegraph.enabled Key: FLINK-22527 URL: https://issues.apache.org/jira/browse/FLINK-22527 Project: Flink

Re: [VOTE] Release 1.13.0, release candidate #2

2021-04-29 Thread Yun Tang
not give friendly hint to tell me enable it via setting rest.flamegraph.enabled: true, will create issue later. Best Yun Tang From: Leonard Xu Sent: Thursday, April 29, 2021 16:52 To: dev Subject: Re: [VOTE] Release 1.13.0, release candidate #2 +1 (non-binding

[jira] [Created] (FLINK-22444) Drop async checkpoint description of state backends in Chinese docs

2021-04-24 Thread Yun Tang (Jira)
Yun Tang created FLINK-22444: Summary: Drop async checkpoint description of state backends in Chinese docs Key: FLINK-22444 URL: https://issues.apache.org/jira/browse/FLINK-22444 Project: Flink

Re: Re: Re: [ANNOUNCE] New Apache Flink Committer - Rui Li

2021-04-22 Thread Yun Tang
Congratulations, Rui! Best, Yun Tang From: Xuannan Su Sent: Friday, April 23, 2021 10:01 To: dev@flink.apache.org ; matth...@ververica.com Subject: Re: Re: Re: [ANNOUNCE] New Apache Flink Committer - Rui Li Congratulations Rui! Best, Xuannan On Apr 22, 2021

[jira] [Created] (FLINK-22369) RocksDB state backend might occur ClassNotFoundException when deserializing on TM side

2021-04-20 Thread Yun Tang (Jira)
Yun Tang created FLINK-22369: Summary: RocksDB state backend might occur ClassNotFoundException when deserializing on TM side Key: FLINK-22369 URL: https://issues.apache.org/jira/browse/FLINK-22369

[jira] [Created] (FLINK-22187) Remove description of sync checkpoint mode of HashMapStateBackend

2021-04-10 Thread Yun Tang (Jira)
Yun Tang created FLINK-22187: Summary: Remove description of sync checkpoint mode of HashMapStateBackend Key: FLINK-22187 URL: https://issues.apache.org/jira/browse/FLINK-22187 Project: Flink

[jira] [Created] (FLINK-22146) Migrate StateBackend related Chinese docs to latest state backend

2021-04-07 Thread Yun Tang (Jira)
Yun Tang created FLINK-22146: Summary: Migrate StateBackend related Chinese docs to latest state backend Key: FLINK-22146 URL: https://issues.apache.org/jira/browse/FLINK-22146 Project: Flink

[jira] [Created] (FLINK-21736) Introduce latency tracking state

2021-03-11 Thread Yun Tang (Jira)
Yun Tang created FLINK-21736: Summary: Introduce latency tracking state Key: FLINK-21736 URL: https://issues.apache.org/jira/browse/FLINK-21736 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-21658) Align flink-benchmarks with job graph builder

2021-03-07 Thread Yun Tang (Jira)
Yun Tang created FLINK-21658: Summary: Align flink-benchmarks with job graph builder Key: FLINK-21658 URL: https://issues.apache.org/jira/browse/FLINK-21658 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-21603) SQLClientKafkaITCase failed due to unexpected end of file

2021-03-04 Thread Yun Tang (Jira)
Yun Tang created FLINK-21603: Summary: SQLClientKafkaITCase failed due to unexpected end of file Key: FLINK-21603 URL: https://issues.apache.org/jira/browse/FLINK-21603 Project: Flink Issue Type

Re: Re: [ANNOUNCE] New Apache Flink Committers - Wei Zhong and Xingbo Huang

2021-02-22 Thread Yun Tang
Congratulation! Best Yun Tang From: Yun Gao Sent: Tuesday, February 23, 2021 10:56 To: Roman Khachatryan ; dev Subject: Re: Re: [ANNOUNCE] New Apache Flink Committers - Wei Zhong and Xingbo Huang Congratulations Wei and Xingbo! Best, Yun

Re: [ANNOUNCE] Welcome Roman Khachatryan a new Apache Flink Committer

2021-02-10 Thread Yun Tang
Congratulations, Roman! Today is also the beginning of Chinese Spring Festival holiday, at which we Chinese celebrate across the world for the next lunar new year, and also very happy to have you on board! Best Yun Tang From: Roman Khachatryan Sent: Thursday

[jira] [Created] (FLINK-21351) Incremental checkpoint data would be lost once a non-stop savepoint completed

2021-02-10 Thread Yun Tang (Jira)
Yun Tang created FLINK-21351: Summary: Incremental checkpoint data would be lost once a non-stop savepoint completed Key: FLINK-21351 URL: https://issues.apache.org/jira/browse/FLINK-21351 Project: Flink

Re: Activate bloom filter in RocksDB State Backend via Flink configuration

2021-02-08 Thread Yun Tang
of old block format. This is related with FLINK-20496 [2] which try to add option to enable partitioned index & filter. [1] https://github.com/facebook/rocksdb/wiki/RocksDB-Bloom-Filter#full-filters-new-format [2] https://issues.apache.org/jira/browse/FLINK-20496 Best Yun

[jira] [Created] (FLINK-21241) E2E test exception check might fail if older checkpoint not completed when triggering the stop-with-savepoint

2021-02-02 Thread Yun Tang (Jira)
Yun Tang created FLINK-21241: Summary: E2E test exception check might fail if older checkpoint not completed when triggering the stop-with-savepoint Key: FLINK-21241 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Created] (FLINK-21119) Building Flink Azure FS Hadoop hangs during python CI

2021-01-25 Thread Yun Tang (Jira)
Yun Tang created FLINK-21119: Summary: Building Flink Azure FS Hadoop hangs during python CI Key: FLINK-21119 URL: https://issues.apache.org/jira/browse/FLINK-21119 Project: Flink Issue Type

[jira] [Created] (FLINK-21048) Refactor documentation related to switch memory allocator

2021-01-19 Thread Yun Tang (Jira)
Yun Tang created FLINK-21048: Summary: Refactor documentation related to switch memory allocator Key: FLINK-21048 URL: https://issues.apache.org/jira/browse/FLINK-21048 Project: Flink Issue

Re: Re: [ANNOUNCE] Welcome Guowei Ma as a new Apache Flink Committer

2021-01-19 Thread Yun Tang
Congratulations Guowei! Best Yun Tang From: Yang Wang Sent: Wednesday, January 20, 2021 13:59 To: dev Subject: Re: Re: [ANNOUNCE] Welcome Guowei Ma as a new Apache Flink Committer Congratulations Guowei! Best, Yang Yun Gao 于2021年1月20日周三 下午1:52写道

Re: [DISCUSS] Planning Flink 1.13

2021-01-18 Thread Yun Tang
+1 for the proposed date and thanks for Dawid & Guowei as the release manager. Best Yun Tang From: Yangze Guo Sent: Friday, January 15, 2021 9:50 To: dev Subject: Re: [DISCUSS] Planning Flink 1.13 Thanks for being the release managers, Guowei and Dawid.

Re: InfluxDB Source Sink Connector

2021-01-14 Thread Yun Tang
I wonder what's relationship between current influxdb connector in bahir-flink [1]? [1] https://github.com/apache/bahir-flink/tree/master/flink-connector-influxdb Best Yun Tang From: Leon Papke Sent: Wednesday, January 13, 2021 19:16 To: dev@flink.apache.org

Re: [DISCUSS] FLIP-157 Migrate Flink Documentation from Jekyll to Hugo

2021-01-14 Thread Yun Tang
+1 for this proposal. I really like this idea for much less build time and no more docker or ruby dependencies. Developers in China often suffer with the international network connect. Best Yun Tang From: Jark Wu Sent: Thursday, January 14, 2021 10:49 To: dev

Re: [ANNOUNCE] Welcome Danny Cranmer as a new Apache Flink Committer

2021-01-12 Thread Yun Tang
Congratulations Danny! Best Yun Tang From: Jingsong Li Sent: Wednesday, January 13, 2021 14:23 To: dev Subject: Re: [ANNOUNCE] Welcome Danny Cranmer as a new Apache Flink Committer Congrats, Danny! Best, Jingsong On Tue, Jan 12, 2021 at 7:55 PM Leonard Xu

Re: [VOTE] FLIP-153: Support state access in Python DataStream API

2021-01-05 Thread Yun Tang
+1 (binding) Best Yun Tang From: Wei Zhong Sent: Wednesday, January 6, 2021 14:07 To: dev Subject: Re: [VOTE] FLIP-153: Support state access in Python DataStream API +1 (non-binding) Best, Wei > 在 2021年1月6日,14:05,Xingbo Huang 写道: > > +1 (no

Re: [DISCUSS] FLIP-153: Support state access in Python DataStream API

2021-01-05 Thread Yun Tang
The design looks good to me now. +1 to start the vote if there are no more comments.. Best Yun Tang From: Dian Fu Sent: Tuesday, January 5, 2021 13:32 To: dev@flink.apache.org Subject: Re: [DISCUSS] FLIP-153: Support state access in Python DataStream API

Re: [DISCUSS] Allow streaming operators to use managed memory

2021-01-05 Thread Yun Tang
? As you can see previous DATAPROC + PYTHON = 100, which describes the situation when one slot has both consumers of managed python and state backend. Best Yun Tang From: Jark Wu Sent: Wednesday, January 6, 2021 13:51 To: dev Subject: Re: [DISCUSS] Allow streaming

Re: letter of application

2021-01-03 Thread Yun Tang
Hi Welcome to the Flink community! There is no more specific contributor permission currently in Flink. You can simply create a JIRA ticket and ask to be assigned to start working. Please take a look at the Flink's contribution guidelines [1] [2] for more information. Best Regards, Yun Tang

[jira] [Created] (FLINK-20675) Asynchronous checkpoint failure would not fail the job anymore

2020-12-18 Thread Yun Tang (Jira)
Yun Tang created FLINK-20675: Summary: Asynchronous checkpoint failure would not fail the job anymore Key: FLINK-20675 URL: https://issues.apache.org/jira/browse/FLINK-20675 Project: Flink

Re: [DISCUSS] Releasing Apache Flink 1.12.1

2020-12-17 Thread Yun Tang
Thanks for driving this quick-fix release. +1 for fixing the bug of RocksDB state-backend with reduce operators. Best Yun Tang From: Till Rohrmann Sent: Thursday, December 17, 2020 20:51 To: dev Subject: Re: [DISCUSS] Releasing Apache Flink 1.12.1 Thanks

Re: [DISCUSS] FLIP-153: Support state access in Python DataStream API

2020-12-16 Thread Yun Tang
[5] https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/stream/state/custom_serialization.html#off-heap-state-backends-eg-rocksdbstatebackend [6] https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/state/queryable_state.html#example Best Yun Tang

Re: [ANNOUNCE] Apache Flink 1.12.0 released

2020-12-10 Thread Yun Tang
Thanks Dian and Robert for driving this release and thanks everyone who makes this great work possible ! Best Yun Tang From: Wei Zhong Sent: Thursday, December 10, 2020 20:32 To: dev@flink.apache.org Cc: user ; annou...@apache.org Subject: Re: [ANNOUNCE

Re: [VOTE] Release 1.11.3, release candidate #1

2020-12-10 Thread Yun Tang
'release-1.11.3-rc1' tag in current code base instead of your descripted 'release-1.11.3-rc3' in previous mail thread. [1] https://issues.apache.org/jira/browse/FLINK-20554 Best Yun Tang From: Xintong Song Sent: Wednesday, December 9, 2020 11:14 To: dev Cc

Re: Running Flink job as a rest

2020-12-02 Thread Yun Tang
/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/socket/SocketWindowWordCount.java Best Yun Tang From: dhurandar S Sent: Thursday, December 3, 2020 5:31 To: Flink Dev ; user Subject: Running Flink job as a rest Can Flink job be running

Re: State Processor API SQL State

2020-12-01 Thread Yun Tang
0faa8454db36f0/flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/stream/StreamingJoinOperator.java#L83 Best Yun Tang From: Dominik Wosiński Sent: Tuesday, December 1, 2020 21:05 To: dev Subject: State Processo

Re: flink 1.9 Restore from a checkpoint taken in 1.11

2020-11-30 Thread Yun Tang
] https://ci.apache.org/projects/flink/flink-docs-release-1.12/ops/upgrading.html#compatibility-table Best Yun Tang From: Lu Niu Sent: Tuesday, December 1, 2020 9:53 To: dev@flink.apache.org Subject: flink 1.9 Restore from a checkpoint taken in 1.11 Hi, Flink

[jira] [Created] (FLINK-20420) ES6 ElasticsearchSinkITCase failed due to no output for 900 seconds

2020-11-30 Thread Yun Tang (Jira)
Yun Tang created FLINK-20420: Summary: ES6 ElasticsearchSinkITCase failed due to no output for 900 seconds Key: FLINK-20420 URL: https://issues.apache.org/jira/browse/FLINK-20420 Project: Flink

[jira] [Created] (FLINK-20288) Correct documentation about savepoint self-contained

2020-11-22 Thread Yun Tang (Jira)
Yun Tang created FLINK-20288: Summary: Correct documentation about savepoint self-contained Key: FLINK-20288 URL: https://issues.apache.org/jira/browse/FLINK-20288 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20287) Add documentation of how to switch memory allocator in Flink docker image

2020-11-22 Thread Yun Tang (Jira)
Yun Tang created FLINK-20287: Summary: Add documentation of how to switch memory allocator in Flink docker image Key: FLINK-20287 URL: https://issues.apache.org/jira/browse/FLINK-20287 Project: Flink

Re: [DISCUSS] Stop adding new bash-based e2e tests to Flink

2020-11-18 Thread Yun Tang
downloading. Best Yun Tang From: Xingbo Huang Sent: Thursday, November 19, 2020 12:09 To: dev Subject: Re: [DISCUSS] Stop adding new bash-based e2e tests to Flink Big +1 for java-based e2e tests. Currently PyFlink related tests each take ~15minutes in bash e2e

Re: [VOTE] Adopt jemalloc as default memory allocator in docker image

2020-11-09 Thread Yun Tang
Hi all, Currently there were 3 binding approvements, 2 non-binding approvements and there were no disapproving votes. Thus this vote has been accepted and thanks everyone for joining the discussion and giving feedback! Best Yun Tang From: Yun Tang Sent

Re: [VOTE] Adopt jemalloc as default memory allocator in docker image

2020-11-09 Thread Yun Tang
+ 1 (binding) Best Yun Tang From: Ufuk Celebi Sent: Saturday, November 7, 2020 2:33 To: dev@flink.apache.org Subject: Re: [VOTE] Adopt jemalloc as default memory allocator in docker image +1 (binding) Thanks Yun for debugging and running the benchmarks

[VOTE] Adopt jemalloc as default memory allocator in docker image

2020-11-06 Thread Yun Tang
://lists.apache.org/thread.html/r596a19f8cf7278bcf9e30c3060cf00562677d4be072050444a5caf99%40%3Cdev.flink.apache.org%3E Best Yun Tang

Re: [DISCUSS][docker] Adopt Jemalloc as default memory allocator for debian based Flink docker image

2020-11-06 Thread Yun Tang
I think we have given enough thoughts but not clear selections currently. I'll create a VOTE thread to choose which memory allocator as default. Hope you could jump in to provide your choices. Best Yun Tang From: Till Rohrmann Sent: Friday, November 6, 2020 16

Re: [DISCUSS][docker] Adopt Jemalloc as default memory allocator for debian based Flink docker image

2020-11-05 Thread Yun Tang
/scala_2.11-java8-debian Best Yun Tang From: Yun Tang Sent: Wednesday, November 4, 2020 15:41 To: dev@flink.apache.org Subject: Re: [DISCUSS][docker] Adopt Jemalloc as default memory allocator for debian based Flink docker image Hi @ Billy I found there existed many

Re: [DISCUSS][docker] Adopt Jemalloc as default memory allocator for debian based Flink docker image

2020-11-03 Thread Yun Tang
Hi @ Billy I found there existed many benchmark case existed in the two repos, which benchmark case did you run? Best Yun Tang From: Xie Billy Sent: Tuesday, November 3, 2020 22:08 To: dev@flink.apache.org Subject: Re: [DISCUSS][docker] Adopt Jemalloc

Re: [DISCUSS][docker] Adopt Jemalloc as default memory allocator for debian based Flink docker image

2020-10-30 Thread Yun Tang
use? In my point of view, compared to who would use more memory in some cases, we should care more about who would behave under the max limit for most cases. Best Yun Tang From: Xie Billy Sent: Friday, October 30, 2020 8:46 To: dev@flink.apache.org Subject:

Re: [DISCUSS][docker] Adopt Jemalloc as default memory allocator for debian based Flink docker image

2020-10-29 Thread Yun Tang
, the frequency of OOM behavior decreases obviously. Considering the OOM killed problem in k8s, change default memory allocator as jemalloc could be something beneficial. [1] https://github.com/jemalloc/jemalloc/wiki/Use-Case%3A-Heap-Profiling Best Yun Tang From

Re: [ANNOUNCE] New Apache Flink Committer - Congxian Qiu

2020-10-29 Thread Yun Tang
Congratulations, Congxian! Best Yun Tang From: Xintong Song Sent: Thursday, October 29, 2020 16:16 To: dev Cc: Congxian Qiu ; klio...@apache.org Subject: Re: [ANNOUNCE] New Apache Flink Committer - Congxian Qiu Congratulations, Congxian. Thank you~ Xintong

Re: [DISCUSS] Disable "Squash and merge" button for Flink repository on GitHub

2020-10-26 Thread Yun Tang
-GitHub/Authorship-of-merge-commits-made-by-Github-Apps-changed/td-p/48797/highlight/false/page/3 Best Yun Tang From: Jark Wu Sent: Monday, March 9, 2020 16:02 To: dev Subject: Re: [DISCUSS] Disable "Squash and merge" button for Flink repository on GitHub Hi

[jira] [Created] (FLINK-19710) Avoid performance regression introduced by thread-local keyword of FRocksDB

2020-10-19 Thread Yun Tang (Jira)
Yun Tang created FLINK-19710: Summary: Avoid performance regression introduced by thread-local keyword of FRocksDB Key: FLINK-19710 URL: https://issues.apache.org/jira/browse/FLINK-19710 Project: Flink

Re: [DISCUSS][docker] Adopt Jemalloc as default memory allocator for debian based Flink docker image

2020-10-16 Thread Yun Tang
fragmentation problem. Does anyone else have other ideas? Best Yun Tang From: Yang Wang Sent: Thursday, October 15, 2020 14:59 To: dev Subject: Re: [DISCUSS][docker] Adopt Jemalloc as default memory allocator for debian based Flink docker image Thanks Yun Tang

[DISCUSS][docker] Adopt Jemalloc as default memory allocator for debian based Flink docker image

2020-10-13 Thread Yun Tang
.io/manual/v/1.0/installation/docker#why-there-is-no-fluent-bit-docker-image-based-on-alpine-linux [6] https://github.com/home-assistant/core/pull/33237 Best Yun Tang

Re: [ANNOUNCE] New PMC member: Zhu Zhu

2020-10-09 Thread Yun Tang
Congratulations, Zhu! Best Yun Tang From: Danny Chan Sent: Friday, October 9, 2020 13:51 To: dev@flink.apache.org Subject: Re: [ANNOUNCE] New PMC member: Zhu Zhu Congrats, Zhu Zhu ~ Best, Danny Chan 在 2020年10月9日 +0800 PM1:05,dev@flink.apache.org,写道

Re: CheckpointedFunction initialization during checkpoint

2020-10-03 Thread Yun Tang
.java#L496 Best Yun Tang From: Aljoscha Krettek Sent: Tuesday, September 29, 2020 20:51 To: dev@flink.apache.org Subject: Re: CheckpointedFunction initialization during checkpoint Hi Teng, I think if the system is slowed down enough it can happen that some parts of

Re: [ANNOUNCE] New Apache Flink Committer - Yun Tang

2020-09-17 Thread Yun Tang
Thanks for all your kind welcome and very glad to be one of the committers of Flink community. Best Yun Tang From: Congxian Qiu Sent: Wednesday, September 16, 2020 13:10 To: dev@flink.apache.org Cc: Zhijiang ; tangyun ; Yun Tang Subject: Re: [ANNOUNCE] New

Re: Re: [ANNOUNCE] New Apache Flink Committer - Godfrey He

2020-09-16 Thread Yun Tang
Congratulations, Godfrey ~ Best Yun Tang From: Kurt Young Sent: Wednesday, September 16, 2020 17:02 To: dev Subject: Re: Re: [ANNOUNCE] New Apache Flink Committer - Godfrey He Congrats and welcome, Godfrey! Best, Kurt On Wed, Sep 16, 2020 at 4:59 PM Xintong

Re: [ANNOUNCE] New Apache Flink Committer - Arvid Heise

2020-09-16 Thread Yun Tang
Congratulations , Arvid  Best Yun Tang From: Yuan Mei Sent: Wednesday, September 16, 2020 14:27 To: dev Subject: Re: [ANNOUNCE] New Apache Flink Committer - Arvid Heise Congrats, Arvid! ☺ On Wed, Sep 16, 2020 at 12:37 PM Guowei Ma wrote: > Congratulati

Re: [DISCUSS] FLIP-142: Disentangle StateBackends from Checkpointing

2020-09-09 Thread Yun Tang
live without checkpointCoordinator on JM side while 'StreamTask' always initialize the 'checkpointStorage' on task side. I think JM knows the inner relationship between state backend and checkpoint while TM seems mix them together. Best Yun Tang From: Konstantin

[jira] [Created] (FLINK-19125) Avoid memory fragmentation when running flink docker image

2020-09-02 Thread Yun Tang (Jira)
Yun Tang created FLINK-19125: Summary: Avoid memory fragmentation when running flink docker image Key: FLINK-19125 URL: https://issues.apache.org/jira/browse/FLINK-19125 Project: Flink Issue

Re: [DISCUSS] Removing deprecated methods from DataStream API

2020-08-28 Thread Yun Tang
://issues.apache.org/jira/browse/FLINK-19035 Best, Yun Tang From: Aljoscha Krettek Sent: Thursday, August 27, 2020 16:45 To: dev@flink.apache.org Subject: Re: [DISCUSS] Removing deprecated methods from DataStream API Did you consider DataStream.project() yet

Re: [ANNOUNCE] New PMC member: Dian Fu

2020-08-27 Thread Yun Tang
Congratulations , Dian! Best Yun Tang From: Yang Wang Sent: Friday, August 28, 2020 10:28 To: Arvid Heise Cc: Benchao Li ; dev ; user-zh ; Dian Fu ; user Subject: Re: [ANNOUNCE] New PMC member: Dian Fu Congratulations Dian ! Best, Yang Arvid Heise

Re: [ANNOUNCE] Apache Flink 1.10.2 released

2020-08-25 Thread Yun Tang
Thanks for Zhu's work to manage this release and everyone who contributed to this! Best, Yun Tang From: Yangze Guo Sent: Tuesday, August 25, 2020 14:47 To: Dian Fu Cc: Zhu Zhu ; dev ; user ; user-zh Subject: Re: [ANNOUNCE] Apache Flink 1.10.2 released Thanks

Re: [VOTE] Release 1.10.2, release candidate #2

2020-08-20 Thread Yun Tang
Thanks for Zhu Zhu's quick response and LGTM now, +1 (non-binding) Best Yun Tang From: Zhu Zhu Sent: Thursday, August 20, 2020 19:39 To: dev ; Yun Tang Subject: Re: [VOTE] Release 1.10.2, release candidate #2 Thanks for pointing it out! @Yun Tang<mailto:m

Re: [VOTE] Release 1.10.2, release candidate #2

2020-08-20 Thread Yun Tang
I checked to build from source code and run example on YARN and they all behave as expected. However, I think we should tell user explicitly for the interface changes to fix FLINK-18242 and already leave comments for the flink-web PR. Best Yun Tang From

Re: [DISCUSS] Planning Flink 1.12

2020-08-09 Thread Yun Tang
+1 for extending the feature freeze due date. From: Zhijiang Sent: Thursday, August 6, 2020 17:05 To: dev Subject: Re: [DISCUSS] Planning Flink 1.12 +1 on my side for feature freeze date by the end of Oct.

Re: Hi

2020-07-28 Thread Yun Tang
/local.html#setup-download-and-start-flink Best, Yun Tang From: Suryanarayana Murthy Maganti Sent: Monday, July 27, 2020 22:04 To: dev@flink.apache.org Subject: Re: Hi I am looking for support for latest versions in Windows. On Sun, Jul 26, 2020 at 11:25 PM Yangze

Re: Flink Redis connectivity

2020-07-21 Thread Yun Tang
apache/bahir-flink Best Yun Tang From: Yangze Guo Sent: Tuesday, July 21, 2020 18:50 To: dev Subject: Re: Flink Redis connectivity Hi, I think you could implement `RichMapFunction` and create `redisClient` in the `open` method. Best, Yangze Guo On Tue, Jul 21

Re: [DISCUSS] Releasing Flink 1.11.1 soon?

2020-07-13 Thread Yun Tang
Hi If we decide to release Flink-1.11.1, I suggest to include fix for FLINK-18573 [1] as current influxdb metrics reporter is totally broken from Flink-1.11 under current plugins mechanism. [1] https://issues.apache.org/jira/browse/FLINK-18573 Best Yun Tang

Re: [ANNOUNCE] New PMC member: Piotr Nowojski

2020-07-08 Thread Yun Tang
Congratulations, Piotr! Best Yun Tang From: Danny Chan Sent: Wednesday, July 8, 2020 15:46 To: dev@flink.apache.org Subject: Re: [ANNOUNCE] New PMC member: Piotr Nowojski Congratulations and nice work Piotr ~ Best, Danny Chan 在 2020年7月7日 +0800 PM10:00,dev

<    1   2   3   4   5   6   >