Congratulations!
Best
Weihua Hu
> 2020年6月5日 13:50，Xingbo Huang 写道：
>
> Congratulations, Xintong.
>
> Best,
> Xingbo
>
> Jiayi Liao 于2020年6月5日周五 下午1:49写道：
>
>> Congratulations!
>>
>> Best,
>> Jiayi Liao
>>
>> On Fri, Jun 5, 2020 at 1:48 PM Biao Liu wrote:
>>
>>> Congrats!
>>>
>>>
Thanks for Jacky and Yangze.
1) we will reorganize your design and move it to the flip
2) we will support lookup and DynamicSource. and current DynamicSource's
optimize, such as supportLimitPushDown/supportLimitPushdown doesn't have
achieved. so we will do it after it have done
Thanks for your
Thanks all for the support. It's a great honor for me.
Thank you~
Xintong Song
On Fri, Jun 5, 2020 at 1:51 PM Xingbo Huang wrote:
> Congratulations, Xintong.
>
> Best,
> Xingbo
>
> Jiayi Liao 于2020年6月5日周五 下午1:49写道：
>
> > Congratulations!
> >
> > Best,
> > Jiayi Liao
> >
> > On Fri, Jun 5,
Congratulations, Xintong.
Best,
Xingbo
Jiayi Liao 于2020年6月5日周五 下午1:49写道：
> Congratulations!
>
> Best,
> Jiayi Liao
>
> On Fri, Jun 5, 2020 at 1:48 PM Biao Liu wrote:
>
> > Congrats!
> >
> > Thanks,
> > Biao /'bɪ.aʊ/
> >
> >
> >
> > On Fri, 5 Jun 2020 at 13:32, Thomas Weise wrote:
> >
> > >
Congratulations!
Best,
Jiayi Liao
On Fri, Jun 5, 2020 at 1:48 PM Biao Liu wrote:
> Congrats!
>
> Thanks,
> Biao /'bɪ.aʊ/
>
>
>
> On Fri, 5 Jun 2020 at 13:32, Thomas Weise wrote:
>
> > Congratulations!
> >
> >
> > On Thu, Jun 4, 2020, 10:17 PM Yuan Mei wrote:
> >
> > > Congrats, Xintong!
> >
Congrats!
Thanks,
Biao /'bɪ.aʊ/
On Fri, 5 Jun 2020 at 13:32, Thomas Weise wrote:
> Congratulations!
>
>
> On Thu, Jun 4, 2020, 10:17 PM Yuan Mei wrote:
>
> > Congrats, Xintong!
> >
> > On Fri, Jun 5, 2020 at 12:45 PM Becket Qin wrote:
> >
> > > Hi all,
> > >
> > > On behalf of the PMC, I’m
Congratulations!
On Thu, Jun 4, 2020, 10:17 PM Yuan Mei wrote:
> Congrats, Xintong!
>
> On Fri, Jun 5, 2020 at 12:45 PM Becket Qin wrote:
>
> > Hi all,
> >
> > On behalf of the PMC, I’m very happy to announce Xintong Song as a new
> > Flink committer.
> >
> > Xintong started to contribute to
Congrats, Xintong!
On Fri, Jun 5, 2020 at 12:45 PM Becket Qin wrote:
> Hi all,
>
> On behalf of the PMC, I’m very happy to announce Xintong Song as a new
> Flink committer.
>
> Xintong started to contribute to Flink about two years ago and has been
> active since. His major work is in Flink
Hequn Cheng created FLINK-18143:
---
Summary: Fix Python meter metric not correct problem
Key: FLINK-18143
URL: https://issues.apache.org/jira/browse/FLINK-18143
Project: Flink
Issue Type: Bug
Congratulates Xintong !
Yun Gao 于2020年6月5日周五 下午1:06写道：
> 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
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
> 在
Congrats, Xintong!
> 在 2020年6月5日，下午12:50，Yangze Guo 写道：
>
> Congrats, Xintong!
>
> Best,
> Yangze Guo
>
> On Fri, Jun 5, 2020 at 12:48 PM Benchao Li wrote:
>>
>> Congratulations Xintong, well deserved!
>>
>> Becket Qin 于2020年6月5日周五 下午12:45写道：
>>
>>> Hi all,
>>>
>>> On behalf of the PMC,
Congratulates Xintong !
Best,
Leonard Xu
> 在 2020年6月5日，12:47，Benchao Li 写道：
>
> Congratulations Xintong, well deserved!
>
> Becket Qin 于2020年6月5日周五 下午12:45写道：
>
>> Hi all,
>>
>> On behalf of the PMC, I’m very happy to announce Xintong Song as a new
>> Flink committer.
>>
>> Xintong started
Congrats, Xintong!
Best,
Yangze Guo
On Fri, Jun 5, 2020 at 12:48 PM Benchao Li wrote:
>
> Congratulations Xintong, well deserved!
>
> Becket Qin 于2020年6月5日周五 下午12:45写道：
>
> > Hi all,
> >
> > On behalf of the PMC, I’m very happy to announce Xintong Song as a new
> > Flink committer.
> >
> >
Congratulations Xintong, well deserved!
Becket Qin 于2020年6月5日周五 下午12:45写道：
> Hi all,
>
> On behalf of the PMC, I’m very happy to announce Xintong Song as a new
> Flink committer.
>
> Xintong started to contribute to Flink about two years ago and has been
> active since. His major work is in
Hi all,
On behalf of the PMC, I’m very happy to announce Xintong Song as a new
Flink committer.
Xintong started to contribute to Flink about two years ago and has been
active since. His major work is in Flink resource management, and have also
participated in discussions, bug fixes and answering
+1 to add these 3 formast into dist, under the lib/ directory.
This is a worth trying step toward better usability for SQL users.
They don't have *any* dependencies and very small, so I think it's safe to
add them.
Best,
Jark
On Fri, 5 Jun 2020 at 11:14, Jingsong Li wrote:
> Hi all,
>
>
Jingsong Lee created FLINK-18142:
Summary: Wrong state names in HiveContinuousMonitoringFunction
Key: FLINK-18142
URL: https://issues.apache.org/jira/browse/FLINK-18142
Project: Flink
Issue
hi Etienne Chauchot:
thanks for your discussion.
for 1) we do not supprt es unbouded source currently
for 2) RichParallelSourceFunction is used for streaming ,InputFormat is for
batch
for 3) i downloaded beam just now. and the beam es connector is also using
es-hadoop. i have read the code of
Hi all,
Considering that 1.11 will be released soon, what about my previous
proposal? Put flink-csv, flink-json and flink-avro under lib.
These three formats are very small and no third party dependence, and they
are widely used by table users.
Best,
Jingsong Lee
On Tue, May 12, 2020 at 4:19 PM
@Tzu-Li (Gordon) Tai Thanks for the info. `mvn clean
install -Prun=e2e-tests` works for me. before verified demo on a clean
source directory.
Best,
Congxian
Tzu-Li (Gordon) Tai 于2020年6月4日周四 下午6:35写道：
> +1 (binding)
>
> Legal
>
> - Verified signatures and hashes of staged Maven artifacts,
Jark Wu created FLINK-18141:
---
Summary: Add documentation for Parquet format
Key: FLINK-18141
URL: https://issues.apache.org/jira/browse/FLINK-18141
Project: Flink
Issue Type: Sub-task
Jark Wu created FLINK-18140:
---
Summary: Add documentation for ORC format
Key: FLINK-18140
URL: https://issues.apache.org/jira/browse/FLINK-18140
Project: Flink
Issue Type: Sub-task
> Welcome to the Apache Flink community.
>
> In order to subscribe to the dev mailing list, you need to send an email to
> dev-subscr...@flink.apache.org. Currently, you are sending to
> dev@flink.apache.org.
>
> Thank you~
>
> Xintong Song
CC Jake,
BTW, please use English in dev mail list
Hi Jake,
Welcome to the Apache Flink community.
In order to subscribe to the dev mailing list, you need to send an email to
dev-subscr...@flink.apache.org. Currently, you are sending to
dev@flink.apache.org.
Thank you~
Xintong Song
On Fri, Jun 5, 2020 at 10:06 AM Jake wrote:
> 订阅 flink
订阅 flink 开发列表
Arvid Heise created FLINK-18139:
---
Summary: Unaligned checkpoints checks wrong channels for inflight
data.
Key: FLINK-18139
URL: https://issues.apache.org/jira/browse/FLINK-18139
Project: Flink
+1 (non-binding)
Checked sums and signatures: OK
Checked no binaries in source distribution: OK
Checked RAT and end-to-end tests (8u101): OK
Checked version in pom/README/setup.py files: OK
Best Regards,
Yu
On Thu, 4 Jun 2020 at 18:35, Tzu-Li (Gordon) Tai
wrote:
> +1 (binding)
>
> Legal
>
>
Hello Aljoscha Krettek and Seth Wiesman,
I am Abdul Basit, An enthusiast Data Science and Engineering professional.
I am currently doing my Industrial PhD focussing on developing predictive
maintenance solutions with the help of Big Data, Cloud and AI tools. My PhD
is in collaboration with Eit
Robert Metzger created FLINK-18138:
--
Summary: KeyedComplexChainTest.testMigrationAndRestore fails with
AskTimeoutException on CI
Key: FLINK-18138
URL: https://issues.apache.org/jira/browse/FLINK-18138
Robert Metzger created FLINK-18137:
--
Summary: JobMasterTriggerSavepointITCase.testStopJobAfterSavepoint
fails with AskTimeoutException
Key: FLINK-18137
URL: https://issues.apache.org/jira/browse/FLINK-18137
Roman Khachatryan created FLINK-18136:
-
Summary: Don't start channel state writing for savepoints (RPC)
Key: FLINK-18136
URL: https://issues.apache.org/jira/browse/FLINK-18136
Project: Flink
Thanks Jacky for starting this discussion.
The requirement of ES source has been proposed in the community many
times. +1 for the feature from my side.
Here are my thoughts:
1. streaming source
As we only support bounded source for JDBC and HBase, so I think it's fine
to have a bounded ES
Jark Wu created FLINK-18135:
---
Summary: Add documentation for the Canal format
Key: FLINK-18135
URL: https://issues.apache.org/jira/browse/FLINK-18135
Project: Flink
Issue Type: Sub-task
Jark Wu created FLINK-18134:
---
Summary: Add documentation for the Debezium format
Key: FLINK-18134
URL: https://issues.apache.org/jira/browse/FLINK-18134
Project: Flink
Issue Type: Sub-task
Jark Wu created FLINK-18131:
---
Summary: Add documentation for the new JSON format
Key: FLINK-18131
URL: https://issues.apache.org/jira/browse/FLINK-18131
Project: Flink
Issue Type: Sub-task
Jark Wu created FLINK-18133:
---
Summary: Add documentation for the new Avro format
Key: FLINK-18133
URL: https://issues.apache.org/jira/browse/FLINK-18133
Project: Flink
Issue Type: Sub-task
Jark Wu created FLINK-18132:
---
Summary: Add documentation for the new CSV format
Key: FLINK-18132
URL: https://issues.apache.org/jira/browse/FLINK-18132
Project: Flink
Issue Type: Sub-task
Hi,
I made the Elasticsearch connector of Apache Beam and I was thinking
about doing the same for Flink when I came by this discussion. I have
some comments regarding the design doc:
1. Streaming source:
ES has data streams features but only for time series data; the aim of
this source is
You don't necessarily need to use maven 3.2.5, you just have to know
what to watch out for.
For that reason we are _not_ forcing maven 3.2.5 in general, but for
releases only to be on the safe side.
Some time ago Gradle was brought up as a potential replacement for
maven, and I'd like to see
Jingsong Lee created FLINK-18130:
Summary: File name conflict for different jobs in filesystem/hive
sink
Key: FLINK-18130
URL: https://issues.apache.org/jira/browse/FLINK-18130
Project: Flink
Till Rohrmann created FLINK-18129:
-
Summary: Unhandled exception stack trace from
DispatcherRestEndpoint when deploying Kubernetes session cluster
Key: FLINK-18129
URL:
Robert Metzger created FLINK-18128:
--
Summary: CoordinatedSourceITCase.testMultipleSources gets stuck
Key: FLINK-18128
URL: https://issues.apache.org/jira/browse/FLINK-18128
Project: Flink
Chesnay Schepler created FLINK-18127:
Summary: Streamline manual execution of Java E2E tests
Key: FLINK-18127
URL: https://issues.apache.org/jira/browse/FLINK-18127
Project: Flink
Issue
Dian Fu created FLINK-18126:
---
Summary: Correct the exception handling of the Python
CompletableFuture
Key: FLINK-18126
URL: https://issues.apache.org/jira/browse/FLINK-18126
Project: Flink
Issue
Robert Metzger created FLINK-18125:
--
Summary: Skip CI execution on documentation pull requests
Key: FLINK-18125
URL: https://issues.apache.org/jira/browse/FLINK-18125
Project: Flink
Issue
Stephan Ewen created FLINK-18124:
Summary: Add documentation for new FLIP-27 source interface
Key: FLINK-18124
URL: https://issues.apache.org/jira/browse/FLINK-18124
Project: Flink
Issue
Robert Metzger created FLINK-18123:
--
Summary:
KubernetesClusterDescriptorTest.testDeployApplicationCluster:135->checkUpdatedConfigAndResourceSetting:194
expected: but was:
Key: FLINK-18123
URL:
Robert Metzger created FLINK-18122:
--
Summary: Kubernetes test fails with "error: timed out waiting for
the condition on jobs/flink-job-cluster"
Key: FLINK-18122
URL:
+1 (binding)
Legal
- Verified signatures and hashes of staged Maven artifacts, source
distribution and Python SDK distribution
- Checked NOTICE file of statefun-flink-distribution and
statefun-ridesharing-example-simulator
Functional
- Full build with end-to-end-tests, JDK 8: mvn clean install
Till Rohrmann created FLINK-18121:
-
Summary: Support creating Docker image from local Flink
distribution
Key: FLINK-18121
URL: https://issues.apache.org/jira/browse/FLINK-18121
Project: Flink
Aljoscha Krettek created FLINK-18120:
Summary: Don't expand documentation sections by default
Key: FLINK-18120
URL: https://issues.apache.org/jira/browse/FLINK-18120
Project: Flink
Issue
Hyeonseop Lee created FLINK-18119:
-
Summary: Fix unlimitedly growing state for time range bounded over
aggregate
Key: FLINK-18119
URL: https://issues.apache.org/jira/browse/FLINK-18119
Project: Flink
Jark Wu created FLINK-18118:
---
Summary: Some SQL Jobs with two input operators are loosing data
with unaligned checkpoints
Key: FLINK-18118
URL: https://issues.apache.org/jira/browse/FLINK-18118
Project:
+1 (binding)
- Signatures and hash are correct.
- All artifacts to be released to Maven in the staging Nexus repository.
- Verify that the source archives do not contain any binaries.
- Go through all commits from the last release. No license problem spotted.
- Check end-to-end tests. All tests
Robert Metzger created FLINK-18117:
--
Summary: "Kerberized YARN per-job on Docker test" "Could not start
hadoop cluster."
Key: FLINK-18117
URL: https://issues.apache.org/jira/browse/FLINK-18117
Hi, Jackey.
Thanks for driving this discussion. I think this proposal should be a
FLIP[1] since it impacts the public interface. However, as we have
only some preliminary discussions atm, a design draft would be ok. But
it would be better to organize your document according to [2].
I've two
Aihua Li created FLINK-18116:
Summary: E2E performance test
Key: FLINK-18116
URL: https://issues.apache.org/jira/browse/FLINK-18116
Project: Flink
Issue Type: Test
Components: API /
Aihua Li created FLINK-18115:
Summary: StabilityTest
Key: FLINK-18115
URL: https://issues.apache.org/jira/browse/FLINK-18115
Project: Flink
Issue Type: Test
Components: API / Core, API
59 matches
Mail list logo
