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: Bu
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 eve
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: Sub-
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
Is
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 Deb
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
On
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: Flin
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.
>
> Regardin
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,
>
> Reg
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
Report
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 between
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 Deb
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 b
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 from
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 y
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
but
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 https://cwiki.apache.org/confluence
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
Report
+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 `FileSourc
27 matches
Mail list logo
