fanrui created FLINK-28454:
--
Summary: Fix the wrong timestamp example of KafkaSource
Key: FLINK-28454
URL: https://issues.apache.org/jira/browse/FLINK-28454
Project: Flink
Issue Type: Bug
Huang Xingbo created FLINK-28453:
Summary: KafkaSourceLegacyITCase.testBrokerFailure hang on azure
Key: FLINK-28453
URL: https://issues.apache.org/jira/browse/FLINK-28453
Project: Flink
+1 for this channel in Slack. Only few people know the entrance to the
performance benchmark result page and posting it in a public slack channel will
attract more attention from Flink developers, also emphasis the importance of
performance issues.
Thanks for driving this Anton!
Best,
+1 for creating a public slack channel for benchmark. Like the build
channel, it will help us find potential problems before release.
Best,
Xingbo
Jing Ge 于2022年7月7日周四 22:41写道：
> +1 for moving to the public slack channel. Flink developers should pay more
> attention to the performance test.
>
Thanks a lot for being our release manager David and everyone who
contributed.
Best,
Xingbo
David Anderson 于2022年7月8日周五 06:18写道：
> The Apache Flink community is very happy to announce the release of Apache
> Flink 1.15.1, which is the first bugfix release for the Apache Flink 1.15
> series.
>
zhangjingcun created FLINK-28452:
Summary: "Reduce" and "aggregate" operations of "window_all" are
supported in Python datastream API
Key: FLINK-28452
URL: https://issues.apache.org/jira/browse/FLINK-28452
Thanks Yang Wang.
--- >>
A: Yeah, the said separated jar pkg won't be loaded by default. But when
users copy the jar pkg from $FLINK_HOME/opt/flink-kubernetes-*.jar to
plugins directory,
then the customized scheduler will be load and the functionality will
be enabled. That would be helpful
The Apache Flink community is very happy to announce the release of Apache
Flink 1.15.1, which is the first bugfix release for the Apache Flink 1.15
series.
Apache Flink® is an open-source stream processing framework for
distributed, high-performing, always-available, and accurate data streaming
dalongliu created FLINK-28451:
-
Summary: HiveFunctionDefinitionFactory load udf using user
classloader instead of thread context classloader
Key: FLINK-28451
URL: https://issues.apache.org/jira/browse/FLINK-28451
Márton Balassi created FLINK-28450:
--
Summary: Run helm linter in k8s operator ci
Key: FLINK-28450
URL: https://issues.apache.org/jira/browse/FLINK-28450
Project: Flink
Issue Type:
+1 for moving to the public slack channel. Flink developers should pay more
attention to the performance test.
Best regards,
Jing
On Thu, Jul 7, 2022 at 2:02 PM Yuan Mei wrote:
> +1 for the proposal Anton, and thanks very much to move this effort
> forward!
>
> In long term, I think it would
Ryan Skraba created FLINK-28449:
---
Summary: [JUnit5 Migration] Module: flink-parquet
Key: FLINK-28449
URL: https://issues.apache.org/jira/browse/FLINK-28449
Project: Flink
Issue Type: Sub-task
Hi Martjin,
I have discussed offline with several contributors from China and found
that most of them thought it difficult to finish the on-going features by
25th July. As there is consensus[1][2] that the feature freeze will happen
by the end of July with potentially two weeks delay, do you
+1 for the proposal Anton, and thanks very much to move this effort forward!
In long term, I think it would be helpful to ask volunteers to help
watching-out the daily micro benchmark results.
But let's make it more visible as the very first step!
Best Regards,
Yuan
On Tue, Jul 5, 2022 at
Weijie Guo created FLINK-28448:
--
Summary: BoundedDataTestBase has potential problem when
compression is enable
Key: FLINK-28448
URL: https://issues.apache.org/jira/browse/FLINK-28448
Project: Flink
Hello,
I have created a FLIP for slightly extending the collect() API to
support collecting an arbitrary number of streams, to make it more
useful for testing complex workflows.
https://cwiki.apache.org/confluence/display/FLINK/FLIP-251%3A+Support+collecting+arbitrary+number+of+streams
I'm happy to announce that we have unanimously approved this release [1].
* Dong Lin (non-binding)
* Yunfeng Zhou (non-binding)
* Dian Fu (binding)
* Yun Gao (binding)
* Becket Qin (binding)
There are no disapproving votes.
Thanks everyone!
[1]
Gyula Fora created FLINK-28447:
--
Summary: Create Kubernetes Operator PR template
Key: FLINK-28447
URL: https://issues.apache.org/jira/browse/FLINK-28447
Project: Flink
Issue Type: Improvement
Yuxin Tan created FLINK-28446:
-
Summary: Expose more information in PartitionDescriptor to support
more optimized Shuffle Service
Key: FLINK-28446
URL: https://issues.apache.org/jira/browse/FLINK-28446
Matyas Orhidi created FLINK-28445:
-
Summary: Support dynamic configurations
Key: FLINK-28445
URL: https://issues.apache.org/jira/browse/FLINK-28445
Project: Flink
Issue Type: New Feature
LuNing Wang created FLINK-28444:
---
Summary: Support SUBSTR without parameter in SQL and Table API
Key: FLINK-28444
URL: https://issues.apache.org/jira/browse/FLINK-28444
Project: Flink
Issue
Xuannan Su created FLINK-28443:
--
Summary: Provide official Flink image for PyFlink
Key: FLINK-28443
URL: https://issues.apache.org/jira/browse/FLINK-28443
Project: Flink
Issue Type: Improvement
Jingsong Lee created FLINK-28442:
Summary: SplitGenerator should use Ordered Packing
Key: FLINK-28442
URL: https://issues.apache.org/jira/browse/FLINK-28442
Project: Flink
Issue Type:
xiaozilong created FLINK-28441:
--
Summary: The parsing result of configuration
`pipeline.cached-files` is incorrect
Key: FLINK-28441
URL: https://issues.apache.org/jira/browse/FLINK-28441
Project: Flink
Huang Xingbo created FLINK-28440:
Summary: EventTimeWindowCheckpointingITCase.testSlidingTimeWindow
failed with restore
Key: FLINK-28440
URL: https://issues.apache.org/jira/browse/FLINK-28440
LuNing Wang created FLINK-28439:
---
Summary: Support SUBSTR and REGEXP built-in function in Table API
Key: FLINK-28439
URL: https://issues.apache.org/jira/browse/FLINK-28439
Project: Flink
Hello everyone,
I am reviving the discussion thread for FLIP-236: Asynchronous Job Submission
[1].
I am looking forward to hearing your feedback.
Thank you,
Nuno
On 2022/05/30 16:11:24 "Afonso, Nuno" wrote:
> Hello everyone,
>
> I would like to start a discussion about FLIP-236: Asynchronous
+1(non-binding), thanks for driving this
--
Best regards,
Mang Zhang
在 2022-07-06 10:44:53，"Zhu Zhu" 写道：
>+1 (binding)
>
>Thanks,
>Zhu
>
>Guowei Ma 于2022年7月5日周二 17:38写道：
>>
>> +1 (binding)
>> Best,
>> Guowei
>>
>>
>> On Tue, Jul 5, 2022 at 12:38 PM Jiangang Liu
>> wrote:
>>
>>
+1 (binding)
Best,
Jing Zhang
Zhu Zhu 于2022年7月6日周三 10:45写道：
> +1 (binding)
>
> Thanks,
> Zhu
>
> Guowei Ma 于2022年7月5日周二 17:38写道：
> >
> > +1 (binding)
> > Best,
> > Guowei
> >
> >
> > On Tue, Jul 5, 2022 at 12:38 PM Jiangang Liu
> > wrote:
> >
> > > +1 for the feature.
> > >
> > > Jing Zhang
+1 (binding)
Best,
Jing Zhang
Mang Zhang 于2022年7月7日周四 14:39写道：
> Hi Godfrey,
> Thank you very much for this vote!
>
>
> Since the titles of the two vote emails are the same, making it easy to
> confuse the emails, I will count the response results of these two emails
> when I finally count the
Thanks for writing this FLIP and initiating the discussion, Gen, Yun and Junhan!
It will be very useful to have these improvements on the web UI for
speculative execution users, allowing them to know what is happening.
I just have a few comment regarding the design details:
1. Can we also show
Xin Hao created FLINK-28438:
---
Summary: We should clear the error message after the session job
is running/finished
Key: FLINK-28438
URL: https://issues.apache.org/jira/browse/FLINK-28438
Project: Flink
Jingsong Lee created FLINK-28437:
Summary: Document Engine Matrix and Build page
Key: FLINK-28437
URL: https://issues.apache.org/jira/browse/FLINK-28437
Project: Flink
Issue Type:
Hi Godfrey,
Thank you very much for this vote!
Since the titles of the two vote emails are the same, making it easy to confuse
the emails, I will count the response results of these two emails when I
finally count the vote results!
the first vote email list:
Matyas Orhidi created FLINK-28436:
-
Summary: test_multi_sessionjob.sh is failing intermittently
Key: FLINK-28436
URL: https://issues.apache.org/jira/browse/FLINK-28436
Project: Flink
Issue
HunterHunter created FLINK-28435:
Summary: Flink version 1.15.0 consumption Kafka has backpressure.
Key: FLINK-28435
URL: https://issues.apache.org/jira/browse/FLINK-28435
Project: Flink
37 matches
Mail list logo
