Hi all,
@Stephan Thanks a lot for driving these efforts. I think a lot of people
is already waiting for this.
+1 for opening the blink source code.
Both a separate repository or a special branch is ok for me. Hopefully,
this will not last too long.
Best, Hequn
On Tue, Jan 22, 2019 at 11:35 PM
+1 This would be very helpful!
On Fri, Jan 25, 2019 at 8:15 AM Guowei Ma wrote:
> +1
>
> This not only helps Chinese users but also helps the community to collect
> more feedback and scenarios.
>
>
> > 在 2019年1月25日，上午2:29，Zhang, Xuefu 写道：
> >
> > +1 on the idea. This will certainly help promo
Hi Timo,
+1 for the FLIP!
Great work and thanks a lot for the detailed document! The task dependency
graph is very helpful for teasing out relationships between tasks.
Looking forward to the JIRAs and hoping to contribute to it!
Best,
Hequn
On Fri, Jan 25, 2019 at 7:54 PM Piotr Nowojski
wrote
Hi Chesnay,
Thanks a lot for the proposal! +1 for a leaner flink-dist and improve the
"Download" page.
I think a leaner flink-dist would be very helpful. If we bundle all jars
into a single one, this will easily cause class conflict problem.
Best,
Hequn
On Fri, Jan 25, 2019 at 2:48 PM jincheng
Hi Ramya,
Fabian is right. The behavior in strict SQL standard mode(SQL:2003) returns
a CHAR(N) type with blank-padded.
Best,
Hequn
On Wed, Jan 30, 2019 at 1:59 AM Fabian Hueske wrote:
> Hi,
>
> Table API queries are executed with SQL semantics.
> In SQL, the strings are padded because the re
Hi,
big +1 for this!
Thank you Jark for writing the great document. I totally agree with the
proposal. It not only keep the English document same as before but also
proposes a way to integrate with Chinese ones.
Best, Hequn
On Mon, Feb 4, 2019 at 6:18 PM Fabian Hueske wrote:
> Happy Chinese
Hi,
+1 on both 1.7.2 and 1.6.4. By then we can have a more stable release.
Best, Hequn
On Mon, Feb 11, 2019 at 8:46 PM Robert Metzger wrote:
> Cool! Then let's do the release together. I haven't done it in a while, but
> we'll manage.
>
> Could you start a separate [DISCUSS] thread for the 1
Hi Jincheng,
+1
Thank you for the discuss and writing a very nice google doc.
Looking forward to the 1.6.4 release. :-)
Best, Hequn
On Tue, Feb 12, 2019 at 5:23 PM Shaoxuan Wang wrote:
> Thanks for driving this release, Jincheng.
> +1 for release 1.6.4.
>
> On Tue, Feb 12, 2019 at 5:06 PM Uf
Great job! Thanks jincheng for your efforts on the RC1 of Flink 1.6.4!
+1 (non-binding)
I have checked the following things:
- download the dist source
- compiled from the downloaded source
- check repositories folder for 1.6.4, and jars can be download
successfully
- Check the relea
Thanks a lot for the great release @Gordon.
Also thanks for the work by the whole community. :-)
Best, Hequn
On Mon, Feb 18, 2019 at 2:12 PM jincheng sun
wrote:
> Thanks a lot for being our release manager Gordon ,
> Great job!
> And also a big thanks to the community for making this release
Thanks for planning on the 1.8 release. +1 for cutting the release branch
soon.
As Stephan and Jincheng said, the refactoring of Table API may block the
release. Fortunately, some issues have already been merged into the master,
for example, deprecate methods in TableEnvironment and Table. And som
Hi Stephan,
Thanks for summarizing the great roadmap! It is very helpful for users and
developers to track the direction of Flink.
+1 for putting the roadmap on the website and update it per release.
Besides, would be great if the roadmap can add the UpsertSource
feature(maybe put it under 'Batch
Thanks Jincheng for managing the release and everybody who contributed!
Best, Hequn
On Mon, Feb 25, 2019 at 9:46 AM jincheng sun
wrote:
> Hi,
>
> The Apache Flink community is very happy to announce the release of
> Apache Flink 1.6.4, which is the fourth bugfix release for the Apache
> Flink 1
@Aljoscha Thanks for driving this and cutting the new branch.
Looking forward to the release candidate :-)
Best, Hequn
On Mon, Feb 25, 2019 at 6:23 PM Kurt Young wrote:
> Thanks Aljoscha!
>
> Best,
> Kurt
>
>
> On Mon, Feb 25, 2019 at 5:43 PM jincheng sun
> wrote:
>
> > Thanks, Aljoscha!
> > T
Hi, Timo
Thanks for putting this together and bring the discussion. +1 to making our
JIRAs a bit more restrictive!
I think this makes a good point of view. It would be helpful to force the
contributors to think more about the issues rather than take it directly or
maybe rashly.
One little suggest
Hi Jincheng,
Thanks a lot for the discussion.
The enhancement of column operations has been asked for many times. The
design in the document gives a whole picture on it. I think it is very
good. I left some minor comments in the document.
Looking forward to the JIRA and the new features.
Best, H
Thanks a lot for the great release Aljoscha!
Also thanks for the work by the whole community. :-)
Best, Hequn
On Wed, Apr 10, 2019 at 6:03 PM Fabian Hueske wrote:
> Congrats to everyone!
>
> Thanks Aljoscha and all contributors.
>
> Cheers, Fabian
>
> Am Mi., 10. Apr. 2019 um 11:54 Uhr schrieb
Hi,
Great job, Gordon! Thanks a lot for driving this and wrapping features up
to a detailed list. +1 on it!
Would be great if we can also add flip29 to the list. @jincheng sun
and I are focusing on it these days. I think
these features in flip29 would bring big enhancements to the Table API. :-
Thank you Jincheng for the release!
+1 (non-binding)
- Release notes are correct.
- Built from source archive successfully.
- Signatures and hash are correct.
- All artifacts(11 artifacts including flink-shaded) have been deployed to
the maven central repository.
One minor comment for the websit
Hi Shaoxuan,
Thanks a lot for driving this. +1 to remove the module.
The git log of this module shows that it has been inactive for a long time.
I think it's ok to remove it for now. It would also be good to switch to
the new interface earlier.
Best, Hequn
On Mon, May 27, 2019 at 8:58 PM Becket
+1 (non-binding)
- Release notes are correct.
- Built from source archive successfully.
- Signatures and hash are correct.
- All artifacts(11 artifacts including flink-shaded) have been deployed to
the maven central repository.
- javax annotations are not included in the slim&uber jar any more.
Hi Jincheng,
Thanks for putting these together with a nice document.
+1 to release 1.8.1. I think it would be nice if we can have a new release
with so many fixes.
Best, Hequn
On Wed, May 29, 2019 at 5:25 PM jincheng sun
wrote:
> Hi all,
> Thank you for your support of the release of 1.8.1.
>
Thanks a lot to Jincheng and Chesnay and to the community making this
release possible!
Best, Hequn
On Mon, Jun 3, 2019 at 3:16 PM Jark Wu wrote:
> Thanks Jincheng for your effort!
>
> On Sat, 1 Jun 2019 at 05:19, Bowen Li wrote:
>
> > Thanks Jincheng for driving this release!
> >
> > On Thu,
+1 on the proposal!
Maintaining only one Python API is helpful for users and contributors.
Best, Hequn
On Wed, Jun 12, 2019 at 9:41 AM Jark Wu wrote:
> +1 and looking forward to the new Python API world.
>
> Best,
> Jark
>
> On Wed, 12 Jun 2019 at 09:22, Becket Qin wrote:
>
>> +1 on deprecatin
Hi,
Thank Robert for raising the discussion. Thank Bowen and Jark for your nice
thoughts.
The DingTalk group grows bigger and bigger. I think the reason is that a
lot of problems are solved quickly in the group. There are a lot of people
who are willing to answer questions in the DingTalk group.
Hi Vino,
Thanks for the proposal, I think it is a very good feature!
One thing I want to make sure is the semantics for the `localKeyBy`. From
the document, the `localKeyBy` API returns an instance of `KeyedStream`
which can also perform sum(), so in this case, what's the semantics for
`localKeyB
;>> users
> > > >>>>>> who use DataStream API to build their jobs.
> > > >>>>>> Users should know its semantics and the difference with keyBy
> API,
> > > >> so
> > > >>>> if
> > > >>>>>> they
rimary search engine for technology-related information?
> > - I think the primary search engine in China is still Baidu for most
> > technicians. So we still need a way to improve SEO.
> > Maybe the Flink China operation team have some experience on this.
> >
> &
2019 at 10:23 PM Kurt Young
> > wrote:
> > >>> >
> > >>> > > Thanks Robert, I left a comment in the JIRA you gave and see what
> > >>> will
> > >>> > > happen.
> > >>> > >
> > >>> >
ot work normally in the future. Please
> report it here again.
>
> Best,
> Vino
>
>
> Hequn Cheng 于2019年6月21日周五 下午2:39写道：
>
> > Hi Vino,
> >
> > Great thanks for your help.
> >
> > > So if someone reports that they can't receive the
fficiently in the mailing list. More people should also be
involved to answer the problems. I don't know whether is it possible for
the Chinese Flink team on duty to answer the problems. I think that would
help.
Great to have other opinions.
Best, Hequn
On Fri, Jun 21, 2019 at 7:50 PM Hequ
Hi Jark,
Impressive document!
I have gone over the document quickly and left some comments. I will have a
detailed look later. Below are two main thoughts from my side:
1. In the TableSource interface, can we move the getBoundedness() method
into the underneath Source?
This brings some benefits l
Congratulations Jincheng!
Best, Hequn
On Mon, Jun 24, 2019 at 11:43 PM Dian Fu wrote:
> Congratulations Jincheng!
>
> On Mon, Jun 24, 2019 at 11:09 PM Robert Metzger
> wrote:
>
> > Hi all,
> >
> > On behalf of the Flink PMC, I'm happy to announce that Jincheng Sun is
> now
> > part of the Apac
Hi Jincheng,
Thanks for raising the discussion!
The key information is very important for query optimizations. It would be
nice if we can use upsert mode to achieve better performance.
+1 for the `withKeys` proposal. :)
Best, Hequn
On Wed, Jun 26, 2019 at 4:37 PM jincheng sun
wrote:
> Hi all
Hi all,
Thanks for raising the nice discussion @Aljoscha.
+1 to sticking to the "lazy majority" voting process.
It is good to get more people involved in the design discussion and get
enough binding votes.
As for the scope of the FLIP, previous replies show a lot of good thoughts.
On the other h
Hi Jincheng,
Thanks a lot for the release which contains so many fixes!
I have done the following checks:
Local Tests
- Built from source archive successfully.
- Signatures and hash are correct.
- All artifacts have been deployed to the maven central repository.
- Run WordCount(batch&str
+1 (binding)
On Tue, Sep 8, 2020 at 7:43 AM jincheng sun
wrote:
> +1(binding)
>
> Best,
> Jincheng
>
>
> Shuiqiang Chen 于2020年9月7日周一 下午3:50写道：
>
> > +1 (non-binding)
> >
> > > 在 2020年9月7日，下午2:38，Wei Zhong 写道：
> > >
> > > +1 (non-binding)
> > >
> > >> 在 2020年9月7日，10:00，Dian Fu 写道：
> > >>
> >
+1 (binding)
Best,
Hequn
On Thu, Sep 10, 2020 at 10:03 AM Dian Fu wrote:
> +1(binding)
>
> Regards,
> Dian
>
> > 在 2020年9月8日，上午7:43，jincheng sun 写道：
> >
> > +1(binding)
> >
> > Best,
> > Jincheng
> >
> > Xingbo Huang 于2020年9月7日周一 下午5:45写道：
> >
> >> Hi,
> >>
> >> +1 (non-binding)
> >>
> >> Bes
Thanks a lot for managing the release!
+1 (binding)
- Go through all new commits for 1.10.1 and spot no new license problems.
- Built from source archive successfully.
- Signatures and hash are correct.
- Run SocketWindowWordCount on the local cluster.
- Install Python package and run Python Word
+1, thanks a lot for driving this.
Best, Hequn
On Tue, May 5, 2020 at 11:56 AM Dian Fu wrote:
> +1
>
> Regards,
> Dian
>
> > 在 2020年5月5日，上午9:58，Yangze Guo 写道：
> >
> > +1
> >
> > Best,
> > Yangze Guo
> >
> > On Tue, May 5, 2020 at 6:14 AM Thomas Weise wrote:
> >>
> >> +1
> >>
> >>
> >> On Mon,
+1 (binding)
- Go through all commits from 1.10.0 to 1.10.1 and spot no new license
problems.
- Built from source archive successfully.
- Travis e2e tests have passed.
- Signatures and hash are correct.
- Run SocketWindowWordCount on the local cluster and check web ui & logs.
- Install Python pack
+1
It would be nice to have these fixes!
Best,
Hequn
On Mon, May 25, 2020 at 5:00 PM Zhijiang
wrote:
> Thanks for driving this, Chesnay!
> +1 on my side.
>
> Best,
> Zhijiang
> --
> From:Till Rohrmann
> Send Time:2020年5月25日(星期一) 1
Sorry about my late check.
I found one blocker just now that the year in the root NOTICE file should
be updated. I have created a jira(FLINK-18031) for it.
Best,
Hequn
On Fri, May 29, 2020 at 12:47 AM Yu Li wrote:
> +1 (non-binding)
>
> Checked issues listed in release notes: ok (*)
> - Add sh
gt; such an important thing, so I wouldn't block the release on it.
>
> On 29/05/2020 09:11, Hequn Cheng wrote:
> > Sorry about my late check.
> > I found one blocker just now that the year in the root NOTICE file should
> > be updated. I have created a jira(FLINK-18031) for it
+1 (binding)
1. Go through all the commits from 11.0.
2. website PR looks good
3. Built from source archive successfully.
4. Signatures and hash are correct.
Best,
Hequn
On Fri, May 29, 2020 at 4:08 PM Chesnay Schepler wrote:
> +1 (binding)
>
> On 28/05/2020 18:49, Yu Li wrote:
> > +1 (non-bin
It seems the release tag is not correct? The version in the poms should
be 2.1.0 instead of 2.1-SNAPSHOT.
Best,
Hequn
On Thu, Jun 4, 2020 at 10:33 AM Congxian Qiu wrote:
> +1 (non-binding)
>
> maybe there is something that needs to be updated in README.md(currently
> the official docs link po
updated version.
>
> Gordon
>
> [1]
>
> https://gitbox.apache.org/repos/asf?p=flink-statefun.git;a=tag;h=c08c9850147d818fc8fed877a01ff87021f3cf21
> [2] https://github.com/apache/flink-statefun/tree/release-2.1.0-rc1
>
> On Thu, Jun 4, 2020 at 12:10 PM Hequn Cheng wrote:
>
Congratulations Xintong!
Best, Hequn
On Fri, Jun 5, 2020 at 2:03 PM Marta Paes Moreira
wrote:
> Congratulations, Tony! Great job!
>
> On Fri, Jun 5, 2020 at 8:00 AM Yang Wang wrote:
>
> > Congratulations, Xintong.
> > Well deserved.
> >
> > Best,
> > Yang
> >
> > Weihua Hu 于2020年6月5日周五 下午1:57
+1 for adding the Python DataStream API and starting with the stateless
part.
There are already some users that expressed their wish to have the Python
DataStream APIs. Once we have the APIs in PyFlink, we can cover more use
cases for our users.
Best, Hequn
On Wed, Jul 8, 2020 at 11:45 AM Shuiqia
+1 for a quick bug fix release and Dian as the release manager.
Best,
Hequn
On Thu, Jul 9, 2020 at 9:22 PM Dian Fu wrote:
> Hi Jark,
>
> Thanks for offering the help. It would definitely be helpful.
>
> Regards,
> Dian
>
> > 在 2020年7月9日，下午8:54，Benchao Li 写道：
> >
> > +1 for a quick bug fix rel
the proposal!
> > >
> > > Best,
> > > Jincheng
> > >
> > >
> > > Xingbo Huang 于2020年7月9日周四 上午10:41写道：
> > >
> > > > Hi Shuiqiang,
> > > >
> > > > Thanks a lot for driving this discussion.
> > > &
Thanks Dian for the great work and thanks to everyone who makes this
release possible!
Best, Hequn
On Wed, Jul 22, 2020 at 4:40 PM Jark Wu wrote:
> Congratulations! Thanks Dian for the great work and to be the release
> manager!
>
> Best,
> Jark
>
> On Wed, 22 Jul 2020 at 15:45, Yangze Guo wro
uot;print".
>
> I think we can now proceed to a vote! Nice work, overall!
>
> Best,
> Aljoscha
>
> On 16.07.20 17:16, Hequn Cheng wrote:
> > Hi,
> >
> > Thanks a lot for your discussions.
> > I think Aljoscha makes good suggestions here! Those
> >>
> >>> Hi Aljoscha, Thank you for your response. I'll keep these two helper
> >>> methods in the Python DataStream implementation.
> >>>
> >>> And thank you all for joining in the discussion. It seems that we have
> >>&g
+1 (binding)
Best,
Hequn
On Tue, Jul 28, 2020 at 2:58 PM Aljoscha Krettek
wrote:
> +1 (binding)
>
> Aljoscha
>
> On 28.07.20 04:12, Dian Fu wrote:
> > Thanks for driving this Shuiqiang.
> >
> > +1
> >
> > Regards,
> > Dian
> >
> >> 在 2020年7月27日，下午3:33，jincheng sun 写道：
> >>
> >> +1(binding)
> >
Hi Jincheng,
Thanks a lot for raising the discussion. +1 for the FLIP.
I think this will bring big benefits for the PyFlink users. Currently, the
Python TableAPI document is hidden deeply under the TableAPI&SQL tab which
makes it quite unreadable. Also, the PyFlink documentation is mixed with
Jav
+1 (binding)
Best,
Hequn
On Wed, Aug 12, 2020 at 10:12 AM Wei Zhong wrote:
> +1 (non-binding)
>
> Best,
> Wei
>
> > 在 2020年8月11日，22:41，Seth Wiesman 写道：
> >
> > +1 (binding)
> >
> > On Sun, Aug 9, 2020 at 8:15 PM jincheng sun
> > wrote:
> >
> >> Hi Seth,
> >>
> >> Thank you for joining the di
hi Ghassan,
TableSource in Flink doesn't support primary key now, but you can achieve
it by doing a group by manually.
Such as:
val resultTable = tableEnv.sql(
"
SELECT ProductID, AVG(Rating) FROM
( SELECT ReviewID, LAST_VALUE(ProductID),
LAST_VALUE(Approved) , L
Hi, udtf variables should not be empty, otherwise calcite failed to convert
the join to an correlate.
Best, Hequn
2018-02-23 0:34 GMT+08:00 叶振宝 <827295...@qq.com>:
> Hey, I am new to flink and I have a question and want to see if anyone can
> help here.
>
> How to use Dimension table in Flink Ta
Hequn Cheng created FLINK-13057:
---
Summary: Correct comments in ListState class
Key: FLINK-13057
URL: https://issues.apache.org/jira/browse/FLINK-13057
Project: Flink
Issue Type: Bug
Hequn Cheng created FLINK-13087:
---
Summary: Add group window Aggregate operator to Table API
Key: FLINK-13087
URL: https://issues.apache.org/jira/browse/FLINK-13087
Project: Flink
Issue Type
Hequn Cheng created FLINK-13196:
---
Summary: Fix Ambiguous column name exception bug for Table API
Key: FLINK-13196
URL: https://issues.apache.org/jira/browse/FLINK-13196
Project: Flink
Issue
Hequn Cheng created FLINK-13392:
---
Summary: WindowAggregate inherited from Aggregate incorrectly
Key: FLINK-13392
URL: https://issues.apache.org/jira/browse/FLINK-13392
Project: Flink
Issue
Hequn Cheng created FLINK-13446:
---
Summary: Row count sliding window outputs incorrectly in blink
planner
Key: FLINK-13446
URL: https://issues.apache.org/jira/browse/FLINK-13446
Project: Flink
Hequn Cheng created FLINK-13637:
---
Summary: Anchors not working in document(building.md, common.md,
queryable_state.md)
Key: FLINK-13637
URL: https://issues.apache.org/jira/browse/FLINK-13637
Project
Hequn Cheng created FLINK-16119:
---
Summary: Port base RelNode classes from Scala to Java
Key: FLINK-16119
URL: https://issues.apache.org/jira/browse/FLINK-16119
Project: Flink
Issue Type
Hequn Cheng created FLINK-16187:
---
Summary: Support Python ML Pipeline API
Key: FLINK-16187
URL: https://issues.apache.org/jira/browse/FLINK-16187
Project: Flink
Issue Type: New Feature
Hequn Cheng created FLINK-16241:
---
Summary: Remove the license and notice file in flink-ml-lib module
on release-1.10 branch
Key: FLINK-16241
URL: https://issues.apache.org/jira/browse/FLINK-16241
Hequn Cheng created FLINK-16248:
---
Summary: Add interfaces for MLEnvironment and MLEnvironmentFactory
Key: FLINK-16248
URL: https://issues.apache.org/jira/browse/FLINK-16248
Project: Flink
Hequn Cheng created FLINK-16249:
---
Summary: Add interfaces for Params, ParamInfo and WithParams
Key: FLINK-16249
URL: https://issues.apache.org/jira/browse/FLINK-16249
Project: Flink
Issue Type
Hequn Cheng created FLINK-16250:
---
Summary: Add interfaces for PipelineStage and Pipeline
Key: FLINK-16250
URL: https://issues.apache.org/jira/browse/FLINK-16250
Project: Flink
Issue Type: Sub
Hequn Cheng created FLINK-16273:
---
Summary: Solve "sun.misc.Unseafe or
java.nio.DirectByteBuffer.(long, int) not available" problem for users
Key: FLINK-16273
URL: https://issues.apache.org/jira/browse/F
Hequn Cheng created FLINK-16565:
---
Summary: Make Pipeline Json compitable between Java and Python if
all Pipelinestage are Java ones
Key: FLINK-16565
URL: https://issues.apache.org/jira/browse/FLINK-16565
Hequn Cheng created FLINK-16670:
---
Summary: Support User-Defined Metrics in Python UDF
Key: FLINK-16670
URL: https://issues.apache.org/jira/browse/FLINK-16670
Project: Flink
Issue Type: New
Hequn Cheng created FLINK-16671:
---
Summary: Support define scopes and variables on Python metric group
Key: FLINK-16671
URL: https://issues.apache.org/jira/browse/FLINK-16671
Project: Flink
Hequn Cheng created FLINK-16672:
---
Summary: Support Counter, Gauge, Meter, Distribution metric type
for Python UDF
Key: FLINK-16672
URL: https://issues.apache.org/jira/browse/FLINK-16672
Project: Flink
Hequn Cheng created FLINK-16673:
---
Summary: Support Counter, Gauge, Meter, Distribution metric type
for Python UDTF
Key: FLINK-16673
URL: https://issues.apache.org/jira/browse/FLINK-16673
Project: Flink
Hequn Cheng created FLINK-16674:
---
Summary: Add documentation about how to use user-defined metrics
for Python UDF
Key: FLINK-16674
URL: https://issues.apache.org/jira/browse/FLINK-16674
Project: Flink
Hequn Cheng created FLINK-16761:
---
Summary: Return JobExecutionResult for Python ExecutionEnvironment
and TableEnvironment
Key: FLINK-16761
URL: https://issues.apache.org/jira/browse/FLINK-16761
Project
Hequn Cheng created FLINK-16763:
---
Summary: Should not use BatchTableEnvironment for Python UDF in
the document of flink-1.10
Key: FLINK-16763
URL: https://issues.apache.org/jira/browse/FLINK-16763
Hequn Cheng created FLINK-16765:
---
Summary: Replace all BatchTableEnvironment to
StreamTableEnvironment in the document of PyFlink
Key: FLINK-16765
URL: https://issues.apache.org/jira/browse/FLINK-16765
Hequn Cheng created FLINK-16766:
---
Summary: Support create StreamTableEnvironment without passing
StreamExecutionEnvironment
Key: FLINK-16766
URL: https://issues.apache.org/jira/browse/FLINK-16766
Hequn Cheng created FLINK-16786:
---
Summary: Fix pyarrow version incompatible problem
Key: FLINK-16786
URL: https://issues.apache.org/jira/browse/FLINK-16786
Project: Flink
Issue Type: Bug
Hequn Cheng created FLINK-16853:
---
Summary: Update the version of protobuf-java from 3.8.0 to 3.7.1
in the NOTICE file of module statefun-flink-distribution
Key: FLINK-16853
URL: https://issues.apache.org/jira
Hequn Cheng created FLINK-16854:
---
Summary: Correct dependency versions in the NOTICE file of module
statefun-ridesharing-example-simulator
Key: FLINK-16854
URL: https://issues.apache.org/jira/browse/FLINK-16854
Hequn Cheng created FLINK-17215:
---
Summary: Clean the build document for Pyflink
Key: FLINK-17215
URL: https://issues.apache.org/jira/browse/FLINK-17215
Project: Flink
Issue Type: Improvement
Hequn Cheng created FLINK-17318:
---
Summary: The comment is not right in
`org.apache.flink.table.planner.delegation.PlannerBase`
Key: FLINK-17318
URL: https://issues.apache.org/jira/browse/FLINK-17318
Hequn Cheng created FLINK-14383:
---
Summary: Support python UDFs with constant value of time interval
types
Key: FLINK-14383
URL: https://issues.apache.org/jira/browse/FLINK-14383
Project: Flink
Hequn Cheng created FLINK-14385:
---
Summary: There are ClassNotFoundException when run the example in
Local Setup Tutorial
Key: FLINK-14385
URL: https://issues.apache.org/jira/browse/FLINK-14385
Project
Hequn Cheng created FLINK-14459:
---
Summary: Python module build hangs
Key: FLINK-14459
URL: https://issues.apache.org/jira/browse/FLINK-14459
Project: Flink
Issue Type: Bug
Components
Hequn Cheng created FLINK-14497:
---
Summary: Support primitive data types in Python user-defined
functions
Key: FLINK-14497
URL: https://issues.apache.org/jira/browse/FLINK-14497
Project: Flink
Hequn Cheng created FLINK-14684:
---
Summary: Add Pinterest to Chinese Powered By page
Key: FLINK-14684
URL: https://issues.apache.org/jira/browse/FLINK-14684
Project: Flink
Issue Type: New
Hequn Cheng created FLINK-15616:
---
Summary: Move boot error messages from python-udf-boot.log to
taskmanager's log file
Key: FLINK-15616
URL: https://issues.apache.org/jira/browse/FLINK-15616
Pr
Hequn Cheng created FLINK-15636:
---
Summary: Support Python UDF for flink planner under batch mode
Key: FLINK-15636
URL: https://issues.apache.org/jira/browse/FLINK-15636
Project: Flink
Issue
Hequn Cheng created FLINK-15675:
---
Summary: Add documentation that Python UDF is not supported for
Flink Planner under batch mode
Key: FLINK-15675
URL: https://issues.apache.org/jira/browse/FLINK-15675
Hequn Cheng created FLINK-15847:
---
Summary: Include flink-ml-api and flink-ml-lib in opt
Key: FLINK-15847
URL: https://issues.apache.org/jira/browse/FLINK-15847
Project: Flink
Issue Type
Hequn Cheng created FLINK-9559:
--
Summary: The type of a union of CHAR columns of different lengths
should be VARCHAR
Key: FLINK-9559
URL: https://issues.apache.org/jira/browse/FLINK-9559
Project: Flink
Hequn Cheng created FLINK-9681:
--
Summary: Make sure minRetentionTime not equal to maxRetentionTime
Key: FLINK-9681
URL: https://issues.apache.org/jira/browse/FLINK-9681
Project: Flink
Issue
Hequn Cheng created FLINK-9850:
--
Summary: Add a string to the print method to identify output for
DataStream
Key: FLINK-9850
URL: https://issues.apache.org/jira/browse/FLINK-9850
Project: Flink
Hequn Cheng created FLINK-9868:
--
Summary: Expose channel id to ProcessFunction
Key: FLINK-9868
URL: https://issues.apache.org/jira/browse/FLINK-9868
Project: Flink
Issue Type: New Feature
201 - 300 of 394 matches
Mail list logo
