[jira] [Commented] (FLINK-5510) Replace Scala Future with FlinkFuture in QueryableStateClient

[ https://issues.apache.org/jira/browse/FLINK-5510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16196560#comment-16196560 ] Yun Tang commented on FLINK-5510: - According to [FLINK-725 (Remove Flink Futures or back t

[jira] [Created] (FLINK-10930) Refactor checkpoint directory layout

Yun Tang created FLINK-10930: Summary: Refactor checkpoint directory layout Key: FLINK-10930 URL: https://issues.apache.org/jira/browse/FLINK-10930 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-9043) Introduce a friendly way to resume the job from externalized checkpoints automatically

[ https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692610#comment-16692610 ] Yun Tang commented on FLINK-9043: - I quite agreed with [~sihuazhou]'s idea, user just nee

[jira] [Comment Edited] (FLINK-9043) Introduce a friendly way to resume the job from externalized checkpoints automatically

[ https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16692610#comment-16692610 ] Yun Tang edited comment on FLINK-9043 at 11/20/18 3:55 AM: --- I q

[jira] [Created] (FLINK-10954) Hardlink from files of previous local stored state might cross devices

Yun Tang created FLINK-10954: Summary: Hardlink from files of previous local stored state might cross devices Key: FLINK-10954 URL: https://issues.apache.org/jira/browse/FLINK-10954 Project: Flink

[jira] [Assigned] (FLINK-10954) Hardlink from files of previous local stored state might cross devices

[ https://issues.apache.org/jira/browse/FLINK-10954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-10954: Assignee: Yun Tang > Hardlink from files of previous local stored state might cross devices > ---

[jira] [Commented] (FLINK-10954) Hardlink from files of previous local stored state might cross devices

[ https://issues.apache.org/jira/browse/FLINK-10954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16693531#comment-16693531 ] Yun Tang commented on FLINK-10954: -- First of all, I plan to handle the exception after

[jira] [Commented] (FLINK-10930) Refactor checkpoint directory layout

[ https://issues.apache.org/jira/browse/FLINK-10930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16698560#comment-16698560 ] Yun Tang commented on FLINK-10930: -- [~StephanEwen] I know this suggested changes would

[jira] [Commented] (FLINK-10930) Refactor checkpoint directory layout

[ https://issues.apache.org/jira/browse/FLINK-10930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16701359#comment-16701359 ] Yun Tang commented on FLINK-10930: -- [~StephanEwen] I try to answer your points of view:

[jira] [Commented] (FLINK-10930) Refactor checkpoint directory layout

[ https://issues.apache.org/jira/browse/FLINK-10930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16704286#comment-16704286 ] Yun Tang commented on FLINK-10930: -- [~StephanEwen] I think your opinion to refactor the

[jira] [Commented] (FLINK-10930) Refactor checkpoint directory layout

[ https://issues.apache.org/jira/browse/FLINK-10930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16708978#comment-16708978 ] Yun Tang commented on FLINK-10930: -- Speaking of eager and proper discarding useless sta

[jira] [Commented] (FLINK-10930) Refactor checkpoint directory layout

[ https://issues.apache.org/jira/browse/FLINK-10930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16713903#comment-16713903 ] Yun Tang commented on FLINK-10930: -- [~StephanEwen] The ideas of cleaning up exclusive a

[jira] [Created] (FLINK-11107) [state] Avoid memory stateBackend to create arbitrary folders under HA path when no checkpoint path configured

Yun Tang created FLINK-11107: Summary: [state] Avoid memory stateBackend to create arbitrary folders under HA path when no checkpoint path configured Key: FLINK-11107 URL: https://issues.apache.org/jira/browse/FLINK-1

[jira] [Updated] (FLINK-11107) [state] Avoid memory stateBackend to create arbitrary folders under HA path when no checkpoint path configured

[ https://issues.apache.org/jira/browse/FLINK-11107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-11107: - Description: Currently, memory state-backend would create a folder named with random UUID under HA dire

[jira] [Commented] (FLINK-11107) [state] Avoid memory stateBackend to create arbitrary folders under HA path when no checkpoint path configured

[ https://issues.apache.org/jira/browse/FLINK-11107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16714033#comment-16714033 ] Yun Tang commented on FLINK-11107: -- @ [~StephanEwen] , as you commented in code below:

[jira] [Commented] (FLINK-10724) Refactor failure handling in check point coordinator

[ https://issues.apache.org/jira/browse/FLINK-10724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16715194#comment-16715194 ] Yun Tang commented on FLINK-10724: -- [~yanghua] I think CheckpointSubsumed should not be

[jira] [Created] (FLINK-13910) Many serializable classes have no explicit 'serialVersionUID'

Yun Tang created FLINK-13910: Summary: Many serializable classes have no explicit 'serialVersionUID' Key: FLINK-13910 URL: https://issues.apache.org/jira/browse/FLINK-13910 Project: Flink Issue

[jira] [Updated] (FLINK-13910) Many serializable classes have no explicit 'serialVersionUID'

[ https://issues.apache.org/jira/browse/FLINK-13910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-13910: - Fix Version/s: 1.9.1 1.10.0 > Many serializable classes have no explicit 'serialVersi

[jira] [Commented] (FLINK-13910) Many serializable classes have no explicit 'serialVersionUID'

[ https://issues.apache.org/jira/browse/FLINK-13910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16919333#comment-16919333 ] Yun Tang commented on FLINK-13910: -- [~aljoscha] [~abgore], what do you think of this? W

[jira] [Comment Edited] (FLINK-13910) Many serializable classes have no explicit 'serialVersionUID'

[ https://issues.apache.org/jira/browse/FLINK-13910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16919333#comment-16919333 ] Yun Tang edited comment on FLINK-13910 at 8/30/19 8:43 AM: --- [~

[jira] [Updated] (FLINK-13910) Many serializable classes have no explicit 'serialVersionUID'

[ https://issues.apache.org/jira/browse/FLINK-13910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-13910: - Component/s: API / Type Serialization System > Many serializable classes have no explicit 'serialVersion

[jira] [Commented] (FLINK-13910) Many serializable classes have no explicit 'serialVersionUID'

[ https://issues.apache.org/jira/browse/FLINK-13910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16919356#comment-16919356 ] Yun Tang commented on FLINK-13910: -- [~dawidwys] Thanks for your reply. Actually I come

[jira] [Commented] (FLINK-13845) Drop all the content of removed "Checkpointed" interface

[ https://issues.apache.org/jira/browse/FLINK-13845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16919384#comment-16919384 ] Yun Tang commented on FLINK-13845: -- [~aljoscha], what do you think of this issue. I thi

[jira] [Commented] (FLINK-10837) Kafka 2.0 test KafkaITCase.testOneToOneSources dead locked on deleteTestTopic?

[ https://issues.apache.org/jira/browse/FLINK-10837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16925526#comment-16925526 ] Yun Tang commented on FLINK-10837: -- I come across this problem in instance [https://ap

[jira] [Created] (FLINK-14032) Make the cache size of RocksDBPriorityQueueSetFactory configurable

Yun Tang created FLINK-14032: Summary: Make the cache size of RocksDBPriorityQueueSetFactory configurable Key: FLINK-14032 URL: https://issues.apache.org/jira/browse/FLINK-14032 Project: Flink I

[jira] [Commented] (FLINK-14077) get java.util.ConcurrentModificationException when push metrics to PushGateway

[ https://issues.apache.org/jira/browse/FLINK-14077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1692#comment-1692 ] Yun Tang commented on FLINK-14077: -- Hi Jun, I think this is not a Flink bug but a Kafka

[jira] [Commented] (FLINK-14091) Job can not trigger checkpoint forever after zookeeper change leader

[ https://issues.apache.org/jira/browse/FLINK-14091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16931030#comment-16931030 ] Yun Tang commented on FLINK-14091: -- >From the error description, I think {{SharedCountC

[jira] [Commented] (FLINK-14196) Nightly e2e-sticky-hadoop2.8 fails due to NPE

[ https://issues.apache.org/jira/browse/FLINK-14196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16940728#comment-16940728 ] Yun Tang commented on FLINK-14196: -- I turned on the debug level log to reproduce this l

[jira] [Commented] (FLINK-14196) Nightly e2e-sticky-hadoop2.8 fails due to NPE

[ https://issues.apache.org/jira/browse/FLINK-14196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16940967#comment-16940967 ] Yun Tang commented on FLINK-14196: -- [~liyu] Consider that the last change to {{nightly.

[jira] [Commented] (FLINK-13418) Avoid InfluxdbReporter to report unnecessary tags

[ https://issues.apache.org/jira/browse/FLINK-13418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948829#comment-16948829 ] Yun Tang commented on FLINK-13418: -- What do you think of this JIRA [~chesnay] as too ma

[jira] [Created] (FLINK-14378) Cleanup rocksDB lib folder if fail to load library

Yun Tang created FLINK-14378: Summary: Cleanup rocksDB lib folder if fail to load library Key: FLINK-14378 URL: https://issues.apache.org/jira/browse/FLINK-14378 Project: Flink Issue Type: Improv

[jira] [Created] (FLINK-14379) Supplement documentation about raw state

Yun Tang created FLINK-14379: Summary: Supplement documentation about raw state Key: FLINK-14379 URL: https://issues.apache.org/jira/browse/FLINK-14379 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-14379) Supplement documentation about raw state

[ https://issues.apache.org/jira/browse/FLINK-14379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16949697#comment-16949697 ] Yun Tang commented on FLINK-14379: -- CC [~liyu]   > Supplement documentation about raw

[jira] [Commented] (FLINK-14385) There are ClassNotFoundException when run the example in Local Setup Tutorial

[ https://issues.apache.org/jira/browse/FLINK-14385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16950413#comment-16950413 ] Yun Tang commented on FLINK-14385: -- The version to affect should start from 1.8.0 due t

[jira] [Closed] (FLINK-12380) Add thread name in the log4j.properties

[ https://issues.apache.org/jira/browse/FLINK-12380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang closed FLINK-12380. Resolution: Information Provided > Add thread name in the log4j.properties > -

[jira] [Created] (FLINK-12520) Support to provide fully-qualified domain host name in TaskManagerMetricGroup

Yun Tang created FLINK-12520: Summary: Support to provide fully-qualified domain host name in TaskManagerMetricGroup Key: FLINK-12520 URL: https://issues.apache.org/jira/browse/FLINK-12520 Project: Flink

[jira] [Commented] (FLINK-8871) Checkpoint cancellation is not propagated to stop checkpointing threads on the task manager

[ https://issues.apache.org/jira/browse/FLINK-8871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16845496#comment-16845496 ] Yun Tang commented on FLINK-8871: - [~yanghua] Yu is my mentor and just want to help me fo

[jira] [Commented] (FLINK-8871) Checkpoint cancellation is not propagated to stop checkpointing threads on the task manager

[ https://issues.apache.org/jira/browse/FLINK-8871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846527#comment-16846527 ] Yun Tang commented on FLINK-8871: - Added checkpoint cancellation design doc [https://doc

[jira] [Comment Edited] (FLINK-8871) Checkpoint cancellation is not propagated to stop checkpointing threads on the task manager

[ https://issues.apache.org/jira/browse/FLINK-8871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16846527#comment-16846527 ] Yun Tang edited comment on FLINK-8871 at 5/23/19 8:55 AM: -- Added

[jira] [Commented] (FLINK-12375) flink-container job jar does not have read permissions

[ https://issues.apache.org/jira/browse/FLINK-12375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16847435#comment-16847435 ] Yun Tang commented on FLINK-12375: -- I fix this in PR [https://github.com/apache/flink/p

[jira] [Comment Edited] (FLINK-12375) flink-container job jar does not have read permissions

[ https://issues.apache.org/jira/browse/FLINK-12375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16847435#comment-16847435 ] Yun Tang edited comment on FLINK-12375 at 5/24/19 10:02 AM:

[jira] [Commented] (FLINK-12546) Base Docker images on `library/flink`

[ https://issues.apache.org/jira/browse/FLINK-12546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16847438#comment-16847438 ] Yun Tang commented on FLINK-12546: -- [~knaufk] please correct me if I am wrong, did you

[jira] [Commented] (FLINK-10855) CheckpointCoordinator does not delete checkpoint directory of late/failed checkpoints

[ https://issues.apache.org/jira/browse/FLINK-10855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16847677#comment-16847677 ] Yun Tang commented on FLINK-10855: -- Thanks [~yanghua] to start this Jira again. I just

[jira] [Commented] (FLINK-10713) RestartIndividualStrategy does not restore state

[ https://issues.apache.org/jira/browse/FLINK-10713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16847683#comment-16847683 ] Yun Tang commented on FLINK-10713: -- Since new scheduling strategy is already started in

[jira] [Commented] (FLINK-12546) Base Docker images on `library/flink`

[ https://issues.apache.org/jira/browse/FLINK-12546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16847710#comment-16847710 ] Yun Tang commented on FLINK-12546: -- [~knaufk] Thanks for your interpretation, and I wou

[jira] [Comment Edited] (FLINK-12546) Base Docker images on `library/flink`

[ https://issues.apache.org/jira/browse/FLINK-12546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16847710#comment-16847710 ] Yun Tang edited comment on FLINK-12546 at 5/24/19 4:42 PM: --- [~

[jira] [Commented] (FLINK-8871) Checkpoint cancellation is not propagated to stop checkpointing threads on the task manager

[ https://issues.apache.org/jira/browse/FLINK-8871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16848149#comment-16848149 ] Yun Tang commented on FLINK-8871: - Thanks for [~srichter]'s comment. I agree we should fi

[jira] [Commented] (FLINK-12546) Base Docker images on `library/flink`

[ https://issues.apache.org/jira/browse/FLINK-12546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849904#comment-16849904 ] Yun Tang commented on FLINK-12546: -- Thanks for [~till.rohrmann]'s explanation, I have a

[jira] [Assigned] (FLINK-8871) Checkpoint cancellation is not propagated to stop checkpointing threads on the task manager

[ https://issues.apache.org/jira/browse/FLINK-8871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-8871: --- Assignee: Yun Tang > Checkpoint cancellation is not propagated to stop checkpointing threads on > t

[jira] [Assigned] (FLINK-11662) Discarded checkpoint can cause Tasks to fail

[ https://issues.apache.org/jira/browse/FLINK-11662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-11662: Assignee: Yun Tang > Discarded checkpoint can cause Tasks to fail > -

[jira] [Assigned] (FLINK-6931) Support custom compression formats for checkpoints (+Upgrade/Compatibility)

[ https://issues.apache.org/jira/browse/FLINK-6931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-6931: --- Assignee: Yun Tang > Support custom compression formats for checkpoints (+Upgrade/Compatibility) > -

[jira] [Commented] (FLINK-6931) Support custom compression formats for checkpoints (+Upgrade/Compatibility)

[ https://issues.apache.org/jira/browse/FLINK-6931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16860668#comment-16860668 ] Yun Tang commented on FLINK-6931: - I think https://github.com/apache/flink/pull/7819 shou

[jira] [Commented] (FLINK-8871) Checkpoint cancellation is not propagated to stop checkpointing threads on the task manager

[ https://issues.apache.org/jira/browse/FLINK-8871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16862673#comment-16862673 ] Yun Tang commented on FLINK-8871: - [~pnowojski] I noticed that you are also refactoring t

[jira] [Commented] (FLINK-12820) Support ignoring null fields when writing to Cassandra

[ https://issues.apache.org/jira/browse/FLINK-12820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16862843#comment-16862843 ] Yun Tang commented on FLINK-12820: -- Would you please help to clarify why current soluti

[jira] [Commented] (FLINK-12837) MiniClusterResource: java.lang.NoSuchFieldError: BIND_PORT

[ https://issues.apache.org/jira/browse/FLINK-12837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16863281#comment-16863281 ] Yun Tang commented on FLINK-12837: -- How did you run your tests? I think this is not a F

[jira] [Commented] (FLINK-12859) ClassNotFoundException during MapRFs init

[ https://issues.apache.org/jira/browse/FLINK-12859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16864791#comment-16864791 ] Yun Tang commented on FLINK-12859: -- [~aitozi] I am afraid that the attached image has b

[jira] [Commented] (FLINK-12859) ClassNotFoundException during MapRFs init

[ https://issues.apache.org/jira/browse/FLINK-12859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16864934#comment-16864934 ] Yun Tang commented on FLINK-12859: -- Actually I cannot reproduce your problem locally an

[jira] [Commented] (FLINK-12820) Support ignoring null fields when writing to Cassandra

[ https://issues.apache.org/jira/browse/FLINK-12820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16865105#comment-16865105 ] Yun Tang commented on FLINK-12820: -- [~ozancicek] Sorry for late reply and thanks for yo

[jira] [Assigned] (FLINK-12915) AbstractOperatorRestoreTestBase can deadlock if one test fails

[ https://issues.apache.org/jira/browse/FLINK-12915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-12915: Assignee: Yun Tang > AbstractOperatorRestoreTestBase can deadlock if one test fails > ---

[jira] [Assigned] (FLINK-12916) KeyedComplexChainTest.testMigrationAndRestore failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-12916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-12916: Assignee: Yun Tang > KeyedComplexChainTest.testMigrationAndRestore failed on Travis > ---

[jira] [Commented] (FLINK-9900) Failed to testRestoreBehaviourWithFaultyStateHandles (org.apache.flink.test.checkpointing.ZooKeeperHighAvailabilityITCase)

[ https://issues.apache.org/jira/browse/FLINK-9900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16869224#comment-16869224 ] Yun Tang commented on FLINK-9900: - Another instance which exceed 300 seconds [https://ap

[jira] [Created] (FLINK-12927) YARNSessionCapacitySchedulerITCase failed due to non prohibited exception

Yun Tang created FLINK-12927: Summary: YARNSessionCapacitySchedulerITCase failed due to non prohibited exception Key: FLINK-12927 URL: https://issues.apache.org/jira/browse/FLINK-12927 Project: Flink

[jira] [Commented] (FLINK-12927) YARNSessionCapacitySchedulerITCase failed due to non prohibited exception

[ https://issues.apache.org/jira/browse/FLINK-12927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16869448#comment-16869448 ] Yun Tang commented on FLINK-12927: -- I think this is because slot 0283de7d26d7fb08895955

[jira] [Updated] (FLINK-12353) Collect all modules of japicmp output under the same directory

[ https://issues.apache.org/jira/browse/FLINK-12353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-12353: - Summary: Collect all modules of japicmp output under the same directory (was: Add missing module to col

[jira] [Created] (FLINK-13004) Correct the logic of needToCleanupState in KeyedProcessFunctionWithCleanupState

Yun Tang created FLINK-13004: Summary: Correct the logic of needToCleanupState in KeyedProcessFunctionWithCleanupState Key: FLINK-13004 URL: https://issues.apache.org/jira/browse/FLINK-13004 Project: Flin

[jira] [Commented] (FLINK-13004) Correct the logic of needToCleanupState in KeyedProcessFunctionWithCleanupState

[ https://issues.apache.org/jira/browse/FLINK-13004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16873815#comment-16873815 ] Yun Tang commented on FLINK-13004: -- [~jark], actually, the {{timestamp}} passed in was

[jira] [Resolved] (FLINK-35353) Translate "Profiler" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-35353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-35353. -- Fix Version/s: 1.20.0 1.19.2 (was: 1.19.0) Resolution:

[jira] [Commented] (FLINK-35826) [SQL] Sliding window may produce unstable calculations when processing changelog data.

[ https://issues.apache.org/jira/browse/FLINK-35826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865430#comment-17865430 ] Yun Tang commented on FLINK-35826: -- [~xuyangzhong] Thanks for taking this ticket, when

[jira] [Assigned] (FLINK-35826) [SQL] Sliding window may produce unstable calculations when processing changelog data.

[ https://issues.apache.org/jira/browse/FLINK-35826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-35826: Assignee: xuyang > [SQL] Sliding window may produce unstable calculations when processing > chan

[jira] [Commented] (FLINK-35832) IFNULL returns incorrect result in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-35832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866298#comment-17866298 ] Yun Tang commented on FLINK-35832: -- [~lsy] [~lincoln.86xy] would you please take a look

[jira] [Commented] (FLINK-32818) Support region failover for adaptive scheduler

[ https://issues.apache.org/jira/browse/FLINK-32818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866932#comment-17866932 ] Yun Tang commented on FLINK-32818: -- [~fanrui] is this feature still in progress? > Sup

[jira] [Commented] (FLINK-35885) proctime aggregate window triggered by watermark

[ https://issues.apache.org/jira/browse/FLINK-35885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868232#comment-17868232 ] Yun Tang commented on FLINK-35885: -- I think this problem might be because user misuse e

[jira] [Commented] (FLINK-34390) Release Testing: Verify FLINK-33325 Built-in cross-platform powerful java profiler

[ https://issues.apache.org/jira/browse/FLINK-34390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818228#comment-17818228 ] Yun Tang commented on FLINK-34390: -- [~easonqin] Thanks for the testing! > Release Test

[jira] [Resolved] (FLINK-34390) Release Testing: Verify FLINK-33325 Built-in cross-platform powerful java profiler

[ https://issues.apache.org/jira/browse/FLINK-34390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-34390. -- Resolution: Fixed > Release Testing: Verify FLINK-33325 Built-in cross-platform powerful java > profi

[jira] [Resolved] (FLINK-34388) Release Testing: Verify FLINK-28915 Support artifact fetching in Standalone and native K8s application mode

[ https://issues.apache.org/jira/browse/FLINK-34388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-34388. -- Resolution: Fixed Thanks for [~Yu Chen]'s work! I'll mark this ticket as resolved first, and we can co

[jira] [Assigned] (FLINK-34500) Release Testing: Verify FLINK-33261 Support Setting Parallelism for Table/SQL Sources

[ https://issues.apache.org/jira/browse/FLINK-34500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-34500: Assignee: Yun Tang > Release Testing: Verify FLINK-33261 Support Setting Parallelism for Table/SQ

[jira] [Commented] (FLINK-34500) Release Testing: Verify FLINK-33261 Support Setting Parallelism for Table/SQL Sources

[ https://issues.apache.org/jira/browse/FLINK-34500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17821299#comment-17821299 ] Yun Tang commented on FLINK-34500: -- I started a local standalone cluster, and submitted

[jira] [Resolved] (FLINK-34500) Release Testing: Verify FLINK-33261 Support Setting Parallelism for Table/SQL Sources

[ https://issues.apache.org/jira/browse/FLINK-34500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-34500. -- Resolution: Fixed > Release Testing: Verify FLINK-33261 Support Setting Parallelism for Table/SQL > S

[jira] [Resolved] (FLINK-33436) Documentation on the built-in Profiler

[ https://issues.apache.org/jira/browse/FLINK-33436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-33436. -- Fix Version/s: 1.19.0 1.20.0 Resolution: Fixed master: 5f06ce765256b375945b9

[jira] [Commented] (FLINK-34522) StateTtlConfig#cleanupInRocksdbCompactFilter still uses the deprecated Time class

[ https://issues.apache.org/jira/browse/FLINK-34522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822754#comment-17822754 ] Yun Tang commented on FLINK-34522: -- merged in release-1.19: 161defe0bb2dc8136133e07699b

[jira] [Created] (FLINK-34617) Correct the Javadoc of org.apache.flink.api.common.time.Time

Yun Tang created FLINK-34617: Summary: Correct the Javadoc of org.apache.flink.api.common.time.Time Key: FLINK-34617 URL: https://issues.apache.org/jira/browse/FLINK-34617 Project: Flink Issue T

[jira] [Resolved] (FLINK-34622) Typo of execution_mode configuration name in Chinese document

[ https://issues.apache.org/jira/browse/FLINK-34622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-34622. -- Fix Version/s: 1.18.2 1.20.0 1.19.1 Assignee: Yu Chen

[jira] [Resolved] (FLINK-34617) Correct the Javadoc of org.apache.flink.api.common.time.Time

[ https://issues.apache.org/jira/browse/FLINK-34617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-34617. -- Fix Version/s: 1.20.0 1.19.1 Resolution: Fixed merged master: 9617598de33b2b

[jira] [Commented] (FLINK-33341) Use available local state for rescaling

[ https://issues.apache.org/jira/browse/FLINK-33341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17778665#comment-17778665 ] Yun Tang commented on FLINK-33341: -- Current FLIP-291 already supports local recovery wi

[jira] [Closed] (FLINK-33355) can't reduce the parallelism from 'n' to '1' when recovering through a savepoint.

[ https://issues.apache.org/jira/browse/FLINK-33355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang closed FLINK-33355. Resolution: Information Provided > can't reduce the parallelism from 'n' to '1' when recovering through a

[jira] [Commented] (FLINK-33355) can't reduce the parallelism from 'n' to '1' when recovering through a savepoint.

[ https://issues.apache.org/jira/browse/FLINK-33355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17779315#comment-17779315 ] Yun Tang commented on FLINK-33355: -- Changing the max-parallelism (instead of parallelis

[jira] [Commented] (FLINK-33355) can't reduce the parallelism from 'n' to '1' when recovering through a savepoint.

[ https://issues.apache.org/jira/browse/FLINK-33355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17779340#comment-17779340 ] Yun Tang commented on FLINK-33355: -- [~edmond_j] could you please share the code to repr

[jira] [Commented] (FLINK-33355) can't reduce the parallelism from 'n' to '1' when recovering through a savepoint.

[ https://issues.apache.org/jira/browse/FLINK-33355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17779358#comment-17779358 ] Yun Tang commented on FLINK-33355: -- [~edmond_j] How did you assign the parallelism, by

[jira] [Commented] (FLINK-33355) can't reduce the parallelism from 'n' to '1' when recovering through a savepoint.

[ https://issues.apache.org/jira/browse/FLINK-33355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17779364#comment-17779364 ] Yun Tang commented on FLINK-33355: -- I think this is because you forgot to set the uid f

[jira] [Assigned] (FLINK-33435) The visualization and download capabilities of profiling history

[ https://issues.apache.org/jira/browse/FLINK-33435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-33435: Assignee: Yu Chen > The visualization and download capabilities of profiling history > -

[jira] [Assigned] (FLINK-33434) Support invoke async-profiler on Taskmanager through REST API

[ https://issues.apache.org/jira/browse/FLINK-33434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-33434: Assignee: Yu Chen > Support invoke async-profiler on Taskmanager through REST API > -

[jira] [Assigned] (FLINK-33436) Documentation on the built-in Profiler

[ https://issues.apache.org/jira/browse/FLINK-33436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-33436: Assignee: Yu Chen > Documentation on the built-in Profiler >

[jira] [Assigned] (FLINK-33325) FLIP-375: Built-in cross-platform powerful java profiler

[ https://issues.apache.org/jira/browse/FLINK-33325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-33325: Assignee: Yu Chen > FLIP-375: Built-in cross-platform powerful java profiler > --

[jira] [Assigned] (FLINK-33433) Support invoke async-profiler on Jobmanager through REST API

[ https://issues.apache.org/jira/browse/FLINK-33433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-33433: Assignee: Yu Chen > Support invoke async-profiler on Jobmanager through REST API > --

[jira] [Assigned] (FLINK-33474) ShowPlan throws undefined exception In Flink Web Submit Page

[ https://issues.apache.org/jira/browse/FLINK-33474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-33474: Assignee: Yu Chen > ShowPlan throws undefined exception In Flink Web Submit Page > --

[jira] [Resolved] (FLINK-33474) ShowPlan throws undefined exception In Flink Web Submit Page

[ https://issues.apache.org/jira/browse/FLINK-33474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-33474. -- Fix Version/s: 1.17.2 1.19.0 1.18.1 Resolution: Fixed mer

[jira] [Commented] (FLINK-20672) notifyCheckpointAborted RPC failure can fail JM

[ https://issues.apache.org/jira/browse/FLINK-20672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17783868#comment-17783868 ] Yun Tang commented on FLINK-20672: -- [~Zakelly] Thanks for picking up the stale tickets.

[jira] [Comment Edited] (FLINK-20672) notifyCheckpointAborted RPC failure can fail JM

[ https://issues.apache.org/jira/browse/FLINK-20672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17783868#comment-17783868 ] Yun Tang edited comment on FLINK-20672 at 11/8/23 3:01 AM: --- [~

[jira] [Commented] (FLINK-20672) notifyCheckpointAborted RPC failure can fail JM

[ https://issues.apache.org/jira/browse/FLINK-20672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17784035#comment-17784035 ] Yun Tang commented on FLINK-20672: -- [~Zakelly] Thanks for the information. If so, I hav

[jira] [Commented] (FLINK-33263) Implement ParallelismProvider for sources in Blink planner

[ https://issues.apache.org/jira/browse/FLINK-33263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17784448#comment-17784448 ] Yun Tang commented on FLINK-33263: -- Do we still have some specific planner called {{Bli

  1   2   3   4   5   6   7   8   9   10   >