[
https://issues.apache.org/jira/browse/FLINK-33461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-33461:
---
Summary: Support streaming related semantics for the new jdbc source (was:
Support stream related
[
https://issues.apache.org/jira/browse/FLINK-34564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17822758#comment-17822758
]
RocMarshal commented on FLINK-34564:
Thx a lot for [~lincoln.86xy] your comments, I'll check the
[
https://issues.apache.org/jira/browse/FLINK-34564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17822744#comment-17822744
]
RocMarshal commented on FLINK-34564:
I discovered this issue while assisting [~fanrui] in fixing a
RocMarshal created FLINK-34564:
--
Summary: Unstable test case
TableSourceITCase#testTableHintWithLogicalTableScanReuse
Key: FLINK-34564
URL: https://issues.apache.org/jira/browse/FLINK-34564
Project:
[
https://issues.apache.org/jira/browse/FLINK-34249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-34249:
---
Description:
pre step: https://issues.apache.org/jira/browse/FLINK-34174
The main reason for
[
https://issues.apache.org/jira/browse/FLINK-34249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17811463#comment-17811463
]
RocMarshal commented on FLINK-34249:
pre step: https://issues.apache.org/jira/browse/FLINK-34174
RocMarshal created FLINK-34249:
--
Summary: Remove DefaultSlotTracker related logic.
Key: FLINK-34249
URL: https://issues.apache.org/jira/browse/FLINK-34249
Project: Flink
Issue Type: Technical
[
https://issues.apache.org/jira/browse/FLINK-34174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17809232#comment-17809232
]
RocMarshal commented on FLINK-34174:
The main reason for initiating this ticket is
RocMarshal created FLINK-34174:
--
Summary: Remove SlotMatchingStrategy related logic
Key: FLINK-34174
URL: https://issues.apache.org/jira/browse/FLINK-34174
Project: Flink
Issue Type: Technical
RocMarshal created FLINK-34102:
--
Summary: Invalid configuration when using 'env.log.max' on yarn
application mode
Key: FLINK-34102
URL: https://issues.apache.org/jira/browse/FLINK-34102
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-33988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-33988:
---
Description:
relevant https://issues.apache.org/jira/browse/FLINK-33166
When I set env. log.
[
https://issues.apache.org/jira/browse/FLINK-33988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-33988:
---
Description:
from https://issues.apache.org/jira/browse/FLINK-33166
When I set env. log.
[
https://issues.apache.org/jira/browse/FLINK-33988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-33988:
---
Description:
from https://issues.apache.org/jira/browse/FLINK-33166
When I set env. log.
[
https://issues.apache.org/jira/browse/FLINK-33988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-33988:
---
Description: from https://issues.apache.org/jira/browse/FLINK-33166
> Invalid configuration when
RocMarshal created FLINK-33988:
--
Summary: Invalid configuration when using initialized root logger
level on yarn application mode
Key: FLINK-33988
URL: https://issues.apache.org/jira/browse/FLINK-33988
[
https://issues.apache.org/jira/browse/FLINK-33959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-33959:
---
Summary: Unstable test case ChangelogRecoveryITCase.testMaterialization on
1.17 release branch
[
https://issues.apache.org/jira/browse/FLINK-33959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17801149#comment-17801149
]
RocMarshal commented on FLINK-33959:
Hi, could someone help to check it ?
Thank you very much :)
>
[
https://issues.apache.org/jira/browse/FLINK-33959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-33959:
---
Attachment: image-2023-12-29-19-51-35-996.png
> Unstable test case
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-33959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-33959:
---
Description:
RocMarshal created FLINK-33959:
--
Summary: Unstable test case
Key: FLINK-33959
URL: https://issues.apache.org/jira/browse/FLINK-33959
Project: Flink
Issue Type: Bug
Components: Tests
[
https://issues.apache.org/jira/browse/FLINK-33959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-33959:
---
Description:
[
https://issues.apache.org/jira/browse/FLINK-33947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-33947:
---
Summary: Fix bugs about prefix in DelegatingConfiguration (was: Fix bugs
in
[
https://issues.apache.org/jira/browse/FLINK-33947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800805#comment-17800805
]
RocMarshal commented on FLINK-33947:
> And how about allow prefix is empty?
SGTM +1.
> Fix bugs in
[
https://issues.apache.org/jira/browse/FLINK-33947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800794#comment-17800794
]
RocMarshal commented on FLINK-33947:
hi, [~fanrui] thanks for your attention.
I want to set the
[
https://issues.apache.org/jira/browse/FLINK-33947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800774#comment-17800774
]
RocMarshal edited comment on FLINK-33947 at 12/27/23 2:09 PM:
--
Before
[
https://issues.apache.org/jira/browse/FLINK-33947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17800774#comment-17800774
]
RocMarshal commented on FLINK-33947:
Before officially starting the repair, there are two issues
RocMarshal created FLINK-33947:
--
Summary: Fix bugs in DelegatingConfiguration missed the prefix
mapping
Key: FLINK-33947
URL: https://issues.apache.org/jira/browse/FLINK-33947
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-29050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798856#comment-17798856
]
RocMarshal edited comment on FLINK-29050 at 12/20/23 8:08 AM:
--
Based on
[
https://issues.apache.org/jira/browse/FLINK-29050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798856#comment-17798856
]
RocMarshal edited comment on FLINK-29050 at 12/20/23 8:07 AM:
--
Based on
[
https://issues.apache.org/jira/browse/FLINK-29050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798856#comment-17798856
]
RocMarshal commented on FLINK-29050:
Based on
RocMarshal created FLINK-33875:
--
Summary: Support slots wait mechanism at DeclarativeSlotPoolBridge
side for Default Scheduler
Key: FLINK-33875
URL: https://issues.apache.org/jira/browse/FLINK-33875
[
https://issues.apache.org/jira/browse/FLINK-33874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-33874:
---
Summary: Support resource request wait mechanism at
DefaultDeclarativeSlotPool side for Default
[
https://issues.apache.org/jira/browse/FLINK-33874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-33874:
---
Parent: FLINK-31757
Issue Type: Sub-task (was: New Feature)
> Introduce resource request
RocMarshal created FLINK-33874:
--
Summary: Introduce resource request wait mechanism at
DefaultDeclarativeSlotPool side for Default Scheduler
Key: FLINK-33874
URL: https://issues.apache.org/jira/browse/FLINK-33874
[
https://issues.apache.org/jira/browse/FLINK-33853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-33853:
---
Summary: [JUnit5 Migration] Migrate Junit5 for DeclarativeSlotPoolBridge
test classes of runtime
RocMarshal created FLINK-33853:
--
Summary: Migrate Junit5 for DefaultDeclarativeSlotPool test classes
Key: FLINK-33853
URL: https://issues.apache.org/jira/browse/FLINK-33853
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-33853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-33853:
---
Summary: [JUnit5 Migration] Migrate Junit5 for DefaultDeclarativeSlotPool
test classes of runtime
RocMarshal created FLINK-33653:
--
Summary: Introduce a benchmark for balanced tasks scheduling
Key: FLINK-33653
URL: https://issues.apache.org/jira/browse/FLINK-33653
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-25420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782972#comment-17782972
]
RocMarshal edited comment on FLINK-25420 at 11/5/23 10:09 AM:
--
Hi,
[
https://issues.apache.org/jira/browse/FLINK-25420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782972#comment-17782972
]
RocMarshal commented on FLINK-25420:
Hi, [~martijnvisser] [~eskabetxe]
I have divided the work
[
https://issues.apache.org/jira/browse/FLINK-33463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782969#comment-17782969
]
RocMarshal edited comment on FLINK-33463 at 11/5/23 9:36 AM:
-
The ticket is
[
https://issues.apache.org/jira/browse/FLINK-33463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782969#comment-17782969
]
RocMarshal commented on FLINK-33463:
The ticket is mainly to do the two items:
1. Support the
[
https://issues.apache.org/jira/browse/FLINK-33459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782968#comment-17782968
]
RocMarshal commented on FLINK-33459:
The ticket is mainly to do the two items:
1. Support the new
RocMarshal created FLINK-33462:
--
Summary: Sort out the document page about the new Jdbc source.
Key: FLINK-33462
URL: https://issues.apache.org/jira/browse/FLINK-33462
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-33459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-33459:
---
Summary: Support the new source that keeps the same functionality as the
original JDBC input format
RocMarshal created FLINK-33463:
--
Summary: Support the implementation of dynamic source tables based
on the new source
Key: FLINK-33463
URL: https://issues.apache.org/jira/browse/FLINK-33463
Project:
RocMarshal created FLINK-33461:
--
Summary: Support stream related semantics for the new jdbc source
Key: FLINK-33461
URL: https://issues.apache.org/jira/browse/FLINK-33461
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-33459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-33459:
---
Summary: Support the new source that supports the same functionality as the
original JDBC input
[
https://issues.apache.org/jira/browse/FLINK-33459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-33459:
---
Summary: Port the new source that supports the same functionality as the
original JDBC input format
RocMarshal created FLINK-33460:
--
Summary: Support more authentication connection types such as the
secret.
Key: FLINK-33460
URL: https://issues.apache.org/jira/browse/FLINK-33460
Project: Flink
RocMarshal created FLINK-33459:
--
Summary: Introduce the new source that supports the same
functionality as the original JDBC input format
Key: FLINK-33459
URL: https://issues.apache.org/jira/browse/FLINK-33459
[
https://issues.apache.org/jira/browse/FLINK-33448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782503#comment-17782503
]
RocMarshal commented on FLINK-33448:
Thanks for the reply~ :)
> Introduce a new configuration item
[
https://issues.apache.org/jira/browse/FLINK-33448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-33448:
---
Description:
Introduce a new configuration item 'taskmanager.load-balance.mode' and make it
[
https://issues.apache.org/jira/browse/FLINK-33448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782487#comment-17782487
]
RocMarshal commented on FLINK-33448:
The Jira ticket resulted from
RocMarshal created FLINK-33448:
--
Summary: Introduce a new configuration item
'taskmanager.load-balance.mode'
Key: FLINK-33448
URL: https://issues.apache.org/jira/browse/FLINK-33448
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-33389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-33389:
---
Summary: Support tasks balancing at slot level for Adaptive Scheduler
(was: Introduce the assigner
[
https://issues.apache.org/jira/browse/FLINK-33386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-33386:
---
Summary: Support tasks balancing at slot level for Default Scheduler (was:
Introduce the strategy
[
https://issues.apache.org/jira/browse/FLINK-33388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-33388:
---
Summary: Support tasks balancing at TM level for Default Scheduler (was:
Implement tasks to
RocMarshal created FLINK-33392:
--
Summary: Add the documentation page for balanced tasks scheduling
Key: FLINK-33392
URL: https://issues.apache.org/jira/browse/FLINK-33392
Project: Flink
Issue
RocMarshal created FLINK-33391:
--
Summary: Support tasks balancing at TM level for Adaptive Scheduler
Key: FLINK-33391
URL: https://issues.apache.org/jira/browse/FLINK-33391
Project: Flink
Issue
RocMarshal created FLINK-33390:
--
Summary: Support slot balancing at TM level for Adaptive Scheduler
Key: FLINK-33390
URL: https://issues.apache.org/jira/browse/FLINK-33390
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-33388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-33388:
---
Summary: Implement tasks to taskmanagers balancing for the Default
Scheduler (was: Implement slots
RocMarshal created FLINK-33389:
--
Summary: Introduce the assigner for Adaptive Scheduler to pursuit
task balancing based slots level
Key: FLINK-33389
URL: https://issues.apache.org/jira/browse/FLINK-33389
RocMarshal created FLINK-33388:
--
Summary: Implement slots to taskmanagers balancing for the Default
Scheduler
Key: FLINK-33388
URL: https://issues.apache.org/jira/browse/FLINK-33388
Project: Flink
RocMarshal created FLINK-33387:
--
Summary: Introduce the abstraction and the interface about loading
Key: FLINK-33387
URL: https://issues.apache.org/jira/browse/FLINK-33387
Project: Flink
Issue
RocMarshal created FLINK-33386:
--
Summary: Introduce the strategy for Default Scheduler to pursue
tasks balancing based on slots level.
Key: FLINK-33386
URL: https://issues.apache.org/jira/browse/FLINK-33386
[
https://issues.apache.org/jira/browse/FLINK-33320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1522#comment-1522
]
RocMarshal commented on FLINK-33320:
Hi, [~fanrui] Thank you for the assign~ I'm willing to
RocMarshal created FLINK-33320:
--
Summary: Support Dynamic Logger Level Adjustment
Key: FLINK-33320
URL: https://issues.apache.org/jira/browse/FLINK-33320
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-25420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17774850#comment-17774850
]
RocMarshal commented on FLINK-25420:
Hi, [~eskabetxe] [~martijnvisser] Thank you very much for
[
https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-31757:
---
Summary: Support Balanced Tasks Scheduling (was: Optimize Flink
un-balanced tasks scheduling)
>
[
https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-31757:
---
Labels: pull-request-available (was: pull-request-available stale-assigned)
> Optimize Flink
[
https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17750078#comment-17750078
]
RocMarshal edited comment on FLINK-31757 at 8/2/23 3:54 AM:
Hi,
[
https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17750078#comment-17750078
]
RocMarshal commented on FLINK-31757:
Hi, [~heigebupahei] Thanks for your attention. we've updated
[
https://issues.apache.org/jira/browse/FLINK-29050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17739030#comment-17739030
]
RocMarshal commented on FLINK-29050:
Hello, sorry for the late update.
Could someone help to review
[
https://issues.apache.org/jira/browse/FLINK-20628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17735249#comment-17735249
]
RocMarshal commented on FLINK-20628:
[~martijnvisser] Yes,I'd like to do it. There's nothing better.
[
https://issues.apache.org/jira/browse/FLINK-20628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17734964#comment-17734964
]
RocMarshal commented on FLINK-20628:
[~martijnvisser] Thank you for your reply.
Yes, I'd like to
[
https://issues.apache.org/jira/browse/FLINK-20628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17733990#comment-17733990
]
RocMarshal commented on FLINK-20628:
Hi, [pscls|https://github.com/pscls] Thank you very much for
[
https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17727041#comment-17727041
]
RocMarshal commented on FLINK-31757:
I have compiled a draft
[
https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17727041#comment-17727041
]
RocMarshal edited comment on FLINK-31757 at 5/29/23 8:25 AM:
-
I have
[
https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715580#comment-17715580
]
RocMarshal commented on FLINK-31757:
I am still working on this jira, and due to the Labor Day
[
https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711897#comment-17711897
]
RocMarshal commented on FLINK-31757:
Thanks for your [~Weijie Guo] sorted concise and precise
[
https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711895#comment-17711895
]
RocMarshal commented on FLINK-31757:
Thank you [~fanrui] & [~huwh] very much.
I'll prepare a design
[
https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711875#comment-17711875
]
RocMarshal commented on FLINK-31757:
Based on this problem, we has achieved balanced task
[
https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal reopened FLINK-31757:
> Optimize Flink un-balanced tasks scheduling
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711776#comment-17711776
]
RocMarshal edited comment on FLINK-31757 at 4/13/23 9:24 AM:
-
h1. Problem
[
https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711776#comment-17711776
]
RocMarshal commented on FLINK-31757:
h1. Problem description and impact
Supposed a Job has 21
[
https://issues.apache.org/jira/browse/FLINK-29672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17710104#comment-17710104
]
RocMarshal commented on FLINK-29672:
It looks like a duplicated Jira as
[
https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17710022#comment-17710022
]
RocMarshal commented on FLINK-31757:
[~Weijie Guo] Glad to get your attention and reminding~:)
I'll
[
https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-31757:
---
Summary: Optimize Flink un-balanced tasks scheduling (was: Optimize Flink
tasks un-balanced
RocMarshal created FLINK-31757:
--
Summary: Optimize Flink tasks un-balanced scheduling
Key: FLINK-31757
URL: https://issues.apache.org/jira/browse/FLINK-31757
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17692057#comment-17692057
]
RocMarshal commented on FLINK-29816:
As described in the historical comments and description text,
[
https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-29816:
---
Attachment: image-2023-02-22-17-26-06-200.png
> Userfunction exception in ProcessWindowFunction was
[
https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17691339#comment-17691339
]
RocMarshal commented on FLINK-29816:
[~Weijie Guo] thanks for the reply.
I'm interested in it. May I
[
https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17691132#comment-17691132
]
RocMarshal commented on FLINK-29816:
hi, [~Weijie Guo] Any process on this issue ?
> Userfunction
[
https://issues.apache.org/jira/browse/FLINK-30511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17654895#comment-17654895
]
RocMarshal commented on FLINK-30511:
Thank you [~Weijie Guo] [~kevin.cyj] . Looking forward to the
[
https://issues.apache.org/jira/browse/FLINK-25421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17652232#comment-17652232
]
RocMarshal commented on FLINK-25421:
Get it. Thanks a lot~ [~eskabetxe]
> Port JDBC Sink to new
[
https://issues.apache.org/jira/browse/FLINK-30511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-30511:
---
Description:
* Code segment:
{code:java}
public class OnTimerDemo {
public static void
RocMarshal created FLINK-30511:
--
Summary: Ignore the Exception in user-timer Triggerble when
recover form state.
Key: FLINK-30511
URL: https://issues.apache.org/jira/browse/FLINK-30511
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-25421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17651050#comment-17651050
]
RocMarshal commented on FLINK-25421:
Hi [~eskabetxe] Is here any new progress about sink ?
> Port
[
https://issues.apache.org/jira/browse/FLINK-26999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17615467#comment-17615467
]
RocMarshal commented on FLINK-26999:
[~rmetzger] , The FLIP current content should be deprecated
1 - 100 of 232 matches
Mail list logo