Yun Gao created FLINK-28824:
---
Summary:
StreamingJobGraphGenerator#triggerSerializationAndReturnFuture might swallow
exception
Key: FLINK-28824
URL: https://issues.apache.org/jira/browse/FLINK-28824
Projec
Yuxin Tan created FLINK-28823:
-
Summary: Enlarge the max requested buffers for
SortMergeResultPartitionReadScheduler
Key: FLINK-28823
URL: https://issues.apache.org/jira/browse/FLINK-28823
Project: Flink
Aitozi created FLINK-28822:
--
Summary: Avoid create VectorizedColumnBatch for each read in
ArrowReader
Key: FLINK-28822
URL: https://issues.apache.org/jira/browse/FLINK-28822
Project: Flink
Issue Ty
+1 (non-binding)
On Wed, Aug 3, 2022 at 5:47 AM Martijn Visser
wrote:
> +1 (binding)
>
> Op wo 3 aug. 2022 om 14:33 schreef Piotr Nowojski :
>
> > +1 (binding)
> >
> > śr., 3 sie 2022 o 14:13 Thomas Weise napisał(a):
> >
> > > +1 (binding)
> > >
> > >
> > > On Sun, Jul 31, 2022 at 10:57 PM Seba
Hi Tamas,
I think `StreamStatementSet.attachAsDataStream()` is what you are looking
for.
Here is detailed documentation. Please take a look:
https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/data_stream_api/#adding-table-api-pipelines-to-datastream-api
Best,
Jark
On Fri, 5 Aug
godfrey he created FLINK-28821:
--
Summary: Adjust join cost for dpp query pattern which could help
more plans use dpp
Key: FLINK-28821
URL: https://issues.apache.org/jira/browse/FLINK-28821
Project: Flink
Simon Su created FLINK-28820:
Summary: Pulsar Connector PulsarSink performance issue when
delivery guarantee is not NONE
Key: FLINK-28820
URL: https://issues.apache.org/jira/browse/FLINK-28820
Project: Fl
Hi Experts,
We are trying to upgrade to flink-1.1.5 and have to refactor our code due
to the following method has been removed from TableEnvironment: void
sqlUpdate(String sql). In our code we mix the SQL and DataStream API and
use the sqlUpdate method to buffer several insert statements, also add
zck created FLINK-28819:
---
Summary: state Time of day TTL
Key: FLINK-28819
URL: https://issues.apache.org/jira/browse/FLINK-28819
Project: Flink
Issue Type: New Feature
Components: API / Data
Huang Xingbo created FLINK-28818:
Summary:
KafkaSinkITCase.testWriteRecordsToKafkaWithExactlyOnceGuarantee failed with
AssertionFailedError
Key: FLINK-28818
URL: https://issues.apache.org/jira/browse/FLINK-28818
Michael created FLINK-28817:
---
Summary: NullPointerException in HybridSource when restoring from
checkpoint
Key: FLINK-28817
URL: https://issues.apache.org/jira/browse/FLINK-28817
Project: Flink
Is
Aitozi created FLINK-28816:
--
Summary: Include some metrics for the pod created in operator
Key: FLINK-28816
URL: https://issues.apache.org/jira/browse/FLINK-28816
Project: Flink
Issue Type: Improvem
zhenyu xing created FLINK-28815:
---
Summary: Translate the "Real Time Reporting with the Table API"
page into Chinese
Key: FLINK-28815
URL: https://issues.apache.org/jira/browse/FLINK-28815
Project: Flink
Sergey Nuyanzin created FLINK-28814:
---
Summary: Update postgres driver because of CVE-2022-31197
Key: FLINK-28814
URL: https://issues.apache.org/jira/browse/FLINK-28814
Project: Flink
Issue
jackylau created FLINK-28813:
Summary: new stach builtinfunction validateClassForRuntime it not
correct
Key: FLINK-28813
URL: https://issues.apache.org/jira/browse/FLINK-28813
Project: Flink
Is
Jingsong Lee created FLINK-28812:
Summary: Add read.compacted to read compacted snapshot only
Key: FLINK-28812
URL: https://issues.apache.org/jira/browse/FLINK-28812
Project: Flink
Issue Type
Hi,
As we are a community focused around Flink I thought I would send you some
information about the new DATA Pill project.
I hope you will be interested because it covers our area and the project is
focused on highly selected content for specialists.
It is also a community-driven project.
DATA
Chesnay Schepler created FLINK-28811:
Summary: Enabled Java 11 tests for Hbase 2
Key: FLINK-28811
URL: https://issues.apache.org/jira/browse/FLINK-28811
Project: Flink
Issue Type: Sub-tas
Jingsong Lee created FLINK-28810:
Summary: Introduce write.skip-compaction to skip compaction on
write
Key: FLINK-28810
URL: https://issues.apache.org/jira/browse/FLINK-28810
Project: Flink
Hi everybody,
I'm happy to let you know that FLIP-217 [1] for implementing "Support
watermark alignment of source splits" has been accepted [2] with 4 positive
votes (with 3 binding) and no negative vote:
- Mason Chen (non-binding)
- Thomas Weise (binding)
- Martijn Visser (binding)
- Piotr Nowoj
Jingsong Lee created FLINK-28809:
Summary: Concurrent write support for table store
Key: FLINK-28809
URL: https://issues.apache.org/jira/browse/FLINK-28809
Project: Flink
Issue Type: New Feat
Chesnay Schepler created FLINK-28808:
Summary: CsvFileFormatFactory#createEncodingFormat should create
ConverterContext on server-side
Key: FLINK-28808
URL: https://issues.apache.org/jira/browse/FLINK-28808
Chesnay Schepler created FLINK-28807:
Summary: Various components don't respect schema lifecycle
Key: FLINK-28807
URL: https://issues.apache.org/jira/browse/FLINK-28807
Project: Flink
Iss
Zhipeng Zhang created FLINK-28806:
-
Summary: Add Estimator and Transformer for IDF
Key: FLINK-28806
URL: https://issues.apache.org/jira/browse/FLINK-28806
Project: Flink
Issue Type: New Featu
Zhipeng Zhang created FLINK-28805:
-
Summary: Add Transformer for HashingTF
Key: FLINK-28805
URL: https://issues.apache.org/jira/browse/FLINK-28805
Project: Flink
Issue Type: New Feature
Zhipeng Zhang created FLINK-28803:
-
Summary: Add Transformer and Estimator for KBinsDiscretizer
Key: FLINK-28803
URL: https://issues.apache.org/jira/browse/FLINK-28803
Project: Flink
Issue Ty
Chesnay Schepler created FLINK-28804:
Summary: Use proper stand-ins for missing metrics groups
Key: FLINK-28804
URL: https://issues.apache.org/jira/browse/FLINK-28804
Project: Flink
Issue
Yordan Pavlov created FLINK-28802:
-
Summary: EOFException when recovering from a checkpoint
Key: FLINK-28802
URL: https://issues.apache.org/jira/browse/FLINK-28802
Project: Flink
Issue Type:
wujinhu created FLINK-28801:
---
Summary: Upgrade OSS SDK Version
Key: FLINK-28801
URL: https://issues.apache.org/jira/browse/FLINK-28801
Project: Flink
Issue Type: Improvement
Components: f
Weijie Guo created FLINK-28800:
--
Summary: HsFileDataManager should avoid busy-loop when fileReader
has not data to read
Key: FLINK-28800
URL: https://issues.apache.org/jira/browse/FLINK-28800
Project: Fl
Weijie Guo created FLINK-28799:
--
Summary: Hybrid shuffle can't schedule graph contains blocking edge
Key: FLINK-28799
URL: https://issues.apache.org/jira/browse/FLINK-28799
Project: Flink
Issue
Bilna created FLINK-28798:
-
Summary: Upgrade JDOM to resolve CVE-2021-33813
Key: FLINK-28798
URL: https://issues.apache.org/jira/browse/FLINK-28798
Project: Flink
Issue Type: Bug
Component
32 matches
Mail list logo
