Jingsong Lee created FLINK-25687:
Summary: DropDelete is incorrect in CompactManager when
outputLevel is zero
Key: FLINK-25687
URL: https://issues.apache.org/jira/browse/FLINK-25687
Project: Flink
Yufei Zhang created FLINK-25686:
---
Summary: Support Pulsar Schema evolution in Pulsar Connector
Key: FLINK-25686
URL: https://issues.apache.org/jira/browse/FLINK-25686
Project: Flink
Issue Type:
Xuannan Su created FLINK-25685:
--
Summary: RestClusterClient gets stuck on submitting job with local
user artifact
Key: FLINK-25685
URL: https://issues.apache.org/jira/browse/FLINK-25685
Project: Flink
Moses created FLINK-25684:
-
Summary: Support enhanced show databases syntax
Key: FLINK-25684
URL: https://issues.apache.org/jira/browse/FLINK-25684
Project: Flink
Issue Type: Improvement
Co
zhangzh created FLINK-25683:
---
Summary: wrong result if table transfrom to DataStream then window
process grouped to mini batch in batch mode
Key: FLINK-25683
URL: https://issues.apache.org/jira/browse/FLINK-25683
Thank you
At 2022-01-18 01:28:49, "Zhilong Hong" wrote:
>Hi, Chengyun:
>
>Thanks for your passion for contributing to the Flink community. You don't
>need a contributor permission to contribute your code to Flink. Find an
>open issue you are interested in at
>http://issues.apache.org/jira/browse/F
Release finalization steps have been completed, except for the Docker images.
Can someone please approve/merge:
https://github.com/apache/flink-docker/pull/97
https://github.com/apache/flink-docker/pull/98
I don't have access to publishing to DockerHub: apache/flink yet. I'm
going to request it,
Hi, Chengyun:
Thanks for your passion for contributing to the Flink community. You don't
need a contributor permission to contribute your code to Flink. Find an
open issue you are interested in at
http://issues.apache.org/jira/browse/FLINK and comment with your ideas. It
would be a good start for
Konstantin Knauf created FLINK-25682:
Summary: Check in script to verify cheksums and signatures for
Apache Flink Releases
Key: FLINK-25682
URL: https://issues.apache.org/jira/browse/FLINK-25682
P
Hi,
I want to contribute to Apache Flink. Would you please give me the contributor
permission? My JIRA full name is Chengyun Zhang.
Hi everyone,
The vote duration has passed and we have approved the release.
Binding votes:
* Till
* Timo
* Chesnay
I would like to ask Thomas to finalise the release and make the
announcement.
Best regards,
Martijn
On Mon, 17 Jan 2022 at 11:29, Chesnay Schepler wrote:
> +1 (binding)
>
> Wen
Martijn Visser created FLINK-25681:
--
Summary: CodeSplitITCase produces large stacktraces and
potentially out of memory errors
Key: FLINK-25681
URL: https://issues.apache.org/jira/browse/FLINK-25681
P
Jingsong Lee created FLINK-25680:
Summary: Introduce Table Store Flink Sink
Key: FLINK-25680
URL: https://issues.apache.org/jira/browse/FLINK-25680
Project: Flink
Issue Type: Sub-task
Robert Metzger created FLINK-25679:
--
Summary: Build arm64 Linux images for Apache Flink
Key: FLINK-25679
URL: https://issues.apache.org/jira/browse/FLINK-25679
Project: Flink
Issue Type: Imp
Hi Yang!
Thanks for the input!
I agree with you on both points that you made. Even if we might support
both standalone and native modes in the long run, we should probably build
the first version on top of the native integration.
This I feel will result in a much simpler, minimalistic first versi
Roman Khachatryan created FLINK-25678:
-
Summary: TaskExecutorStateChangelogStoragesManager.shutdown is not
thread-safe
Key: FLINK-25678
URL: https://issues.apache.org/jira/browse/FLINK-25678
Proje
Timo Walther created FLINK-25677:
Summary: Update ReplicateRows to the new type system
Key: FLINK-25677
URL: https://issues.apache.org/jira/browse/FLINK-25677
Project: Flink
Issue Type: Sub-t
+1 (binding)
Went over the pom changes and double-checked licensing.
On 17/01/2022 10:44, Timo Walther wrote:
+1 (binding)
I had an offline chat with Fabian Paul about the mentioned changes.
The serializer changes should be acceptable as the migration would
have failed/stuck otherwise. At no
Hi everyone,
Thanks for Piotr to drive this topic.
I have several questions on this FLIP.
1. From my understanding, native savepoint appears much closer to current
alignment checkpoint. What's their difference?
2. If self-contained and relocatable are the most important difference, why
n
Dian Fu created FLINK-25676:
---
Summary: Add set_description in Python API
Key: FLINK-25676
URL: https://issues.apache.org/jira/browse/FLINK-25676
Project: Flink
Issue Type: Improvement
Com
Hi everyone,
The voting time for FLIP-206: Support PyFlink Runtime Execution in Thread
Mode[1] has passed. I'm closing the vote now.
There were 4 +1 votes, 4 of which are binding:
- Wei Zhong (binding)
- Till Rohrmann (binding)
- Thomas Weise (binding)
- Dian Fu (binding)
There were no -1 votes
+1 (binding)
I had an offline chat with Fabian Paul about the mentioned changes.
The serializer changes should be acceptable as the migration would have
failed/stuck otherwise. At no point in time we end up with a corrupt
serializer snapshot. We will update older 1.14 release notes to point
o
Thanks Wenhao for referring the JMX solution.
I believe it is a good alternative for who they do not have the ssh
permission of the production machines.
Best,
Yang
Wenhao Ji 于2022年1月16日周日 20:20写道：
> The FLIP has been marked as rejected.
>
> Anyone landing here looking for a solution to change
Glad to see that the interest of this thread keeps going. And thanks
Thomas, Gyula, and Marton for driving this effort.
I want to share my two cents about the Flink K8s operator.
> Standalone deployment VS native K8s integration
There is already some feature requirement issue[1] for the existin
Hi Chang,
Yes, I think this would make most sense to do.
Cheers,
Till
On Mon, Jan 17, 2022 at 9:13 AM Chang Chen wrote:
> IIUC, TableEnvironment isn't thread-safe, since it contains some internal
> states, for example, PlannerContext that has RelOptCluster used to optimize
> SQL.
>
> So do I c
Till Rohrmann created FLINK-25675:
-
Summary: UnalignedCheckpointCompatibilityITCase.test hangs on AZP
Key: FLINK-25675
URL: https://issues.apache.org/jira/browse/FLINK-25675
Project: Flink
Is
Till Rohrmann created FLINK-25674:
-
Summary:
CassandraConnectorITCase.testCassandraPojoNoAnnotatedKeyspaceAtLeastOnceSink
fails on AZP
Key: FLINK-25674
URL: https://issues.apache.org/jira/browse/FLINK-25674
Till Rohrmann created FLINK-25673:
-
Summary:
AdaptiveSchedulerITCase.testStopWithSavepointFailOnFirstSavepointSucceedOnSecond
hangs on AZP
Key: FLINK-25673
URL: https://issues.apache.org/jira/browse/FLINK-25673
Martijn Visser created FLINK-25672:
--
Summary: FileSource enumerator remembers paths of all already
processed files which can result in large state
Key: FLINK-25672
URL: https://issues.apache.org/jira/browse/FLINK
I went through the commit diff and found the following changes that
might cause issues in my opinion. Maybe it makes sense to take a second
look before I will cast my vote:
// change of transformations
https://github.com/apache/flink/commit/b7cd97b02d7f39b5190d27fbaf6e6287f127b9a9
// change o
+1 Thanks Xuannan, no more objections from my side
On Mon, Jan 17, 2022 at 7:14 AM Yun Gao
wrote:
> Hi Xuannan,
>
> Very thanks for the detailed explanation and sorry for the very
> late response.
>
> For cached result partition v.s. managed table, I also agree with
> the current conclusion that
Yun Gao created FLINK-25671:
---
Summary: npm ci failed with code EPROTO when downloading
stylelint-config-prettier-8.0.2.tgz
Key: FLINK-25671
URL: https://issues.apache.org/jira/browse/FLINK-25671
Project: Fl
Kyle created FLINK-25670:
Summary: StateFun: Unable to handle oversize HTTP message if state
size is large
Key: FLINK-25670
URL: https://issues.apache.org/jira/browse/FLINK-25670
Project: Flink
Issu
IIUC, TableEnvironment isn't thread-safe, since it contains some internal
states, for example, PlannerContext that has RelOptCluster used to optimize
SQL.
So do I create a TableEnvironment per thread?
Lijie Wang created FLINK-25669:
--
Summary: Support register operator coordinators for newly
initialized ExecutionJobVertex.
Key: FLINK-25669
URL: https://issues.apache.org/jira/browse/FLINK-25669
Project:
Lijie Wang created FLINK-25668:
--
Summary: Support calcuate network memory for dynamic graph.
Key: FLINK-25668
URL: https://issues.apache.org/jira/browse/FLINK-25668
Project: Flink
Issue Type: Su
36 matches
Mail list logo
