[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=17814180#comment-17814180 ] Feng Jiajie commented on FLINK-33981: - Hi [~fanrui] , thanks for the review, I have submitted the

[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

[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=17811659#comment-17811659 ] Feng Jiajie commented on FLINK-33981: - I found the issue and will submit a fix later. Please assign

[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

[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

[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=17802398#comment-17802398 ] Feng Jiajie commented on FLINK-33981: - The above code can be consistently reproduced in Flink

[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

[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 >

[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=17779507#comment-17779507 ] Feng Jiajie commented on FLINK-33360: - pr: https://github.com/apache/flink/pull/23593 >

[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

[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=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=16999892#comment-16999892 ] Feng Jiajie commented on FLINK-15308: - Really looking forward to it. > Job failed when enable

[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=16999706#comment-16999706 ] Feng Jiajie commented on FLINK-15308: - Hi [~kevin.cyj] , I can reproduce the problem every time.

[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=16998931#comment-16998931 ] Feng Jiajie edited comment on FLINK-15308 at 12/18/19 8:35 AM: --- Here is my

[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=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=16998931#comment-16998931 ] Feng Jiajie commented on FLINK-15308: -

[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

[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

[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

[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

[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

[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

[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

[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: