[jira] [Updated] (FLINK-35737) Prevent Memory Leak by Closing MemoryExecutionGraphInfoStore on MiniCluster Shutdown

[ https://issues.apache.org/jira/browse/FLINK-35737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feng Jiajie updated FLINK-35737: Description: MemoryExecutionGraphInfoStore registers a ShutdownHook upon construction and deregis

[jira] [Created] (FLINK-35737) Prevent Memory Leak by Closing MemoryExecutionGraphInfoStore on MiniCluster Shutdown

Feng Jiajie created FLINK-35737: --- Summary: Prevent Memory Leak by Closing MemoryExecutionGraphInfoStore on MiniCluster Shutdown Key: FLINK-35737 URL: https://issues.apache.org/jira/browse/FLINK-35737 Pr

[jira] [Commented] (FLINK-33981) File Descriptor References Not Released After Job Execution in MiniCluster Mode

[ https://issues.apache.org/jira/browse/FLINK-33981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814180#comment-17814180 ] Feng Jiajie commented on FLINK-33981: - Hi [~fanrui] , thanks for the review, I have

[jira] [Updated] (FLINK-33981) File Descriptor References Not Released After Job Execution in MiniCluster Mode

[ https://issues.apache.org/jira/browse/FLINK-33981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feng Jiajie updated FLINK-33981: Fix Version/s: 1.19.0 1.17.3 1.18.2 > File Descriptor Refere

[jira] [Commented] (FLINK-33981) File Descriptor References Not Released After Job Execution in MiniCluster Mode

[ https://issues.apache.org/jira/browse/FLINK-33981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811659#comment-17811659 ] Feng Jiajie commented on FLINK-33981: - I found the issue and will submit a fix later

[jira] [Updated] (FLINK-33981) File Descriptor References Not Released After Job Execution in MiniCluster Mode

[ https://issues.apache.org/jira/browse/FLINK-33981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feng Jiajie updated FLINK-33981: Description: When using MiniCluster mode, file descriptors like *{{/tmp/minicluster_6e62ab17ab058

[jira] [Updated] (FLINK-33981) File Descriptor References Not Released After Job Execution in MiniCluster Mode

[ https://issues.apache.org/jira/browse/FLINK-33981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feng Jiajie updated FLINK-33981: Description: When using MiniCluster mode, file descriptors like {{/tmp/minicluster_6e62ab17ab058e

[jira] [Commented] (FLINK-33981) File Descriptor References Not Released After Job Execution in MiniCluster Mode

[ https://issues.apache.org/jira/browse/FLINK-33981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17802398#comment-17802398 ] Feng Jiajie commented on FLINK-33981: - The above code can be consistently reproduced

[jira] [Created] (FLINK-33981) File Descriptor References Not Released After Job Execution in MiniCluster Mode

Feng Jiajie created FLINK-33981: --- Summary: File Descriptor References Not Released After Job Execution in MiniCluster Mode Key: FLINK-33981 URL: https://issues.apache.org/jira/browse/FLINK-33981 Project

[jira] [Updated] (FLINK-33360) HybridSource fails to clear the previous round's state when switching sources, leading to data loss

[ https://issues.apache.org/jira/browse/FLINK-33360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feng Jiajie updated FLINK-33360: Fix Version/s: 1.18.1 > HybridSource fails to clear the previous round's state when switching > s

[jira] [Updated] (FLINK-33360) HybridSource fails to clear the previous round's state when switching sources, leading to data loss

[ https://issues.apache.org/jira/browse/FLINK-33360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feng Jiajie updated FLINK-33360: Affects Version/s: 1.18.0 > HybridSource fails to clear the previous round's state when switching

[jira] [Commented] (FLINK-33360) HybridSource fails to clear the previous round's state when switching sources, leading to data loss

[ https://issues.apache.org/jira/browse/FLINK-33360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17779507#comment-17779507 ] Feng Jiajie commented on FLINK-33360: - pr: https://github.com/apache/flink/pull/2359

[jira] [Created] (FLINK-33360) HybridSource fails to clear the previous round's state when switching sources, leading to data loss

Feng Jiajie created FLINK-33360: --- Summary: HybridSource fails to clear the previous round's state when switching sources, leading to data loss Key: FLINK-33360 URL: https://issues.apache.org/jira/browse/FLINK-33360

[jira] [Updated] (FLINK-33171) Consistent implicit type coercion support for equal and non-equal comparisons for codegen

[ https://issues.apache.org/jira/browse/FLINK-33171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feng Jiajie updated FLINK-33171: Summary: Consistent implicit type coercion support for equal and non-equal comparisons for codegen

[jira] [Updated] (FLINK-33171) Consistent implicit type coercion support for equal and non-equi comparison for codegen

[ https://issues.apache.org/jira/browse/FLINK-33171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feng Jiajie updated FLINK-33171: Summary: Consistent implicit type coercion support for equal and non-equi comparison for codegen

[jira] [Commented] (FLINK-33171) Table SQL support Not Equal for TimePoint type and TimeString

[ https://issues.apache.org/jira/browse/FLINK-33171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17770698#comment-17770698 ] Feng Jiajie commented on FLINK-33171: - I have attempted to submit a pull request:  [

[jira] [Created] (FLINK-33171) Table SQL support Not Equal for TimePoint type and TimeString

Feng Jiajie created FLINK-33171: --- Summary: Table SQL support Not Equal for TimePoint type and TimeString Key: FLINK-33171 URL: https://issues.apache.org/jira/browse/FLINK-33171 Project: Flink

[jira] [Updated] (FLINK-15152) Job running without periodic checkpoint for stop failed at the beginning

[ https://issues.apache.org/jira/browse/FLINK-15152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feng Jiajie updated FLINK-15152: Priority: Critical (was: Major) > Job running without periodic checkpoint for stop failed at the

[jira] [Commented] (FLINK-15308) Job failed when enable pipelined-shuffle.compression and numberOfTaskSlots > 1

[ https://issues.apache.org/jira/browse/FLINK-15308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16999892#comment-16999892 ] Feng Jiajie commented on FLINK-15308: - Really looking forward to it. > Job failed w

[jira] [Commented] (FLINK-15308) Job failed when enable pipelined-shuffle.compression and numberOfTaskSlots > 1

[ https://issues.apache.org/jira/browse/FLINK-15308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16999706#comment-16999706 ] Feng Jiajie commented on FLINK-15308: - Hi [~kevin.cyj] , I can reproduce the proble

[jira] [Comment Edited] (FLINK-15308) Job failed when enable pipelined-shuffle.compression and numberOfTaskSlots > 1

[ https://issues.apache.org/jira/browse/FLINK-15308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16998931#comment-16998931 ] Feng Jiajie edited comment on FLINK-15308 at 12/18/19 8:35 AM: ---

[jira] [Comment Edited] (FLINK-15308) Job failed when enable pipelined-shuffle.compression and numberOfTaskSlots > 1

[ https://issues.apache.org/jira/browse/FLINK-15308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16998931#comment-16998931 ] Feng Jiajie edited comment on FLINK-15308 at 12/18/19 8:30 AM: ---

[jira] [Commented] (FLINK-15308) Job failed when enable pipelined-shuffle.compression and numberOfTaskSlots > 1

[ https://issues.apache.org/jira/browse/FLINK-15308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16998931#comment-16998931 ] Feng Jiajie commented on FLINK-15308: - [https://github.com/fengjiajie/my-flink-test/

[jira] [Updated] (FLINK-15308) Job failed when enable pipelined-shuffle.compression and numberOfTaskSlots > 1

[ https://issues.apache.org/jira/browse/FLINK-15308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feng Jiajie updated FLINK-15308: Priority: Blocker (was: Major) > Job failed when enable pipelined-shuffle.compression and numberO

[jira] [Created] (FLINK-15308) Job failed when enable pipelined-shuffle.compression and numberOfTaskSlots > 1

Feng Jiajie created FLINK-15308: --- Summary: Job failed when enable pipelined-shuffle.compression and numberOfTaskSlots > 1 Key: FLINK-15308 URL: https://issues.apache.org/jira/browse/FLINK-15308 Project:

[jira] [Updated] (FLINK-15152) Job running without periodic checkpoint for stop failed at the beginning

[ https://issues.apache.org/jira/browse/FLINK-15152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feng Jiajie updated FLINK-15152: Labels: checkpoint scheduler (was: checkpoint) > Job running without periodic checkpoint for stop

[jira] [Updated] (FLINK-15152) Job running without periodic checkpoint for stop failed at the beginning

[ https://issues.apache.org/jira/browse/FLINK-15152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feng Jiajie updated FLINK-15152: Description: I have a streaming job configured with periodically checkpoint, but after one week r

[jira] [Updated] (FLINK-15152) Job running without periodic checkpoint for stop failed at the beginning

[ https://issues.apache.org/jira/browse/FLINK-15152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feng Jiajie updated FLINK-15152: Description: I have a streaming job configured with periodically checkpoint, but after one week r

[jira] [Updated] (FLINK-15152) Job running without periodic checkpoint for stop failed at the beginning

[ https://issues.apache.org/jira/browse/FLINK-15152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feng Jiajie updated FLINK-15152: Description: I have a streaming job configured with periodically checkpoint, but after one week r

[jira] [Updated] (FLINK-15152) Job running without periodic checkpoint for stop failed at the beginning

[ https://issues.apache.org/jira/browse/FLINK-15152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feng Jiajie updated FLINK-15152: Description: I have a streaming job configured with periodically checkpoint, but after one week r

[jira] [Created] (FLINK-15152) Job running without periodic checkpoint for stop failed at the beginning

Feng Jiajie created FLINK-15152: --- Summary: Job running without periodic checkpoint for stop failed at the beginning Key: FLINK-15152 URL: https://issues.apache.org/jira/browse/FLINK-15152 Project: Flink