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:
Zichen Liu created FLINK-28007:
--
Summary: Tests for AWS Connectors Using SDK v2 to use Synchronous
Clients
Key: FLINK-28007
URL: https://issues.apache.org/jira/browse/FLINK-28007
Project: Flink
+1 non-binding
for that we can't always block at 2.12.7. but we should let users know
about this binary incompatibility if execute this update.
btw, the configuration
of scala-maven-plugin may need to update to match target-8, target-11 jvm
format.
Martijn Visser 于2022年6月10日 周五18:32写道：
> Hi
Chesnay Schepler created FLINK-28006:
Summary: Run architecture tests in single JVM
Key: FLINK-28006
URL: https://issues.apache.org/jira/browse/FLINK-28006
Project: Flink
Issue Type:
Chesnay Schepler created FLINK-28005:
Summary: Reduce network memory in UnalignedCheckpointITCase
Key: FLINK-28005
URL: https://issues.apache.org/jira/browse/FLINK-28005
Project: Flink
Chesnay Schepler created FLINK-28004:
Summary: Reduce CI heap space by 25%
Key: FLINK-28004
URL: https://issues.apache.org/jira/browse/FLINK-28004
Project: Flink
Issue Type: Technical
Iit would be nice to include a fix for FLINK-27933. A PR is already
opened for the 1.15 branch, and is overall trivial.
On 10/06/2022 12:15, David Anderson wrote:
Since no one has brought up any blockers, I'll plan to start the release
process on Monday unless I hear otherwise.
Best,
David
Jing Zhang created FLINK-28003:
--
Summary: 'pos ' field would be updated to 'POSITION' when use
SqlClient
Key: FLINK-28003
URL: https://issues.apache.org/jira/browse/FLINK-28003
Project: Flink
Huang Xingbo created FLINK-28002:
Summary: test_connectors.py failed with "object is not an instance
of declaring class" in JDK11
Key: FLINK-28002
URL: https://issues.apache.org/jira/browse/FLINK-28002
Huang Xingbo created FLINK-28001:
Summary: PlannerScalaFreeITCase.testImperativeUdaf failed with
Permission denied
Key: FLINK-28001
URL: https://issues.apache.org/jira/browse/FLINK-28001
Project:
1) With the declarative slot allocation protocol, it's not easy to
keep the slow slots which may have satisfy the slot request already,
but ask for more slots from the resource manager.
And we are also concerned to use detected slow slots, which may add
load to the slow nodes and further slow down
Gabor Somogyi created FLINK-28000:
-
Summary: security.kerberos.login.principal can be defined wihtout
keytab which is wrong configuration
Key: FLINK-28000
URL: https://issues.apache.org/jira/browse/FLINK-28000
Hi everyone,
As previously discussed [1] I would like to open a vote thread for updating
Flink from Scala 2.12.7 to Scala 2.12.16 and accept that there will be a
binary incompatibility when this upgrade is executed.
For this vote, I'm following the FLIP criteria since I think that best fits
with
Since no one has brought up any blockers, I'll plan to start the release
process on Monday unless I hear otherwise.
Best,
David
On Thu, Jun 9, 2022 at 10:20 AM Yun Gao
wrote:
> Hi David,
>
> Very thanks for driving the new version, also +1 since we already
> accumulated some fixes.
>
>
Hi Dian, Guys,
Thanks for your suggestion for the `PREVIOUS_AND_CURRENT`. I have updated the
naming of WithinType value in the FLIP.
If there are no other questions, I will start the VOTE thread next Monday.
Regards,
Nicholas Jiang
On 2022/06/10 10:02:46 Dian Fu wrote:
> Hi Nicholas,
>
>
luoyuxia created FLINK-27999:
Summary: Fix test failure for Hive3
Key: FLINK-27999
URL: https://issues.apache.org/jira/browse/FLINK-27999
Project: Flink
Issue Type: Improvement
Hi Nicholas,
Regarding the naming of `WithinType`, I'm OK with it. For
`PREVIOUS_AND_NEXT`, I guess `PREVIOUS_AND_CURRENT` makes more sense.
What's your thought?
Regards,
Dian
On Thu, Jun 9, 2022 at 10:09 AM Nicholas Jiang
wrote:
> Hi Dian,
>
> About the indication of the time interval
Hi everyone,
Please review and vote on the release candidate #1 for the version 1.14.5,
as follows:
[ ] +1, Approve the release
[ ] -1, Do not approve the release (please provide specific comments)
The complete staging area is available for your review, which includes:
* JIRA release notes [1],
Martijn Visser created FLINK-27998:
--
Summary: Upgrade Calcite version to 1.30
Key: FLINK-27998
URL: https://issues.apache.org/jira/browse/FLINK-27998
Project: Flink
Issue Type: Technical
henvealf created FLINK-27997:
Summary: How to unregister custom metrics at runtime?
Key: FLINK-27997
URL: https://issues.apache.org/jira/browse/FLINK-27997
Project: Flink
Issue Type: Improvement
Hi Godfrey,
compared to the solution proposed in the FLIP (using a SELECT
statement), I wonder if you have considered adding APIs to catalogs /
connectors to perform this task as an alternative?
I could imagine that for many connectors, statistics could be
implemented in a less expensive way
1)
It's true that if we handle this entirely in the scheduler we may get a
bunch of slow slots from the RM.
My point is that this isn't necessarily a problem; it depends on how you
handle those slots.
We anyway need to account for the possibility that we're not getting any
new fast slots
Hi godfrey, Thanks for driving this meaningful topic.
I think statistics are essential and meaningful for the optimizer, I'm just
wondering which situation is needed. From the user side, the optimizer
should be executed by the framework, maybe they do not want to consider too
much about it. Could
Hi all,
I would like to open a discussion on FLIP-240: Introduce "ANALYZE
TABLE" Syntax.
As FLIP-231 mentioned, statistics are one of the most important inputs
to the optimizer. Accurate and complete statistics allows the
optimizer to be more powerful. "ANALYZE TABLE" syntax is a very common
Hi Martjin,
Thank you for good feedback! I might not be able to address them all
especially around catalog table schema inference design.
>* What I'm missing overall, is the section on 'Public Interfaces'. The FLIP
has a large Proposed Changes section
I updated
luoyuxia created FLINK-27996:
Summary: Hive dialect support interval
Key: FLINK-27996
URL: https://issues.apache.org/jira/browse/FLINK-27996
Project: Flink
Issue Type: Sub-task
+1 for deprecating SourceFunction from me as well. And a big THANK YOU to
Alex Fedulov for bringing forward FLIP-238.
David
On Fri, Jun 10, 2022 at 4:03 AM Lijie Wang wrote:
> Hi all,
>
> Sorry for my mistake. The `StreamExecutionEnvironment#readFiles` and can be
> easily replaced by
Shengkai Fang created FLINK-27995:
-
Summary: Upgrade Janio version
Key: FLINK-27995
URL: https://issues.apache.org/jira/browse/FLINK-27995
Project: Flink
Issue Type: Improvement
wangkang created FLINK-27994:
Summary: ERROR
org.apache.flink.runtime.source.coordinator.SourceCoordinator
Key: FLINK-27994
URL: https://issues.apache.org/jira/browse/FLINK-27994
Project: Flink
+ 1
Best regards,
LuNing Wang
Jing Ge 于2022年6月10日周五 04:08写道：
> +1 (not-binding)
>
> Best regards,
> Jing
>
> On Thu, Jun 9, 2022 at 9:23 AM Jingsong Li wrote:
>
> > +1
> >
> > Thanks for driving.
> >
> > Best,
> > Jingsong
> >
> > On Thu, Jun 9, 2022 at 2:17 PM Nicholas Jiang
> > wrote:
> >
30 matches
Mail list logo
