Aiden Gong created FLINK-30219:
--
Summary: Fetch results api in sql gateway return error result.
Key: FLINK-30219
URL: https://issues.apache.org/jira/browse/FLINK-30219
Project: Flink
Issue Type:
Thanks for the reply.
Gyula and Max.
Prasanna
On Sat, 26 Nov 2022, 00:24 Maximilian Michels, wrote:
> Hi John, hi Prasanna, hi Rui,
>
> Gyula already gave great answers to your questions, just adding to it:
>
> >What’s the reason to add auto scaling to the Operator instead of to the
> JobMana
Hi John, hi Prasanna, hi Rui,
Gyula already gave great answers to your questions, just adding to it:
>What’s the reason to add auto scaling to the Operator instead of to the
JobManager?
As Gyula mentioned, the JobManager is not the ideal place, at least not
until Flink supports in-place autoscal
Lukas Mahl created FLINK-30218:
--
Summary: [Kafka Connector] java.lang.OutOfMemoryError: Metaspace
Key: FLINK-30218
URL: https://issues.apache.org/jira/browse/FLINK-30218
Project: Flink
Issue Typ
xljtswf created FLINK-30217:
---
Summary: Use ListState#update() to replace clear + add mode.
Key: FLINK-30217
URL: https://issues.apache.org/jira/browse/FLINK-30217
Project: Flink
Issue Type: Improve
+1 (non-binding)
Etienne
Le 25/11/2022 à 10:31, Chesnay Schepler a écrit :
Hi everyone,
Please review and vote on the release candidate #1 for the version
3.0.0, as follows:
[ ] +1, Approve the release
[ ] -1, Do not approve the release (please provide specific comments)
The complete stagin
Daren Wong created FLINK-30216:
--
Summary: Address tabs/spaces in checkstyle/spotless
Key: FLINK-30216
URL: https://issues.apache.org/jira/browse/FLINK-30216
Project: Flink
Issue Type: Improvemen
The Apache Flink community is very happy to announce the release of
Apache Flink 1.15.3, which is the third 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 a
Chesnay Schepler created FLINK-30215:
Summary: Deprecated Cassandra explicit Scala support
Key: FLINK-30215
URL: https://issues.apache.org/jira/browse/FLINK-30215
Project: Flink
Issue Typ
Hi all,
Sorry for the late jumping in.
To meet Weihua's need, Dong's proposal seems pretty fine, but the
modification it requires, I'm afraid, is not really easy.
RestartBackoffTimeStrategy is quite a simple interface. The strategy even
doesn't know which task is failing, not to mention the divis
Hey Martijn,
I have no strong opinion on 2.0.0 vs 3.0.0, but am happy to change for
consistency.
Yes, we will externalize the remaining connectors prior to Flink 1.17.
Thanks.
On Fri, Nov 25, 2022 at 8:22 AM Martijn Visser
wrote:
> Hi Danny,
>
> I'm wondering if it makes more sense to start w
Hi everyone,
Please review and vote on the release candidate #1 for the version
3.0.0, 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],
Rui Fan created FLINK-30214:
---
Summary: The resource is not enough
Key: FLINK-30214
URL: https://issues.apache.org/jira/browse/FLINK-30214
Project: Flink
Issue Type: Bug
Reporter: Rui Fa
Rui Fan created FLINK-30213:
---
Summary: The edge is wrong when the vertex parallelism is changed
Key: FLINK-30213
URL: https://issues.apache.org/jira/browse/FLINK-30213
Project: Flink
Issue Type: Bu
Caizhi Weng created FLINK-30212:
---
Summary: Introduce a TableStoreCompactJob class for users to
submit compact jobs in Table Store
Key: FLINK-30212
URL: https://issues.apache.org/jira/browse/FLINK-30212
Caizhi Weng created FLINK-30211:
---
Summary: Introduce CompactStoreSink for compact jobs in Table Store
Key: FLINK-30211
URL: https://issues.apache.org/jira/browse/FLINK-30211
Project: Flink
Issu
Caizhi Weng created FLINK-30210:
---
Summary: Refactor StoreCompactOperator to accept records
containing partitions and buckets in Table Store
Key: FLINK-30210
URL: https://issues.apache.org/jira/browse/FLINK-30210
Caizhi Weng created FLINK-30209:
---
Summary: Introduce CompactFileStoreSource for compact jobs of
Table Store
Key: FLINK-30209
URL: https://issues.apache.org/jira/browse/FLINK-30209
Project: Flink
xljtswf created FLINK-30208:
---
Summary: avoid unconditional state update in CountTrigger#onElement
Key: FLINK-30208
URL: https://issues.apache.org/jira/browse/FLINK-30208
Project: Flink
Issue Type:
Caizhi Weng created FLINK-30207:
---
Summary: Move split initialization and discovery logic fully into
SnapshotEnumerator in Table Store
Key: FLINK-30207
URL: https://issues.apache.org/jira/browse/FLINK-30207
Caizhi Weng created FLINK-30206:
---
Summary: Allow FileStoreScan to read incremental changes from
OVERWRITE snapshot in Table Store
Key: FLINK-30206
URL: https://issues.apache.org/jira/browse/FLINK-30206
Caizhi Weng created FLINK-30205:
---
Summary: Modify compact interface for TableWrite and
FileStoreWrite to support normal compaction in Table Store
Key: FLINK-30205
URL: https://issues.apache.org/jira/browse/FLINK-302
Caizhi Weng created FLINK-30204:
---
Summary: Table Store support separated compact jobs
Key: FLINK-30204
URL: https://issues.apache.org/jira/browse/FLINK-30204
Project: Flink
Issue Type: New Feat
Hi Danny,
I'm wondering if it makes more sense to start with version 3.0.0 (like we
did with Elasticsearch) to avoid possible confusion about a Flink 2.0
release. I have no strong opinion on that topic though.
+1 for the plans otherwise. For my understanding, that would imply that
before the Flin
Yeah, at some point I've investigated performance issues with AWS K8s. They
have somewhat strict rate limits on the K8s api server.
You run into the rate limits by configuring a very high checkpoint
frequency (I guess something like 500ms) and a high
state.checkpoints.num-retained count (e.g. 10).
Hi,
In order to subscribe to the Dev mailing list, please send an email to
dev-subscr...@flink.apache.org
This is also explained at
https://flink.apache.org/community.html#mailing-lists
Best regards,
Martijn
On Fri, Nov 25, 2022 at 9:03 AM 王汛洪 wrote:
>
Matthias Pohl created FLINK-30203:
-
Summary: BatchPandasConversionTests.test_empty_to_pandas failed
Key: FLINK-30203
URL: https://issues.apache.org/jira/browse/FLINK-30203
Project: Flink
Issu
28 matches
Mail list logo
