[jira] [Comment Edited] (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=16686065#comment-16686065 ] Yun Tang edited comment on FLINK-10855 at 11/14/18 3:54 AM:

[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=16686065#comment-16686065 ] Yun Tang commented on FLINK-10855: -- [~till.rohrmann], as far as I know, the checkpoint

[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] [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=17852289#comment-17852289 ] Yun Tang commented on FLINK-9043: - [~mszacillo] After six years of launching this discuss

[jira] [Commented] (FLINK-35291) Improve the ROW data deserialization performance of DebeziumEventDeserializationScheme

[ https://issues.apache.org/jira/browse/FLINK-35291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17852300#comment-17852300 ] Yun Tang commented on FLINK-35291: -- I think this is a useful observation. Since {{Strin

[jira] [Commented] (FLINK-33265) Support source parallelism setting for Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-33265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17852431#comment-17852431 ] Yun Tang commented on FLINK-33265: -- [~sudewei.sdw] What's the progress of this ticket?

[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] [Comment Edited] (FLINK-36043) [SQL] Unexpected SinkMaterializer operator generated when use coalesce function on upsert key fields

[ https://issues.apache.org/jira/browse/FLINK-36043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17873210#comment-17873210 ] Yun Tang edited comment on FLINK-36043 at 8/13/24 1:58 PM: --- [~

[jira] [Commented] (FLINK-36043) [SQL] Unexpected SinkMaterializer operator generated when use coalesce function on upsert key fields

[ https://issues.apache.org/jira/browse/FLINK-36043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17873210#comment-17873210 ] Yun Tang commented on FLINK-36043: -- [~catyee] I think the root cause is the difference

[jira] [Updated] (FLINK-32299) Upload python jar when sql contains python udf jar

[ https://issues.apache.org/jira/browse/FLINK-32299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-32299: - Fix Version/s: 1.19.0 > Upload python jar when sql contains python udf jar > ---

[jira] [Created] (FLINK-34967) Update Website copyright footer to 2024

Yun Tang created FLINK-34967: Summary: Update Website copyright footer to 2024 Key: FLINK-34967 URL: https://issues.apache.org/jira/browse/FLINK-34967 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-34976) LD_PRELOAD environment may not be effective after su to flink user

[ https://issues.apache.org/jira/browse/FLINK-34976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17832742#comment-17832742 ] Yun Tang commented on FLINK-34976: -- I don't think the running Flink process would drop

[jira] [Resolved] (FLINK-34968) Update flink-web copyright to 2024

[ https://issues.apache.org/jira/browse/FLINK-34968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-34968. -- Assignee: Yu Chen Resolution: Fixed merged in asf-site: 3cda9946df98f0d2abda396ac87f7bc192ec70e0

[jira] [Closed] (FLINK-34967) Update Website copyright footer to 2024

[ https://issues.apache.org/jira/browse/FLINK-34967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang closed FLINK-34967. Resolution: Fixed > Update Website copyright footer to 2024 > --- > >

[jira] [Commented] (FLINK-33934) Flink SQL Source use raw format maybe lead to data lost

[ https://issues.apache.org/jira/browse/FLINK-33934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17834765#comment-17834765 ] Yun Tang commented on FLINK-33934: -- I think it's easy to let data lost when using {{raw

[jira] [Updated] (FLINK-33934) Flink SQL Source use raw format maybe lead to data lost

[ https://issues.apache.org/jira/browse/FLINK-33934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-33934: - Affects Version/s: 1.19.0 1.18.0 1.17.0

[jira] [Assigned] (FLINK-33934) Flink SQL Source use raw format maybe lead to data lost

[ https://issues.apache.org/jira/browse/FLINK-33934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-33934: Assignee: Yuan Kui > Flink SQL Source use raw format maybe lead to data lost > --

[jira] [Commented] (FLINK-35039) Create Profiling JobManager/TaskManager Instance failed

[ https://issues.apache.org/jira/browse/FLINK-35039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838867#comment-17838867 ] Yun Tang commented on FLINK-35039: -- [~wczhu] Thanks for finding this problem in YARN en

[jira] [Updated] (FLINK-35111) Modify the spelling mistakes in the taskmanager html

[ https://issues.apache.org/jira/browse/FLINK-35111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-35111: - Fix Version/s: 1.19.0 (was: 1.20.0) > Modify the spelling mistakes in the taskman

[jira] [Updated] (FLINK-35111) Modify the spelling mistakes in the taskmanager html

[ https://issues.apache.org/jira/browse/FLINK-35111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-35111: - Affects Version/s: (was: 1.19.0) > Modify the spelling mistakes in the taskmanager html > --

[jira] [Assigned] (FLINK-35039) Create Profiling JobManager/TaskManager Instance failed

[ https://issues.apache.org/jira/browse/FLINK-35039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-35039: Assignee: ude > Create Profiling JobManager/TaskManager Instance failed > ---

[jira] [Commented] (FLINK-35039) Create Profiling JobManager/TaskManager Instance failed

[ https://issues.apache.org/jira/browse/FLINK-35039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838951#comment-17838951 ] Yun Tang commented on FLINK-35039: -- [~wczhu] Already assigned to you. > Create Profili

[jira] [Created] (FLINK-9758) ContinuousFileProcessingTest failed due to not setting runtimeContext

Yun Tang created FLINK-9758: --- Summary: ContinuousFileProcessingTest failed due to not setting runtimeContext Key: FLINK-9758 URL: https://issues.apache.org/jira/browse/FLINK-9758 Project: Flink Is

[jira] [Commented] (FLINK-4387) Instability in KvStateClientTest.testClientServerIntegration()

[ https://issues.apache.org/jira/browse/FLINK-4387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16538561#comment-16538561 ] Yun Tang commented on FLINK-4387: - [~NicoK] Has this issue already been fixed? I noticed

[jira] [Commented] (FLINK-9598) [Checkpoints] The config Minimum Pause Between Checkpoints doesn't work when there's a checkpoint failure

[ https://issues.apache.org/jira/browse/FLINK-9598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16545318#comment-16545318 ] Yun Tang commented on FLINK-9598: - Hi [~premsantosh], the "Minimum Pause Between Checkpoi

[jira] [Assigned] (FLINK-9598) [Checkpoints] The config Minimum Pause Between Checkpoints doesn't work when there's a checkpoint failure

[ https://issues.apache.org/jira/browse/FLINK-9598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-9598: --- Assignee: Yun Tang > [Checkpoints] The config Minimum Pause Between Checkpoints doesn't work when >

[jira] [Commented] (FLINK-10712) RestartPipelinedRegionStrategy does not restore state

[ https://issues.apache.org/jira/browse/FLINK-10712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668964#comment-16668964 ] Yun Tang commented on FLINK-10712: -- We have refactored _FailoverRegion.java_ to support

[jira] [Comment Edited] (FLINK-10712) RestartPipelinedRegionStrategy does not restore state

[ https://issues.apache.org/jira/browse/FLINK-10712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16668964#comment-16668964 ] Yun Tang edited comment on FLINK-10712 at 10/30/18 4:18 PM:

[jira] [Assigned] (FLINK-10712) RestartPipelinedRegionStrategy does not restore state

[ https://issues.apache.org/jira/browse/FLINK-10712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-10712: Assignee: Yun Tang > RestartPipelinedRegionStrategy does not restore state >

[jira] [Created] (FLINK-10267) [State] Fix arbitrary iterator access on RocksDBMapIterator

Yun Tang created FLINK-10267: Summary: [State] Fix arbitrary iterator access on RocksDBMapIterator Key: FLINK-10267 URL: https://issues.apache.org/jira/browse/FLINK-10267 Project: Flink Issue Ty

[jira] [Updated] (FLINK-10267) [State] Fix arbitrary iterator access on RocksDBMapIterator

[ https://issues.apache.org/jira/browse/FLINK-10267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-10267: - Description: Currently, RocksDBMapIterator would load 128 entries into local cacheEntries every time if

[jira] [Created] (FLINK-9328) RocksDBStateBackend might use PlaceholderStreamStateHandle to restor due to StateBackendTestBase class not register snapshots in some UTs

Yun Tang created FLINK-9328: --- Summary: RocksDBStateBackend might use PlaceholderStreamStateHandle to restor due to StateBackendTestBase class not register snapshots in some UTs Key: FLINK-9328 URL: https://issues.apach

[jira] [Commented] (FLINK-11138) RocksDB's wal seems to be useless in rocksdb-state-backend that reduce the disk's overhead

[ https://issues.apache.org/jira/browse/FLINK-11138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16719713#comment-16719713 ] Yun Tang commented on FLINK-11138: -- Yes, you are right. But we already disable the WAL

[jira] [Commented] (FLINK-11171) Unexpected timestamp deserialization failure in RocksDB state backend

[ https://issues.apache.org/jira/browse/FLINK-11171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16722952#comment-16722952 ] Yun Tang commented on FLINK-11171: -- [~sayatez] I think the 2nd problem should have no r

[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=16728133#comment-16728133 ] Yun Tang commented on FLINK-10930: -- I plan to close this issue, and we should move to

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

[ https://issues.apache.org/jira/browse/FLINK-10930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang closed FLINK-10930. Resolution: Won't Fix > Refactor checkpoint directory layout > > >

[jira] [Commented] (FLINK-11212) operator metric key can repalce operator name by operator id

[ https://issues.apache.org/jira/browse/FLINK-11212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16728299#comment-16728299 ] Yun Tang commented on FLINK-11212: -- >From my point of view, the operator id is not so r

[jira] [Commented] (FLINK-10912) Configurable RocksDBStateBackend options factory

[ https://issues.apache.org/jira/browse/FLINK-10912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16728304#comment-16728304 ] Yun Tang commented on FLINK-10912: -- [~thw] I would like to take this issue if you don't

[jira] [Assigned] (FLINK-10912) Configurable RocksDBStateBackend options factory

[ https://issues.apache.org/jira/browse/FLINK-10912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-10912: Assignee: Yun Tang > Configurable RocksDBStateBackend options factory > -

[jira] [Assigned] (FLINK-11292) Document how to use the new CompositeTypeSerializerSnapshot

[ https://issues.apache.org/jira/browse/FLINK-11292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-11292: Assignee: Yun Tang > Document how to use the new CompositeTypeSerializerSnapshot > --

[jira] [Created] (FLINK-11313) [checkpoint] Introduce LZ4 compression for keyed state in full checkpoints and savepoints

Yun Tang created FLINK-11313: Summary: [checkpoint] Introduce LZ4 compression for keyed state in full checkpoints and savepoints Key: FLINK-11313 URL: https://issues.apache.org/jira/browse/FLINK-11313 Pro

[jira] [Assigned] (FLINK-11333) First-class support for Protobuf types with evolvable schema

[ https://issues.apache.org/jira/browse/FLINK-11333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-11333: Assignee: Yun Tang > First-class support for Protobuf types with evolvable schema > -

[jira] [Assigned] (FLINK-11363) Check and remove TaskManagerConfigurationTest

[ https://issues.apache.org/jira/browse/FLINK-11363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-11363: Assignee: Yun Tang > Check and remove TaskManagerConfigurationTest >

[jira] [Assigned] (FLINK-11366) Check and port TaskManagerMetricsTest to new code base if necessary

[ https://issues.apache.org/jira/browse/FLINK-11366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-11366: Assignee: Yun Tang > Check and port TaskManagerMetricsTest to new code base if necessary > --

[jira] [Assigned] (FLINK-11368) Check and port TaskManagerStartupTest to new code base if necessary

[ https://issues.apache.org/jira/browse/FLINK-11368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-11368: Assignee: Yun Tang > Check and port TaskManagerStartupTest to new code base if necessary > --

[jira] [Commented] (FLINK-11380) YarnFlinkResourceManagerTest test case crashed

[ https://issues.apache.org/jira/browse/FLINK-11380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16748350#comment-16748350 ] Yun Tang commented on FLINK-11380: -- Another instance https://api.travis-ci.org/v3/job/4

[jira] [Commented] (FLINK-9920) BucketingSinkFaultToleranceITCase fails on travis

[ https://issues.apache.org/jira/browse/FLINK-9920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16748419#comment-16748419 ] Yun Tang commented on FLINK-9920: - Another instance:  [https://api.travis-ci.org/v3/job/4

[jira] [Commented] (FLINK-11427) Protobuf parquet writer implementation

[ https://issues.apache.org/jira/browse/FLINK-11427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16752126#comment-16752126 ] Yun Tang commented on FLINK-11427: -- [~zjuguanghu] I just have a curious question which

[jira] [Commented] (FLINK-11437) EventTimeWindowCheckpointingITCase#testTumblingTimeWindowWithKVStateMaxMaxParallelism caused CancellationException

[ https://issues.apache.org/jira/browse/FLINK-11437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16754159#comment-16754159 ] Yun Tang commented on FLINK-11437: --  From the detailed message, I think this is because

[jira] [Commented] (FLINK-11333) First-class support for Protobuf types with evolvable schema

[ https://issues.apache.org/jira/browse/FLINK-11333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16755185#comment-16755185 ] Yun Tang commented on FLINK-11333: -- I planed to use avro-protobuf to extract Protobuf m

[jira] [Commented] (FLINK-9920) BucketingSinkFaultToleranceITCase fails on travis

[ https://issues.apache.org/jira/browse/FLINK-9920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16757409#comment-16757409 ] Yun Tang commented on FLINK-9920: - With more detailed messages, I believe this bug happen

[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] [Updated] (FLINK-12333) Add documentation for all async operations through REST

[ https://issues.apache.org/jira/browse/FLINK-12333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-12333: - Summary: Add documentation for all async operations through REST (was: Add documentation around save p

[jira] [Commented] (FLINK-12333) Add documentation around save point with cancel lifecycle through REST

[ https://issues.apache.org/jira/browse/FLINK-12333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16827811#comment-16827811 ] Yun Tang commented on FLINK-12333: -- Actually, not only triggering savepoint operation,

[jira] [Created] (FLINK-12353) Add missing module to collect_japicmp_reports.sh

Yun Tang created FLINK-12353: Summary: Add missing module to collect_japicmp_reports.sh Key: FLINK-12353 URL: https://issues.apache.org/jira/browse/FLINK-12353 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-12358) Verify whether rest documenation needs to be updated when building pull request

Yun Tang created FLINK-12358: Summary: Verify whether rest documenation needs to be updated when building pull request Key: FLINK-12358 URL: https://issues.apache.org/jira/browse/FLINK-12358 Project: Flin

[jira] [Commented] (FLINK-12333) Add documentation for all async operations through REST

[ https://issues.apache.org/jira/browse/FLINK-12333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16829232#comment-16829232 ] Yun Tang commented on FLINK-12333: -- [~till.rohrmann] I have already refactored {{Abstr

[jira] [Commented] (FLINK-12353) Add missing module to collect_japicmp_reports.sh

[ https://issues.apache.org/jira/browse/FLINK-12353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16829387#comment-16829387 ] Yun Tang commented on FLINK-12353: -- [~Zentol] This sounds more reasonable, I would like

[jira] [Commented] (FLINK-12358) Verify whether rest documenation needs to be updated when building pull request

[ https://issues.apache.org/jira/browse/FLINK-12358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16829395#comment-16829395 ] Yun Tang commented on FLINK-12358: -- [~Zentol] Thanks for your suggestion, I would try t

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

Yun Tang created FLINK-12380: Summary: Add thread name in the log4j.properties Key: FLINK-12380 URL: https://issues.apache.org/jira/browse/FLINK-12380 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-12416) Docker build script fails on symlink creation ln -s

[ https://issues.apache.org/jira/browse/FLINK-12416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16834344#comment-16834344 ] Yun Tang commented on FLINK-12416: -- [~slav4ik], would you please share the full command

[jira] [Assigned] (FLINK-12416) Docker build script fails on symlink creation ln -s

[ https://issues.apache.org/jira/browse/FLINK-12416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-12416: Assignee: Yun Tang > Docker build script fails on symlink creation ln -s > --

[jira] [Commented] (FLINK-12416) Docker build script fails on symlink creation ln -s

[ https://issues.apache.org/jira/browse/FLINK-12416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16834981#comment-16834981 ] Yun Tang commented on FLINK-12416: -- [~slav4ik] Thanks for your reply, I could reproduce

[jira] [Commented] (FLINK-12416) Docker build script fails on symlink creation ln -s

[ https://issues.apache.org/jira/browse/FLINK-12416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16835413#comment-16835413 ] Yun Tang commented on FLINK-12416: -- [~rmetzger] Sure, after figure out why this problem

[jira] [Assigned] (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:all-tabpanel ] Yun Tang reassigned FLINK-12375: Assignee: Yun Tang > flink-container job jar does not have read permissions > ---

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

[ https://issues.apache.org/jira/browse/FLINK-12380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16837766#comment-16837766 ] Yun Tang commented on FLINK-12380: -- [~azagrebin] If so why current [logbak.xml|https:/

[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

  1   2   3   4   5   6   7   8   9   10   >