[jira] [Closed] (FLINK-33128) TestValuesRuntimeFunctions$TestValuesLookupFunction does not call open() on converter

[ https://issues.apache.org/jira/browse/FLINK-33128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-33128. --- > TestValuesRuntimeFunctions$TestValuesLookupFunction does not call open() on > converter > ---

[jira] [Resolved] (FLINK-33128) TestValuesRuntimeFunctions$TestValuesLookupFunction does not call open() on converter

[ https://issues.apache.org/jira/browse/FLINK-33128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao resolved FLINK-33128. - Resolution: Fixed > TestValuesRuntimeFunctions$TestValuesLookupFunction does not call open() on > conve

[jira] [Updated] (FLINK-33128) TestValuesRuntimeFunctions$TestValuesLookupFunction does not call open() on converter

[ https://issues.apache.org/jira/browse/FLINK-33128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-33128: Affects Version/s: 1.19.0 (was: 1.16.2) > TestValuesRuntimeFunctions$TestValues

[jira] [Assigned] (FLINK-33128) TestValuesRuntimeFunctions$TestValuesLookupFunction does not call open() on converter

[ https://issues.apache.org/jira/browse/FLINK-33128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-33128: --- Assignee: Jerome Gagnon > TestValuesRuntimeFunctions$TestValuesLookupFunction does not call open()

[jira] [Commented] (FLINK-33128) TestValuesRuntimeFunctions$TestValuesLookupFunction does not call open() on converter

[ https://issues.apache.org/jira/browse/FLINK-33128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17779959#comment-17779959 ] Yun Gao commented on FLINK-33128: - Merged on master via f31770fcf5769052f1ac32a6529de979

[jira] [Commented] (FLINK-29459) Sink v2 has bugs in supporting legacy v1 implementations with global committer

[ https://issues.apache.org/jira/browse/FLINK-29459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746204#comment-17746204 ] Yun Gao commented on FLINK-29459: - Hi [~martijnvisser]  Logically it does not involve th

[jira] [Commented] (FLINK-32455) Breaking change in TypeSerializerUpgradeTestBase prevents flink-connector-kafka from building against 1.18-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-32455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17743256#comment-17743256 ] Yun Gao commented on FLINK-32455: - Hi [~renqs] [~tzulitai] sorry for the late reply, it

[jira] [Commented] (FLINK-30238) Unified Sink committer does not clean up state on final savepoint

[ https://issues.apache.org/jira/browse/FLINK-30238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17740371#comment-17740371 ] Yun Gao commented on FLINK-30238: - Hi [~jingge]  may I have a double confirmation on the

[jira] [Commented] (FLINK-32455) Breaking change in TypeSerializerUpgradeTestBase prevents flink-connector-kafka from building against 1.18-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-32455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17740024#comment-17740024 ] Yun Gao commented on FLINK-32455: - Thanks [~tzulitai] for the quick fix!  For the forma

[jira] [Commented] (FLINK-32455) Breaking change in TypeSerializerUpgradeTestBase prevents flink-connector-kafka from building against 1.18-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-32455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17738503#comment-17738503 ] Yun Gao commented on FLINK-32455: - May I first have a double confirmation on the directi

[jira] [Commented] (FLINK-32455) Breaking change in TypeSerializerUpgradeTestBase prevents flink-connector-kafka from building against 1.18-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-32455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17738502#comment-17738502 ] Yun Gao commented on FLINK-32455: - Sorry for missing the external repositories, I'll als

[jira] [Closed] (FLINK-27518) Refactor migration tests to support version update automatically

[ https://issues.apache.org/jira/browse/FLINK-27518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-27518. --- Fix Version/s: 1.18.0 Resolution: Fixed > Refactor migration tests to support version update automati

[jira] [Commented] (FLINK-27518) Refactor migration tests to support version update automatically

[ https://issues.apache.org/jira/browse/FLINK-27518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722035#comment-17722035 ] Yun Gao commented on FLINK-27518: - Merged on master via 82fb74e23b1dfa46fa98c89a58d7f312

[jira] [Closed] (FLINK-31708) RuntimeException/KryoException thrown when deserializing an empty protobuf record

[ https://issues.apache.org/jira/browse/FLINK-31708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-31708. --- Resolution: Fixed > RuntimeException/KryoException thrown when deserializing an empty protobuf > record > -

[jira] [Commented] (FLINK-31708) RuntimeException/KryoException thrown when deserializing an empty protobuf record

[ https://issues.apache.org/jira/browse/FLINK-31708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17714437#comment-17714437 ] Yun Gao commented on FLINK-31708: - Merged on master via d9e9d1ca741c84a18dbfac0ed44bd38c

[jira] [Assigned] (FLINK-31708) RuntimeException/KryoException thrown when deserializing an empty protobuf record

[ https://issues.apache.org/jira/browse/FLINK-31708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-31708: --- Assignee: shen > RuntimeException/KryoException thrown when deserializing an empty protobuf > reco

[jira] [Assigned] (FLINK-31632) watermark aligned idle source can't resume

[ https://issues.apache.org/jira/browse/FLINK-31632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-31632: --- Assignee: haishui > watermark aligned idle source can't resume > --

[jira] [Commented] (FLINK-31655) Adaptive Channel selection for partitioner

[ https://issues.apache.org/jira/browse/FLINK-31655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17707102#comment-17707102 ] Yun Gao commented on FLINK-31655: - Hi [~tartarus] thanks for the proposal, it also looks

[jira] [Commented] (FLINK-30238) Unified Sink committer does not clean up state on final savepoint

[ https://issues.apache.org/jira/browse/FLINK-30238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17697246#comment-17697246 ] Yun Gao commented on FLINK-30238: - Hi [~agg_neha07] I think the change of intermediate s

[jira] [Commented] (FLINK-30238) Unified Sink committer does not clean up state on final savepoint

[ https://issues.apache.org/jira/browse/FLINK-30238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17697241#comment-17697241 ] Yun Gao commented on FLINK-30238: - Hi [~fpaul] sorry for the long delay for it took me s

[jira] [Commented] (FLINK-30238) Unified Sink committer does not clean up state on final savepoint

[ https://issues.apache.org/jira/browse/FLINK-30238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689588#comment-17689588 ] Yun Gao commented on FLINK-30238: - Hi [~pnowojski] , for this specific issue, based on m

[jira] [Commented] (FLINK-26173) Sink GlobalCommitter's behavior is not compatible

[ https://issues.apache.org/jira/browse/FLINK-26173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17686323#comment-17686323 ] Yun Gao commented on FLINK-26173: - I'll first close this issue since it seems the PR has

[jira] [Closed] (FLINK-26173) Sink GlobalCommitter's behavior is not compatible

[ https://issues.apache.org/jira/browse/FLINK-26173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-26173. --- Fix Version/s: 1.15.0 Resolution: Fixed > Sink GlobalCommitter's behavior is not compatible > ---

[jira] [Closed] (FLINK-26970) Fix comment style error

[ https://issues.apache.org/jira/browse/FLINK-26970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-26970. --- Resolution: Not A Problem > Fix comment style error > --- > > Key: FLINK

[jira] [Commented] (FLINK-26970) Fix comment style error

[ https://issues.apache.org/jira/browse/FLINK-26970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17686321#comment-17686321 ] Yun Gao commented on FLINK-26970: - Hi [~codingcaproni] very thanks for the efforts, base

[jira] [Commented] (FLINK-30448) "filter(Objects::nonNull)" will bring down task with failure cause: ClassCastException

[ https://issues.apache.org/jira/browse/FLINK-30448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17686305#comment-17686305 ] Yun Gao commented on FLINK-30448: - Very thanks [~pltbkd] for the analyzing! Hi [~float2n

[jira] [Closed] (FLINK-30448) "filter(Objects::nonNull)" will bring down task with failure cause: ClassCastException

[ https://issues.apache.org/jira/browse/FLINK-30448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-30448. --- Resolution: Won't Fix > "filter(Objects::nonNull)" will bring down task with failure cause: > ClassCastExce

[jira] [Commented] (FLINK-30238) Unified Sink committer does not clean up state on final savepoint

[ https://issues.apache.org/jira/browse/FLINK-30238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17686272#comment-17686272 ] Yun Gao commented on FLINK-30238: - Hi, I might first complement some background before c

[jira] [Updated] (FLINK-30906) TwoInputStreamTask passes wrong configuration object when creating input processor

[ https://issues.apache.org/jira/browse/FLINK-30906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-30906: Component/s: Runtime / Task > TwoInputStreamTask passes wrong configuration object when creating input >

[jira] [Created] (FLINK-30906) TwoInputStreamTask passes wrong configuration object when creating input processor

Yun Gao created FLINK-30906: --- Summary: TwoInputStreamTask passes wrong configuration object when creating input processor Key: FLINK-30906 URL: https://issues.apache.org/jira/browse/FLINK-30906 Project: Fli

[jira] [Closed] (FLINK-30505) Close the connection between TM and JM when task executor failed

[ https://issues.apache.org/jira/browse/FLINK-30505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-30505. --- Resolution: Won't Fix > Close the connection between TM and JM when task executor failed > -

[jira] [Commented] (FLINK-30505) Close the connection between TM and JM when task executor failed

[ https://issues.apache.org/jira/browse/FLINK-30505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17683269#comment-17683269 ] Yun Gao commented on FLINK-30505: - Thanks [~damumu] and [~xtsong] for the discussion! No

[jira] [Created] (FLINK-30877) Add support for @Before / @After for JUnit 4 and 5

Yun Gao created FLINK-30877: --- Summary: Add support for @Before / @After for JUnit 4 and 5 Key: FLINK-30877 URL: https://issues.apache.org/jira/browse/FLINK-30877 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-27518) Refactor migration tests to support version update automatically

[ https://issues.apache.org/jira/browse/FLINK-27518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17678182#comment-17678182 ] Yun Gao commented on FLINK-27518: - Sorry for it takes more time than I thought to finish

[jira] [Commented] (FLINK-27518) Refactor migration tests to support version update automatically

[ https://issues.apache.org/jira/browse/FLINK-27518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17653822#comment-17653822 ] Yun Gao commented on FLINK-27518: - Got that, I'm now a bit freed and will improve the pr

[jira] [Assigned] (FLINK-30468) The SortOrder of BusyRatio should be descend by default

[ https://issues.apache.org/jira/browse/FLINK-30468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-30468: --- Assignee: Rui Fan > The SortOrder of BusyRatio should be descend by default > -

[jira] [Commented] (FLINK-30412) create many checkpoint empty dir when job not enable checkpoint

[ https://issues.apache.org/jira/browse/FLINK-30412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652768#comment-17652768 ] Yun Gao commented on FLINK-30412: - Hi [~xiaodao] sorry for the late reply, may I have a

[jira] [Commented] (FLINK-30412) create many checkpoint empty dir when job not enable checkpoint

[ https://issues.apache.org/jira/browse/FLINK-30412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17651167#comment-17651167 ] Yun Gao commented on FLINK-30412: - Hi [~xtsong] [~xiaodao]  I have a double check on the

[jira] [Commented] (FLINK-30131) flink iterate will suspend when record is a bit large

[ https://issues.apache.org/jira/browse/FLINK-30131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17647939#comment-17647939 ] Yun Gao commented on FLINK-30131: - Hi [~landlord] do you still have problem on this issu

[jira] [Commented] (FLINK-30403) The reported latest completed checkpoint is discarded

[ https://issues.apache.org/jira/browse/FLINK-30403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17647937#comment-17647937 ] Yun Gao commented on FLINK-30403: - Hi [~tisonet] , it looks to me we have to keep the cu

[jira] [Commented] (FLINK-30424) Add source operator restore readerState log to distinguish split is from newPartitions or split state

[ https://issues.apache.org/jira/browse/FLINK-30424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17647920#comment-17647920 ] Yun Gao commented on FLINK-30424: - Hi [~lemonjing] could you pointed out to me the posit

[jira] [Commented] (FLINK-30251) Move the IO with DFS during abort checkpoint to an asynchronous thread.

[ https://issues.apache.org/jira/browse/FLINK-30251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17644676#comment-17644676 ] Yun Gao commented on FLINK-30251: - [~Ming Li] Hi sorry I might also need to complement o

[jira] [Comment Edited] (FLINK-30251) Move the IO with DFS during abort checkpoint to an asynchronous thread.

[ https://issues.apache.org/jira/browse/FLINK-30251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17644674#comment-17644674 ] Yun Gao edited comment on FLINK-30251 at 12/8/22 8:55 AM: -- Hi [

[jira] [Commented] (FLINK-30251) Move the IO with DFS during abort checkpoint to an asynchronous thread.

[ https://issues.apache.org/jira/browse/FLINK-30251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17644674#comment-17644674 ] Yun Gao commented on FLINK-30251: - Hi [~Ming Li] very thanks for reporting the issue and

[jira] [Closed] (FLINK-27341) TaskManager running together with JobManager are bind to 127.0.0.1

[ https://issues.apache.org/jira/browse/FLINK-27341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-27341. --- Resolution: Fixed > TaskManager running together with JobManager are bind to 127.0.0.1 > ---

[jira] [Commented] (FLINK-27341) TaskManager running together with JobManager are bind to 127.0.0.1

[ https://issues.apache.org/jira/browse/FLINK-27341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17642246#comment-17642246 ] Yun Gao commented on FLINK-27341: - Merged on master via fc5e8bacef34119579defca625647648

[jira] [Updated] (FLINK-27341) TaskManager running together with JobManager are bind to 127.0.0.1

[ https://issues.apache.org/jira/browse/FLINK-27341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-27341: Fix Version/s: 1.17.0 1.16.1 1.15.4 > TaskManager running together w

[jira] [Commented] (FLINK-30131) flink iterate will suspend when record is a bit large

[ https://issues.apache.org/jira/browse/FLINK-30131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641760#comment-17641760 ] Yun Gao commented on FLINK-30131: - Hi [~landlord] from the attached image, it seems the

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

[ https://issues.apache.org/jira/browse/FLINK-30081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641751#comment-17641751 ] Yun Gao commented on FLINK-30081: - Hi [~liuml07]  the mini-cluster does not start new pr

[jira] [Commented] (FLINK-27518) Refactor migration tests to support version update automatically

[ https://issues.apache.org/jira/browse/FLINK-27518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641079#comment-17641079 ] Yun Gao commented on FLINK-27518: - Hi [~mapohl] sorry I'm a bit bound in recent weeks an

[jira] [Commented] (FLINK-28973) Extending /jars/:jarid/plan API to support setting Flink configs

[ https://issues.apache.org/jira/browse/FLINK-28973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638208#comment-17638208 ] Yun Gao commented on FLINK-28973: - Very thanks [~ConradJam] for the update! [~Zhanghao C

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

[ https://issues.apache.org/jira/browse/FLINK-30184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638198#comment-17638198 ] Yun Gao commented on FLINK-30184: - Thanks [~fanrui] for the explanation! Now I got the i

[jira] [Commented] (FLINK-29856) Triggering savepoint does not trigger source operator checkpoint

[ https://issues.apache.org/jira/browse/FLINK-29856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638190#comment-17638190 ] Yun Gao commented on FLINK-29856: - Hi [~mason6345]  may I have a double confirmation tha

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

[ https://issues.apache.org/jira/browse/FLINK-30184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638166#comment-17638166 ] Yun Gao commented on FLINK-30184: - Hi [~fanrui] perhaps [FlameGraph | https://nightlies

[jira] [Commented] (FLINK-30131) flink iterate will suspend when record is a bit large

[ https://issues.apache.org/jira/browse/FLINK-30131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638164#comment-17638164 ] Yun Gao commented on FLINK-30131: - Hi [~landlord]  sorry for the later response, first m

[jira] [Commented] (FLINK-16582) NettyBufferPoolTest may have warns on NettyBuffer leak

[ https://issues.apache.org/jira/browse/FLINK-16582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17637079#comment-17637079 ] Yun Gao commented on FLINK-16582: - Merged on master via 88a161101bb33b4c088325788bd11d41

[jira] [Closed] (FLINK-16582) NettyBufferPoolTest may have warns on NettyBuffer leak

[ https://issues.apache.org/jira/browse/FLINK-16582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-16582. --- Resolution: Fixed > NettyBufferPoolTest may have warns on NettyBuffer leak > --

[jira] [Assigned] (FLINK-16582) NettyBufferPoolTest may have warns on NettyBuffer leak

[ https://issues.apache.org/jira/browse/FLINK-16582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-16582: --- Assignee: Yun Gao > NettyBufferPoolTest may have warns on NettyBuffer leak > -

[jira] [Updated] (FLINK-16582) NettyBufferPoolTest may have warns on NettyBuffer leak

[ https://issues.apache.org/jira/browse/FLINK-16582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-16582: Fix Version/s: 1.16.1 1.15.4 > NettyBufferPoolTest may have warns on NettyBuffer leak

[jira] [Updated] (FLINK-16582) NettyBufferPoolTest may have warns on NettyBuffer leak

[ https://issues.apache.org/jira/browse/FLINK-16582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-16582: Labels: pull-request-available (was: auto-deprioritized-major auto-unassigned pull-request-available) >

[jira] [Closed] (FLINK-29557) The SinkOperator's OutputFormat function is not recognized

[ https://issues.apache.org/jira/browse/FLINK-29557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-29557. --- Fix Version/s: 1.17.0 Resolution: Fixed > The SinkOperator's OutputFormat function is not recognized

[jira] [Commented] (FLINK-29557) The SinkOperator's OutputFormat function is not recognized

[ https://issues.apache.org/jira/browse/FLINK-29557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17636277#comment-17636277 ] Yun Gao commented on FLINK-29557: - Merged on master via a56af3b5702f805b477f8cf11a27167e

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

[ https://issues.apache.org/jira/browse/FLINK-29572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635269#comment-17635269 ] Yun Gao edited comment on FLINK-29572 at 11/17/22 10:04 AM:

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

[ https://issues.apache.org/jira/browse/FLINK-29572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-29572. --- Resolution: Duplicate > Flink Task Manager skip loopback interface for resource manager registration > -

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

[ https://issues.apache.org/jira/browse/FLINK-29572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635269#comment-17635269 ] Yun Gao commented on FLINK-29572: - Hi all, I'll first close this issue for its duplicate

[jira] [Commented] (FLINK-29610) Infinite timeout is used in SavepointHandlers and CheckpointTriggerHandler calls to RestfulGateway

[ https://issues.apache.org/jira/browse/FLINK-29610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635265#comment-17635265 ] Yun Gao commented on FLINK-29610: - Thanks [~Jiale] for the PR! I'll have a look > Infin

[jira] [Closed] (FLINK-29498) Flink Async I/O Retry Strategies Do Not Work for Scala AsyncDataStream API

[ https://issues.apache.org/jira/browse/FLINK-29498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-29498. --- Fix Version/s: 1.17.0 Resolution: Fixed > Flink Async I/O Retry Strategies Do Not Work for Scala Asyn

[jira] [Commented] (FLINK-29498) Flink Async I/O Retry Strategies Do Not Work for Scala AsyncDataStream API

[ https://issues.apache.org/jira/browse/FLINK-29498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635258#comment-17635258 ] Yun Gao commented on FLINK-29498: - Merged on master via d426489c9e5c634e2eec8fde6c713567

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

[ https://issues.apache.org/jira/browse/FLINK-29940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635245#comment-17635245 ] Yun Gao commented on FLINK-29940: - Hi [~liuml07] It looks to me that it might not be an

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

[ https://issues.apache.org/jira/browse/FLINK-29925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635235#comment-17635235 ] Yun Gao commented on FLINK-29925: - cc [~junhan]  > table ui of configure value is stran

[jira] [Commented] (FLINK-27341) TaskManager running together with JobManager are bind to 127.0.0.1

[ https://issues.apache.org/jira/browse/FLINK-27341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17634670#comment-17634670 ] Yun Gao commented on FLINK-27341: - Very thanks [~huwh] for the checking! I'll have a loo

[jira] [Commented] (FLINK-27341) TaskManager running together with JobManager are bind to 127.0.0.1

[ https://issues.apache.org/jira/browse/FLINK-27341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17631342#comment-17631342 ] Yun Gao commented on FLINK-27341: - Hi [~chesnay]  sorry for missing the comment, I also

[jira] [Assigned] (FLINK-27341) TaskManager running together with JobManager are bind to 127.0.0.1

[ https://issues.apache.org/jira/browse/FLINK-27341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-27341: --- Assignee: Weihua Hu > TaskManager running together with JobManager are bind to 127.0.0.1 >

[jira] [Commented] (FLINK-22587) Support aggregations in batch mode with DataStream API

[ https://issues.apache.org/jira/browse/FLINK-22587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17630193#comment-17630193 ] Yun Gao commented on FLINK-22587: - Hi, sorry for forgetting to update here, with some mo

[jira] [Commented] (FLINK-28469) Setting a timer within broadcast applyToKeyedState()

[ https://issues.apache.org/jira/browse/FLINK-28469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628176#comment-17628176 ] Yun Gao commented on FLINK-28469: - Hi [~Sandys-Lumsdaine]  logically it is a bit hard to

[jira] [Commented] (FLINK-28455) pyflink tableResult collect result to local timeout

[ https://issues.apache.org/jira/browse/FLINK-28455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628168#comment-17628168 ] Yun Gao commented on FLINK-28455: - [~hxb]  could you help to have a look at this issue?

[jira] [Updated] (FLINK-28455) pyflink tableResult collect result to local timeout

[ https://issues.apache.org/jira/browse/FLINK-28455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-28455: Component/s: API / Python (was: API / Core) > pyflink tableResult collect result to l

[jira] [Commented] (FLINK-28598) ClusterEntryPoint can't get the real exit reason when shutting down

[ https://issues.apache.org/jira/browse/FLINK-28598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628167#comment-17628167 ] Yun Gao commented on FLINK-28598: - [~zlzhang0122] May I have a double confirmation of th

[jira] [Commented] (FLINK-29364) Root cause of Exceptions thrown in the SourceReader start() method gets "swallowed".

[ https://issues.apache.org/jira/browse/FLINK-29364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628164#comment-17628164 ] Yun Gao commented on FLINK-29364: - Thanks [~wanglijie] for the checking, and [~afedulov]

[jira] [Commented] (FLINK-29852) The operator is repeatedly displayed on the Flink Web UI

[ https://issues.apache.org/jira/browse/FLINK-29852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628149#comment-17628149 ] Yun Gao commented on FLINK-29852: - Hi [~JasonLee] thanks for reporting the issue! Could

[jira] [Commented] (FLINK-28973) Extending /jars/:jarid/plan API to support setting Flink configs

[ https://issues.apache.org/jira/browse/FLINK-28973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626512#comment-17626512 ] Yun Gao commented on FLINK-28973: - Hi [~Zhanghao Chen] very thanks for the clarification

[jira] [Comment Edited] (FLINK-27341) TaskManager running together with JobManager are bind to 127.0.0.1

[ https://issues.apache.org/jira/browse/FLINK-27341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626508#comment-17626508 ] Yun Gao edited comment on FLINK-27341 at 10/31/22 9:59 AM: --- Hi

[jira] [Commented] (FLINK-27341) TaskManager running together with JobManager are bind to 127.0.0.1

[ https://issues.apache.org/jira/browse/FLINK-27341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626508#comment-17626508 ] Yun Gao commented on FLINK-27341: - Hi [~nobleyd] sorry after I checked the code, it look

[jira] [Commented] (FLINK-29610) Infinite timeout is used in SavepointHandlers calls to RestfulGateway

[ https://issues.apache.org/jira/browse/FLINK-29610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626504#comment-17626504 ] Yun Gao commented on FLINK-29610: - Hi [~Jiale] , It looks to me RestConfiguration.timeou

[jira] [Assigned] (FLINK-29565) In Flink per job mode, the logs printed by taskManager on the web UI will not be highlighted, because the log contents are annotated due to special symbols, which will

[ https://issues.apache.org/jira/browse/FLINK-29565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-29565: --- Assignee: wangshiwei > In Flink per job mode, the logs printed by taskManager on the web UI will no

[jira] [Commented] (FLINK-29565) In Flink per job mode, the logs printed by taskManager on the web UI will not be highlighted, because the log contents are annotated due to special symbols, which will

[ https://issues.apache.org/jira/browse/FLINK-29565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625435#comment-17625435 ] Yun Gao commented on FLINK-29565: - Thanks [~1336399775] for helping fix the issue! I hav

[jira] [Commented] (FLINK-29565) In Flink per job mode, the logs printed by taskManager on the web UI will not be highlighted, because the log contents are annotated due to special symbols, which will

[ https://issues.apache.org/jira/browse/FLINK-29565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625396#comment-17625396 ] Yun Gao commented on FLINK-29565: - Hi [~1336399775] then would you like to open a PR to

[jira] [Commented] (FLINK-28973) Extending /jars/:jarid/plan API to support setting Flink configs

[ https://issues.apache.org/jira/browse/FLINK-28973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624941#comment-17624941 ] Yun Gao commented on FLINK-28973: - Hi [~Zhanghao Chen] may I have a double confirmation

[jira] [Commented] (FLINK-29339) JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager blocks main thread

[ https://issues.apache.org/jira/browse/FLINK-29339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624908#comment-17624908 ] Yun Gao commented on FLINK-29339: -  The PR is already under review previously, let's con

[jira] [Commented] (FLINK-29565) In Flink per job mode, the logs printed by taskManager on the web UI will not be highlighted, because the log contents are annotated due to special symbols, which will

[ https://issues.apache.org/jira/browse/FLINK-29565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624900#comment-17624900 ] Yun Gao commented on FLINK-29565: - Also cc [~junhan]  > In Flink per job mode, the logs

[jira] [Assigned] (FLINK-29610) Infinite timeout is used in SavepointHandlers calls to RestfulGateway

[ https://issues.apache.org/jira/browse/FLINK-29610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-29610: --- Assignee: Jiale Tan > Infinite timeout is used in SavepointHandlers calls to RestfulGateway > -

[jira] [Commented] (FLINK-29610) Infinite timeout is used in SavepointHandlers calls to RestfulGateway

[ https://issues.apache.org/jira/browse/FLINK-29610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624896#comment-17624896 ] Yun Gao commented on FLINK-29610: - Thanks [~Jiale] for tracking the issue! I assigned th

[jira] [Commented] (FLINK-29557) The SinkOperator's OutputFormat function is not recognized

[ https://issues.apache.org/jira/browse/FLINK-29557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624867#comment-17624867 ] Yun Gao commented on FLINK-29557: - Hi [~aitozi] LGTM, very thanks for tracking the issue

[jira] [Commented] (FLINK-29557) The SinkOperator's OutputFormat function is not recognized

[ https://issues.apache.org/jira/browse/FLINK-29557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17623601#comment-17623601 ] Yun Gao commented on FLINK-29557: - Thanks [~aitozi] for reporting the issue! Now I have

[jira] [Commented] (FLINK-29459) Sink v2 has bugs in supporting legacy v1 implementations with global committer

[ https://issues.apache.org/jira/browse/FLINK-29459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17623149#comment-17623149 ] Yun Gao commented on FLINK-29459: - Hi [~fpaul] [~KristoffSC] Very thanks for fixing the

[jira] [Commented] (FLINK-29498) Flink Async I/O Retry Strategies Do Not Work for Scala AsyncDataStream API

[ https://issues.apache.org/jira/browse/FLINK-29498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17621460#comment-17621460 ] Yun Gao commented on FLINK-29498: - [~eric.xiao] Thanks for the PR! I'll have a look > F

[jira] [Comment Edited] (FLINK-29183) flink job ended before window time up while using bounded stream source

[ https://issues.apache.org/jira/browse/FLINK-29183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620855#comment-17620855 ] Yun Gao edited comment on FLINK-29183 at 10/20/22 7:39 AM: --- Hi

[jira] [Commented] (FLINK-29183) flink job ended before window time up while using bounded stream source

[ https://issues.apache.org/jira/browse/FLINK-29183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620855#comment-17620855 ] Yun Gao commented on FLINK-29183: - Hi [~landlord] , this is indeed a known issue that cu

[jira] [Commented] (FLINK-29610) Infinite timeout is used in SavepointHandlers calls to RestfulGateway

[ https://issues.apache.org/jira/browse/FLINK-29610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620844#comment-17620844 ] Yun Gao commented on FLINK-29610: - Thanks [~Jiale] for creating the issue. Since it seem

[jira] [Commented] (FLINK-29498) Flink Async I/O Retry Strategies Do Not Work for Scala AsyncDataStream API

[ https://issues.apache.org/jira/browse/FLINK-29498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620102#comment-17620102 ] Yun Gao commented on FLINK-29498: - Thanks [~eric.xiao] for the efforts! I also think we

  1   2   3   4   5   6   7   8   9   10   >