[jira] [Closed] (FLINK-30189) HsSubpartitionFileReader may load data that has been consumed from memory

2022-12-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-30189. Fix Version/s: 1.17.0 1.16.1 Resolution: Fixed - master (1.17):

[jira] [Closed] (FLINK-29870) split ResourceNotEnoughNotifier from ResourceActions

2022-12-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-29870. Resolution: Done master (1.17): 209df810f13e2fcbe5a4ca8bb015a8a5f662adc4 > split

[jira] [Closed] (FLINK-30239) The flame graph doesn't work due to groupExecutionsByLocation has bug

2022-12-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-30239. Resolution: Fixed - master (1.17): 95be1e5abfe78d7ed8d171a779f280277f51569c - release-1.16:

[jira] [Commented] (FLINK-29925) table ui of configure value is strange

2022-12-01 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17641778#comment-17641778 ] Xintong Song commented on FLINK-29925: -- Ok, I see. That's a good point. Do you want to work on

[jira] [Commented] (FLINK-29925) table ui of configure value is strange

2022-12-01 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17641765#comment-17641765 ] Xintong Song commented on FLINK-29925: -- [~bytesmith], could you explain a bit more about what is

[jira] [Commented] (FLINK-29934) maven-assembly-plugin 2.4 make assemble plugin could find xml in flink clients module

2022-12-01 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17641761#comment-17641761 ] Xintong Song commented on FLINK-29934: -- I also cannot reproduce this. [~jackylau], do you still

[jira] [Commented] (FLINK-29940) ExecutionGraph logs job state change at ERROR level when job fails

2022-12-01 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17641758#comment-17641758 ] Xintong Song commented on FLINK-29940: -- Agree with [~gaoyunhaii] that the state changing of a job,

[jira] [Closed] (FLINK-29940) ExecutionGraph logs job state change at ERROR level when job fails

2022-12-01 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-29940. Resolution: Won't Do > ExecutionGraph logs job state change at ERROR level when job fails >

[jira] [Commented] (FLINK-29640) Enhance the function configured by execution.shutdown-on-attached-exit by heartbeat between client and dispatcher

2022-11-28 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17640338#comment-17640338 ] Xintong Song commented on FLINK-29640: -- Sure, I'll take a look. > Enhance the function configured

[jira] [Closed] (FLINK-30084) Remove unused ResourceActions.notifyAllocationFailure

2022-11-28 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-30084. Fix Version/s: 1.17.0 Resolution: Done master (1.17):

[jira] [Assigned] (FLINK-30185) Provide the flame graph to the subtask level

2022-11-27 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-30185: Assignee: Rui Fan > Provide the flame graph to the subtask level >

[jira] [Commented] (FLINK-30185) Provide the flame graph to the subtask level

2022-11-27 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17639837#comment-17639837 ] Xintong Song commented on FLINK-30185: -- [~fanrui], Sounds good to me. You are assigned. Please

[jira] [Commented] (FLINK-30185) Provide the flame graph to the subtask level

2022-11-27 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17639778#comment-17639778 ] Xintong Song commented on FLINK-30185: -- I think this makes a nice improvement. Could you explain a

[jira] [Commented] (FLINK-30184) Save TM/JM thread stack periodically

2022-11-27 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17639775#comment-17639775 ] Xintong Song commented on FLINK-30184: -- [~fanrui], sorry for the late response. I agree with

[jira] [Closed] (FLINK-29685) Add JM info into ExecutionGraph

2022-11-24 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-29685. Resolution: Won't Do > Add JM info into ExecutionGraph > --- > >

[jira] [Commented] (FLINK-29685) Add JM info into ExecutionGraph

2022-11-24 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17638196#comment-17638196 ] Xintong Song commented on FLINK-29685: -- Agree with [~martijnvisser], I think this should not be

[jira] [Updated] (FLINK-27079) Setup cron jobs

2022-11-23 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-27079: - Fix Version/s: 1.15.4 (was: 1.15.3) > Setup cron jobs > ---

[jira] [Updated] (FLINK-27080) Enable builds for pull requests

2022-11-23 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-27080: - Fix Version/s: 1.15.4 (was: 1.15.3) > Enable builds for pull requests >

[jira] [Updated] (FLINK-27415) Read empty csv file throws exception in FileSystem table connector

2022-11-23 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-27415: - Fix Version/s: 1.15.4 (was: 1.15.3) > Read empty csv file throws

[jira] [Updated] (FLINK-27077) Setup per-commit builds

2022-11-23 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-27077: - Fix Version/s: 1.15.4 (was: 1.15.3) > Setup per-commit builds >

[jira] [Updated] (FLINK-27492) Flink table scala example does not including the scala-api jars

2022-11-23 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-27492: - Fix Version/s: 1.15.4 (was: 1.15.3) > Flink table scala example does not

[jira] [Updated] (FLINK-28959) 504 gateway timeout when consume large number of topics using TopicPatten

2022-11-23 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28959: - Fix Version/s: 1.15.4 (was: 1.15.3) > 504 gateway timeout when consume

[jira] [Updated] (FLINK-27075) Migrate CI from Azure to Github Actions

2022-11-23 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-27075: - Fix Version/s: 1.15.4 (was: 1.15.3) > Migrate CI from Azure to Github

[jira] [Updated] (FLINK-27954) JobVertexFlameGraphHandler does not work on standby Dispatcher

2022-11-23 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-27954: - Fix Version/s: 1.15.4 (was: 1.15.3) > JobVertexFlameGraphHandler does

[jira] [Updated] (FLINK-28863) Snapshot result of RocksDB native savepoint should have empty shared-state

2022-11-23 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28863: - Fix Version/s: 1.15.4 (was: 1.15.3) > Snapshot result of RocksDB native

[jira] [Updated] (FLINK-28909) Add ribbon filter policy option in RocksDBConfiguredOptions

2022-11-23 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28909: - Fix Version/s: 1.15.4 (was: 1.15.3) > Add ribbon filter policy option in

[jira] [Updated] (FLINK-27082) Disable tests relying on non-writable directories

2022-11-23 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-27082: - Fix Version/s: 1.15.4 (was: 1.15.3) > Disable tests relying on

[jira] [Updated] (FLINK-29530) CommittableMessageTypeInfo#toString may force client to have S3 credentials

2022-11-23 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29530: - Fix Version/s: 1.15.4 (was: 1.15.3) >

[jira] [Updated] (FLINK-27917) PulsarUnorderedPartitionSplitReaderTest.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition failed with AssertionError

2022-11-23 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-27917: - Fix Version/s: 1.15.4 (was: 1.15.3) >

[jira] [Closed] (FLINK-30101) Always use StandaloneClientHAServices to create RestClusterClient when retriving a Flink on YARN cluster client

2022-11-22 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-30101. Resolution: Won't Do > Always use StandaloneClientHAServices to create RestClusterClient when >

[jira] [Reopened] (FLINK-30101) Always use StandaloneClientHAServices to create RestClusterClient when retriving a Flink on YARN cluster client

2022-11-22 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reopened FLINK-30101: -- > Always use StandaloneClientHAServices to create RestClusterClient when > retriving a Flink on

[jira] [Updated] (FLINK-29639) Add ResourceId in TransportException for debugging

2022-11-22 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29639: - Fix Version/s: 1.16.1 1.15.4 > Add ResourceId in TransportException for

[jira] [Comment Edited] (FLINK-29639) Add ResourceId in TransportException for debugging

2022-11-22 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635612#comment-17635612 ] Xintong Song edited comment on FLINK-29639 at 11/22/22 9:15 AM: - master

[jira] [Commented] (FLINK-30101) Always use StandaloneClientHAServices to create RestClusterClient when retriving a Flink on YARN cluster client

2022-11-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636970#comment-17636970 ] Xintong Song commented on FLINK-30101: -- I'm not sure about the proposed changes.

[jira] [Closed] (FLINK-29234) Dead lock in DefaultLeaderElectionService

2022-11-18 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-29234. Fix Version/s: 1.17.0 1.16.1 1.15.4 Resolution: Fixed

[jira] [Closed] (FLINK-29639) Add ResourceId in TransportException for debugging

2022-11-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-29639. Fix Version/s: 1.17.0 Resolution: Done master (1.17):

[jira] [Commented] (FLINK-30073) Managed memory can be wasted if RocksDB memory is fixed-per-slot

2022-11-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635599#comment-17635599 ] Xintong Song commented on FLINK-30073: -- I'm no more familiar with the background of FLINK-14484

[jira] [Commented] (FLINK-30073) Managed memory can be wasted if RocksDB memory is fixed-per-slot

2022-11-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635294#comment-17635294 ] Xintong Song commented on FLINK-30073: -- I'd consider this more a design limitation, rather than a

[jira] [Closed] (FLINK-29975) Let hybrid full spilling strategy supports partition reuse

2022-11-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-29975. Fix Version/s: 1.17.0 Resolution: Done master (1.17):

[jira] [Commented] (FLINK-29984) Flink Histogram not emitting min and max when using Prometheus Reporter

2022-11-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635271#comment-17635271 ] Xintong Song commented on FLINK-29984: -- [~qingwei91], You can add a config option in

[jira] [Closed] (FLINK-29573) Flink does not work for windows if installing on other drive except for C drive

2022-11-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-29573. Resolution: Won't Fix > Flink does not work for windows if installing on other drive except for C

[jira] [Commented] (FLINK-29573) Flink does not work for windows if installing on other drive except for C drive

2022-11-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635256#comment-17635256 ] Xintong Song commented on FLINK-29573: -- We are not supporting running Flink on Windows any more.

[jira] [Commented] (FLINK-29944) Support accumulator in source reader

2022-11-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635246#comment-17635246 ] Xintong Song commented on FLINK-29944: -- Agree with [~luoyuxia]. [~hk__lrzy], We are aware that the

[jira] [Assigned] (FLINK-29984) Flink Histogram not emitting min and max when using Prometheus Reporter

2022-11-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-29984: Assignee: Lim Qing Wei > Flink Histogram not emitting min and max when using Prometheus

[jira] [Commented] (FLINK-29984) Flink Histogram not emitting min and max when using Prometheus Reporter

2022-11-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635240#comment-17635240 ] Xintong Song commented on FLINK-29984: -- Thanks for reporting and volunteering to fix this,

[jira] [Closed] (FLINK-8712) Cannot execute job with multiple slot sharing groups on LocalExecutor

2022-11-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-8712. --- Resolution: Won't Fix > Cannot execute job with multiple slot sharing groups on LocalExecutor >

[jira] [Commented] (FLINK-28558) HistoryServer log retrieval configuration improvement

2022-11-16 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635154#comment-17635154 ] Xintong Song commented on FLINK-28558: -- This feature helps integrate the log browsing service into

[jira] [Commented] (FLINK-28558) HistoryServer log retrieval configuration improvement

2022-11-16 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635098#comment-17635098 ] Xintong Song commented on FLINK-28558: -- I'm not familiar whether there's any existing tools that

[jira] [Commented] (FLINK-28558) HistoryServer log retrieval configuration improvement

2022-11-16 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635085#comment-17635085 ] Xintong Song commented on FLINK-28558: -- [~leo.zhi] Here's the documentation for this feature.

[jira] [Updated] (FLINK-29818) HsResultPartitionTest.testAvailability fails

2022-11-16 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29818: - Affects Version/s: (was: 1.16.0) > HsResultPartitionTest.testAvailability fails >

[jira] [Closed] (FLINK-29818) HsResultPartitionTest.testAvailability fails

2022-11-16 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-29818. Fix Version/s: 1.17.0 Resolution: Fixed > HsResultPartitionTest.testAvailability fails >

[jira] [Comment Edited] (FLINK-29818) HsResultPartitionTest.testAvailability fails

2022-11-16 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17634711#comment-17634711 ] Xintong Song edited comment on FLINK-29818 at 11/16/22 9:51 AM: - master

[jira] [Commented] (FLINK-29818) HsResultPartitionTest.testAvailability fails

2022-11-16 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17634711#comment-17634711 ] Xintong Song commented on FLINK-29818: -- - master (1.17): 39f0e9bfadf0317328ede1d8c7dd37894beaae38

[jira] [Assigned] (FLINK-29639) Add ResourceId in TransportException for debugging

2022-11-15 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-29639: Assignee: Weijie Guo (was: Liu) > Add ResourceId in TransportException for debugging >

[jira] [Commented] (FLINK-29639) Add ResourceId in TransportException for debugging

2022-11-15 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17634702#comment-17634702 ] Xintong Song commented on FLINK-29639: -- There's no response from the assignee for ~1month.

[jira] [Commented] (FLINK-8712) Cannot execute job with multiple slot sharing groups on LocalExecutor

2022-11-09 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17631364#comment-17631364 ] Xintong Song commented on FLINK-8712: - When this issue is originally reported, one major problem is

[jira] [Commented] (FLINK-8712) Cannot execute job with multiple slot sharing groups on LocalExecutor

2022-11-09 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630867#comment-17630867 ] Xintong Song commented on FLINK-8712: - [~huwh], what about batch jobs? Say you have 10 maps in one

[jira] [Commented] (FLINK-8712) Cannot execute job with multiple slot sharing groups on LocalExecutor

2022-11-08 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630805#comment-17630805 ] Xintong Song commented on FLINK-8712: - [~huwh], could you please explain a bit more about how do you

[jira] [Updated] (FLINK-29927) AkkaUtils#getAddress may cause memory leak

2022-11-08 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29927: - Component/s: Runtime / RPC > AkkaUtils#getAddress may cause memory leak >

[jira] [Updated] (FLINK-29927) AkkaUtils#getAddress may cause memory leak

2022-11-08 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29927: - Affects Version/s: 1.15.2 1.16.0 > AkkaUtils#getAddress may cause memory

[jira] [Commented] (FLINK-29923) Hybrid Shuffle may face deadlock when running a task need to execute big size data

2022-11-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17630168#comment-17630168 ] Xintong Song commented on FLINK-29923: -- Thanks for reporting this, [~AlexXXX]. [~Weijie Guo],

[jira] [Updated] (FLINK-29923) Hybrid Shuffle may face deadlock when running a task need to execute big size data

2022-11-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29923: - Description: The flink 1.16 offers hybrid shuffle to combine the superiority of blocking

[jira] [Updated] (FLINK-29923) Hybrid Shuffle may face deadlock when running a task need to execute big size data

2022-11-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29923: - Affects Version/s: 1.16.0 (was: 1.11.6) > Hybrid Shuffle may face

[jira] [Closed] (FLINK-29892) flink-conf.yaml does not accept hash (#) in the env.java.opts property

2022-11-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-29892. Resolution: Duplicate > flink-conf.yaml does not accept hash (#) in the env.java.opts property >

[jira] [Reopened] (FLINK-29892) flink-conf.yaml does not accept hash (#) in the env.java.opts property

2022-11-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reopened FLINK-29892: -- > flink-conf.yaml does not accept hash (#) in the env.java.opts property >

[jira] [Closed] (FLINK-29892) flink-conf.yaml does not accept hash (#) in the env.java.opts property

2022-11-07 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-29892. Resolution: Fixed Let's close this duplicated ticket and keep the discussion in FLINK-15358 >

[jira] [Commented] (FLINK-29572) Flink Task Manager skip loopback interface for resource manager registration

2022-11-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629563#comment-17629563 ] Xintong Song commented on FLINK-29572: -- Thanks for the pointer, [~huwh]. I think FLINK-27341 is

[jira] [Commented] (FLINK-18229) Pending worker requests should be properly cleared

2022-11-04 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628798#comment-17628798 ] Xintong Song commented on FLINK-18229: -- Thanks for the notice, [~huwh]. I'll take a look. Just to

[jira] [Assigned] (FLINK-28697) MapDataSerializer doesn't declare a serialVersionUID

2022-11-03 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-28697: Assignee: (was: Josh Mahonin) > MapDataSerializer doesn't declare a serialVersionUID

[jira] [Assigned] (FLINK-28697) MapDataSerializer doesn't declare a serialVersionUID

2022-11-03 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-28697: Assignee: Josh Mahonin > MapDataSerializer doesn't declare a serialVersionUID >

[jira] [Updated] (FLINK-28697) MapDataSerializer doesn't declare a serialVersionUID

2022-11-03 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28697: - Issue Type: Technical Debt (was: Bug) > MapDataSerializer doesn't declare a serialVersionUID >

[jira] [Commented] (FLINK-29322) Expose savepoint format on Web UI

2022-11-03 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628159#comment-17628159 ] Xintong Song commented on FLINK-29322: -- Any updates for this ticket? > Expose savepoint format on

[jira] [Commented] (FLINK-29647) report stackoverflow when using kryo

2022-11-02 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628074#comment-17628074 ] Xintong Song commented on FLINK-29647: -- [~jackin853], As [~zhuzh] mentioned previously, you can

[jira] [Commented] (FLINK-29639) Add ResourceId in TransportException for debugging

2022-10-30 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626366#comment-17626366 ] Xintong Song commented on FLINK-29639: -- Hi [~Jiangang], is there any updates on this issue? > Add

[jira] [Closed] (FLINK-28889) Hybrid shuffle should supports multiple consumer

2022-10-30 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-28889. Resolution: Done master (1.17): d11940c4a78c71548b5a06af50da2e5f9cb68918 > Hybrid shuffle should

[jira] [Updated] (FLINK-29639) Add ResourceId in TransportException for debugging

2022-10-30 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29639: - Component/s: Runtime / Coordination > Add ResourceId in TransportException for debugging >

[jira] [Commented] (FLINK-29572) Flink Task Manager skip loopback interface for resource manager registration

2022-10-30 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626342#comment-17626342 ] Xintong Song commented on FLINK-29572: -- I'm still not convinced that this is a bug of Flink. Maybe

[jira] [Closed] (FLINK-29728) TablePlanner prevents Flink from starting is working directory is a symbolic link

2022-10-30 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-29728. Fix Version/s: 1.17.0 1.16.1 Resolution: Fixed - master (1.17):

[jira] [Updated] (FLINK-29728) TablePlanner prevents Flink from starting is working directory is a symbolic link

2022-10-30 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29728: - Component/s: Table SQL / Planner (was: Runtime / Coordination) >

[jira] [Assigned] (FLINK-29728) TablePlanner prevents Flink from starting is working directory is a symbolic link

2022-10-30 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-29728: Assignee: Weijie Guo > TablePlanner prevents Flink from starting is working directory is

[jira] [Closed] (FLINK-28102) Flink AkkaRpcSystemLoader fails when temporary directory is a symlink

2022-10-30 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-28102. Fix Version/s: 1.17.0 1.16.1 Resolution: Fixed - master (1.17):

[jira] [Updated] (FLINK-28102) Flink AkkaRpcSystemLoader fails when temporary directory is a symlink

2022-10-30 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28102: - Affects Version/s: 1.15.2 (was: 1.15.0)

[jira] [Comment Edited] (FLINK-29572) Flink Task Manager skip loopback interface for resource manager registration

2022-10-27 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17625383#comment-17625383 ] Xintong Song edited comment on FLINK-29572 at 10/28/22 2:15 AM: You

[jira] [Commented] (FLINK-29572) Flink Task Manager skip loopback interface for resource manager registration

2022-10-27 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17625383#comment-17625383 ] Xintong Song commented on FLINK-29572: -- You don't have to configure different ports for each task

[jira] [Closed] (FLINK-28769) Flink History Server show wrong name of batch jobs

2022-10-27 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-28769. Resolution: Won't Fix Closing as we are no longer actively maintaining the deprecated DataSet

[jira] [Updated] (FLINK-28863) Snapshot result of RocksDB native savepoint should have empty shared-state

2022-10-27 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28863: - Component/s: (was: Runtime / Checkpointing) > Snapshot result of RocksDB native savepoint

[jira] [Closed] (FLINK-28879) New File Sink s3 end-to-end test failed with Output hash mismatch

2022-10-27 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-28879. Resolution: Cannot Reproduce This has never been reproduced since reported 2.5 months ago.

[jira] [Closed] (FLINK-29124) Redundant checkNotNull in cli Package

2022-10-27 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-29124. Resolution: Not A Problem I don't think this is a valid issue. Not relying on the callers

[jira] [Commented] (FLINK-29125) Placeholder in Apache Flink Web Frontend to display some "tags" to distinguish between frontends of different clusters

2022-10-27 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624917#comment-17624917 ] Xintong Song commented on FLINK-29125: -- [~junhan], would you have time to take a look at this? >

[jira] [Closed] (FLINK-29306) fail to check multiple flink-dist*.jar for config.sh

2022-10-27 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-29306. Fix Version/s: 1.17.0 Resolution: Fixed master (1.17):

[jira] [Closed] (FLINK-29647) report stackoverflow when using kryo

2022-10-27 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-29647. Resolution: Workaround Closing this for now as we are not upgrading kryo version right now. Feel

[jira] [Updated] (FLINK-29758) Serialization issue with enum

2022-10-27 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29758: - Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile) Table SQL / API

[jira] [Assigned] (FLINK-29766) Speculative execution should also work in hybrid shuffle mode

2022-10-26 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-29766: Assignee: Weijie Guo > Speculative execution should also work in hybrid shuffle mode >

[jira] [Assigned] (FLINK-29767) Adaptive batch scheduler supports hybrid shuffle

2022-10-26 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-29767: Assignee: Weijie Guo > Adaptive batch scheduler supports hybrid shuffle >

[jira] [Commented] (FLINK-29572) Flink Task Manager skip loopback interface for resource manager registration

2022-10-26 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624813#comment-17624813 ] Xintong Song commented on FLINK-29572: -- bq. If this works, TM will report its address as

[jira] [Closed] (FLINK-29134) fetch metrics may cause oom(ThreadPool task pile up)

2022-10-25 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-29134. Fix Version/s: 1.17.0 1.15.3 1.16.1 Resolution: Fixed

[jira] [Closed] (FLINK-29435) securityConfiguration supports dynamic configuration

2022-10-25 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-29435. Fix Version/s: 1.17.0 Resolution: Done master (1.17):

[jira] [Comment Edited] (FLINK-28468) Creating benchmark channel in Apache Flink slack

2022-10-25 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17623729#comment-17623729 ] Xintong Song edited comment on FLINK-28468 at 10/25/22 10:09 AM: - Thanks

[jira] [Closed] (FLINK-28468) Creating benchmark channel in Apache Flink slack

2022-10-25 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-28468. Resolution: Done Thanks [~Yanfei Lei] for setting this up. The benchmark reports are not

[jira] [Assigned] (FLINK-28468) Creating benchmark channel in Apache Flink slack

2022-10-25 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-28468: Assignee: Yanfei Lei (was: Anton Kalashnikov) > Creating benchmark channel in Apache

<    3   4   5   6   7   8   9   10   11   12   >