WeiNan Zhao created FLINK-22844:
---
Summary: Add doc to introduce ExplainDetails for EXPLAIN sytnax
Key: FLINK-22844
URL: https://issues.apache.org/jira/browse/FLINK-22844
Project: Flink
Issue T
xiaozilong created FLINK-22843:
--
Summary: Document and code are inconsistent.
Key: FLINK-22843
URL: https://issues.apache.org/jira/browse/FLINK-22843
Project: Flink
Issue Type: Improvement
Xintong Song created FLINK-22842:
Summary: Streaming File Sink end-to-end test fail due to not
finish after 900s
Key: FLINK-22842
URL: https://issues.apache.org/jira/browse/FLINK-22842
Project: Flink
lukehua created FLINK-22841:
---
Summary: how to update configuration of the native kubernetes
deployment model flink cluster?
Key: FLINK-22841
URL: https://issues.apache.org/jira/browse/FLINK-22841
Project: F
Xu xiaolong created FLINK-22839:
---
Summary: Assign-evenly kafkaTopicPartitions of multiple topics to
flinkKafkaConsumer subtask
Key: FLINK-22839
URL: https://issues.apache.org/jira/browse/FLINK-22839
Pr
Xu xiaolong created FLINK-22840:
---
Summary: Assign-evenly kafkaTopicPartitions of multiple topics to
flinkKafkaConsumer subtask
Key: FLINK-22840
URL: https://issues.apache.org/jira/browse/FLINK-22840
Pr
Hi Yuan, thanks for launching this discussion.
I prefer option-3 as this is the easiest to understand for users.
Best
Yun Tang
From: Roman Khachatryan
Sent: Monday, May 31, 2021 16:53
To: dev
Subject: Re: [DISCUSS][Statebackend][Runtime] Changelog Statebackend
Gao Fei created FLINK-22838:
---
Summary: Flink Dashboard display incorrect Version in 1.13，actual
display 1.12.2
Key: FLINK-22838
URL: https://issues.apache.org/jira/browse/FLINK-22838
Project: Flink
Xu xiaolong created FLINK-22837:
---
Summary: Assign-evenly kafkaTopicPartitions of multiple topics to
flinkKafkaConsumer subtask
Key: FLINK-22837
URL: https://issues.apache.org/jira/browse/FLINK-22837
Pr
Xintong Song created FLINK-22836:
Summary: OffsetsInitializerTest.testTimestampOffsetsInitializer
fails on azure
Key: FLINK-22836
URL: https://issues.apache.org/jira/browse/FLINK-22836
Project: Flink
discussed the PR with Thosmas offline. Thomas, please correct me if I
missed anything.
Right now, the PR differs from the FLIP-150 doc regarding the converter.
* Current PR uses the enumerator checkpoint state type as the input for the
converter
* FLIP-150 defines a new EndStateT interface.
It see
After some good discussion about how to enhance the Sink API to process
watermarks, I believe we're ready to proceed with a vote. Voting will be
open until at least Friday, June 4th, 2021.
Reference:
https://cwiki.apache.org/confluence/display/FLINK/FLIP-167%3A+Watermarks+for+Sink+API
Discussion
Roman Khachatryan created FLINK-22835:
-
Summary: ChangelogStateBackend tests use nested backend on recovery
Key: FLINK-22835
URL: https://issues.apache.org/jira/browse/FLINK-22835
Project: Flink
Hi, Till ~ Thanks for your comments. Yes, I think we are on the same page –
we are discussing how should JMPartitionTracker manage partitions properly ~
> If the ShuffleMaster should lose a result partition, then a reading task
should fail with a PartitionException which will invalidate the partit
Dawid Wysakowicz created FLINK-22834:
Summary: KafkaITCase.testBigRecordJob times out on azure
Key: FLINK-22834
URL: https://issues.apache.org/jira/browse/FLINK-22834
Project: Flink
Issu
Piotr Nowojski created FLINK-22833:
--
Summary: Source tasks (both old and new) are not reporting
checkpointStartDelay via CheckpointMetrics
Key: FLINK-22833
URL: https://issues.apache.org/jira/browse/FLINK-22833
The error message says that we are trying to reuse a transaction id that is
currently being used or has expired.
I am not 100% sure how this can happen. My suspicion is that you have
resumed a job multiple times from the same savepoint. Have you checked that
there is no other job which has been re
Thanks Till will do so ...
On Tuesday, June 1, 2021, 06:22:32 PM GMT+5:30, Till Rohrmann
wrote:
Hi Dipanjan,
this type of question is best sent to Flink's user mailing list because there
are a lot more people using Flink who could help you. The dev mailing list is
intended to be used
Timo Walther created FLINK-22832:
Summary: Drop usages of legacy planner in SQL Client
Key: FLINK-22832
URL: https://issues.apache.org/jira/browse/FLINK-22832
Project: Flink
Issue Type: Sub-t
Hi Dipanjan,
this type of question is best sent to Flink's user mailing list because
there are a lot more people using Flink who could help you. The dev mailing
list is intended to be used for development discussions.
Cheers,
Till
On Tue, Jun 1, 2021 at 1:31 PM Dipanjan Mazumder wrote:
> Hi ,
Timo Walther created FLINK-22831:
Summary: Drop usages of legacy planner in Scala shell
Key: FLINK-22831
URL: https://issues.apache.org/jira/browse/FLINK-22831
Project: Flink
Issue Type: Sub-
Ravi created FLINK-22830:
Summary: DataSet API to allow to collect and do the bulk upload in
DB
Key: FLINK-22830
URL: https://issues.apache.org/jira/browse/FLINK-22830
Project: Flink
Issue Type: Imp
Hi ,
I have integrated flink-siddhi library ([com.github.haoch/flink-siddhi_2.11
"0.2.2-SNAPSHOT"]) and i tried to configure and implement control stream from
flink-siddh and it broke with AbstractMethodError. When i tried running the
same with flink 1.11.0 it worked.
More Details is given in
Hi Till,
Thanks so that means it should work will try and see ..
RegardsDipanjan
On Tuesday, June 1, 2021, 01:48:19 PM GMT+5:30, Till Rohrmann
wrote:
Hi Dipanjan,
I am assuming that you are using the flink-siddhi library [1]. I am not an
expert but it looks as if the AbstractSiddhi
Timo Walther created FLINK-22829:
Summary: Drop usages of legacy planner in Hbase modules
Key: FLINK-22829
URL: https://issues.apache.org/jira/browse/FLINK-22829
Project: Flink
Issue Type: Su
Thanks Danny for starting the discussion.
+1 for this feature.
I like schema evolution.
A question:
Can we support multiple pipelines? For example, I have three source tables
and just one sink table.
So, I will write three CTAS:
- CTAS IF NOT EXISTS 1
- CTAS IF NOT EXISTS 2
- CTAS IF NOT EXIST
Arvid Heise created FLINK-22828:
---
Summary: Allow using a custom AWS credentials provider for the
Kinesis Connector
Key: FLINK-22828
URL: https://issues.apache.org/jira/browse/FLINK-22828
Project: Flink
There's a related effort: https://issues.apache.org/jira/browse/FLINK-21108
On 6/1/2021 10:14 AM, Till Rohrmann wrote:
Hi Gabor, welcome to the Flink community!
Thanks for sharing this proposal with the community Márton. In general, I
agree that authentication is missing and that this is requir
Ma Jun created FLINK-22827:
--
Summary: Hive CREATE TABLE Support CLUSTERED BY
Key: FLINK-22827
URL: https://issues.apache.org/jira/browse/FLINK-22827
Project: Flink
Issue Type: New Feature
Hi Jin,
thanks for starting this discussion and the initiative to implement a
remote shuffle service. It has always been the idea of the ShuffleService
abstraction to make this possible and we probably have overlooked some
details.
What I have understood from your description, you would like to i
徐州州 created FLINK-22826:
---
Summary: link sql1.13.1基于change log流数据join导致数据丢失
Key: FLINK-22826
URL: https://issues.apache.org/jira/browse/FLINK-22826
Project: Flink
Issue Type: Bug
Components: T
徐州州 created FLINK-22825:
---
Summary: link sql1.13.1基于change log流数据join导致数据丢失
Key: FLINK-22825
URL: https://issues.apache.org/jira/browse/FLINK-22825
Project: Flink
Issue Type: Bug
Components: T
Timo Walther created FLINK-22824:
Summary: Drop usages of legacy planner in Kafka modules
Key: FLINK-22824
URL: https://issues.apache.org/jira/browse/FLINK-22824
Project: Flink
Issue Type: Su
Gabor Somogyi created FLINK-22823:
-
Summary: Add Basic and SPNEGO authentication support
Key: FLINK-22823
URL: https://issues.apache.org/jira/browse/FLINK-22823
Project: Flink
Issue Type: New
Hi Dipanjan,
I am assuming that you are using the flink-siddhi library [1]. I am not an
expert but it looks as if the AbstractSiddhiOperator overrides the
snapshotState [2] method to store the Siddhi state in Flink.
[1] https://github.com/haoch/flink-siddhi
[2]
https://github.com/haoch/flink-sidd
Hi Gabor, welcome to the Flink community!
Thanks for sharing this proposal with the community Márton. In general, I
agree that authentication is missing and that this is required for using
Flink within an enterprise. The thing I am wondering is whether this
feature strictly needs to be implemented
Timo Walther created FLINK-22822:
Summary: Drop usages of legacy planner in JDBC module
Key: FLINK-22822
URL: https://issues.apache.org/jira/browse/FLINK-22822
Project: Flink
Issue Type: Sub-
Dawid Wysakowicz created FLINK-22821:
Summary: FlinkKafkaProducerMigrationTest fails with "Address
already in use"
Key: FLINK-22821
URL: https://issues.apache.org/jira/browse/FLINK-22821
Project:
Yang Wang created FLINK-22820:
-
Summary: Stopping Yarn session cluster will cause fatal error
Key: FLINK-22820
URL: https://issues.apache.org/jira/browse/FLINK-22820
Project: Flink
Issue Type: Bu
Dawid Wysakowicz created FLINK-22819:
Summary: YARNFileReplicationITCase fails with "The YARN
application unexpectedly switched to state FAILED during deployment"
Key: FLINK-22819
URL: https://issues.apache.or
Dawid Wysakowicz created FLINK-22818:
Summary: IgnoreInFlightDataITCase fails on azure
Key: FLINK-22818
URL: https://issues.apache.org/jira/browse/FLINK-22818
Project: Flink
Issue Type: B
41 matches
Mail list logo
