xuyong created FLINK-29826:
--
Summary: flink-sql-connector-hbase-1.4 netty class not found,
because of shade not work
Key: FLINK-29826
URL: https://issues.apache.org/jira/browse/FLINK-29826
Project: Flink
Hoang Tri Tam created FLINK-29827:
-
Summary: [Connector][AsyncSinkWriter] Checkpointed states block
writer from sending records
Key: FLINK-29827
URL: https://issues.apache.org/jira/browse/FLINK-29827
Hi all,
@Piotr
When FlinkKafkaConsumer was marked as deprecated, the migration steps were
included in the release notes:
https://nightlies.apache.org/flink/flink-docs-master/release-notes/flink-1.14/#flink-24055httpsissuesapacheorgjirabrowseflink-24055
Scrolling up a bit shows how move from FlinkK
Shammon created FLINK-29828:
---
Summary: Support to read data from table with given snapshot id
Key: FLINK-29828
URL: https://issues.apache.org/jira/browse/FLINK-29828
Project: Flink
Issue Type: Sub-
Yubin Li created FLINK-29829:
Summary: align explain results in different platforms
Key: FLINK-29829
URL: https://issues.apache.org/jira/browse/FLINK-29829
Project: Flink
Issue Type: Bug
Thanks Shengkai.
> We don't have any detailed plan about this. But I know Livy has a
similar feature.
How can we check with Livy on this?
Back to the SQL client: is this the master issue tracking enabling SQL
Client <-> Gateway connection?
https://issues.apache.org/jira/browse/FLINK-29751 (Migra
Martijn Visser created FLINK-29830:
--
Summary:
PulsarSinkITCase$DeliveryGuaranteeTest.writeRecordsToPulsar failed
Key: FLINK-29830
URL: https://issues.apache.org/jira/browse/FLINK-29830
Project: Flink
Martijn Visser created FLINK-29831:
--
Summary: Multiple Hive tests are failing
Key: FLINK-29831
URL: https://issues.apache.org/jira/browse/FLINK-29831
Project: Flink
Issue Type: Bug
Congratulations Danny!
Best,
Guowei
On Tue, Nov 1, 2022 at 2:20 PM weijie guo wrote:
> Congratulations Danny!
>
> Best regards,
>
> Weijie
>
>
> Maximilian Michels 于2022年10月13日周四 21:41写道：
>
> > Congratulations Danny! Well deserved :)
> >
> > -Max
> >
> > On Thu, Oct 13, 2022 at 2:40 PM Yang Wa
Shammon created FLINK-29832:
---
Summary: Refactor default database name in flink table store
Key: FLINK-29832
URL: https://issues.apache.org/jira/browse/FLINK-29832
Project: Flink
Issue Type: Bug
Huang Xingbo created FLINK-29833:
Summary: Improve PyFlink support in Windows
Key: FLINK-29833
URL: https://issues.apache.org/jira/browse/FLINK-29833
Project: Flink
Issue Type: Improvement
Thanks Martijn and David,
And what about the FlinkKafkaProducer? In order to migrate it, the user has
to make sure that the transactions stored on the state are committed, and
that there are no lingering/pending transactions (lingering transactions
are blocking further reads to be readable until t
Chesnay Schepler created FLINK-29834:
Summary: Clear static Jackson TypeFactory cache on CL release
Key: FLINK-29834
URL: https://issues.apache.org/jira/browse/FLINK-29834
Project: Flink
Hi devs and users,
I'd like to share some highlights about the 1.17 release sync on 11/1/2022.
- The release sync is scheduled for biweekly Tuesdays at 9am (Central
European Standard Time) / 4pm (China Standard Time).
- Retrospective for 1.16: a discussion [1] is opened by Matthias for
collectin
Matthias Pohl created FLINK-29835:
-
Summary: BlobServer fails to provide artifacts
Key: FLINK-29835
URL: https://issues.apache.org/jira/browse/FLINK-29835
Project: Flink
Issue Type: Bug
Matthias Pohl created FLINK-29836:
-
Summary: PulsarUnorderedSourceITCase failed due to an expected job
restart not happening
Key: FLINK-29836
URL: https://issues.apache.org/jira/browse/FLINK-29836
Pro
Congrats, Danny!
Best,
Yuxin
Guowei Ma 于2022年11月1日周二 16:36写道：
> Congratulations Danny!
> Best,
> Guowei
>
>
> On Tue, Nov 1, 2022 at 2:20 PM weijie guo
> wrote:
>
> > Congratulations Danny!
> >
> > Best regards,
> >
> > Weijie
> >
> >
> > Maximilian Michels 于2022年10月13日周四 21:41写道：
> >
> > >
Thanks Yun Tang for joining the discussion.
I’ve deleted these branches with same name tag except release-1.14.6-rc2 which
has no same name tag.
release-1.12.3-rc1
release-1.13.2-rc2
release-1.14.3-rc1
release-1.15.0-rc1
release-1.14.6-rc2
Best,
Leonard
>
> Hi Leonard,
>
> Thanks
Congratulations, Danny!
Best,
Ahmed
On 01/11/2022, 09:51, "Yuxin Tan" wrote:
CAUTION: This email originated from outside of the organization. Do not
click links or open attachments unless you can confirm the sender and know the
content is safe.
Congrats, Danny!
Best,
Yuxin
Thanks Steven! My confusion stemmed from the lack of context in the FLIP.
The first version did not lay out how the refactoring would be used down
the line, e.g. by the ShuffleCoordinator. The OperatorCoordinator API is a
non-public API and before reading the code, I wasn't even aware how exactly
i
Congrats, Danny!
Best regards,
Jing
On Tue, Nov 1, 2022 at 11:42 AM Hamdy, Ahmed
wrote:
> Congratulations, Danny!
> Best,
> Ahmed
>
> On 01/11/2022, 09:51, "Yuxin Tan" wrote:
>
> CAUTION: This email originated from outside of the organization. Do
> not click links or open attachments unle
Hi all,
I am totally fine to do step 2 with 1.17. It would give us more room to do
some breaking changes if we would do it with 1.18.
@Danny
Thanks for the hint. Commonly, all related interfaces/classes should be
graduated too. Classes like SingleThreadMultiplexSourceReaderBase and
RecordEmitter
PR for upgrading to Flink 1.15.2 has been merged. Thanks for the efforts,
Galen and Filip!
We should be ready to kick off a new release for StateFun with the Flink
version upgrade.
I'll cut off a release branch now on apache/flink-statefun for
release-3.3.x to move things forward.
@Galen, @Filip i
Thanks Gordon and Filip, I appreciate your help on this one.
On Tue, Nov 1, 2022 at 1:07 PM Tzu-Li (Gordon) Tai
wrote:
> PR for upgrading to Flink 1.15.2 has been merged. Thanks for the efforts,
> Galen and Filip!
>
> We should be ready to kick off a new release for StateFun with the Flink
> ver
Btw, I'll assume that we're using this thread to gather consensus for
code-freezing for 3.3.x series of StateFun. I know there hasn't been much
activity on the repo, so this is just a formality really :)
>From the commit history, it looks like we're mainly including the below
major changes and bug
MartijnVisser commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-shared-utils/pull/1#discussion_r1010743355
##
README.md:
##
@@ -1 +1,79 @@
-This repository contains utilities for [Apache
Flink](https://flink.apache.org/) connectors.
\ No newline at end
Eric Xiao created FLINK-29837:
-
Summary: SQL API does not expose the RowKind of the Row for
processing Changelogs
Key: FLINK-29837
URL: https://issues.apache.org/jira/browse/FLINK-29837
Project: Flink
luoyuxia created FLINK-29838:
Summary: Hive streaming sink for partitioned table should contain
metastore by default
Key: FLINK-29838
URL: https://issues.apache.org/jira/browse/FLINK-29838
Project: Flink
chenqizhu created FLINK-29839:
-
Summary: SQL Gateway with hiveserver2 throw exception
Key: FLINK-29839
URL: https://issues.apache.org/jira/browse/FLINK-29839
Project: Flink
Issue Type: Bug
Caizhi Weng created FLINK-29840:
---
Summary: Old record may overwrite new record in Table Store when
snapshot committing is slow
Key: FLINK-29840
URL: https://issues.apache.org/jira/browse/FLINK-29840
Pro
hcj created FLINK-29841:
---
Summary: docs/content/docs/deployment/config.md has error
Key: FLINK-29841
URL: https://issues.apache.org/jira/browse/FLINK-29841
Project: Flink
Issue Type: Bug
Comp
Caizhi Weng created FLINK-29842:
---
Summary: Change commitIdentifier in Table Store snapshot to long
value
Key: FLINK-29842
URL: https://issues.apache.org/jira/browse/FLINK-29842
Project: Flink
Hi everyone,
Happy to announce that FLIP-263 [1] has been accepted.
>From vote thread [2], There are 9 approving votes, 7 of which are binding:
- Yanfei Lei (non-binding)
- Yuan Mei (binding)
- Zakelly Lan (non-binding)
- Yun Gao (binding)
- Godfrey He (binding)
- Dawid Wysakowicz (binding)
Yunfeng Zhou created FLINK-29843:
Summary: Euclidean Distance Measure generates NAN distance values
Key: FLINK-29843
URL: https://issues.apache.org/jira/browse/FLINK-29843
Project: Flink
Issu
Thanks Jing for starting the discussion.
+1 for removing FlinkKafkaConsumer, as KafkaSource has evolved for many
release cycles and should be stable enough. I have some concerns about the
new Kafka sink based on sink v2, as sink v2 still has some ongoing work in
1.17 (maybe Yun Gao could provide s
Hangxiang Yu created FLINK-29844:
Summary: FLIP-263: Improve resolving schema compatibility
Key: FLINK-29844
URL: https://issues.apache.org/jira/browse/FLINK-29844
Project: Flink
Issue Type:
36 matches
Mail list logo
