+1 for the new GraphBuilder API supports more complex
estimator / model structure and helps to reduce the repeat
code. Thanks Dong for the proposal.
Best,
Yun
--
From:Becket Qin
Send Time:2021 Nov. 22 (Mon.) 11:45
To:dev
Subject:R
Very thanks for all the warm responses ! We are greatly welcome more use cases
and co-work on Flink Remote Shuffle and bash processing with Flink~
Best,
Yun
--
From:Yingjie Cao
Send Time:2021 Dec. 1 (Wed.) 11:16
To:dev
Subject:Re
+1 for making the lifecycle of the savepoint / external checkpoint more clear.
Thanks Dawid for the FLIP~
Best,
Yun
--Original Mail --
Sender:Till Rohrmann
Send Date:Wed Dec 1 21:28:48 2021
Recipients:dev
Subject:Re: [VOTE] FLIP-193: Snapshots ownership
Than
Congratulations Matthias!
Best,
Yun
--
From:Jing Zhang
Send Time:2021 Dec. 3 (Fri.) 13:45
To:dev
Cc:Matthias Pohl
Subject:Re: [ANNOUNCE] New Apache Flink Committer - Matthias Pohl
Congratulations, Matthias!
刘建刚 于2021年12月3日周五 1
Congratulations Ingo!
Best,
Yun
--
From:刘建刚
Send Time:2021 Dec. 3 (Fri.) 11:52
To:dev
Cc:"Ingo Bürk"
Subject:Re: [ANNOUNCE] New Apache Flink Committer - Ingo Bürk
Congratulations！
Best,
Liu Jiangang
Till Rohrmann 于2021年12月2日周
Hi Yingjie,
Very thanks for drafting the FLIP and initiating the discussion!
May I have a double confirmation for
taskmanager.network.sort-shuffle.min-parallelism that
since other frameworks like Spark have used sort-based shuffle for all the
cases, does our
current circumstance still have dif
+1 (non-binding)
* Reviewed the blog post.
* Verified each version could run normally with example jobs.
* Checked each version only contains the log4j2 fix.
Thanks Chesnay for driving the emergency fix releases!
Best,
Yun
--
From
---
From:Till Rohrmann
Send Time:2021 Dec. 14 (Tue.) 18:57
To:Jingsong Li
Cc:Yingjie Cao ; 刘建刚 ; dev
; Yun Gao ; user
; user-zh
Subject:Re: [DISCUSS] Change some default config values of blocking shuffle
As part of this FLIP, does it make sense to also extend the documentation fo
Hi,
May I have a double confirmation that it seems we still have log4j version
written as
2.15.0 in dev/project-configuration.md in the commit corresponding to release
tags,
which seems to be not consistent with the PR in the github, is it expected and
would it
have influence?
Best,
Yun
-
driving the emergency releases!
Best,
Yun
--
From:Chesnay Schepler
Send Time:2021 Dec. 16 (Thu.) 09:03
To:dev ; Yun Gao ; Stephan
Ewen
Subject:Re: [VOTE] Release 1.11.6/1.12.7/1.13.5/1.14.2, release candidate #1
That's
fication. Very thanks for the explanation~
Best,
Yun
--
From:Yun Gao
Send Time:2021 Dec. 16 (Thu.) 09:14
To:dev ; Yun Gao ; Stephan
Ewen
Subject:Re: [VOTE] Release 1.11.6/1.12.7/1.13.5/1.14.2, release candidate #1
Hi Chesnay,
V
t; >>
> > At some point, Flink will definitely have some WAL adapter that can turn
> > any sink into an exactly-once sink (with some caveats). For now, we keep
> > that as an orthogonal solution as it has a rather high price (bursty
> > workload with high latenc
at just forwards the committables) and use a post-commit
> > topology that achieves that.
> > Another option is that they use the preCommit topology and insert a
> > constant key-by that forwards all committables to a single committer.
> > We are planning to provide building block
ut that issue is also in Sink V1 and kind
of orthogonal. It's also nothing that we can solve without involving more folks
(I'm trying to kick start that in the background).
On Thu, Dec 16, 2021 at 1:31 PM Yun Gao wrote:
Hi,
Very thanks Fabian for the explanation and it solves mo
Hi everyone,
Please review and vote on the release candidate #1 for the version 2.0.0 of
Apache Flink ML,
as follows:
[ ] +1, Approve the release
[ ] -1, Do not approve the release (please provide specific comments)
**Testing Guideline**
You can find here [1] a page in the project wiki on instr
;No public key".
[1] https://dist.apache.org/repos/dist/dev/flink/flink-ml-2.0.0-rc1
[2] https://dist.apache.org/repos/dist/release/flink/KEYS
On Tue, Dec 28, 2021 at 11:45 AM Yun Gao wrote:
Hi everyone,
Please review and vote on the release candidate #1 for the version 2.0.0 of
Apache Fli
Hi everyone,
Please review and vote on the release candidate #2 for the version 2.0.0 of
Apache Flink ML,
as follows:
[ ] +1, Approve the release
[ ] -1, Do not approve the release (please provide specific comments)
**Testing Guideline**
You can find here [1] a page in the project wiki on instruc
lease notes
- Checked source code tag "release-2.0.0-rc2"
On Tue, Dec 28, 2021 at 8:58 PM Yun Gao
wrote:
> Hi everyone,
> Please review and vote on the release candidate #2 for the version 2.0.0
> of Apache Flink ML,
> as follows:
> [ ] +1, Approve the release
> [
Hi everyone,
Please review and vote on the release candidate #3 for the version 2.0.0 of
Apache Flink ML,
as follows:
[ ] +1, Approve the release
[ ] -1, Do not approve the release (please provide specific comments)
**Testing Guideline**
You can find here [1] a page in the project wiki on instruc
:21 2022
Recipients:dev , Yun Gao
Subject:Re: Re: [DISCUSS] FLIP-191: Extend unified Sink interface to support
small file compaction
Hi Yun,
Thanks for summarizing the two issues.
1. Losing intermediate shuffle data in batch mode
I fully agree with your analysis. We will start to mitigate
+1 (binding).
Very thanks for proposing the FLIP!
Best,
Yun
--
From:Martijn Visser
Send Time:2022 Jan. 4 (Tue.) 17:22
To:dev
Subject:Re: [VOTE] FLIP-191: Extend unified Sink interface to support small
file compaction
+1 (non-b
Hi,
Very thanks for initiating the discussion!
Also +1 to drop the current DataSet based Gelly library so that we could
finally drop the
legacy DataSet API.
For whether to keep the graph computing ability, from my side graph query /
graph computing and
chaining them with the preprocessing pi
cases (though
>>>> may not the best) and for other cases, user may need to tune the memory
>>>> settings.
>>>> >> >
>>>> >> > >>> Can you share the tpcds results for different configs?
>>>> Although we change the def
Hi Xuannan,
Very thanks for drafting the FLIP and initiating the discussion!
I have several issues, sorry if I have misunderstandings:
1. With the cached stream, when would the compile and job submission
happens? Does it happen on calling execute_and_cache() ? If so, could
we support the job wit
ibutions do not contain any
> binaries
> > > > > - Built the source distribution with Maven to ensure all source
> files
> > > > have
> > > > > Apache headers
> > > > > - Verified that all POM files point to the same version
> >
I'm happy to announce that we have unanimously approved this release.
There are 6 approving votes, 3 of which are binding:
* Dong Lin (non-binding)
* Zhipeng Zhang (non-binding)
* Xingbo Huang (non-binding)
* Till Rohrmann (binding)
* Dian Fu (binding)
* Becket Qin (binding)
There are no disapp
The Apache Flink community is very happy to announce the release of Apache
Flink ML 2.0.0.
Apache Flink ML provides API and infrastructure that simplifies implementing
distributed ML algorithms,
and it also provides a library of off-the-shelf ML algorithms.
Please check out the release blog po
+1 since it would highly improve the open-box experience for batch jobs.
Thanks Yingjie for drafting the PR and initiating the discussion.
Best,
Yun
--Original Mail --
Sender:Yingjie Cao
Send Date:Tue Jan 11 15:15:01 2022
Recipients:dev
Subject:[VOTE] FLIP-19
Currently it seems the issues of flink-statefun and flink-ml are
also managed in the issues.apache.org ?
Best,
Yun
--Original Mail --
Sender:Jingsong Li
Send Date:Wed Jan 12 13:54:03 2022
Recipients:dev
Subject:[DISCUSS] Seek help for making JIRA links clickab
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 they could be differentiated at the moment:
cached result partition could be viewed as an internal, lightweig
issing cache at the scheduler requires a lot more work
> on the scheduler, compared to re-submit the job at the client side.
> Thus, for this FLIP, we will choose the first method. When the
> scheduler is ready, we can make it work with the scheduler. And the
> process should be
+1
Thanks Martijn for the efforts!
Best,
Yun
--
From:Yun Tang
Send Time:2022 Jan. 20 (Thu.) 15:22
To:dev
Subject:Re: [VOTE] Creating external connector repositories
+1
Thanks for driving this topic, Martijn
Best,
Yun Tang
+1 (binding)
Thanks Xuannan for driving this!
Best,
Yun
--
From:David Morávek
Send Time:2022 Jan. 20 (Thu.) 15:12
To:dev
Subject:Re: [VOTE] FLIP-205: Support cache in DataStream for Batch Processing
+1 (non-binding)
D.
On Thu
Congratulations Feng and Zhipeng!
Best,
Yun
--
From:Jing Zhang
Send Time:2022 Feb. 18 (Fri.) 22:22
To:dev
Subject:Re: Re: [ANNOUNCE] New Apache Flink Committers: Feng Wang, Zhipeng Zhang
Congratulations!
Best,
Jing Zhang
Bencha
Feb. 18 (Fri.) 22:04
To:dev
Subject:Re: [ANNOUNCE] New Flink PMC members: Igal Shilman, Konstantin Knauf
and Yun Gao
Congratulations!
Best,
Jing Zhang
Benchao Li 于2022年2月18日周五 20:22写道：
> Congratulations!
>
> Yu Li 于2022年2月18日周五 19:34写道：
>
> > Congratulations!
> >
Date:Thu Feb 24 21:51:58 2022
Recipients:dev
CC:Johannes Moser , Yun Gao
Subject:Re: [ANNOUNCE] Flink 1.15 Feature Freeze
Hi all,
I'd like to ask if it is fine to merge this PR[1]. It is an extension of
sink metrics that has been covered originally by FLIP-33 [2]. Such
extension has been po
Hi Mu,
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 issues
Hi Simon,
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 issu
Very thanks Till for all the efforts! Good luck for the next chapter~
Best,
Yun
--
Sender:Piotr Nowojski
Date:2022/02/28 22:10:46
Recipient:dev
Theme:Re: Change of focus
Good luck Till and thanks for all of your efforts.
Best,
Piot
staged artifacts randomly for some modules.
Best,
Yun Gao
--Original Mail --
Sender:Yun Tang
Send Date:Wed Mar 2 17:05:05 2022
Recipients:dev
Subject:Re: [VOTE] Release 1.14.4, release candidate #1
+1 non-binding
- Checked the signatures for pending release
Congratulations Martijn!
Best,
Yun Gao
--Original Mail --
Sender:Roman Khachatryan
Send Date:Fri Mar 4 15:22:08 2022
Recipients:dev
Subject:Re: [ANNOUNCE] New Apache Flink Committer - Martijn Visser
Congratulations Martijn!
Regards,
Roman
On Fri, Mar 4, 2022
Congratulations David!
Best,
Yun Gao
--
From:Jing Zhang
Send Time:2022 Mar. 8 (Tue.) 11:10
To:dev
Subject:Re: [ANNOUNCE] New Apache Flink Committer - David Morávek
Congratulations David!
Ryan Skraba 于2022年3月7日周一 22:18写道
the PR into both master and release-1.15 branches
- The JIRA ticket should be closed with the correct fix-versions (1.15.0 &
1.16.0).
We are now creating the rc0, which is expected to be delivered soon.
Thank you~
Joe, Till & Yun Gao
Congratulations, Yuan!
Best,
Yun Gao
--
From:Francesco Guardiani
Send Time:2022 Mar. 15 (Tue.) 00:21
To:dev
Subject:Re: [ANNOUNCE] New PMC member: Yuan Mei
Congratulations, Yuan!
On Mon, Mar 14, 2022 at 3:51 PM yanfei lei
Hi Piotr,
Very thanks for the information and very sorry for the missing!
Now I updated the flink.version property of the benchmark library
and also update it to the checklist in the releasing introduction
document~
Best,
Yun Gao
Hi Yu,
Currently we still have some ongoing blocker issues tracked under [1].
We are tighly tracking the progress of these issues and we'll start creating
the RC0 immediately after these blockers are solved, and hopefully inside
this week.
Best,
Yun Gao
[1]
https://issues.apache.org
[2].
- all artifacts that would normally be deployed to the Maven Central
Repository [3].
- source code tag "release-1.15.0-rc0" [4]
Your help testing the release will be greatly appreciated! And we'll create
the votable RC1 as soon as all the efforts are finished.
Thank you~
Joe, Ti
Congratulations Hequn!
Best,
Yun
--
From:Hequn Cheng
Send Time:2020 Apr. 18 (Sat.) 12:48
To:dev
Subject:Re: [ANNOUNCE] New Apache Flink PMC Member - Hequn Chen
Many thanks for your support. Thank you!
Best,
Hi Dhurandar:
Currently StreamingFileSink should be able to change the prefix and suffix
of the filename[1], it could be changed to something like -0-0.
Could this solve your problem ?
Best,
Yun
[1]
https://ci.apache.org/projects/flink/flink-docs-stable/dev/connectors/streamfile_si
Congratulates Xintong !
Best
Yun
--
Sender:Leonard Xu
Date:2020/06/05 12:51:20
Recipient:dev
Cc:Xintong Song
Theme:Re: [ANNOUNCE] New Apache Flink Committer - Xintong Song
Congratulates Xintong !
Best,
Leonard Xu
> 在 2020年6月5日，1
Congratulations, Benchao!
Best,
Yun
--
Sender:Danny Chan
Date:2020/06/10 20:01:01
Recipient:
Theme:Re: [ANNOUNCE] New Flink Committer: Benchao Li
Congrats Benchao!
Best,
Danny Chan
在 2020年6月10日 +0800 AM11:57，dev@flink.apache.org，写
+1 for have a editorconfig file that is more consistent with Flink's code
sytle.
From my own experience, whenever I open the Flink repo for the first time, I
have to manually change the continuation indent to 4 and disable the wildcard
imports. I also think that it should be more nice to new d
Congratulations Yu!
Best,
Yun
--
Sender:Zhijiang
Date:2020/06/17 11:18:35
Recipient:Dian Fu; dev
Cc:Haibo Sun; user;
user-zh
Theme:Re: [ANNOUNCE] Yu Li is now part of the Flink PMC
Congratulations Yu! Well deserved!
Best,
Zhijian
Hi Dhurandar,
With my understand I think what you need is to get notified when a file is
written successfully (committed) on the S3 FileSystem. However, currently there
is no public API for the listener and there an issue tracking it [1].
With the current version, one possible method co
Congratulations Piotr !
Best,
Yun
--
Sender:Austin Bennett
Date:2020/07/07 10:06:15
Recipient:
Theme:Re: [ANNOUNCE] New PMC member: Piotr Nowojski
Thanks for what you do, Piotr!
On Mon, Jul 6, 2020, 7:02 PM Matt Wang wrote:
> C
Yun Gao created FLINK-14521:
---
Summary: CoLocationGroup is not set into JobVertex if the stream
node chained with others
Key: FLINK-14521
URL: https://issues.apache.org/jira/browse/FLINK-14521
Project
Yun Gao created FLINK-12171:
---
Summary: The network buffer memory size should not be checked
against the heap size on the TM side
Key: FLINK-12171
URL: https://issues.apache.org/jira/browse/FLINK-12171
Yun Gao created FLINK-12852:
---
Summary: Deadlock occurs when requiring exclusive buffer for
RemoteInputChannel
Key: FLINK-12852
URL: https://issues.apache.org/jira/browse/FLINK-12852
Project: Flink
Yun Gao created FLINK-12865:
---
Summary: State inconsistency between RM and TM on the slot status
Key: FLINK-12865
URL: https://issues.apache.org/jira/browse/FLINK-12865
Project: Flink
Issue Type
Yun Gao created FLINK-13531:
---
Summary: Do not print log and call release if no requests should
be evicted in slot sharing
Key: FLINK-13531
URL: https://issues.apache.org/jira/browse/FLINK-13531
Project
Yun Gao created FLINK-13752:
---
Summary: TaskDeploymentDescriptor cannot be recycled by GC due to
referenced by an anonymous function
Key: FLINK-13752
URL: https://issues.apache.org/jira/browse/FLINK-13752
Yun Gao created FLINK-26974:
---
Summary: Python EmbeddedThreadDependencyTests.test_add_python_file
failed on azure
Key: FLINK-26974
URL: https://issues.apache.org/jira/browse/FLINK-26974
Project: Flink
Yun Gao created FLINK-26977:
---
Summary:
JobMasterStopWithSavepointITCase.throwingExceptionOnCallbackWithRestartsShouldSimplyRestartInTerminate
failed on azure
Key: FLINK-26977
URL: https://issues.apache.org/jira/browse
Yun Gao created FLINK-26979:
---
Summary: JsonFunctionsITCase.test failed on azure
Key: FLINK-26979
URL: https://issues.apache.org/jira/browse/FLINK-26979
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-26980:
---
Summary: PulsarUnorderedSourceReaderTest hang on azure
Key: FLINK-26980
URL: https://issues.apache.org/jira/browse/FLINK-26980
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-27073:
---
Summary: HAQueryableStateFsBackendITCase hangs on azure
Key: FLINK-27073
URL: https://issues.apache.org/jira/browse/FLINK-27073
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-27083:
---
Summary:
SavepointITCase.testStopWithSavepointFailingAfterSnapshotCreation failed on
azure
Key: FLINK-27083
URL: https://issues.apache.org/jira/browse/FLINK-27083
Project
Yun Gao created FLINK-27118:
---
Summary: Flink on Yarned failed with the default flink-conf
Key: FLINK-27118
URL: https://issues.apache.org/jira/browse/FLINK-27118
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-27131:
---
Summary: CastFunctionITCase.test failed on azure
Key: FLINK-27131
URL: https://issues.apache.org/jira/browse/FLINK-27131
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-27162:
---
Summary:
RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState failed on
azure
Key: FLINK-27162
URL: https://issues.apache.org/jira/browse/FLINK-27162
Project
Yun Gao created FLINK-27164:
---
Summary:
ResumeCheckpointManuallyITCase.testExternalizedFSCheckpointsWithLocalRecoveryZookeeper
failed on azure
Key: FLINK-27164
URL: https://issues.apache.org/jira/browse/FLINK-27164
Yun Gao created FLINK-27167:
---
Summary: Deploying master snapshot failed due to generating
javadoc failed
Key: FLINK-27167
URL: https://issues.apache.org/jira/browse/FLINK-27167
Project: Flink
Yun Gao created FLINK-27169:
---
Summary: PartiallyFinishedSourcesITCase.test hangs on azure
Key: FLINK-27169
URL: https://issues.apache.org/jira/browse/FLINK-27169
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-27216:
---
Summary: CheckpointCoordinatorTest.testMinCheckpointPause failed
on azure
Key: FLINK-27216
URL: https://issues.apache.org/jira/browse/FLINK-27216
Project: Flink
Yun Gao created FLINK-27219:
---
Summary: CliClientITCase.testSqlStatements failed on azure with
jdk11
Key: FLINK-27219
URL: https://issues.apache.org/jira/browse/FLINK-27219
Project: Flink
Issue
Yun Gao created FLINK-27284:
---
Summary: KafkaSinkITCase$IntegrationTests.testScaleUp failed on
azures due to failed to create topic
Key: FLINK-27284
URL: https://issues.apache.org/jira/browse/FLINK-27284
Yun Gao created FLINK-27285:
---
Summary: CassandraConnectorITCase failed on azure due to
NoHostAvailableException
Key: FLINK-27285
URL: https://issues.apache.org/jira/browse/FLINK-27285
Project: Flink
Yun Gao created FLINK-27341:
---
Summary: TaskManager running together with JobManager are bind to
127.0.0.1
Key: FLINK-27341
URL: https://issues.apache.org/jira/browse/FLINK-27341
Project: Flink
Yun Gao created FLINK-27413:
---
Summary: Drop scala 2.11 support from the flink-docker
Key: FLINK-27413
URL: https://issues.apache.org/jira/browse/FLINK-27413
Project: Flink
Issue Type: Bug
Yun Gao created FLINK-27492:
---
Summary: Flink table / sql scala API is missing in the binary
package
Key: FLINK-27492
URL: https://issues.apache.org/jira/browse/FLINK-27492
Project: Flink
Issue
Yun Gao created FLINK-27518:
---
Summary: Refactor migration tests to support generate snapshots of
new version automatically
Key: FLINK-27518
URL: https://issues.apache.org/jira/browse/FLINK-27518
Project
Yun Gao created FLINK-27910:
---
Summary: FileSink not registered the timer to enforce rolling
policy if started from scratch
Key: FLINK-27910
URL: https://issues.apache.org/jira/browse/FLINK-27910
Project
Yun Gao created FLINK-28386:
---
Summary: Trigger an immediate checkpoint after all sources finished
Key: FLINK-28386
URL: https://issues.apache.org/jira/browse/FLINK-28386
Project: Flink
Issue Type
Yun Gao created FLINK-28824:
---
Summary:
StreamingJobGraphGenerator#triggerSerializationAndReturnFuture might swallow
exception
Key: FLINK-28824
URL: https://issues.apache.org/jira/browse/FLINK-28824
Yun Gao created FLINK-28871:
---
Summary: Make DPP also works if batch shuffle mode is not
ALL_BLOCKING
Key: FLINK-28871
URL: https://issues.apache.org/jira/browse/FLINK-28871
Project: Flink
Issue
Yun Gao created FLINK-29459:
---
Summary: Sink v2 has bugs in supporting legacy v1 implementations
with global committer
Key: FLINK-29459
URL: https://issues.apache.org/jira/browse/FLINK-29459
Project: Flink
Yun Gao created FLINK-29462:
---
Summary: LookupJoinITCase failed on azure due to classloader
leaking
Key: FLINK-29462
URL: https://issues.apache.org/jira/browse/FLINK-29462
Project: Flink
Issue
Yun Gao created FLINK-30877:
---
Summary: Add support for @Before / @After for JUnit 4 and 5
Key: FLINK-30877
URL: https://issues.apache.org/jira/browse/FLINK-30877
Project: Flink
Issue Type: Sub
Yun Gao created FLINK-30906:
---
Summary: TwoInputStreamTask passes wrong configuration object when
creating input processor
Key: FLINK-30906
URL: https://issues.apache.org/jira/browse/FLINK-30906
Project
Yun Gao created FLINK-10469:
---
Summary: FileChannel may not write the whole buffer in a single
call to FileChannel.write(Buffer buffer)
Key: FLINK-10469
URL: https://issues.apache.org/jira/browse/FLINK-10469
Yun Gao created FLINK-10981:
---
Summary: Add or modify metrics to show the maximum usage of
InputBufferPool/OutputBufferPool to help debugging back pressure
Key: FLINK-10981
URL: https://issues.apache.org/jira/browse
Yun Gao created FLINK-15664:
---
Summary: Flink plan visualizer does not show operators information
completely when there are line wrap
Key: FLINK-15664
URL: https://issues.apache.org/jira/browse/FLINK-15664
Yun Gao created FLINK-15701:
---
Summary: Allows transfer.sh to retry when fails to uploads logs.
Key: FLINK-15701
URL: https://issues.apache.org/jira/browse/FLINK-15701
Project: Flink
Issue Type
Yun Gao created FLINK-16009:
---
Summary: Native support for the Variable-length and Zig-zag
Variable-length integers
Key: FLINK-16009
URL: https://issues.apache.org/jira/browse/FLINK-16009
Project: Flink
Yun Gao created FLINK-16137:
---
Summary: Translate all DataStream API related pages into Chinese
Key: FLINK-16137
URL: https://issues.apache.org/jira/browse/FLINK-16137
Project: Flink
Issue Type
Yun Gao created FLINK-16138:
---
Summary: Translate "Overview" page of "DataStream API" into Chinese
Key: FLINK-16138
URL: https://issues.apache.org/jira/browse/FLINK-16138
Project: Flink
Yun Gao created FLINK-16151:
---
Summary: Translate "Event-time/Pre-defined Timestamp Extractors /
Watermark Emitters" into Chinese
Key: FLINK-16151
URL: https://issues.apache.org/jira/browse/F
Yun Gao created FLINK-16152:
---
Summary: Translate "Operator/index" into Chinese
Key: FLINK-16152
URL: https://issues.apache.org/jira/browse/FLINK-16152
Project: Flink
Issue Type
Yun Gao created FLINK-16153:
---
Summary: Translate "Operator/windows" into Chinese
Key: FLINK-16153
URL: https://issues.apache.org/jira/browse/FLINK-16153
Project: Flink
Issue Type
Yun Gao created FLINK-16155:
---
Summary: Translate "Operator/Process Function" into Chinese
Key: FLINK-16155
URL: https://issues.apache.org/jira/browse/FLINK-16155
Project: Flink
Issue
201 - 300 of 561 matches
Mail list logo
