Re: [DISCUSS ] Make state.backend.incremental as true by default

2022-06-13 Thread Yun Tang
checkpoints. Best Yun Tang From: Martijn Visser Sent: Monday, June 13, 2022 18:05 To: dev@flink.apache.org Subject: Re: [DISCUSS ] Make state.backend.incremental as true by default Hi Lihe, What happens if we enable incremental checkpoints by default while the used

Re: [ANNOUNCE] New Apache Flink PMC Member - Jingsong Lee

2022-06-13 Thread Yun Tang
Congratulations, Jingsong! Well deserved. Best Yun Tang From: Xingbo Huang Sent: Monday, June 13, 2022 17:39 To: dev Subject: Re: [ANNOUNCE] New Apache Flink PMC Member - Jingsong Lee Congratulations, Jingsong! Best, Xingbo Jane Chan 于2022年6月13日周一 17:23写道

Re: [ANNOUNCE] Apache Flink Kubernetes Operator 1.0.0 released

2022-06-08 Thread Yun Tang
Good news! Thanks Yang for driving the 1.0.0 release and all guys who ever contributed to make this release happen. Best Yun Tang From: Nicholas Jiang Sent: Wednesday, June 8, 2022 19:40 To: dev@flink.apache.org Subject: Re: [ANNOUNCE] Apache Flink Kubernetes

Re: [VOTE] FLIP-229: Introduces Join Hint for Flink SQL Batch Job

2022-05-18 Thread Yun Tang
Thanks for driving, +1 (binding) Best Yun Tang From: Jark Wu Sent: Wednesday, May 18, 2022 23:09 To: dev Subject: Re: [VOTE] FLIP-229: Introduces Join Hint for Flink SQL Batch Job +1(binding) Best, Jark On Wed, 18 May 2022 at 14:18, Jingsong Li wrote: >

Re: [VOTE] Creating an Apache Flink slack workspace

2022-05-18 Thread Yun Tang
Thanks Xintong for driving this. +1 from my side. Best Yun Tang From: Zhu Zhu Sent: Wednesday, May 18, 2022 17:08 To: dev Subject: Re: [VOTE] Creating an Apache Flink slack workspace +1 (binding) Thanks, Zhu Timo Walther 于2022年5月18日周三 16:52写道: > &

Re: [Discuss] Creating an Apache Flink slack workspace

2022-05-11 Thread Yun Tang
to set up our own slack workspace. Best Yun Tang From: Jingsong Li Sent: Thursday, May 12, 2022 10:49 To: Xintong Song Cc: dev ; user Subject: Re: [Discuss] Creating an Apache Flink slack workspace Hi all, Regarding using ASF slack. I share the problems I saw

Re: Flink job restarted from empty state when execution.shutdown-on-application-finish is enabled

2022-05-10 Thread Yun Tang
isted checkpoint information on shutdown when the job status is globally >terminated. Did you ever check the configmap, which used to store the completed checkpoint store, that its content has been empty after you just trigger a job manager failure? Best Yun Tang __

Re: [VOTE] Apache Flink Table Store 0.1.0, release candidate #2

2022-05-07 Thread Yun Tang
not give correct description of how to build and get the expected jar package, and I created a PR [1] to resolve this. [1] https://github.com/apache/flink-table-store/pull/112 Best Yun Tang From: Yu Li Sent: Saturday, May 7, 2022 17:20 To: dev Subject: Re: [VOTE

Re: How to support C#/dotNet ?

2022-05-06 Thread Yun Tang
project [4] for more information to see how to support C# API in Flink. [1] https://github.com/HEF-Sharp/HEF.Flink [2] https://github.com/microsoft/Mobius [3] https://github.com/microsoft/Mobius/tree/master/csharp/Adapter [4] https://github.com/dotnet/spark Best Yun Tang

[jira] [Created] (FLINK-27531) Add explict doc on data consistency problem of RocksDB's map state iterator

2022-05-06 Thread Yun Tang (Jira)
Yun Tang created FLINK-27531: Summary: Add explict doc on data consistency problem of RocksDB's map state iterator Key: FLINK-27531 URL: https://issues.apache.org/jira/browse/FLINK-27531 Project: Flink

Re: [ANNOUNCE] New Flink PMC member: Yang Wang

2022-05-06 Thread Yun Tang
Congratulations, Yang! Best Yun Tang From: Jing Ge Sent: Friday, May 6, 2022 14:24 To: dev Subject: Re: [ANNOUNCE] New Flink PMC member: Yang Wang Congrats Yang and well Deserved! Best regards, Jing On Fri, May 6, 2022 at 7:38 AM Lincoln Lee wrote

Re: [ANNOUNCE] Apache Flink 1.15.0 released

2022-05-05 Thread Yun Tang
Great news! Thanks for Yun Gao, Till and Joe for driving this release and everyone who ever contributed to this release. Best Yun Tang From: Timo Walther Sent: Thursday, May 5, 2022 17:20 To: dev@flink.apache.org Subject: Re: [ANNOUNCE] Apache Flink 1.15.0

Re: [DISCUSS] Keep the Community Member Information Up-to-Date

2022-04-29 Thread Yun Tang
like a better solution. Best Yun Tang From: tison Sent: Thursday, April 28, 2022 21:52 To: dev Subject: Re: [DISCUSS] Keep the Community Member Information Up-to-Date Hi Xintong, Thanks for starting this discussion. +0 to replace the information with link

Re: [DISCUSS] Maintain a Calcite repository for Flink to accelerate the development for Flink SQL features

2022-04-23 Thread Yun Tang
and data correctness. [1] https://github.com/ververica/frocksdb/commit/3da8249d50c8a3a6ea229f43890d37e098372786 [2] https://github.com/facebook/rocksdb/issues/9390 Best Yun Tang From: Jing Zhang Sent: Saturday, April 23, 2022 15:21 To: dev Cc: Yun Tang

Re: [DISCUSS] FLIP-220: Temporal State

2022-04-22 Thread Yun Tang
comparing the bytes. Thus, we might need to avoid to write the length in the serialized bytes. On the other hand, changelog logger would record operation per key one by one in the logs. We need to consider how to distinguish each key in the combined serialized byte arrays. Best

Re: [DISCUSS] FLIP-220: Temporal State

2022-04-20 Thread Yun Tang
to store key bytes serialized by the new serializer (as we might not be able to write the length in the beginning of serialized bytes to make the order of bytes same as natural order). Best Yun Tang. From: Nico Kruber Sent: Wednesday, April 20, 2022 0:38 To: dev Cc

[jira] [Created] (FLINK-27295) UnalignedCheckpointITCase failed due to OperatorCoordinatorHolder cannot mark checkpoint

2022-04-18 Thread Yun Tang (Jira)
Yun Tang created FLINK-27295: Summary: UnalignedCheckpointITCase failed due to OperatorCoordinatorHolder cannot mark checkpoint Key: FLINK-27295 URL: https://issues.apache.org/jira/browse/FLINK-27295

Re: [DISCUSS] FLIP-220: Temporal State

2022-04-14 Thread Yun Tang
ate types are introduced. [1] https://github.com/apache/flink/blob/master/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/aggregate/MinWithRetractAggFunction.java Best, Yun Tang From: David Morávek Sent: Wednesday, April 13, 2

Re: [DISCUSS] FLIP-220: Temporal State

2022-04-12 Thread Yun Tang
Hi David, Could you share some explanations why SortedMapState cannot work in details? I just cannot catch up what the statement below means: This was rejected as being overly difficult to implement in a way that would cleanly leverage RocksDB’s iterators. Best Yun Tang

[jira] [Created] (FLINK-26985) With legacy restore mode, incremantal checkpoints would be deleted by mistake

2022-04-01 Thread Yun Tang (Jira)
Yun Tang created FLINK-26985: Summary: With legacy restore mode, incremantal checkpoints would be deleted by mistake Key: FLINK-26985 URL: https://issues.apache.org/jira/browse/FLINK-26985 Project: Flink

[jira] [Created] (FLINK-26882) Unaligned checkpoint with 0s timeout would fail RescaleCheckpointManuallyITCase

2022-03-28 Thread Yun Tang (Jira)
Yun Tang created FLINK-26882: Summary: Unaligned checkpoint with 0s timeout would fail RescaleCheckpointManuallyITCase Key: FLINK-26882 URL: https://issues.apache.org/jira/browse/FLINK-26882 Project

[jira] [Created] (FLINK-26650) Avoid to print stack trace for checkpoint trigger failure if not all tasks are started

2022-03-15 Thread Yun Tang (Jira)
Yun Tang created FLINK-26650: Summary: Avoid to print stack trace for checkpoint trigger failure if not all tasks are started Key: FLINK-26650 URL: https://issues.apache.org/jira/browse/FLINK-26650

Re: [ANNOUNCE] New PMC member: Yuan Mei

2022-03-14 Thread Yun Tang
Congratulations, Yuan! Best, Yun Tang From: Zakelly Lan Sent: Monday, March 14, 2022 16:55 To: dev@flink.apache.org Subject: Re: [ANNOUNCE] New PMC member: Yuan Mei Congratulations, Yuan! Best, Zakelly On Mon, Mar 14, 2022 at 4:49 PM Johannes Moser wrote

[jira] [Created] (FLINK-26575) Improve the info message when restoring keyed state backend

2022-03-09 Thread Yun Tang (Jira)
Yun Tang created FLINK-26575: Summary: Improve the info message when restoring keyed state backend Key: FLINK-26575 URL: https://issues.apache.org/jira/browse/FLINK-26575 Project: Flink Issue

Re: [DISCUSS] Enable scala formatting check

2022-03-09 Thread Yun Tang
The feature freeze is already passed, and we just not cut the release branch yet. I am a bit against the idea to include this in Flink-1.15 as this is really a feature change to build system not to mentition it includes 118k lines change! Thanks Yun Tang On 2022/03/09 16:48:10 Francesco

[jira] [Created] (FLINK-26550) Correct the information of checkpoint failure

2022-03-09 Thread Yun Tang (Jira)
Yun Tang created FLINK-26550: Summary: Correct the information of checkpoint failure Key: FLINK-26550 URL: https://issues.apache.org/jira/browse/FLINK-26550 Project: Flink Issue Type: Bug

Re: status of Apple Silicon (M1) as Flink dev platform?

2022-03-08 Thread Yun Tang
Hi David, For the problem of RocksDB running on M1 machines, RocksDB community has recently resolved this in RocksDB-6.29 [1], maybe we could involve this change in next Flink-1.16. [1] https://github.com/facebook/rocksdb/pull/9662 Best Yun Tang From: David

[jira] [Created] (FLINK-26464) Introduce new metrics to represent full checkpoint size

2022-03-03 Thread Yun Tang (Jira)
Yun Tang created FLINK-26464: Summary: Introduce new metrics to represent full checkpoint size Key: FLINK-26464 URL: https://issues.apache.org/jira/browse/FLINK-26464 Project: Flink Issue Type

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

2022-03-02 Thread Yun Tang
+1 non-binding - Checked the signatures for pending release artifacts. - Download the pre-built flink-dist of both scala_2.11 and scala_2.12 versions and run them locally with the StateMachine example. - Reviewed the flink-web PR Best Yun Tang From: Seth Wiesman

Re: [DISCUSS] Enable scala formatting check

2022-03-02 Thread Yun Tang
+1 I also noticed that the project of scalafmt [1] is much more active than scalatyle [2], which has no release in the past 4 years. [1] https://github.com/scalameta/scalafmt/releases [2] https://github.com/scalastyle/scalastyle/tags Best Yun Tang From

Re: Re: Change of focus

2022-02-28 Thread Yun Tang
Thanks a lot for your efforts and kindness of mentoring contributors in Apache Flink community, Till! Good luck with your new adventure in your new life. Best Yun Tang From: Yuan Mei Sent: Tuesday, March 1, 2022 11:00 To: dev Subject: Re: Re: Change of focus

[jira] [Created] (FLINK-26338) Add documentation of savepoint type on Command-Line part

2022-02-23 Thread Yun Tang (Jira)
Yun Tang created FLINK-26338: Summary: Add documentation of savepoint type on Command-Line part Key: FLINK-26338 URL: https://issues.apache.org/jira/browse/FLINK-26338 Project: Flink Issue Type

Re: [ANNOUNCE] New Flink PMC members: Igal Shilman, Konstantin Knauf and Yun Gao

2022-02-16 Thread Yun Tang
Congratulations to all of you! Best, Yun Tang From: Yangze Guo Sent: Thursday, February 17, 2022 10:44 To: dev Cc: ro...@apache.org Subject: Re: [ANNOUNCE] New Flink PMC members: Igal Shilman, Konstantin Knauf and Yun Gao Congratulations! Well deserved. Best

Re: [ANNOUNCE] New Apache Flink Committers: Feng Wang, Zhipeng Zhang

2022-02-16 Thread Yun Tang
Congratulations to Feng and Zhipeng! Best, Yun Tang From: Yangze Guo Sent: Thursday, February 17, 2022 10:58 To: dev Subject: Re: [ANNOUNCE] New Apache Flink Committers: Feng Wang, Zhipeng Zhang Congratulations! Well deserved! Best, Yangze Guo On Thu, Feb 17

[jira] [Created] (FLINK-26101) Avoid shared state registry to discard duplicate changelog state

2022-02-13 Thread Yun Tang (Jira)
Yun Tang created FLINK-26101: Summary: Avoid shared state registry to discard duplicate changelog state Key: FLINK-26101 URL: https://issues.apache.org/jira/browse/FLINK-26101 Project: Flink

[jira] [Created] (FLINK-25872) Restoring from incremental checkpoint with changelog state-backend cannot work well with snapshot CLAIM mode

2022-01-28 Thread Yun Tang (Jira)
Yun Tang created FLINK-25872: Summary: Restoring from incremental checkpoint with changelog state-backend cannot work well with snapshot CLAIM mode Key: FLINK-25872 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Created] (FLINK-25862) Refactor SharedStateRegistry to limit StreamStateHandle to register/unregister

2022-01-28 Thread Yun Tang (Jira)
Yun Tang created FLINK-25862: Summary: Refactor SharedStateRegistry to limit StreamStateHandle to register/unregister Key: FLINK-25862 URL: https://issues.apache.org/jira/browse/FLINK-25862 Project

Re: [DISCUSS] FLIP-213: TaskManager's Flame Graphs

2022-01-26 Thread Yun Tang
-platforms problems? Best, Yun Tang From: David Morávek Sent: Thursday, January 27, 2022 2:56 To: dev Subject: Re: [DISCUSS] FLIP-213: TaskManager's Flame Graphs I'd second to Alex's concerns. Is there a reason why you can't use the async-profiler directly

[jira] [Created] (FLINK-25816) Changelog keyed state backend would come across NPE during notification

2022-01-25 Thread Yun Tang (Jira)
Yun Tang created FLINK-25816: Summary: Changelog keyed state backend would come across NPE during notification Key: FLINK-25816 URL: https://issues.apache.org/jira/browse/FLINK-25816 Project: Flink

Re: [DISCUSS] Pushing Apache Flink 1.15 Feature Freeze

2022-01-25 Thread Yun Tang
Since the official Spring Festival holidays in China starts from Jan 31th to Feb 6th, and many developers in China would enjoy the holidays at that time. +1 for extending the feature freeze. Best Yun Tang From: Jingsong Li Sent: Wednesday, January 26, 2022 10:32

Re: [VOTE] Creating external connector repositories

2022-01-19 Thread Yun Tang
+1 Thanks for driving this topic, Martijn Best, Yun Tang From: Jingsong Li Sent: Thursday, January 20, 2022 12:18 To: dev Subject: Re: [VOTE] Creating external connector repositories +1 Thanks for driving this Martijn! Best, Jingsong On Thu, Jan 20, 2022

Re: [DISCUSS] FLIP-203: Incremental savepoints

2022-01-17 Thread Yun Tang
patibility-Between-Different-Releases Best, Yun Tang From: Konstantin Knauf Sent: Friday, January 14, 2022 20:39 To: dev ; Seth Wiesman ; Nico Kruber ; dander...@apache.org Subject: Re: [DISCUSS] FLIP-203: Incremental savepoints Hi everyone, Thank you, Pio

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

2022-01-12 Thread Yun Tang
-web PR. Best Yun Tang From: Martijn Visser Sent: Wednesday, January 12, 2022 0:34 To: dev Subject: [VOTE] Release 1.14.3, release candidate #1 Hi everyone, Please review and vote on the release candidate #1 for the version 1.14.3, as follows: [ ] +1, Approve

Re: [DISCUSS] Seek help for making JIRA links clickable in github

2022-01-12 Thread Yun Tang
Hi Jingsong, I have already created the ticket [1] to ask for help from ASF infrastructure. Let's wait to see the progress to make it done in github. [1] https://issues.apache.org/jira/browse/INFRA-22729 Best Yun Tang From: Yun Gao Sent: Wednesday, January 12

Re: [DISCUSS] FLIP-201: Persist local state in working directory

2022-01-10 Thread Yun Tang
I think this feature could indeed help recovery faster on the case of node failure. It seems this feature could only work well with k8s-like deployment environment? Best, Yun Tang From: David Morávek Sent: Wednesday, January 5, 2022 19:51 To: dev Subject: Re

Re: [VOTE] Create a separate sub project for FLIP-188: flink-store

2022-01-09 Thread Yun Tang
+1 for the name of `flink-table-store`. Best Yun Tang From: Jingsong Li Sent: Monday, January 10, 2022 10:46 To: dev Subject: Re: [VOTE] Create a separate sub project for FLIP-188: flink-store Hi David, thanks for your suggestion. I think we should re-use

Re: [DISCUSS] Deprecate MapR FS

2022-01-09 Thread Yun Tang
+1 for dropping the MapR Fs. Best Yun Tang From: Till Rohrmann Sent: Wednesday, January 5, 2022 18:33 To: Martijn Visser Cc: David Morávek ; dev ; Seth Wiesman ; User Subject: Re: [DISCUSS] Deprecate MapR FS +1 for dropping the MapR FS. Cheers, Till On Wed

[jira] [Created] (FLINK-25557) Introduce incremental/full checkpoint size stats

2022-01-06 Thread Yun Tang (Jira)
Yun Tang created FLINK-25557: Summary: Introduce incremental/full checkpoint size stats Key: FLINK-25557 URL: https://issues.apache.org/jira/browse/FLINK-25557 Project: Flink Issue Type

[jira] [Created] (FLINK-25524) If enabled changelog, RocksDB incremental checkpoint would always be full

2022-01-05 Thread Yun Tang (Jira)
Yun Tang created FLINK-25524: Summary: If enabled changelog, RocksDB incremental checkpoint would always be full Key: FLINK-25524 URL: https://issues.apache.org/jira/browse/FLINK-25524 Project: Flink

[jira] [Created] (FLINK-25494) Duplicate element serializer during DefaultOperatorStateBackendSnapshotStrategy#syncPrepareResources

2021-12-30 Thread Yun Tang (Jira)
Yun Tang created FLINK-25494: Summary: Duplicate element serializer during DefaultOperatorStateBackendSnapshotStrategy#syncPrepareResources Key: FLINK-25494 URL: https://issues.apache.org/jira/browse/FLINK-25494

[jira] [Created] (FLINK-25479) Changlog materialization with incremental checkpoint cannot work well in local tests

2021-12-29 Thread Yun Tang (Jira)
Yun Tang created FLINK-25479: Summary: Changlog materialization with incremental checkpoint cannot work well in local tests Key: FLINK-25479 URL: https://issues.apache.org/jira/browse/FLINK-25479 Project

[jira] [Created] (FLINK-25478) Changelog materialization with incremental checkpoint could cause checkpointed data lost

2021-12-29 Thread Yun Tang (Jira)
Yun Tang created FLINK-25478: Summary: Changelog materialization with incremental checkpoint could cause checkpointed data lost Key: FLINK-25478 URL: https://issues.apache.org/jira/browse/FLINK-25478

[jira] [Created] (FLINK-25466) TTL configuration could parse in StateTtlConfig#DISABLED

2021-12-27 Thread Yun Tang (Jira)
Yun Tang created FLINK-25466: Summary: TTL configuration could parse in StateTtlConfig#DISABLED Key: FLINK-25466 URL: https://issues.apache.org/jira/browse/FLINK-25466 Project: Flink Issue Type

[jira] [Created] (FLINK-25465) Correct the logic to materizate on wrapped changelog state

2021-12-27 Thread Yun Tang (Jira)
Yun Tang created FLINK-25465: Summary: Correct the logic to materizate on wrapped changelog state Key: FLINK-25465 URL: https://issues.apache.org/jira/browse/FLINK-25465 Project: Flink Issue

[jira] [Created] (FLINK-25458) Supports local recovery

2021-12-27 Thread Yun Tang (Jira)
Yun Tang created FLINK-25458: Summary: Supports local recovery Key: FLINK-25458 URL: https://issues.apache.org/jira/browse/FLINK-25458 Project: Flink Issue Type: Sub-task Reporter

[jira] [Created] (FLINK-25446) Avoid sanity check on read bytes on DataInputStream#read(byte[])

2021-12-26 Thread Yun Tang (Jira)
Yun Tang created FLINK-25446: Summary: Avoid sanity check on read bytes on DataInputStream#read(byte[]) Key: FLINK-25446 URL: https://issues.apache.org/jira/browse/FLINK-25446 Project: Flink

[jira] [Created] (FLINK-25438) KafkaProducerExactlyOnceITCase.testMultipleSinkOperators failed due to topic 'exactlyTopicCustomOperator20' already exists

2021-12-23 Thread Yun Tang (Jira)
Yun Tang created FLINK-25438: Summary: KafkaProducerExactlyOnceITCase.testMultipleSinkOperators failed due to topic 'exactlyTopicCustomOperator20' already exists Key: FLINK-25438 URL: https://issues.apache.org/jira

[jira] [Created] (FLINK-25429) Avoid to close output streams twice during uploading changelogs

2021-12-23 Thread Yun Tang (Jira)
Yun Tang created FLINK-25429: Summary: Avoid to close output streams twice during uploading changelogs Key: FLINK-25429 URL: https://issues.apache.org/jira/browse/FLINK-25429 Project: Flink

[jira] [Created] (FLINK-25423) Enable loading state backend via configuration in state processor api

2021-12-22 Thread Yun Tang (Jira)
Yun Tang created FLINK-25423: Summary: Enable loading state backend via configuration in state processor api Key: FLINK-25423 URL: https://issues.apache.org/jira/browse/FLINK-25423 Project: Flink

Re: [VOTE] FLIP-198: Working directory for Flink processes

2021-12-16 Thread Yun Tang
+1 (binding) Best Yun Tang From: Yang Wang Sent: Friday, December 17, 2021 12:42 To: dev Cc: Till Rohrmann Subject: Re: [VOTE] FLIP-198: Working directory for Flink processes +1 (binding) Best, Yang David Morávek 于2021年12月17日周五 05:39写道: > +1 (non-bind

Re: [VOTE] Release 1.11.6/1.12.7/1.13.5/1.14.2, release candidate #1

2021-12-15 Thread Yun Tang
that FLINK-25317 [1] was tagged as 1.14.2 version to resolve by mistake. [1] https://issues.apache.org/jira/browse/FLINK-25317 Best Yun Tang From: Chesnay Schepler Sent: Wednesday, December 15, 2021 10:55 To: dev@flink.apache.org Subject: [VOTE] Release 1.11.6

Re: [VOTE] Release 1.11.5/1.12.6/1.13.4/1.14.1, release candidate #1

2021-12-14 Thread Yun Tang
+ 1 (non-binding) for releasing flink-1.13.4 and flink-1.14.1 currently * reviewed blog post * checked that the hot fix verion only contains the log4j2 version bump Best Yun Tang From: Chesnay Schepler Sent: Tuesday, December 14, 2021 17:12 To: dev

Re: [VOTE] Release 1.11.5/1.12.6/1.13.4/1.14.1, release candidate #1

2021-12-13 Thread Yun Tang
/#files Best Yun Tang From: Zhu Zhu Sent: Tuesday, December 14, 2021 11:00 To: dev Subject: Re: [VOTE] Release 1.11.5/1.12.6/1.13.4/1.14.1, release candidate #1 +1 (binding) - verified the differences of source releases to the corresponding latest releases

Re: [DISCUSS] FLIP-198: Working directory for Flink processes

2021-12-11 Thread Yun Tang
flink/blob/cf1e8c39111378735e4c05a5edb3bd713229bb08/flink-core/src/main/java/org/apache/flink/configuration/CoreOptions.java#L363 Best Yun Tang From: Till Rohrmann Sent: Saturday, December 11, 2021 0:54 To: dev Subject: [DISCUSS] FLIP-198: Working directory for Flink pro

[jira] [Created] (FLINK-25237) ElasticsearchSinkITCase fails due to NoNodeAvailableException

2021-12-09 Thread Yun Tang (Jira)
Yun Tang created FLINK-25237: Summary: ElasticsearchSinkITCase fails due to NoNodeAvailableException Key: FLINK-25237 URL: https://issues.apache.org/jira/browse/FLINK-25237 Project: Flink Issue

Re: [VOTE] FLIP-193: Snapshots ownership

2021-12-03 Thread Yun Tang
+1 Thanks for driving this, Dawid. Best Yun Tang From: Roman Khachatryan Sent: Thursday, December 2, 2021 17:02 To: dev Subject: Re: [VOTE] FLIP-193: Snapshots ownership +1 Thanks for driving this effort Dawid Regards, Roman On Wed, Dec 1, 2021 at 2:04 PM

Re: Re:Re: [ANNOUNCE] New Apache Flink Committer - Ingo Bürk

2021-12-02 Thread Yun Tang
Congratulations, Ingo! Best Yun Tang From: Yuepeng Pan Sent: Friday, December 3, 2021 14:14 To: dev@flink.apache.org Cc: Ingo Bürk Subject: Re:Re: [ANNOUNCE] New Apache Flink Committer - Ingo Bürk Congratulations, Ingo! Best, Yuepeng Pan At 2021-12

[jira] [Created] (FLINK-25116) Fabric8FlinkKubeClientITCase hangs on Azure

2021-11-30 Thread Yun Tang (Jira)
Yun Tang created FLINK-25116: Summary: Fabric8FlinkKubeClientITCase hangs on Azure Key: FLINK-25116 URL: https://issues.apache.org/jira/browse/FLINK-25116 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-25067) Correct the description of RocksDB's background threads

2021-11-25 Thread Yun Tang (Jira)
Yun Tang created FLINK-25067: Summary: Correct the description of RocksDB's background threads Key: FLINK-25067 URL: https://issues.apache.org/jira/browse/FLINK-25067 Project: Flink Issue Type

Re: [VOTE][FLIP-195] Improve the name and structure of vertex and operator name for job

2021-11-23 Thread Yun Tang
+1 (binding) Best Yun Tang On 2021/11/24 07:50:15 Sergey Nuyanzin wrote: > +1 (non-binding) > > On Wed, Nov 24, 2021 at 8:38 AM godfrey he wrote: > > > +1 (binding) > > > > Best, > > Godfrey > > > > Jark Wu 于2021年11月24日周三 下午12:02写道: > &

Re: [DISCUSS] FLIP-193: Snapshots ownership

2021-11-22 Thread Yun Tang
Yun Tang On 2021/11/22 19:49:11 Dawid Wysakowicz wrote: > There is one more fundamental issue with either of your two > proposals that've just came to my mind. > What happens if you have externalized checkpoints and the job fails > before the initial checkpoint c

Re: [DISCUSS] Improve the name and structure of job vertex and operator name for job

2021-11-22 Thread Yun Tang
Hi Wenlong, Thanks for the update. And +1 for this proposal. Best Yun Tang On 2021/11/22 07:28:25 "wenlong.lwl" wrote: > Hi, Yun Gao, Yun Tang, and Aitozi, > thanks for the suggestion again, I have added following section in proposed > changes at > https://cwiki.apache.

Re: [DISCUSS] Improve the name and structure of job vertex and operator name for job

2021-11-18 Thread Yun Tang
"source --> flatMap --> sink" to "[vertex-0] souce --> [vertex-1] flatMap --> [vertex-2] sink". This could make user or developer much easier to know which vertex is wrong when meeting exceptions. Best Yun Tang On 2021/11/17 07:42:28 godfrey he wrote: > Hi Wenlon

Re: [DISCUSS] Definition of Done for Apache Flink

2021-11-18 Thread Yun Tang
s at most of the time. I think this discussion draws the attention that whether we should strictly obey the review process via using flinkbot or still not force committer to leverage it. [1] https://github.com/apache/flink/pull/17801#issuecomment-970048058 Best Yun Tang On 2021/11/16 10:38:39 Ingo

Re: [ANNOUNCE] New Apache Flink Committer - Yingjie Cao

2021-11-18 Thread Yun Tang
Congratulations, Yinjie! Best Yun Tang On 2021/11/18 08:01:44 Martijn Visser wrote: > Congratulations! > > On Thu, 18 Nov 2021 at 02:44, Leonard Xu wrote: > > > Congratulations!Yingjie > > > > Best, > > Leonard > > > > > 在 2021年11月18日,0

[jira] [Created] (FLINK-24932) Frocksdb cannot run on Apple M1

2021-11-16 Thread Yun Tang (Jira)
Yun Tang created FLINK-24932: Summary: Frocksdb cannot run on Apple M1 Key: FLINK-24932 URL: https://issues.apache.org/jira/browse/FLINK-24932 Project: Flink Issue Type: Bug Components

Re: Re:[ANNOUNCE] New Apache Flink Committer - Jing Zhang

2021-11-15 Thread Yun Tang
Congratulations, Jing! Best Yun Tang From: Yuepeng Pan Sent: Tuesday, November 16, 2021 10:12 To: dev@flink.apache.org Cc: beyond1...@gmail.com Subject: Re:[ANNOUNCE] New Apache Flink Committer - Jing Zhang Congrats. Best, Yuepeng Pan At 2021-11

Re: [ANNOUNCE] New Apache Flink Committer - Leonard Xu

2021-11-12 Thread Yun Tang
Congratulations & well deserved, Leonard! Best, Yun Tang Get Outlook for Android<https://aka.ms/AAb9ysg> From: Dian Fu Sent: Friday, November 12, 2021 4:34:35 PM To: dev Subject: Re: [ANNOUNCE] New Apache Flink Committer - Leonard Xu Congratulation

Re: [ANNOUNCE] New Apache Flink Committer - Yangze Guo

2021-11-12 Thread Yun Tang
Congratulations, Yangze! Best, Yun Tang Get Outlook for Android<https://aka.ms/AAb9ysg> From: Dian Fu Sent: Friday, November 12, 2021 4:34:53 PM To: dev Subject: Re: [ANNOUNCE] New Apache Flink Committer - Yangze Guo Congratulations! Regards, Dian

[jira] [Created] (FLINK-24788) Report RocksDB statistics as metrics

2021-11-05 Thread Yun Tang (Jira)
Yun Tang created FLINK-24788: Summary: Report RocksDB statistics as metrics Key: FLINK-24788 URL: https://issues.apache.org/jira/browse/FLINK-24788 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-24787) Add more details of state latency tracking documentation

2021-11-05 Thread Yun Tang (Jira)
Yun Tang created FLINK-24787: Summary: Add more details of state latency tracking documentation Key: FLINK-24787 URL: https://issues.apache.org/jira/browse/FLINK-24787 Project: Flink Issue Type

[jira] [Created] (FLINK-24786) Introduce metrics of RocksDB's statistis

2021-11-05 Thread Yun Tang (Jira)
Yun Tang created FLINK-24786: Summary: Introduce metrics of RocksDB's statistis Key: FLINK-24786 URL: https://issues.apache.org/jira/browse/FLINK-24786 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-24785) Relocate RocksDB's log under flink log directory by default

2021-11-05 Thread Yun Tang (Jira)
Yun Tang created FLINK-24785: Summary: Relocate RocksDB's log under flink log directory by default Key: FLINK-24785 URL: https://issues.apache.org/jira/browse/FLINK-24785 Project: Flink Issue

[jira] [Created] (FLINK-24784) Enable state.backend.latency-track.state-name-as-variable by default

2021-11-05 Thread Yun Tang (Jira)
Yun Tang created FLINK-24784: Summary: Enable state.backend.latency-track.state-name-as-variable by default Key: FLINK-24784 URL: https://issues.apache.org/jira/browse/FLINK-24784 Project: Flink

[jira] [Created] (FLINK-24783) Improve state backend monitoring experience and usability

2021-11-05 Thread Yun Tang (Jira)
Yun Tang created FLINK-24783: Summary: Improve state backend monitoring experience and usability Key: FLINK-24783 URL: https://issues.apache.org/jira/browse/FLINK-24783 Project: Flink Issue Type

Re: [ANNOUNCE] Documentation now available at nightlies.apache.org

2021-11-04 Thread Yun Tang
ion? Best Yun Tang From: Chesnay Schepler Sent: Friday, September 10, 2021 13:32 To: dev@flink.apache.org ; Leonard Xu Subject: Re: [ANNOUNCE] Documentation now available at nightlies.apache.org A redirection will be setup by infra at some point. On 10/09/

[jira] [Created] (FLINK-24678) Correct the metric name of map state contains latency

2021-10-28 Thread Yun Tang (Jira)
Yun Tang created FLINK-24678: Summary: Correct the metric name of map state contains latency Key: FLINK-24678 URL: https://issues.apache.org/jira/browse/FLINK-24678 Project: Flink Issue Type

[jira] [Created] (FLINK-24667) Channel state writer would fail the task directly if meeting exception previously

2021-10-27 Thread Yun Tang (Jira)
Yun Tang created FLINK-24667: Summary: Channel state writer would fail the task directly if meeting exception previously Key: FLINK-24667 URL: https://issues.apache.org/jira/browse/FLINK-24667 Project

Re: [ANNOUNCE] Apache Flink 1.13.3 released

2021-10-22 Thread Yun Tang
Thanks for Chesnay & Martijn and everyone who made this release happen. Best Yun Tang From: JING ZHANG Sent: Friday, October 22, 2021 10:17 To: dev Cc: Martijn Visser ; Jingsong Li ; Chesnay Schepler ; user Subject: Re: [ANNOUNCE] Apache Flink 1.13.3 rele

Re: [DISCUSS] Releasing Flink 1.13.3

2021-09-23 Thread Yun Tang
of flink-1.13.3. [1] https://issues.apache.org/jira/browse/FLINK-23519 Best Yun Tang From: Leonard Xu Sent: Friday, September 24, 2021 10:22 To: +dev Subject: Re: [DISCUSS] Releasing Flink 1.13.3 > My conclusion would be that there are no tickets open right

[jira] [Created] (FLINK-24210) Window related serailizer should not return 0 as its serialized length

2021-09-08 Thread Yun Tang (Jira)
Yun Tang created FLINK-24210: Summary: Window related serailizer should not return 0 as its serialized length Key: FLINK-24210 URL: https://issues.apache.org/jira/browse/FLINK-24210 Project: Flink

[jira] [Created] (FLINK-24106) Remove notice that python does not support state TTL

2021-09-01 Thread Yun Tang (Jira)
Yun Tang created FLINK-24106: Summary: Remove notice that python does not support state TTL Key: FLINK-24106 URL: https://issues.apache.org/jira/browse/FLINK-24106 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-24105) state TTL might not take effect for pyflink

2021-09-01 Thread Yun Tang (Jira)
Yun Tang created FLINK-24105: Summary: state TTL might not take effect for pyflink Key: FLINK-24105 URL: https://issues.apache.org/jira/browse/FLINK-24105 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-24046) Refactor the relationship bwtween PredefinedOptions and RocksDBConfigurableOptions

2021-08-29 Thread Yun Tang (Jira)
Yun Tang created FLINK-24046: Summary: Refactor the relationship bwtween PredefinedOptions and RocksDBConfigurableOptions Key: FLINK-24046 URL: https://issues.apache.org/jira/browse/FLINK-24046 Project

[jira] [Created] (FLINK-23992) Update doc version in release-1.13 to 1.13.2

2021-08-26 Thread Yun Tang (Jira)
Yun Tang created FLINK-23992: Summary: Update doc version in release-1.13 to 1.13.2 Key: FLINK-23992 URL: https://issues.apache.org/jira/browse/FLINK-23992 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-23869) Correct javadoc of ExecutionConfig#registerKryoType

2021-08-19 Thread Yun Tang (Jira)
Yun Tang created FLINK-23869: Summary: Correct javadoc of ExecutionConfig#registerKryoType Key: FLINK-23869 URL: https://issues.apache.org/jira/browse/FLINK-23869 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-23800) Expose newly added RocksDB native metrics

2021-08-16 Thread Yun Tang (Jira)
Yun Tang created FLINK-23800: Summary: Expose newly added RocksDB native metrics Key: FLINK-23800 URL: https://issues.apache.org/jira/browse/FLINK-23800 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-23798) Avoid using reflection to get filter when partition filter is enabled

2021-08-16 Thread Yun Tang (Jira)
Yun Tang created FLINK-23798: Summary: Avoid using reflection to get filter when partition filter is enabled Key: FLINK-23798 URL: https://issues.apache.org/jira/browse/FLINK-23798 Project: Flink

[jira] [Created] (FLINK-23791) Enable RocksDB log again

2021-08-15 Thread Yun Tang (Jira)
Yun Tang created FLINK-23791: Summary: Enable RocksDB log again Key: FLINK-23791 URL: https://issues.apache.org/jira/browse/FLINK-23791 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-23789) Remove unnecessary setTotalOrderForSeek for Rocks iterator

2021-08-15 Thread Yun Tang (Jira)
Yun Tang created FLINK-23789: Summary: Remove unnecessary setTotalOrderForSeek for Rocks iterator Key: FLINK-23789 URL: https://issues.apache.org/jira/browse/FLINK-23789 Project: Flink Issue

<    1   2   3   4   5   6   >