Thanks,
Aitozi.
Timo Walther 于2023年12月14日周四 17:29写道：
> Hi Alan,
>
> thanks for proposing this FLIP. It's a great addition to Flink and has
> been requested multiple times. It will be in particular interesting for
> accessing REST endpoints and other remote services.
&
Hi Peter, Timo
Sorry for this breaking change, I didn't notice that was a breaking
change.
I'm +1 to revert the FLINK-33523
Regards,
aitozi
Timo Walther 于2023年12月7日周四 20:41写道：
> Hi Peter,
>
> thanks for reaching out to the Flink community. This is indeed a serious
> i
Aitozi created FLINK-32711:
--
Summary: Type mismatch when proctime function used as parameter
Key: FLINK-32711
URL: https://issues.apache.org/jira/browse/FLINK-32711
Project: Flink
Issue Type
Aitozi created FLINK-32659:
--
Summary: DB connection may leak if exception is thrown in
JdbcOutputFormat#close
Key: FLINK-32659
URL: https://issues.apache.org/jira/browse/FLINK-32659
Project: Flink
Hi guys,
Since there are no further comments, Kindly ping for the vote thread
[1] :D
Thanks,
Aitozi.
[1]: https://lists.apache.org/thread/7g5n2vshosom2dj9bp7x4n01okrnx4xx
Aitozi 于2023年6月26日周一 10:31写道：
> Hi Lincoln,
> Thanks for your confirmation. I have updated the consensus
Hi Awake,
Thanks for your good point, updated
Best,
Aitozi.
宇航 李 于2023年7月5日周三 11:29写道：
> Hi Aitozi,
>
> I think it is necessary to add the following description in FLIP to
> express the difference between user-defined asynchronous table function and
> AsyncTableFunction:
&
hread/7vk1799ryvrz4lsm5254q64ctm89mx2l
[2]
https://cwiki.apache.org/confluence/display/FLINK/FLIP-313%3A+Add+support+of+User+Defined+AsyncTableFunction
Best regards,
Aitozi
Aitozi 于2023年6月14日周三 09:47写道：
> Hi all,
> Thanks for all the feedback about FLIP-313: Add support of User
> Defined AsyncTableFunctio
Hi Lincoln,
Thanks for your confirmation. I have updated the consensus to the FLIP
doc.
If there are no other comments, I'd like to restart the vote process in [1]
today.
https://lists.apache.org/thread/7g5n2vshosom2dj9bp7x4n01okrnx4xx
Thanks,
Aitozi.
Lincoln Lee 于2023年6月21日周三 22
'lateral join' are not the same as in
the current joins page[1], so maybe it would be better if we unified them
into 'join table function'
Yes, we should unified to the 'join table function', updated.
Best,
Aitozi
Lincoln Lee 于2023年6月15日周四 09:15写道：
> Hi Aitozi,
a-size
>the runtime filter can be pushed down along the probe side, as close to
data sources as possible
What's the representation of the runtime filter node in planner ? Is it a
Filternode
Best,
Aitozi.
Benchao Li 于2023年6月15日周四 14:30写道：
> Hi Lijie,
>
> Regarding the shuffle
an external io
operation, it's better to add the `close` method to actively release
resources as a good example for users
Make sense to me, will update the FLIP
Best,
Aitozi.
Lincoln Lee 于2023年6月14日周三 14:24写道：
> Hi Aitozi,
>
> Sorry for the lately reply here! Supports async u
objection or an insufficient number of votes.
[1]
https://cwiki.apache.org/confluence/display/FLINK/FLIP-313%3A+Add+support+of+User+Defined+AsyncTableFunction
[2] https://lists.apache.org/thread/7vk1799ryvrz4lsm5254q64ctm89mx2l
Best regards,
Aitozi
Get your meaning now, thanks :)
Best,
Aitozi.
Feng Jin 于2023年6月13日周二 11:16写道：
> Hi Aitozi,
>
> Sorry for the confusing description.
>
> What I meant was that if we need to remind users about tire safety issues,
> we should introduce the new UDTF interface instead of execut
Hi Feng,
Thanks for your question. We do not provide a way to switch the UDTF
between sync and async way,
So there should be no thread safety problem here.
Best,
Aitozi
Feng Jin 于2023年6月13日周二 10:31写道：
> Hi Aitozi, We do need to remind users about thread safety issues. Thank you
> fo
Aitozi created FLINK-32320:
--
Summary: Same correlate can not be reused due to the different
correlationId
Key: FLINK-32320
URL: https://issues.apache.org/jira/browse/FLINK-32320
Project: Flink
BTW, If there are no other more blocking issue / comments, I would like to
start a VOTE in another thread this wednesday 6.14
Thanks,
Aitozi.
Aitozi 于2023年6月12日周一 23:34写道：
> Hi, Jing,
> Thanks for your explanation. I get your point now.
>
> For the performance part, I think
total memory consumption.
Thanks,
Aitozi.
Jing Ge 于2023年6月12日周一 20:28写道：
> Hi Aitozi,
>
> Which key will be used for lookup is not an issue, only one row will be
> required for each key in order to enrich it. True, it depends on the
> implementation whether multiple rows or sin
join will not affect the semantic of
the async udtf.
We use the Async TableFunction here and the table function can collect
multiple rows.
Thanks,
Atiozi.
Jing Ge 于2023年6月10日周六 00:15写道：
> Hi Aitozi,
>
> The keyRow used in this case contains all keys[1].
>
> Best regards,
>
[1]:
https://github.com/apache/flink/blob/191ec6ca3943d7119f14837efe112e074d815c47/flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/LookupFunction.java#L52
Thanks,
Aitozi.
Jing Ge 于2023年6月9日周五 17:05写道：
> Hi Aitozi,
>
> Thanks for the feedback. Looking f
user. But for the asynchronously
version, usually means
the main process is running in a dedicated thread pool. So if we run the
originally UDTFs in
asynchronously way, it may bring thread-safe problem.
@Jing Ge Also add the "Performance" section in FLIP.
Thanks,
Aitozi.
Feng Jin
these option, I updated the FLIP about this you can
refer to
the section of "ConfigOption" and "Rejected Alternatives"
In the end, for the performance evaluation, I'd like to do some tests and
will update it to the FLIP doc
Thanks,
Aitozi.
Jing Ge 于2023年6月9日周五 07:23写道：
+1
Looking forward to this feature.
Best,
Aitozi.
Jing Ge 于2023年6月8日周四 04:44写道：
> +1
>
> Best Regards,
> Jing
>
> On Wed, Jun 7, 2023 at 10:52 AM weijie guo
> wrote:
>
> > +1 (binding)
> >
> > Best regards,
> >
> > Weijie
>
free. Since the code base of the table module is too big,
> > instead of porting to Java, all scala code has been hidden. Furthermore,
> > there are ongoing efforts to remove Scala code from Flink. As you can
> see,
> > the community tries to limit (i.e. get rid of) scala code as
.
Thanks,
Atiozi.
Mason Chen 于2023年6月8日周四 12:40写道：
> Hi Aitozi,
>
> I think it makes sense to make it easier for SQL users to make RPCs. Do you
> think your proposal can extend to the ability to batch data for the RPC?
> This is also another common strategy to increase throughput.
Hi Ron:
Sorry for the late reply after the voting process. I just want to ask
> Traverse the ExecNode DAG and create a FusionExecNode for physical
operators that can be fused together.
which kind of operators can be fused together ? are the operators in an
operator chain? Is this optimization
-udtf.buffer-capacity`
`table.exec.async-udtf.timeout`
Best,
Aitozi.
Aitozi 于2023年6月5日周一 12:20写道：
> Hi Jing,
>
> > what is the difference between the RPC call or query you mentioned
> and the lookup in a very
> general way
>
> I think the RPC call or query service
async udtf.
In the end, We can also see the user defined async table function is an
enhancement of the current lateral table join
which only supports sync lateral join now.
Best,
Aitozi.
Jing Ge 于2023年6月2日周五 19:37写道：
> Hi Aitozi,
>
> Thanks for the update. Just out of curiosity,
erage the async function to improve the
throughput.
Thanks,
Aitozi.
Jing Ge 于2023年6月1日周四 22:55写道：
> Hi Aitozi,
>
> Sorry for the late reply. Would you like to update the proposed changes
> with more details into the FLIP too?
> I got your point. It looks like a rational idea. Howev
Hi Jing,
What do you think about it? Can we move forward this feature?
Thanks,
Aitozi.
Aitozi 于2023年5月29日周一 09:56写道：
> Hi Jing,
> > "Do you mean to support the AyncTableFunction beyond the
> LookupTableSource?"
> Yes, I mean to support the AyncTableFunction bey
In CorrelatedCodeGenerator, we will know the TableFunction's Kind of
`FunctionKind.Table` or `FunctionKind.ASYNC_TABLE`
For `FunctionKind.ASYNC_TABLE` we can generate a AsyncWaitOperator to
execute the async table function.
Thanks,
Aitozi.
Jing Ge 于2023年5月29日周一 03:22写道：
> Hi Ait
fs/
[2]: https://lists.apache.org/thread/qljwd40v5ntz6733cwcdr8s4z97b343b
Thanks.
Aitozi.
Jing Ge 于2023年5月27日周六 06:40写道：
> Hi Aitozi,
>
> Thanks for your proposal. I am not quite sure if I understood your thoughts
> correctly. You described a special case implementation of the
> Async
May I ask for some feedback :D
Thanks,
Aitozi
Aitozi 于2023年5月23日周二 19:14写道：
>
> Just catch an user case report from Giannis Polyzos for this usage:
>
> https://lists.apache.org/thread/qljwd40v5ntz6733cwcdr8s4z97b343b
>
> Aitozi 于2023年5月23日周二 17:45写道：
> >
> > Hi
Just catch an user case report from Giannis Polyzos for this usage:
https://lists.apache.org/thread/qljwd40v5ntz6733cwcdr8s4z97b343b
Aitozi 于2023年5月23日周二 17:45写道：
>
> Hi guys,
> I want to bring up a discussion about adding support of User
> Defined AsyncTableFunction in Flink.
D+Add+support+of+User+Defined+AsyncTableFunction
Thanks,
Aitozi.
+1
Best,
Aitozi
ron 于2023年4月18日周二 09:18写道：
>
> +1
>
>
> > -原始邮件-
> > 发件人: "Lincoln Lee"
> > 发送时间: 2023-04-18 09:08:08 (星期二)
> > 收件人: dev@flink.apache.org
> > 抄送:
> > 主题: Re: [VOTE] FLIP-302: Support TRUNCATE TABLE statement in
d.
Anyway, it's unclear for the implementer to know which stage will the
`apply` happen, So +1 for introducing the copy for EncodingFormat and
DecodingFormat to align the supporting of deep copy semantic this time.
Best,
Aitozi.
tanjialiang 于2023年4月13日周四 10:05写道：
>
> Hi, devs.
>
Well, thanks xia for your clarification. Agree with your point, I have
no other concerns.
Best,
Aitozi.
yuxia 于2023年4月13日周四 16:17写道：
>
> Hi, Aitozi.
> Thanks for your inputs. I understand your concern. Althogh the external
> connector can update the metadata in method `execu
hould be cleared
Best,
Aitozi.
liu ron 于2023年4月13日周四 11:28写道：
>
> Hi, xia
>
> Thanks for your explanation, for the first question, given the current
> status, I think we can provide the generic interface in the future if we
> need it. For the second question, it makes sense to
and GPUs. The Arrow memory format also supports
> > zero-copy reads for lightning-fast data access without serialization
> > overhead. it will bring a lot.
> >And we may do some surveys, what other engines support like
> > spark/hive/presto and so on, how that support
Aitozi created FLINK-31790:
--
Summary: Filesystem batch sink should also respect to the
PartitionCommitPolicy
Key: FLINK-31790
URL: https://issues.apache.org/jira/browse/FLINK-31790
Project: Flink
Aitozi created FLINK-31787:
--
Summary: Add the explicit ROW constructor to the system function
doc
Key: FLINK-31787
URL: https://issues.apache.org/jira/browse/FLINK-31787
Project: Flink
Issue Type
Aitozi created FLINK-31774:
--
Summary: Add document for delete and update statement
Key: FLINK-31774
URL: https://issues.apache.org/jira/browse/FLINK-31774
Project: Flink
Issue Type: Improvement
Aitozi created FLINK-31755:
--
Summary: ROW function can not work with RewriteIntersectAllRule
Key: FLINK-31755
URL: https://issues.apache.org/jira/browse/FLINK-31755
Project: Flink
Issue Type: Bug
obuf. It will not impact the internal data
structure representation in Flink. For proof of concept, please refer to:
https://github.com/Aitozi/flink/commits/arrow-format.
@Martijn > I'm wondering if there's really much benefit for the Flink project to
add another file format, over pr
amework closely.
So, I'd like to introduce the flink-arrow formats module to support the
arrow format naturally.
Looking forward to some suggestions.
Best,
Aitozi
[1]: https://apache-flink.slack.com/archives/C03GV7L3G2C/p1677915016551629
[2]: https://apache-flink.slack.com/
Aitozi created FLINK-31497:
--
Summary: Drop the deprecated CatalogViewImpl
Key: FLINK-31497
URL: https://issues.apache.org/jira/browse/FLINK-31497
Project: Flink
Issue Type: Technical Debt
solution. as described in [4]
Looking forward to your inputs.
Best,
Aitozi.
[1]: https://issues.apache.org/jira/projects/FLINK/issues/FLINK-29088
[2]: https://issues.apache.org/jira/projects/FLINK/issues/FLINK-31205
[3]: Efficient and Extensible Algorithms for Multi Query Optimization
https:
Aitozi created FLINK-31426:
--
Summary: Upgrade the deprecated UniqueConstraint to the new one
Key: FLINK-31426
URL: https://issues.apache.org/jira/browse/FLINK-31426
Project: Flink
Issue Type
+1 (non-binding)
Best,
Aitozi
Jing Ge 于2023年3月13日周一 22:10写道：
> +1 (binding)
>
> Best Regards,
> Jing
>
> On Mon, Mar 13, 2023 at 1:57 PM Hang Ruan wrote:
>
> > +1 (non-binding)
> >
> > Best,
> > Hang
> >
> > yuxia 于2023年3月13日周一 20:
Congratulations, Yuxia
Best,
Aitozi
Yuxin Tan 于2023年3月13日周一 10:36写道：
> Congratulations, Yuxia!
>
> Best,
> Yuxin
>
>
> Jark Wu 于2023年3月13日周一 10:26写道：
>
> > Hi, everyone
> >
> > On behalf of the PMC, I'm very happy to announce Yuxia Luo as a
Aitozi created FLINK-31390:
--
Summary: Optimize the FlinkChangelogModeInferenceProgram by
avoiding unnecessary traversals.
Key: FLINK-31390
URL: https://issues.apache.org/jira/browse/FLINK-31390
Project
Aitozi created FLINK-31362:
--
Summary: Add document about how to use C-style escape strings
Key: FLINK-31362
URL: https://issues.apache.org/jira/browse/FLINK-31362
Project: Flink
Issue Type
> we can initiate corresponding support issues for
specific connectors to follow up on support after finalizing the API
changes
Make sense to me!
Best,
Aitozi.
Lincoln Lee 于2023年3月7日周二 15:05写道：
> Thanks Jingsong & Hang,
>
> Using Optional as the return value is a good ide
Hi Lincoln,
Thank you for sharing this FLIP. Overall, it looks good to me. I have
one question: with the introduction of this interface,
will any existing Flink connectors need to be updated in order to take
advantage of its capabilities? For example, HBase.
yuxia 于2023年3月7日周二 10:01写道：
> Tha
Hi, Jark
FYI, this feature has already been supported in Calcite 1.33.0 [1].
Therefore, I believe we can use it directly after upgrading the Calcite
version.
Best,
Aitozi.
[1]: https://issues.apache.org/jira/browse/CALCITE-5305
Aitozi 于2023年3月6日周一 16:48写道：
> Thanks, will give it a
Thanks, will give it a try
Best,
Aitozi.
Jark Wu 于2023年3月6日周一 15:11写道：
> Hi Aitozi,
>
> I would suggest trying to contribute it to the upstream project Calcite
> first.
>
> Best,
> Jark
>
> > 2023年3月6日 11:51，Aitozi 写道：
> >
> > Hi Jark,
> >
>
accommodate this new
syntax.
I am unsure whether we should initially incorporate this alteration in
Calcite or if we can directly supersede the StringLiteral behavior within
the Flink project. Nevertheless, I believe supporting this change is
achievable.
Thanks,
Aitozi.
Jark Wu 于2023年3月6日周一 1
y use
SELECT SPLIT_INDEX(col, '\n', 0); for the query.
I know this is not standard behavior in ANSI SQL. I'm opening this thread
for some opinions from the community guys.
[1]:
https://dev.mysql.com/doc/refman/8.0/en/string-literals.html#character-escape-sequences
Thanks,
Aitozi
Aitozi created FLINK-31296:
--
Summary: Add JoinConditionEqualityTransferRule to stream optimizer
Key: FLINK-31296
URL: https://issues.apache.org/jira/browse/FLINK-31296
Project: Flink
Issue Type
Aitozi created FLINK-31260:
--
Summary: PushLocalHashAggIntoScanRule should also work with union
RelNode
Key: FLINK-31260
URL: https://issues.apache.org/jira/browse/FLINK-31260
Project: Flink
Issue
e read/write operations in the Catalog, the
TableEnvironment#getCatalog will expose all of them to the user side. So I
learned to add a new api in TableEnvironment to reduce reliance on the
current TableEnvironment#getCatalog.
Thanks,
Aitozi
Ran Tao 于2023年2月23日周四 23:44写道：
> Hi, JingSong, Jing.
Aitozi created FLINK-31205:
--
Summary: do optimize for multi sink in a single relNode tree
Key: FLINK-31205
URL: https://issues.apache.org/jira/browse/FLINK-31205
Project: Flink
Issue Type
Aitozi created FLINK-30570:
--
Summary: RexNodeExtractor#isSupportedPartitionPredicate generates
unexpected partition predicates
Key: FLINK-30570
URL: https://issues.apache.org/jira/browse/FLINK-30570
Project
Aitozi created FLINK-30551:
--
Summary: Add open method to PartitionCommitPolicy
Key: FLINK-30551
URL: https://issues.apache.org/jira/browse/FLINK-30551
Project: Flink
Issue Type: Improvement
rectly.
For the getTable, I have no strong preference but I think it can also
work with ResolvedCatalogBaseTable to return the
ResolvedCatalogBaseTable. Since the current implementation is already
able to do that.
Thanks,
Aitozi
Aitozi created FLINK-30242:
--
Summary: Push localHashAggregate pass the union node
Key: FLINK-30242
URL: https://issues.apache.org/jira/browse/FLINK-30242
Project: Flink
Issue Type: Improvement
Aitozi created FLINK-30198:
--
Summary: Support AdaptiveBatchScheduler to set per-task size for
reducer task
Key: FLINK-30198
URL: https://issues.apache.org/jira/browse/FLINK-30198
Project: Flink
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
Aitozi created FLINK-29980:
--
Summary: Wrap the HiveSource's bulkFormat to handle the partition
keys
Key: FLINK-29980
URL: https://issues.apache.org/jira/browse/FLINK-29980
Project: Flink
Aitozi created FLINK-29800:
--
Summary: Continuous failover will leak the inprogress output file
Key: FLINK-29800
URL: https://issues.apache.org/jira/browse/FLINK-29800
Project: Flink
Issue Type: Bug
Aitozi created FLINK-29795:
--
Summary: The source.file.stream.io-fetch-size can not be set by
with properties
Key: FLINK-29795
URL: https://issues.apache.org/jira/browse/FLINK-29795
Project: Flink
Aitozi created FLINK-29748:
--
Summary: Expose the optimize phase in the connector context
Key: FLINK-29748
URL: https://issues.apache.org/jira/browse/FLINK-29748
Project: Flink
Issue Type
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
Aitozi created FLINK-29308:
--
Summary: NoResourceAvailableException fails the batch job
Key: FLINK-29308
URL: https://issues.apache.org/jira/browse/FLINK-29308
Project: Flink
Issue Type: Improvement
Aitozi created FLINK-29200:
--
Summary: Provide the way to delay the pod deletion for debugging
purpose
Key: FLINK-29200
URL: https://issues.apache.org/jira/browse/FLINK-29200
Project: Flink
Issue
Aitozi created FLINK-29088:
--
Summary: Project push down cause the source reuse can not work
Key: FLINK-29088
URL: https://issues.apache.org/jira/browse/FLINK-29088
Project: Flink
Issue Type
Aitozi created FLINK-29085:
--
Summary: Add the name for test as hint for BuiltInFunctionTestBase
Key: FLINK-29085
URL: https://issues.apache.org/jira/browse/FLINK-29085
Project: Flink
Issue Type
Aitozi created FLINK-29066:
--
Summary: Reconsider the runtime property of the
BuiltInFunctionDefinition
Key: FLINK-29066
URL: https://issues.apache.org/jira/browse/FLINK-29066
Project: Flink
Issue
Aitozi created FLINK-29061:
--
Summary: Cleanup dead code in StringCallGen
Key: FLINK-29061
URL: https://issues.apache.org/jira/browse/FLINK-29061
Project: Flink
Issue Type: Improvement
Congrats Lijie!
Best regards,
Aitozi
Jing Ge 于2022年8月19日周五 06:02写道：
> Congrats Lijie!
>
> Best regards,
> Jing
>
> On Thu, Aug 18, 2022 at 8:40 AM Terry Wang wrote:
>
> > Congratulations, Lijie!
> >
> > On Thu, Aug 18, 2022 at 11:31 AM Leonard Xu
Congratulations, Junhan!
Best,
Aitozi
Guowei Ma 于2022年8月19日周五 13:18写道：
> Congratulations, Junhan!
> Best,
> Guowei
>
>
> On Fri, Aug 19, 2022 at 6:01 AM Jing Ge wrote:
>
> > Congrats Junhan!
> >
> > Best regards,
> > Jing
> >
Aitozi created FLINK-28838:
--
Summary: Avoid to notify the elementQueue consumer when the fetch
result is empty
Key: FLINK-28838
URL: https://issues.apache.org/jira/browse/FLINK-28838
Project: Flink
Aitozi created FLINK-28822:
--
Summary: Avoid create VectorizedColumnBatch for each read in
ArrowReader
Key: FLINK-28822
URL: https://issues.apache.org/jira/browse/FLINK-28822
Project: Flink
Issue
Aitozi created FLINK-28816:
--
Summary: Include some metrics for the pod created in operator
Key: FLINK-28816
URL: https://issues.apache.org/jira/browse/FLINK-28816
Project: Flink
Issue Type
Aitozi created FLINK-28751:
--
Summary: Poor performance of the built in json_value function
Key: FLINK-28751
URL: https://issues.apache.org/jira/browse/FLINK-28751
Project: Flink
Issue Type
Aitozi created FLINK-28531:
--
Summary: Shutdown cluster after history server archive finished
Key: FLINK-28531
URL: https://issues.apache.org/jira/browse/FLINK-28531
Project: Flink
Issue Type: Bug
Aitozi created FLINK-28478:
--
Summary: Session Cluster will lost if it failed between status
recorded and deploy
Key: FLINK-28478
URL: https://issues.apache.org/jira/browse/FLINK-28478
Project: Flink
Aitozi created FLINK-28477:
--
Summary: Support to scan the history server dir with max depth
Key: FLINK-28477
URL: https://issues.apache.org/jira/browse/FLINK-28477
Project: Flink
Issue Type: Bug
Thanks Junhan for driving this. It a great improvement for the batch jobs.
I'm looking forward to this feature in our internal use case. +1 for it.
One more question:
Are each attempts of the TaskManager or JobManager pods (if failure occurs)
all be shown in the ui ?
Best,
Aitozi.
Yang Wa
Congrats, Jingsong!
Best,
Aitozi
Zhuoluo Yang 于2022年6月16日周四 09:26写道：
> Many congratulations to teacher Lee!
>
> Thanks,
> Zhuoluo
>
>
> Dian Fu 于2022年6月16日周四 08:54写道：
>
> > Congratulations, Jingsong!
> >
> > Regards,
> > Dian
>
Aitozi created FLINK-28008:
--
Summary: Can not get secondary resource from after operator restart
Key: FLINK-28008
URL: https://issues.apache.org/jira/browse/FLINK-28008
Project: Flink
Issue Type
Aitozi created FLINK-27979:
--
Summary: Support to upgrade session cluster in a more fine grained
way
Key: FLINK-27979
URL: https://issues.apache.org/jira/browse/FLINK-27979
Project: Flink
Issue
Aitozi created FLINK-27961:
--
Summary: The EventUtils generate event name should take the
resource's uid into account
Key: FLINK-27961
URL: https://issues.apache.org/jira/browse/FLINK-27961
Project:
Aitozi created FLINK-27960:
--
Summary: Make the apt-get updating optional
Key: FLINK-27960
URL: https://issues.apache.org/jira/browse/FLINK-27960
Project: Flink
Issue Type: Improvement
Aitozi created FLINK-27930:
--
Summary: Format the timestamp in status to make it explicit
Key: FLINK-27930
URL: https://issues.apache.org/jira/browse/FLINK-27930
Project: Flink
Issue Type
Aitozi created FLINK-27925:
--
Summary: Avoid to create watcher without the resourceVersion
Key: FLINK-27925
URL: https://issues.apache.org/jira/browse/FLINK-27925
Project: Flink
Issue Type
Aitozi created FLINK-27921:
--
Summary: Introduce the checkResourceRequirementsWithDelay in
DeclarativeSlotManager
Key: FLINK-27921
URL: https://issues.apache.org/jira/browse/FLINK-27921
Project: Flink
Thanks Yang and Nice to see it happen.
Best,
Aitozi.
Yang Wang 于2022年6月5日周日 16:14写道：
> The Apache Flink community is very happy to announce the release of Apache
> Flink Kubernetes Operator 1.0.0.
>
> The Flink Kubernetes Operator allows users to manage their Apache Flink
> a
+1 (non-binding)
Best,
Aitozi
Yangze Guo 于2022年5月27日周五 11:17写道：
> +1
>
> Best,
> Yangze Guo
>
> On Thu, May 26, 2022 at 4:42 PM Xintong Song
> wrote:
> >
> > +1
> >
> > Best,
> >
> > Xintong
> >
> >
> >
>
Aitozi created FLINK-27737:
--
Summary: Clean the outdated comments and unfencedMainExecutor
Key: FLINK-27737
URL: https://issues.apache.org/jira/browse/FLINK-27737
Project: Flink
Issue Type
1 - 100 of 234 matches
Mail list logo
