[
https://issues.apache.org/jira/browse/FLINK-25113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17631679#comment-17631679
]
Aitozi commented on FLINK-25113:
sorry for missing the ticket link :)
h
[
https://issues.apache.org/jira/browse/FLINK-25113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17632146#comment-17632146
]
Aitozi commented on FLINK-25113:
When I try to work on this, I found that I c
Aitozi created FLINK-30019:
--
Summary: Remove the unused HiveTableFileInputFormat in hive
connector
Key: FLINK-30019
URL: https://issues.apache.org/jira/browse/FLINK-30019
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-30019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17633826#comment-17633826
]
Aitozi commented on FLINK-30019:
cc [~luoyuxia], [~lsy] can you help review thi
[
https://issues.apache.org/jira/browse/FLINK-25113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17633829#comment-17633829
]
Aitozi commented on FLINK-25113:
Hi [~slinkydeveloper], [~luoyuxia] , [~lsy] I
[
https://issues.apache.org/jira/browse/FLINK-29585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17634112#comment-17634112
]
Aitozi commented on FLINK-29585:
fyi, I'm trying to work on this now. I will
[
https://issues.apache.org/jira/browse/FLINK-29308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17610964#comment-17610964
]
Aitozi commented on FLINK-29308:
Hi [~zhuzh] . I encountered this problem when u
[
https://issues.apache.org/jira/browse/FLINK-29308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17611336#comment-17611336
]
Aitozi commented on FLINK-29308:
Yes, but actually the job can keep to run when o
[
https://issues.apache.org/jira/browse/FLINK-29308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17611337#comment-17611337
]
Aitozi commented on FLINK-29308:
In our use case, we just ignore
[
https://issues.apache.org/jira/browse/FLINK-28875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17611338#comment-17611338
]
Aitozi commented on FLINK-28875:
Sorry [~gyfora], I have not start this work ye
[
https://issues.apache.org/jira/browse/FLINK-29088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17611341#comment-17611341
]
Aitozi commented on FLINK-29088:
Hi, [~twalthr] looking forward to your feed
[
https://issues.apache.org/jira/browse/FLINK-29308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17611389#comment-17611389
]
Aitozi commented on FLINK-29308:
Yes, your concern is r
Aitozi created FLINK-29557:
--
Summary: The SinkOperator's OutputFormat function is not recognized
Key: FLINK-29557
URL: https://issues.apache.org/jira/browse/FLINK-29557
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-29557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-29557:
---
Description:
In the {{SimpleOperatorFactory#of}}, only {{StreamSink}} is handled to register
as
[
https://issues.apache.org/jira/browse/FLINK-29557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-29557:
---
Description:
In the {{SimpleOperatorFactory#of}}, only {{StreamSink}} is handled to register
as
[
https://issues.apache.org/jira/browse/FLINK-29557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-29557:
---
Description:
In the {{SimpleOperatorFactory#of}}, only {{StreamSink}} is handled to register
as
[
https://issues.apache.org/jira/browse/FLINK-29585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17615777#comment-17615777
]
Aitozi commented on FLINK-29585:
Hi [~luoyuxia], I would like to give a try on
[
https://issues.apache.org/jira/browse/FLINK-29557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17616135#comment-17616135
]
Aitozi commented on FLINK-29557:
Anyone can help confirm this issue ?
&
[
https://issues.apache.org/jira/browse/FLINK-29557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618052#comment-17618052
]
Aitozi commented on FLINK-29557:
Thanks [~gaoyunhaii] for your reply.
[
https://issues.apache.org/jira/browse/FLINK-10929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619217#comment-17619217
]
Aitozi commented on FLINK-10929:
Nice to see a good discussion about Arrow support
[
https://issues.apache.org/jira/browse/FLINK-24624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi closed FLINK-24624.
--
Resolution: Won't Fix
> Add clean up phase when kubernetes session star
Aitozi created FLINK-26112:
--
Summary: Port getEndpoint method to the specific service type
subclass
Key: FLINK-26112
URL: https://issues.apache.org/jira/browse/FLINK-26112
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-26112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-26112:
---
Description: In the [FLINK-20830
|https://issues.apache.org/jira/projects/FLINK/issues/FLINK-20830]we
[
https://issues.apache.org/jira/browse/FLINK-17232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17491971#comment-17491971
]
Aitozi commented on FLINK-17232:
Hi, when i do some work to refactor the cod
[
https://issues.apache.org/jira/browse/FLINK-26112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-26112:
---
Parent: FLINK-17196
Issue Type: Sub-task (was: Improvement)
> Port getEndpoint method to
[
https://issues.apache.org/jira/browse/FLINK-26112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17491973#comment-17491973
]
Aitozi commented on FLINK-26112:
I found it's also an improvement of the imple
[
https://issues.apache.org/jira/browse/FLINK-26112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-26112:
---
Description: In the
[FLINK-20830|https://issues.apache.org/jira/projects/FLINK/issues/FLINK-20830]we
[
https://issues.apache.org/jira/browse/FLINK-26112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-26112:
---
Description: In the
[FLINK-20830|https://issues.apache.org/jira/browse/FLINK-20830]we introduce
serval
[
https://issues.apache.org/jira/browse/FLINK-26112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-26112:
---
Description: In the
[FLINK-20830|https://issues.apache.org/jira/browse/FLINK-20830], we introduce
serval
[
https://issues.apache.org/jira/browse/FLINK-16601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17492038#comment-17492038
]
Aitozi commented on FLINK-16601:
Hi [~felixzheng], I think this issue have already
[
https://issues.apache.org/jira/browse/FLINK-17232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17492049#comment-17492049
]
Aitozi commented on FLINK-17232:
After some dig for the [external
IPs|h
[
https://issues.apache.org/jira/browse/FLINK-26112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-26112:
---
Summary: Port getRestEndpoint method to the specific service type subclass
(was: Port getEndpoint method
[
https://issues.apache.org/jira/browse/FLINK-17232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17492365#comment-17492365
]
Aitozi commented on FLINK-17232:
Let me make it more clear. There are two impl
[
https://issues.apache.org/jira/browse/FLINK-17232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17492365#comment-17492365
]
Aitozi edited comment on FLINK-17232 at 2/15/22, 5:15 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-17232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17492365#comment-17492365
]
Aitozi edited comment on FLINK-17232 at 2/15/22, 5:16 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-20830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17492366#comment-17492366
]
Aitozi commented on FLINK-20830:
[~wangyang0918] OK, I will create a backport PR
[
https://issues.apache.org/jira/browse/FLINK-25660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479140#comment-17479140
]
Aitozi commented on FLINK-25660:
[~guoyangze] , [~junhany] Thanks for your guidanc
[
https://issues.apache.org/jira/browse/FLINK-25660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi closed FLINK-25660.
--
Resolution: Not A Bug
> Failed to build flink-runtime-
[
https://issues.apache.org/jira/browse/FLINK-20830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480572#comment-17480572
]
Aitozi commented on FLINK-20830:
Hi [~chesnay], [~wangyang0918], Sorry for brin
[
https://issues.apache.org/jira/browse/FLINK-20830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17480946#comment-17480946
]
Aitozi commented on FLINK-20830:
I have created the pull request, please take a
[
https://issues.apache.org/jira/browse/FLINK-17232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17495844#comment-17495844
]
Aitozi commented on FLINK-17232:
[~wangyang0918] Could you help review
[PR|h
Aitozi created FLINK-26332:
--
Summary: Move the Operator Env to the common Utils
Key: FLINK-26332
URL: https://issues.apache.org/jira/browse/FLINK-26332
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-17232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17496678#comment-17496678
]
Aitozi commented on FLINK-17232:
Get it, thanks
> Rethink the implicit beha
[
https://issues.apache.org/jira/browse/FLINK-26332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-26332:
---
Parent: FLINK-25963
Issue Type: Sub-task (was: Improvement)
> Move the Operator Env to the com
[
https://issues.apache.org/jira/browse/FLINK-26332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17496680#comment-17496680
]
Aitozi commented on FLINK-26332:
I want to work on this :D
> Move the Operator
Aitozi created FLINK-26337:
--
Summary: Avoid load flink conf each reconcile loop
Key: FLINK-26337
URL: https://issues.apache.org/jira/browse/FLINK-26337
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-26337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17496791#comment-17496791
]
Aitozi commented on FLINK-26337:
cc [~gyfora] [~wangyang0918]
> Avoid loa
[
https://issues.apache.org/jira/browse/FLINK-26337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17496813#comment-17496813
]
Aitozi commented on FLINK-26337:
Yes, I can take this ticket.
> Avoid load fli
Aitozi created FLINK-26339:
--
Summary: Introduce the webhook config to free the environment
options
Key: FLINK-26339
URL: https://issues.apache.org/jira/browse/FLINK-26339
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-26339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17496827#comment-17496827
]
Aitozi commented on FLINK-26339:
cc [~gyfora] [~wangyang0918], I can work on
[
https://issues.apache.org/jira/browse/FLINK-26337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-26337:
---
Component/s: Kubernetes Operator
> Avoid load flink conf each reconcile l
[
https://issues.apache.org/jira/browse/FLINK-26339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17497158#comment-17497158
]
Aitozi commented on FLINK-26339:
I mixed it up, there is no need to do this now, s
[
https://issues.apache.org/jira/browse/FLINK-26339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi closed FLINK-26339.
--
Resolution: Not A Problem
> Introduce the webhook config to free the environment opti
[
https://issues.apache.org/jira/browse/FLINK-26136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17497184#comment-17497184
]
Aitozi commented on FLINK-26136:
Hi [~gyfora], I have a doubt for this issue. I t
[
https://issues.apache.org/jira/browse/FLINK-26136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17497202#comment-17497202
]
Aitozi commented on FLINK-26136:
Got it, thanks.
> Implement shared validatio
Aitozi created FLINK-26356:
--
Summary: Revisit the create of RestClusterClient
Key: FLINK-26356
URL: https://issues.apache.org/jira/browse/FLINK-26356
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-26356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17497848#comment-17497848
]
Aitozi commented on FLINK-26356:
I have not make it very clear yet, I will do
[
https://issues.apache.org/jira/browse/FLINK-26356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-26356:
---
Description:
The clusterClient is built as below. The config is mixed up with the
FlinkDeploymentSpec and
[
https://issues.apache.org/jira/browse/FLINK-26377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17498393#comment-17498393
]
Aitozi commented on FLINK-26377:
I have the same sense to extract common reconc
[
https://issues.apache.org/jira/browse/FLINK-26356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17498402#comment-17498402
]
Aitozi commented on FLINK-26356:
I have some misunderstand before, since the oper
[
https://issues.apache.org/jira/browse/FLINK-26377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17498393#comment-17498393
]
Aitozi edited comment on FLINK-26377 at 2/26/22, 6:35 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-26377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17498393#comment-17498393
]
Aitozi edited comment on FLINK-26377 at 2/26/22, 7:01 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-26377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17498393#comment-17498393
]
Aitozi edited comment on FLINK-26377 at 2/26/22, 7:01 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-26377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17498408#comment-17498408
]
Aitozi commented on FLINK-26377:
Get it !
> Extract Reconciler in
[
https://issues.apache.org/jira/browse/FLINK-26377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17498687#comment-17498687
]
Aitozi commented on FLINK-26377:
ok, i will take a look first before work o
Aitozi created FLINK-26399:
--
Summary: Make some option of operator configurable
Key: FLINK-26399
URL: https://issues.apache.org/jira/browse/FLINK-26399
Project: Flink
Issue Type: Sub-task
Aitozi created FLINK-26435:
--
Summary: Provide the container name for CI debug log
Key: FLINK-26435
URL: https://issues.apache.org/jira/browse/FLINK-26435
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-26435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-26435:
---
Description:
Current kubectl log for the CI have not specified the container name as below
{code:java
[
https://issues.apache.org/jira/browse/FLINK-26435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17500052#comment-17500052
]
Aitozi commented on FLINK-26435:
Hmm.. It's come from the {{flink-kubernetes
[
https://issues.apache.org/jira/browse/FLINK-26435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-26435:
---
Parent: (was: FLINK-25963)
Issue Type: Bug (was: Sub-task)
> Provide the container name for
[
https://issues.apache.org/jira/browse/FLINK-26435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17500086#comment-17500086
]
Aitozi commented on FLINK-26435:
Get it, Done.
> Provide the container name
[
https://issues.apache.org/jira/browse/FLINK-26377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17501360#comment-17501360
]
Aitozi commented on FLINK-26377:
[~gyfora] I have finished it, and just submit the
Aitozi created FLINK-26493:
--
Summary: Use state machine based mechanism to simply the reconciler
Key: FLINK-26493
URL: https://issues.apache.org/jira/browse/FLINK-26493
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-26493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17501379#comment-17501379
]
Aitozi commented on FLINK-26493:
Do you have some inputs for this [~gy
[
https://issues.apache.org/jira/browse/FLINK-26493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17501379#comment-17501379
]
Aitozi edited comment on FLINK-26493 at 3/4/22, 3:22 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-26493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17501381#comment-17501381
]
Aitozi commented on FLINK-26493:
I will try to define a initial state machine tran
[
https://issues.apache.org/jira/browse/FLINK-26493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17501409#comment-17501409
]
Aitozi commented on FLINK-26493:
Agree, I will try to capture the current s
Aitozi created FLINK-26528:
--
Summary: Trigger the updateControl when the FlinkDeployment have
changed
Key: FLINK-26528
URL: https://issues.apache.org/jira/browse/FLINK-26528
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-26528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-26528:
---
Description: If the CR has not changed since last reconcile, we could
create a UpdateControl with
[
https://issues.apache.org/jira/browse/FLINK-26719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17509231#comment-17509231
]
Aitozi commented on FLINK-26719:
> If we do not want to provide stronger res
[
https://issues.apache.org/jira/browse/FLINK-26719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17509231#comment-17509231
]
Aitozi edited comment on FLINK-26719 at 3/19/22, 9:3
[
https://issues.apache.org/jira/browse/FLINK-26719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17509231#comment-17509231
]
Aitozi edited comment on FLINK-26719 at 3/19/22, 9:3
[
https://issues.apache.org/jira/browse/FLINK-26719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17509231#comment-17509231
]
Aitozi edited comment on FLINK-26719 at 3/19/22, 9:3
[
https://issues.apache.org/jira/browse/FLINK-26719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17509231#comment-17509231
]
Aitozi edited comment on FLINK-26719 at 3/19/22, 9:3
[
https://issues.apache.org/jira/browse/FLINK-26719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi closed FLINK-26719.
--
Resolution: Not A Problem
> Rethink the default reschedule reconcile l
Aitozi created FLINK-26737:
--
Summary: Add CRD management in development doc
Key: FLINK-26737
URL: https://issues.apache.org/jira/browse/FLINK-26737
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-26737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-26737:
---
Description: Add the crd operation in the development doc, such as
generate, upgrade and so on. (was: Add
[
https://issues.apache.org/jira/browse/FLINK-26737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17509237#comment-17509237
]
Aitozi commented on FLINK-26737:
I will work on it, Please help assign this t
Aitozi created FLINK-26754:
--
Summary: KafkaCommitterTest#testRetryCommittableOnRetriableError
stuck
Key: FLINK-26754
URL: https://issues.apache.org/jira/browse/FLINK-26754
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-26754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17509570#comment-17509570
]
Aitozi commented on FLINK-26754:
It seems have sth to do with
[
https://issues.apache.org/jira/browse/FLINK-26448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17509575#comment-17509575
]
Aitozi commented on FLINK-26448:
Hi [~jingge] , what's the problem with the k
[
https://issues.apache.org/jira/browse/FLINK-26754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17509592#comment-17509592
]
Aitozi commented on FLINK-26754:
After looking into this, it's caused by
[ https://issues.apache.org/jira/browse/FLINK-26448 ]
Aitozi deleted comment on FLINK-26448:
was (Author: aitozi):
Hi [~jingge] , what's the problem with the kafka test env with 1 broker? Does
the https://issues.apache.org/jira/browse/FLINK-
[
https://issues.apache.org/jira/browse/FLINK-26754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi closed FLINK-26754.
--
Resolution: Duplicate
> KafkaCommitterTest#testRetryCommittableOnRetriableError st
[
https://issues.apache.org/jira/browse/FLINK-26754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17509606#comment-17509606
]
Aitozi commented on FLINK-26754:
After checking the master branch, I found it has
[
https://issues.apache.org/jira/browse/FLINK-26776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aitozi updated FLINK-26776:
---
Attachment: image-2022-03-21-19-53-44-689.png
> The LocalBufferPoolDestroyTest#isInBlockingBufferRequest
Aitozi created FLINK-26776:
--
Summary: The LocalBufferPoolDestroyTest#isInBlockingBufferRequest
is fragile in different JDK environment
Key: FLINK-26776
URL: https://issues.apache.org/jira/browse/FLINK-26776
[
https://issues.apache.org/jira/browse/FLINK-26776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17509797#comment-17509797
]
Aitozi commented on FLINK-26776:
I will try to make a solution for it.
&
[
https://issues.apache.org/jira/browse/FLINK-26776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17509796#comment-17509796
]
Aitozi commented on FLINK-26776:
An example that can not pass.
!image-2022-03-21-1
[
https://issues.apache.org/jira/browse/FLINK-26776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17509806#comment-17509806
]
Aitozi commented on FLINK-26776:
Then I found it has been solved by
h
701 - 800 of 897 matches
Mail list logo