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
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
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:
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
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
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
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
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
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
Chesnay Schepler created FLINK-23889:
Summary: Unnecessary logging from FineGrainedSlotManager
Key: FLINK-23889
URL: https://issues.apache.org/jira/browse/FLINK-23889
Project: Flink
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
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:
Xintong Song created FLINK-23903:
Summary:
ZooKeeperLeaderRetrievalConnectionHandlingTest.testSuspendedConnectionDoesNotClearLeaderInformationIfClearanceOnLostConnection
fails on azure
Key: FLINK-23903
URL:
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
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:
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
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-23900:
Summary: Migrate to ClusterActorRefProvider
Key: FLINK-23900
URL: https://issues.apache.org/jira/browse/FLINK-23900
Project: Flink
Issue Type:
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,
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:
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
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:
24 matches
Mail list logo
