[jira] [Created] (FLINK-10640) Enable Slot Resource Profile for Resource Management

2018-10-22 Thread Xintong Song (JIRA)
Xintong Song created FLINK-10640: Summary: Enable Slot Resource Profile for Resource Management Key: FLINK-10640 URL: https://issues.apache.org/jira/browse/FLINK-10640 Project: Flink Issue Ty

[jira] [Commented] (FLINK-13554) ResourceManager should have a timeout on starting new TaskExecutors.

2019-09-01 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16920566#comment-16920566 ] Xintong Song commented on FLINK-13554: -- The stuck happens before the TaskExecutor r

[jira] [Created] (FLINK-13980) FLIP-49 Unified Memory Configuration for TaskExecutors

2019-09-05 Thread Xintong Song (Jira)
Xintong Song created FLINK-13980: Summary: FLIP-49 Unified Memory Configuration for TaskExecutors Key: FLINK-13980 URL: https://issues.apache.org/jira/browse/FLINK-13980 Project: Flink Issue

[jira] [Created] (FLINK-13981) Introduce a switch for enabling the new task executor memory configurations

2019-09-05 Thread Xintong Song (Jira)
Xintong Song created FLINK-13981: Summary: Introduce a switch for enabling the new task executor memory configurations Key: FLINK-13981 URL: https://issues.apache.org/jira/browse/FLINK-13981 Project:

[jira] [Created] (FLINK-13985) Use native memory for managed memory.

2019-09-05 Thread Xintong Song (Jira)
Xintong Song created FLINK-13985: Summary: Use native memory for managed memory. Key: FLINK-13985 URL: https://issues.apache.org/jira/browse/FLINK-13985 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-13982) Implement memory calculation logics

2019-09-05 Thread Xintong Song (Jira)
Xintong Song created FLINK-13982: Summary: Implement memory calculation logics Key: FLINK-13982 URL: https://issues.apache.org/jira/browse/FLINK-13982 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-13984) Separate on-heap and off-heap managed memory pools

2019-09-05 Thread Xintong Song (Jira)
Xintong Song created FLINK-13984: Summary: Separate on-heap and off-heap managed memory pools Key: FLINK-13984 URL: https://issues.apache.org/jira/browse/FLINK-13984 Project: Flink Issue Type

[jira] [Created] (FLINK-13986) Clean-up of legacy mode

2019-09-05 Thread Xintong Song (Jira)
Xintong Song created FLINK-13986: Summary: Clean-up of legacy mode Key: FLINK-13986 URL: https://issues.apache.org/jira/browse/FLINK-13986 Project: Flink Issue Type: Sub-task Repo

[jira] [Created] (FLINK-13983) Launch task executor with new memory calculation logics

2019-09-05 Thread Xintong Song (Jira)
Xintong Song created FLINK-13983: Summary: Launch task executor with new memory calculation logics Key: FLINK-13983 URL: https://issues.apache.org/jira/browse/FLINK-13983 Project: Flink Issue

[jira] [Updated] (FLINK-13981) Introduce a switch for enabling the new task executor memory configurations

2019-09-05 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-13981: - Description: Introduce a temporal config option as a switch between the current / new task execu

[jira] [Updated] (FLINK-13982) Implement memory calculation logics

2019-09-05 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-13982: - Description: * Introduce new configuration options * Introduce data structures and utilities.

[jira] [Updated] (FLINK-13985) Use native memory for managed memory.

2019-09-05 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-13985: - Description: * Allocate memory with {{Unsafe.allocateMemory}} ** {{MemoryManager}} Implement t

[jira] [Updated] (FLINK-13983) Launch task executor with new memory calculation logics

2019-09-05 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-13983: - Description: * Invoke data structures and utilities introduced in Step 2 to generate JVM parame

[jira] [Updated] (FLINK-13984) Separate on-heap and off-heap managed memory pools

2019-09-05 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-13984: - Description: * Update {{MemoryManager}} to have two separated pools. * Extend {{MemoryManager}}

[jira] [Updated] (FLINK-13986) Clean-up of legacy mode

2019-09-05 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-13986: - Description: * Fix / update / remove test cases for legacy mode * Deprecate / remove legacy con

[jira] [Created] (FLINK-14058) FLIP-53 Fine Grained Operator Resource Management

2019-09-11 Thread Xintong Song (Jira)
Xintong Song created FLINK-14058: Summary: FLIP-53 Fine Grained Operator Resource Management Key: FLINK-14058 URL: https://issues.apache.org/jira/browse/FLINK-14058 Project: Flink Issue Type:

[jira] [Updated] (FLINK-14058) FLIP-53 Fine Grained Operator Resource Management

2019-09-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14058: - External issue URL: (was: https://cwiki.apache.org/confluence/display/FLINK/FLIP-53%3A+Fine+Gr

[jira] [Created] (FLINK-14059) Introduce option allSourcesInSamePipelinedRegion in ExecutionConfig

2019-09-11 Thread Xintong Song (Jira)
Xintong Song created FLINK-14059: Summary: Introduce option allSourcesInSamePipelinedRegion in ExecutionConfig Key: FLINK-14059 URL: https://issues.apache.org/jira/browse/FLINK-14059 Project: Flink

[jira] [Created] (FLINK-14063) Operators use fractions to decide how many managed memory to allocate

2019-09-11 Thread Xintong Song (Jira)
Xintong Song created FLINK-14063: Summary: Operators use fractions to decide how many managed memory to allocate Key: FLINK-14063 URL: https://issues.apache.org/jira/browse/FLINK-14063 Project: Flink

[jira] [Created] (FLINK-14061) Introduce managed memory fractions to StreamConfig

2019-09-11 Thread Xintong Song (Jira)
Xintong Song created FLINK-14061: Summary: Introduce managed memory fractions to StreamConfig Key: FLINK-14061 URL: https://issues.apache.org/jira/browse/FLINK-14061 Project: Flink Issue Type

[jira] [Created] (FLINK-14062) Set managed memory fractions according to slot sharing groups

2019-09-11 Thread Xintong Song (Jira)
Xintong Song created FLINK-14062: Summary: Set managed memory fractions according to slot sharing groups Key: FLINK-14062 URL: https://issues.apache.org/jira/browse/FLINK-14062 Project: Flink

[jira] [Created] (FLINK-14060) Set slot sharing groups according to pipelined regions

2019-09-11 Thread Xintong Song (Jira)
Xintong Song created FLINK-14060: Summary: Set slot sharing groups according to pipelined regions Key: FLINK-14060 URL: https://issues.apache.org/jira/browse/FLINK-14060 Project: Flink Issue

[jira] [Commented] (FLINK-13979) Translate new streamfilesink docs to chinese

2019-09-16 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16930288#comment-16930288 ] Xintong Song commented on FLINK-13979: -- I'm taking a look at the PR. Will get back

[jira] [Created] (FLINK-14106) Make SlotManager pluggable

2019-09-17 Thread Xintong Song (Jira)
Xintong Song created FLINK-14106: Summary: Make SlotManager pluggable Key: FLINK-14106 URL: https://issues.apache.org/jira/browse/FLINK-14106 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-12122) Spread out tasks evenly across all available registered TaskManagers

2019-09-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16931510#comment-16931510 ] Xintong Song commented on FLINK-12122: -- Hi [~anton_ryabtsev], The community is cur

[jira] [Created] (FLINK-14187) FLIP-56 Dynamic Slot Allocation

2019-09-24 Thread Xintong Song (Jira)
Xintong Song created FLINK-14187: Summary: FLIP-56 Dynamic Slot Allocation Key: FLINK-14187 URL: https://issues.apache.org/jira/browse/FLINK-14187 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-14189) Extend TaskExecutor to support dynamic slot allocation

2019-09-24 Thread Xintong Song (Jira)
Xintong Song created FLINK-14189: Summary: Extend TaskExecutor to support dynamic slot allocation Key: FLINK-14189 URL: https://issues.apache.org/jira/browse/FLINK-14189 Project: Flink Issue

[jira] [Created] (FLINK-14188) TaskExecutor derive and register with default slot resource profile

2019-09-24 Thread Xintong Song (Jira)
Xintong Song created FLINK-14188: Summary: TaskExecutor derive and register with default slot resource profile Key: FLINK-14188 URL: https://issues.apache.org/jira/browse/FLINK-14188 Project: Flink

[jira] [Created] (FLINK-14191) Extend SlotManager to support dynamic slot allocation on pending task executors

2019-09-24 Thread Xintong Song (Jira)
Xintong Song created FLINK-14191: Summary: Extend SlotManager to support dynamic slot allocation on pending task executors Key: FLINK-14191 URL: https://issues.apache.org/jira/browse/FLINK-14191 Proje

[jira] [Created] (FLINK-14190) Extend SlotManager to support dynamic slot allocation on registered TaskExecutors.

2019-09-24 Thread Xintong Song (Jira)
Xintong Song created FLINK-14190: Summary: Extend SlotManager to support dynamic slot allocation on registered TaskExecutors. Key: FLINK-14190 URL: https://issues.apache.org/jira/browse/FLINK-14190 Pr

[jira] [Created] (FLINK-14192) Enable the dynamic slot allocation feature.

2019-09-24 Thread Xintong Song (Jira)
Xintong Song created FLINK-14192: Summary: Enable the dynamic slot allocation feature. Key: FLINK-14192 URL: https://issues.apache.org/jira/browse/FLINK-14192 Project: Flink Issue Type: Sub-t

[jira] [Created] (FLINK-14193) Update RestAPI / Web UI

2019-09-24 Thread Xintong Song (Jira)
Xintong Song created FLINK-14193: Summary: Update RestAPI / Web UI Key: FLINK-14193 URL: https://issues.apache.org/jira/browse/FLINK-14193 Project: Flink Issue Type: Sub-task Repo

[jira] [Created] (FLINK-14194) Clean-up of legacy mode.

2019-09-24 Thread Xintong Song (Jira)
Xintong Song created FLINK-14194: Summary: Clean-up of legacy mode. Key: FLINK-14194 URL: https://issues.apache.org/jira/browse/FLINK-14194 Project: Flink Issue Type: Sub-task Rep

[jira] [Commented] (FLINK-14059) Introduce option allSourcesInSamePipelinedRegion in ExecutionConfig

2019-09-27 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16939334#comment-16939334 ] Xintong Song commented on FLINK-14059: -- [~zhuzh], I agree that {{allSourcesInSameP

[jira] [Commented] (FLINK-14123) Change taskmanager.memory.fraction default value to 0.6

2019-10-01 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16942428#comment-16942428 ] Xintong Song commented on FLINK-14123: -- [~StephanEwen], I'm not sure about this.

[jira] [Comment Edited] (FLINK-14123) Change taskmanager.memory.fraction default value to 0.6

2019-10-01 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16942428#comment-16942428 ] Xintong Song edited comment on FLINK-14123 at 10/2/19 1:59 AM: ---

[jira] [Comment Edited] (FLINK-14123) Change taskmanager.memory.fraction default value to 0.6

2019-10-01 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16942428#comment-16942428 ] Xintong Song edited comment on FLINK-14123 at 10/2/19 2:00 AM: ---

[jira] [Commented] (FLINK-14123) Change taskmanager.memory.fraction default value to 0.6

2019-10-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16946470#comment-16946470 ] Xintong Song commented on FLINK-14123: -- [~liupengcheng], The reason we have smalle

[jira] [Commented] (FLINK-14123) Change taskmanager.memory.fraction default value to 0.6

2019-10-12 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16950010#comment-16950010 ] Xintong Song commented on FLINK-14123: -- Good point. FLIP-49 does not fix this probl

[jira] [Commented] (FLINK-14123) Change taskmanager.memory.fraction default value to 0.6

2019-10-14 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16950981#comment-16950981 ] Xintong Song commented on FLINK-14123: -- [~liupengcheng], I consulted [~trohrmann] t

[jira] [Commented] (FLINK-14123) Change taskmanager.memory.fraction default value to 0.6

2019-10-15 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952028#comment-16952028 ] Xintong Song commented on FLINK-14123: -- I don't no either. I think you can try ask

[jira] [Updated] (FLINK-12763) Fail job immediately if tasks’ resource needs can not be satisfied.

2019-06-14 Thread Xintong Song (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-12763: - Summary: Fail job immediately if tasks’ resource needs can not be satisfied. (was: Fail job imm

[jira] [Updated] (FLINK-12766) Dynamically allocate TaskExecutor’s managed memory to slots.

2019-06-23 Thread Xintong Song (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-12766: - Summary: Dynamically allocate TaskExecutor’s managed memory to slots. (was: Dynamically allocat

[jira] [Updated] (FLINK-12766) Dynamically allocate TaskExecutor’s managed memory to slots.

2019-06-23 Thread Xintong Song (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-12766: - Description: This step is a temporal workaround for release 1.9 to meet the basic usability requ

[jira] [Commented] (FLINK-35557) MemoryManager only reserves memory per consumer type once

2024-06-10 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853850#comment-17853850 ] Xintong Song commented on FLINK-35557: -- I think this is by design. As suggested by

[jira] [Comment Edited] (FLINK-35557) MemoryManager only reserves memory per consumer type once

2024-06-10 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853850#comment-17853850 ] Xintong Song edited comment on FLINK-35557 at 6/11/24 1:26 AM: ---

[jira] [Closed] (FLINK-35531) Avoid calling hsync in flush method in BaseHadoopFsRecoverableFsDataOutputStream

2024-06-10 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-35531. Fix Version/s: 1.18.2 1.20.0 1.19.2 Assignee: dzcxzl

[jira] [Assigned] (FLINK-30081) Local executor can not accept different jvm-overhead.min/max values

2024-02-18 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-30081: Assignee: Mingliang Liu > Local executor can not accept different jvm-overhead.min/max va

[jira] [Updated] (FLINK-30081) Local executor can not accept different jvm-overhead.min/max values

2024-02-18 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-30081: - Priority: Major (was: Minor) > Local executor can not accept different jvm-overhead.min/max val

[jira] [Updated] (FLINK-33728) Do not rewatch when KubernetesResourceManagerDriver watch fail

2024-02-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-33728: - Fix Version/s: 1.20.0 (was: 1.19.0) > Do not rewatch when KubernetesResou

[jira] [Closed] (FLINK-33728) Do not rewatch when KubernetesResourceManagerDriver watch fail

2024-02-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-33728. Fix Version/s: 1.19.0 Resolution: Done master (1.19): e7e31a99d6f93d4dadda21fbd1ebee079fe24

[jira] [Comment Edited] (FLINK-33728) Do not rewatch when KubernetesResourceManagerDriver watch fail

2024-02-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819433#comment-17819433 ] Xintong Song edited comment on FLINK-33728 at 2/22/24 1:21 AM: ---

[jira] [Assigned] (FLINK-34371) FLIP-331: Support EndOfStreamTrigger and isOutputOnlyAfterEndOfStream operator attribute to optimize task deployment

2024-02-28 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-34371: Assignee: Yunfeng Zhou > FLIP-331: Support EndOfStreamTrigger and isOutputOnlyAfterEndOfS

[jira] [Closed] (FLINK-34371) FLIP-331: Support EndOfStreamTrigger and isOutputOnlyAfterEndOfStream operator attribute to optimize task deployment

2024-02-28 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-34371. Fix Version/s: 1.20.0 Resolution: Done master (1.20): 94b5f031a785d16077d870fe9e009d1680774

[jira] [Commented] (FLINK-34528) Disconnect TM in JM when TM was killed to further reduce the job restart time

2024-02-28 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17821631#comment-17821631 ] Xintong Song commented on FLINK-34528: -- I'm not sure about introducing an option fo

[jira] [Commented] (FLINK-34526) Actively disconnect the killed TM in RM to reduce restart time

2024-02-28 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17821640#comment-17821640 ] Xintong Song commented on FLINK-34526: -- This makes sense tome. Just to provide som

[jira] [Commented] (FLINK-34589) FineGrainedSlotManager doesn't handle errors in the resource reconcilliation step

2024-03-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17824248#comment-17824248 ] Xintong Song commented on FLINK-34589: -- [~mapohl], thanks for reaching out. Do you

[jira] [Closed] (FLINK-33041) Add an introduction about how to migrate DataSet API to DataStream

2023-11-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-33041. Fix Version/s: 1.18.1 Assignee: Wencong Liu Resolution: Done - master (1.19): 9fce

[jira] [Closed] (FLINK-33905) FLIP-382: Unify the Provision of Diverse Metadata for Context-like APIs

2024-01-10 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-33905. Resolution: Done master (1.19): 06b46a9cbf0d8fa987bbde570510f75a7558f54d > FLIP-382: Unify the Pr

[jira] [Commented] (FLINK-33728) do not rewatch when KubernetesResourceManagerDriver watch fail

2024-01-14 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806586#comment-17806586 ] Xintong Song commented on FLINK-33728: -- Sorry for the late reply, I was distracted

[jira] [Closed] (FLINK-32978) Deprecate RichFunction#open(Configuration parameters)

2024-01-14 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-32978. Resolution: Fixed Breaking changes reverted. master (1.19): 1d6150f386d9c9ec61f4ab30853b915de77120

[jira] [Assigned] (FLINK-33728) do not rewatch when KubernetesResourceManagerDriver watch fail

2024-01-14 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-33728: Assignee: xiaogang zhou > do not rewatch when KubernetesResourceManagerDriver watch fail

[jira] [Commented] (FLINK-33728) do not rewatch when KubernetesResourceManagerDriver watch fail

2024-01-14 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806641#comment-17806641 ] Xintong Song commented on FLINK-33728: -- Sure, thanks for volunteering working on th

[jira] [Closed] (FLINK-34084) Deprecate unused configuration in BinaryInput/OutputFormat and FileInput/OutputFormat

2024-01-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-34084. Resolution: Done master (1.19): 4559b851b22d6ffa197aa311adbea15b21a43c66 > Deprecate unused confi

[jira] [Assigned] (FLINK-34237) MongoDB connector compile failed with Flink 1.19-SNAPSHOT

2024-01-25 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-34237: Assignee: Wencong Liu > MongoDB connector compile failed with Flink 1.19-SNAPSHOT > -

[jira] [Commented] (FLINK-34237) MongoDB connector compile failed with Flink 1.19-SNAPSHOT

2024-01-25 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811082#comment-17811082 ] Xintong Song commented on FLINK-34237: -- Thanks for reporting. This is indeed an uni

[jira] [Updated] (FLINK-34237) MongoDB connector compile failed with Flink 1.19-SNAPSHOT

2024-01-25 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-34237: - Fix Version/s: 1.19.0 (was: mongodb-1.1.0) > MongoDB connector compile fa

[jira] [Closed] (FLINK-34237) MongoDB connector compile failed with Flink 1.19-SNAPSHOT

2024-01-26 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-34237. Resolution: Fixed master (1.19): d0829ba3b162c24f2655b35258c9a8dc61cdba67 > MongoDB connector com

[jira] [Commented] (FLINK-34402) Class loading conflicts when using PowerMock in ITcase.

2024-02-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815096#comment-17815096 ] Xintong Song commented on FLINK-34402: -- Hi [~nilerzhou], The description of this i

[jira] [Commented] (FLINK-34402) Class loading conflicts when using PowerMock in ITcase.

2024-02-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815142#comment-17815142 ] Xintong Song commented on FLINK-34402: -- Thanks for the detailed information. I thi

[jira] [Commented] (FLINK-34402) Class loading conflicts when using PowerMock in ITcase.

2024-02-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17815206#comment-17815206 ] Xintong Song commented on FLINK-34402: -- > Returning to the change, do you have any

[jira] [Closed] (FLINK-34402) Class loading conflicts when using PowerMock in ITcase.

2024-02-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-34402. Resolution: Not A Bug Thanks for you understanding. Closing the ticket as "Not A Bug" > Class l

[jira] [Updated] (FLINK-31335) using sql-gateway to submit job to yarn cluster, sql-gateway don't support kerberos

2023-11-28 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-31335: - Fix Version/s: 1.17.3 (was: 1.17.2) > using sql-gateway to submit job to

[jira] [Assigned] (FLINK-33810) Propagate RecordAttributes that contains isProcessingBacklog status

2023-12-19 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-33810: Assignee: Xuannan Su > Propagate RecordAttributes that contains isProcessingBacklog statu

[jira] [Closed] (FLINK-33810) Propagate RecordAttributes that contains isProcessingBacklog status

2023-12-19 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-33810. Fix Version/s: 1.19.0 Resolution: Done master (1.19): f6bbf1cf364a3b4d04e6b6ddc522bad6431b4

[jira] [Assigned] (FLINK-33939) Make husky in runtime-web no longer affect git global hooks

2023-12-25 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-33939: Assignee: Jason TANG > Make husky in runtime-web no longer affect git global hooks >

[jira] [Commented] (FLINK-33939) Make husky in runtime-web no longer affect git global hooks

2023-12-25 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800423#comment-17800423 ] Xintong Song commented on FLINK-33939: -- Sounds good to me. Thanks for reporting and

[jira] [Assigned] (FLINK-33938) Correct implicit coercions in relational operators to adopt typescript 5.0

2023-12-26 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-33938: Assignee: Ao Yuchen > Correct implicit coercions in relational operators to adopt typescr

[jira] [Commented] (FLINK-33962) Chaining-agnostic OperatorID generation for improved state compatibility on parallelism change

2024-01-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17801976#comment-17801976 ] Xintong Song commented on FLINK-33962: -- Thanks for reaching out, [~Zhanghao Chen].

[jira] [Updated] (FLINK-33939) Make husky in runtime-web no longer affect git global hooks

2024-01-03 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-33939: - Priority: Major (was: Minor) > Make husky in runtime-web no longer affect git global hooks > --

[jira] [Updated] (FLINK-33939) Make husky in runtime-web no longer affect git global hooks

2024-01-03 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-33939: - Fix Version/s: 1.19.0 1.17.3 1.18.2 > Make husky in runtim

[jira] [Updated] (FLINK-33939) Make husky in runtime-web no longer affect git global hooks

2024-01-03 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-33939: - Issue Type: Bug (was: Improvement) > Make husky in runtime-web no longer affect git global hook

[jira] [Closed] (FLINK-33939) Make husky in runtime-web no longer affect git global hooks

2024-01-03 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-33939. Resolution: Fixed - master (1.19): 8e8e2d649e98071bc15ee768cf65da3e96f255b4 - release-1.18: 8342ac

[jira] [Updated] (FLINK-33939) Make husky in runtime-web no longer affect git global hooks

2024-01-03 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-33939: - Affects Version/s: 1.9.0 > Make husky in runtime-web no longer affect git global hooks > ---

[jira] [Commented] (FLINK-33728) do not rewatch when KubernetesResourceManagerDriver watch fail

2024-01-08 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17804564#comment-17804564 ] Xintong Song commented on FLINK-33728: -- Thanks for pulling me in. I'm also concern

[jira] [Commented] (FLINK-32978) Deprecate RichFunction#open(Configuration parameters)

2024-01-08 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17804566#comment-17804566 ] Xintong Song commented on FLINK-32978: -- Thanks for reporting this, [~Sergey Nuyanzi

[jira] [Reopened] (FLINK-32978) Deprecate RichFunction#open(Configuration parameters)

2024-01-08 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reopened FLINK-32978: -- Reopening the ticket to fix the unexpected breaking changes. > Deprecate RichFunction#open(Config

[jira] [Closed] (FLINK-33938) Correct implicit coercions in relational operators to adopt typescript 5.0

2024-01-08 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-33938. Resolution: Fixed - master (1.19): e07545e458bd22099244a353ac29477ca3a13811 - release-1.18: 12463f

[jira] [Assigned] (FLINK-35089) Two input AbstractStreamOperator may throw NPE when receiving RecordAttributes

2024-04-15 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-35089: Assignee: Xuannan Su > Two input AbstractStreamOperator may throw NPE when receiving Reco

[jira] [Closed] (FLINK-30081) Local executor can not accept different jvm-overhead.min/max values

2024-04-15 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-30081. Fix Version/s: 1.20.0 Resolution: Fixed master (1.20): 9cc5ab9caf368ef336599e7d48f679c8c975

[jira] [Closed] (FLINK-35089) Two input AbstractStreamOperator may throw NPE when receiving RecordAttributes

2024-04-16 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-35089. Fix Version/s: 1.20.0 1.19.1 Resolution: Fixed - master (1.20): 7a90a05e

[jira] [Assigned] (FLINK-35359) Using proper type for configuration

2024-08-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-35359: Assignee: Xuannan Su (was: Xintong Song) > Using proper type for configuration > ---

[jira] [Assigned] (FLINK-35359) Using proper type for configuration

2024-08-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-35359: Assignee: Xintong Song (was: Xuannan Su) > Using proper type for configuration > ---

[jira] [Updated] (FLINK-35803) ResumeCheckpointManuallyITCase fails with checkpoint file merging

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-35803: - Fix Version/s: 2.0-preview (was: 2.0.0) > ResumeCheckpointManuallyITCase

[jira] [Updated] (FLINK-35801) testSwitchFromEnablingToDisablingFileMerging failed in AZP

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-35801: - Fix Version/s: 2.0-preview (was: 2.0.0) > testSwitchFromEnablingToDisabli

[jira] [Updated] (FLINK-35872) Fix the incorrect partition generation during period refresh in Full Mode

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-35872: - Fix Version/s: 2.0-preview (was: 2.0.0) > Fix the incorrect partition gen

[jira] [Updated] (FLINK-36189) Documentation build is failing with NPM installation problem

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-36189: - Fix Version/s: 2.0-preview (was: 2.0.0) > Documentation build is failing

[jira] [Updated] (FLINK-35974) PyFlink YARN per-job on Docker test failed because docker-compose command not found

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-35974: - Fix Version/s: 2.0-preview (was: 2.0.0) > PyFlink YARN per-job on Docker

[jira] [Updated] (FLINK-34446) SqlValidatorException with LATERAL TABLE and JOIN

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-34446: - Fix Version/s: 2.0-preview (was: 2.0.0) > SqlValidatorException with LATE

[jira] [Updated] (FLINK-4198) Replace org.apache.flink.streaming.api.windowing.time.Time with org.apache.flink.api.common.time.Time

2024-09-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-4198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-4198: Fix Version/s: 2.0-preview (was: 2.0.0) > Replace org.apache.flink.streaming

  1   2   3   4   5   6   7   8   9   10   >