Chesnay Schepler created FLINK-23887:
Summary: Check thread pollution for 1.14
Key: FLINK-23887
URL: https://issues.apache.org/jira/browse/FLINK-23887
Project: Flink
Issue Type: Improveme
Liviu Firu created FLINK-23888:
--
Summary: Flink azure fs doesn't work
Key: FLINK-23888
URL: https://issues.apache.org/jira/browse/FLINK-23888
Project: Flink
Issue Type: Bug
Components:
Chesnay Schepler created FLINK-23889:
Summary: Unnecessary logging from FineGrainedSlotManager
Key: FLINK-23889
URL: https://issues.apache.org/jira/browse/FLINK-23889
Project: Flink
Issue
Yik San Chan created FLINK-23891:
Summary: Support
'sink.partition-commit.policy.kind'='metastore,success-file' config for batch
Hive sink
Key: FLINK-23891
URL: https://issues.apache.org/jira/browse/FLINK-23891
Yue Ma created FLINK-23890:
--
Summary: CepOperator may create a large number of timers and cause
performance problems
Key: FLINK-23890
URL: https://issues.apache.org/jira/browse/FLINK-23890
Project: Flink
Chesnay Schepler created FLINK-23892:
Summary: FineGrainedSlotManager is not sending signal for lacking
resources
Key: FLINK-23892
URL: https://issues.apache.org/jira/browse/FLINK-23892
Project: F
Hi everyone,
if the HybridSource is self contained, then I don't see a lot of harm in
doing the backport. We should probably explicitly state in the docs that a
certain minor version is required for this source to be available because
our docs don't distinguish between minor versions and having to
Chesnay Schepler created FLINK-23893:
Summary: Fine-grained resource allocation may fail depending on
slot allocation order
Key: FLINK-23893
URL: https://issues.apache.org/jira/browse/FLINK-23893
Chesnay Schepler created FLINK-23894:
Summary: Resolve/hide akka warning regarding ActorRefProvider
Key: FLINK-23894
URL: https://issues.apache.org/jira/browse/FLINK-23894
Project: Flink
Timo Walther created FLINK-23895:
Summary: Upsert materializer is not inserted for all sink providers
Key: FLINK-23895
URL: https://issues.apache.org/jira/browse/FLINK-23895
Project: Flink
Is
David Morávek created FLINK-23896:
-
Summary: The new KafkaSink drops data if job fails between
checkpoint and transaction commit.
Key: FLINK-23896
URL: https://issues.apache.org/jira/browse/FLINK-23896
Rui Li created FLINK-23897:
--
Summary: Fix obsolete doc about creating hive table with flink
Key: FLINK-23897
URL: https://issues.apache.org/jira/browse/FLINK-23897
Project: Flink
Issue Type: Bug
Chesnay Schepler created FLINK-23898:
Summary: WARN log level not mapped correctly to akka log levels
Key: FLINK-23898
URL: https://issues.apache.org/jira/browse/FLINK-23898
Project: Flink
Wenhao Ji created FLINK-23899:
-
Summary: Translate the "Elastic Scaling" page into chinese
Key: FLINK-23899
URL: https://issues.apache.org/jira/browse/FLINK-23899
Project: Flink
Issue Type: Impro
Chesnay Schepler created FLINK-23900:
Summary: Migrate to ClusterActorRefProvider
Key: FLINK-23900
URL: https://issues.apache.org/jira/browse/FLINK-23900
Project: Flink
Issue Type: Improv
Parag Somani created FLINK-23901:
Summary: Fink with HA, upgrade from 1.12.1 to 1.13.2 causes NPE
Key: FLINK-23901
URL: https://issues.apache.org/jira/browse/FLINK-23901
Project: Flink
Issue
Jeff Yang created FLINK-23902:
-
Summary: Support Hive version 2.3.8
Key: FLINK-23902
URL: https://issues.apache.org/jira/browse/FLINK-23902
Project: Flink
Issue Type: Improvement
Compon
Xintong Song created FLINK-23903:
Summary:
ZooKeeperLeaderRetrievalConnectionHandlingTest.testSuspendedConnectionDoesNotClearLeaderInformationIfClearanceOnLostConnection
fails on azure
Key: FLINK-23903
URL: https
Hi Till,
I've updated the wiki page as per the discussion on flip-177. I hope it makes
more sense now.
Cheers, Steffen
On 16.07.21, 18:28, "Till Rohrmann" wrote:
CAUTION: This email originated from outside of the organization. Do not
click links or open attachments unless you can confir
Hi everyone,
according to the SupportsReadableMetadata interface, the planner is
supposed to project required metadata columns prior to applying them:
> The planner will select required metadata columns (i.e. perform
projection push down) and will call applyReadableMetadata(List, DataType)
with a
liwei li created FLINK-23904:
Summary: Add a parameter to flink's startup command that points to
the directory named jobid containing all versions of checkpoint
Key: FLINK-23904
URL: https://issues.apache.org/jira/bro
Thanks for the update Steffen. I'll try to take a look at it asap.
Cheers,
Till
On Fri, Aug 20, 2021 at 1:34 PM Hausmann, Steffen wrote:
> Hi Till,
>
> I've updated the wiki page as per the discussion on flip-177. I hope it
> makes more sense now.
>
> Cheers, Steffen
>
> On 16.07.21, 18:28, "T
Hello,
I am working on reviewing a PR [1] to add JSON support for the AWS Glue
Schema Registry integration. The module only builds for Scala 2.12 due to a
dependency incompatibility. The end-to-end tests have been implemented
using the newer Java framework rather than bash scripts. However, it
app
huntercc created FLINK-23905:
Summary: Reduce the load on JobManager when submitting large-scale
job with a big user jar
Key: FLINK-23905
URL: https://issues.apache.org/jira/browse/FLINK-23905
Project: Fl
24 matches
Mail list logo
