Re: How to specify dependencies for an application that needs to use modified version of Flink

, reimport your app project. - Jark Wu > 在 2016年5月12日，上午2:33，Saiph Kappa 写道： > > Hi, > > I'm performing some modifications on Flink (current trunk version). I want > a scala app (sbt based) to use that modified version. I'm only modifying > the flink-streaming-j

Re: How to specify dependencies for an application that needs to use modified version of Flink

Sorry for mistyped the command. You can enter into flink/flink-streaming-java and run `mvn clean package install -DskipTests=true` . It will install only flink-streaming-java module. > 在 2016年5月12日，上午10:02，Jark 写道： > > Hi Saiph, >You can enter flink directory and run `mvn c

Re: [DISCUSS] API breaking change in DataStream Windows

As an user, I don’t like “casting option”. Because people who need set parallelism after CoGroup will certainly fall into this issue. They will subconsciously think Flink does not support this feature. We can’t assume most users will read JavaDocs and document carefully. Maybe we can post this

Re: Add MapState for keyed streams

That makes sense! Maybe we can make MapState implement Iterable interface. > 在 2016年10月19日，下午5:48，SHI Xiaogang 写道： > > Hi Jark > > If the state is very big, it may occupy a lot of memory if we return > Set>. > > By wrapping the returned iterator, we can easily imp

Re: [ANNOUNCE] New Flink committer Jincheng Sun

Welcome on board and congratulations Jincheng! > 在 2017年7月11日，上午12:15，Matthias J. Sax 写道： > > -BEGIN PGP SIGNED MESSAGE- > Hash: SHA512 > > Congrats! > > On 7/10/17 6:42 AM, Ted Yu wrote: >> Congratulations, Jincheng. >> >> On Mon, Jul 10, 2017 at 6:17 AM, Fabian Hueske >> wrote: >>

Re: [ANNOUNCE] New Flink PMC member: Tzu-Li (Gordon) Tai

Congrats Gordon! > 在 2017年7月11日，上午9:37，Zhuoluo Yang 写道： > > Congrats. > > Thanks, > > Zhuoluo 😀 > > > > > >> 在 2017年7月11日，上午3:34，Henry Saputra > > 写道： >> >> Welcome and congrats! >> >> On Mon, Jul 10, 2017 at 9:24 AM Fabian Hueske >

Re: [ANNOUNCE] Apache Flink 1.8.1 released

Thanks for being the release manager and the great job! Cheers, Jark On Wed, 3 Jul 2019 at 10:16, Dian Fu wrote: > Awesome! Thanks a lot for being the release manager. Great job! @Jincheng > > Regards, > Dian > > 在 2019年7月3日，上午10:08，jincheng sun 写道： > > I've

Re: [DISCUSS]Support Upsert mode for Streaming Non-window FlatAggregate

keys which may result in a wrong result. So I think it would be better to couple key information with UDTAGG interface (i.e. "Approach 3" in your design doc). Regards, Jark On Thu, 4 Jul 2019 at 18:06, Kurt Young wrote: > Hi Jincheng, > > Thanks for the clarification. I think

Re: Flink 1.9 blink planner

ly, we can finish this at the end of this week. Best, Jark On Thu, 4 Jul 2019 at 19:20, kaka chen wrote: > Hi All: > > We found TableEnvironment in Flink 1.9 blink planner didn't support > functions such as sqlUpdate() and registerTableSink(), when I used Scala > api, it will t

Re: [VOTE] Migrate to sponsored Travis account

+1 for the migration and great thanks to Chesnay and Bowen for pushing this! Cheers, Jark On Fri, 5 Jul 2019 at 09:34, Congxian Qiu wrote: > +1 for the migration. > > Best, > Congxian > > > Hequn Cheng 于2019年7月4日周四 下午9:42写道： > > > +1. > > > > An

Re: [DISCUSS]Support Upsert mode for Streaming Non-window FlatAggregate

ate function should return two sets of unique key, one is "rankid", another is "rankid, time". This will be more align with current TopN node in blink planner and let optimizer to decide which key based on the downstream information (column selection, sink's primary key). Be

Re: [DISCUSS]Support Upsert mode for Streaming Non-window FlatAggregate

Thanks Jincheng, I think approach 3 there is no ambiguity in the semantics and can better explain a deterministic result, although it is not so easy to use. So I'm +1 to approach 3. Best, Jark On Fri, 5 Jul 2019 at 18:13, jincheng sun wrote: > Hi, > > @Kurt @Jark thanks

Re: [ANNOUNCE] Rong Rong becomes a Flink committer

Congratulations Rong Rong! Welcome on board! On Thu, 11 Jul 2019 at 22:25, Fabian Hueske wrote: > Hi everyone, > > I'm very happy to announce that Rong Rong accepted the offer of the Flink > PMC to become a committer of the Flink project. > > Rong has been contributing to Flink for many years, m

Re: blink planner issue

FLINK-13290) to track this problem. Best, Jark On Tue, 16 Jul 2019 at 17:35, kaka chen wrote: > I am looking this issue, the related codes which throw errors are: > > SinkCodeGenerator:: validateFieldType() > > ... > > // Tuple/Case class/Row type

Re: blink planner issue

LINK-12848). Best, Jark On Tue, 16 Jul 2019 at 23:38, kaka chen wrote: > Hi Caizhi and Jark, > > I think you are correct, from the quick view for source code, it should > only compares field types in the equals method. > Currently some composite logical row type has compared name a

Re: Flink "allow lateness" for tables

ate records, but the window output delay will get larger. Best, Jark On Wed, 17 Jul 2019 at 17:39, Ramya Ramamurthy wrote: > Hi, > > I would like to know if there is some configuration which enabled to > configure allow lateness in table. The documentation mentions about streams &g

Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project

Congratulations Becket! Well deserved. Cheers, Jark On Thu, 18 Jul 2019 at 15:56, Paul Lam wrote: > Congrats Becket! > > Best, > Paul Lam > > > 在 2019年7月18日，15:41，Robert Metzger 写道： > > > > Hi all, > > > > I'm excited to announce that Jiang

Re: 请问这些名词，在翻译 Glossary 时，有必要翻译成中文吗？

Hi highfei, Thanks for bringing up this discussion. I would suggest to move the discussion to the Glossary translation JIRA FLINK-13037 <https://issues.apache.org/jira/browse/FLINK-13037>. Thanks, Jark On Fri, 19 Jul 2019 at 09:00, Zili Chen wrote: > Hi, > > 欢迎有 PR

Re: 请问这些名词，在翻译 Glossary 时，有必要翻译成中文吗？

Hi, Just find the Glossary translation PR is created [1]. Let's move the discussion there. [1]. https://github.com/apache/flink/pull/9173 On Fri, 19 Jul 2019 at 11:22, Jark Wu wrote: > Hi highfei, > > Thanks for bringing up this discussion. I would suggest to move the >

Re: [DISCUSS] A more restrictive JIRA workflow

A quick question, what should we do if a developer creates a JIRA issue and then create a pull request at once without assigning? Regards, Jark On Thu, 18 Jul 2019 at 18:50, Zili Chen wrote: > Checking the result, as a discovery, I found that one can > still file a JIRA with &q

Re: flink-mapr-fs failed in travis

It seems that it is introduced by this commit: https://github.com/apache/flink/commit/5c36c650e6520d92191ce2da33f7dcae774319f6 Hi @Chesnay Schepler , do we need to add "-Punsafe-mapr-repo" to the ".travis.yml"? Best, Jark On Fri, 19 Jul 2019 at 10:58, JingsongLee w

Re: flink-mapr-fs failed in travis

anv_watchdog.sh . > > > > On 19/07/2019 09:58, Chesnay Schepler wrote: > >> I did modify the .travis.yml do activate the unsafe-mapr-repo > >> profile; did I modified the wrong profile?... > >> > >> > >> On 19/07/2019 07:57, Jark Wu wrote: > &g

[DISCUSS] Setup a bui...@flink.apache.org mailing list for travis builds

g list too[1]. After we have such a mailing list, we can integrate it to travis according to the travis doc[2]. What do you think? Do we need a formal vote for this? Best and thanks, Jark [1]: https://beam.apache.org/community/contact-us/ [2]: https://docs.travis-ci.com/user/notifications/#c

Re: Re: [ANNOUNCE] Zhijiang Wang has been added as a committer to the Flink project

Congratulations Zhijiang! On Tue, 23 Jul 2019 at 11:30, vino yang wrote: > Congratulations Zhijiang! > > Haibo Sun 于2019年7月23日周二 上午10:48写道： > > > Congrats, Zhejiang! > > > > > > Best, > > Haibo > > 在 2019-07-23 10:26:20，"Yun Tang" 写道： > > >Congratulations Zhijiang, well deserved. > > > > > >B

Re: [ANNOUNCE] Kete Young is now part of the Flink PMC

Congratulations Kurt! Well deserved. Cheers, Jark On Tue, 23 Jul 2019 at 17:43, LakeShen wrote: > Congratulations Kurt! > > Congxian Qiu 于2019年7月23日周二 下午5:37写道： > > > Congratulations Kurt! > > Best, > > Congxian > > > > > > Dian Fu

Re: [DISCUSS] Setup a bui...@flink.apache.org mailing list for travis builds

Thank you all for your positive feedback. We have three binding +1s, so I think, we can proceed with this. Hi @Robert Metzger , could you create a request to INFRA for the mailing list? I'm not sure if this needs a PMC permission. Thanks, Jark On Tue, 23 Jul 2019 at 16:42, jincheng sun

Re: [DISCUSS] Setup a bui...@flink.apache.org mailing list for travis builds

Thanks Robert for helping out that. Best, Jark On Wed, 24 Jul 2019 at 19:16, Robert Metzger wrote: > I've requested the creation of the list, and made Jark, Chesnay and me > moderators of it. > > On Wed, Jul 24, 2019 at 1:12 PM Robert Metzger > wrote: > > > @

Re: [DISCUSS] Support computed column for Flink SQL

hts in the doc. Best, Jark [1]: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-Ground-Source-and-Sink-Concepts-in-Flink-SQL-tt29126.html On Mon, 29 Jul 2019 at 16:52, Timo Walther wrote: > Hi Danny, > > thanks for working on this issue and writing down the conce

Re: [DISCUSS] Setup a bui...@flink.apache.org mailing list for travis builds

have some progress. Thanks, Jark [1]: https://github.com/apache/flink/pull/9230 On Thu, 25 Jul 2019 at 22:59, Robert Metzger wrote: > The mailing list has been created, you can now subscribe to it. > > On Wed, Jul 24, 2019 at 1:43 PM Jark Wu wrote: > > > Thanks Robert for hel

Re: NoSuchMethodError: org.apache.calcite.tools.FrameworkConfig.getTraitDefs()

Hi Lakeshen, Thanks for trying out blink planner. First question, are you using blink-1.5.1 or flink-1.9-table-planner-blink ? We suggest to use the latter one because we don't maintain blink-1.5.1, you can try flink 1.9 instead. Best, Jark On Tue, 30 Jul 2019 at 17:02, LakeShen wrote:

Re: [VOTE] Publish the PyFlink into PyPI

+1 (non-binding) Cheers, Jark On Thu, 1 Aug 2019 at 17:45, Yu Li wrote: > +1 (non-binding) > > Thanks for driving this! > > Best Regards, > Yu > > > On Thu, 1 Aug 2019 at 11:41, Till Rohrmann wrote: > > > +1 > > > > Cheers, > > Till &g

Re: [RESULT][VOTE] Migrate to sponsored Travis account

Hi Chesnay, Can we assign Flink Committers the permission of flink-ci/flink repo? Several times, when I pushed some new commits, the old build jobs are still in pending and not canceled. Before we fix that, we can manually cancel some old jobs to save build resource. Best, Jark On Wed, 10 Jul

Re: [DISCUSS] CPU flame graph for a job vertex in web UI.

Hi David, The demo looks charming! I think it will definitely help a lot when performance tuning. A big +1 for this. I cc-ed Yadong who's one of the main contributors of the new Web UI. Maybe he can give some help on the front end. Regards, Jark On Fri, 2 Aug 2019 at 04:26, David Mo

Re: [DISCUSS][CODE STYLE] Usage of Java Optional

ptional, because Optional is not serializable. Do we allow Optional as class field only if the class is not serializable or forbid this totally? Thanks, Jark On Fri, 2 Aug 2019 at 16:30, Biao Liu wrote: > Hi Andrey, > > Thanks for working on this. > > +1 it's clear and a

Re: [DISCUSS][CODE STYLE] Usage of Java Optional

Hi Zili, Yes. I agree to use @Nullable/@Nonnull/SerializableOptional as the class field instead of Optional. On Fri, 2 Aug 2019 at 17:00, Zili Chen wrote: > Hi Jark, > > Follow your opinion, for class field, we can make > use of @Nullable/@Nonnull annotation or Flink's >

Re: [RESULT][VOTE] Migrate to sponsored Travis account

Wow. That's great! Thanks Chesnay. On Fri, 2 Aug 2019 at 17:50, Chesnay Schepler wrote: > I'm currently modifying the cibot to do this automatically; should be > finished until Monday. > > On 02/08/2019 07:41, Jark Wu wrote: > > Hi Chesnay, > > > > Can w

Re: [ANNOUNCE] Hequn becomes a Flink committer

Congratulations Hequn! It's great to have you in the community! On Wed, 7 Aug 2019 at 21:00, Fabian Hueske wrote: > Congratulations Hequn! > > Am Mi., 7. Aug. 2019 um 14:50 Uhr schrieb Robert Metzger < > rmetz...@apache.org>: > >> Congratulations! >> >> On Wed, Aug 7, 2019 at 1:09 PM highfei2.

Re: [DISCUSS] Repository split

s enough to the potential development slow down we might meet. Regards, Jark [1]: https://github.com/apache/bahir-flink/graphs/commit-activity On Fri, 9 Aug 2019 at 00:26, Till Rohrmann wrote: > I pretty much agree with your points Dav/wid. Some problems which we want > to solve with a re

Re: Flink cannot recognized catalog set by registerCatalog.

e or default in-memory one? I think, it would be better to improve the description and add a NOTE on it. Regards, Jark On Tue, 13 Aug 2019 at 10:52, Xuefu Z wrote: > Yes, tableEnv.registerTable(_) etc always registers in the default catalog. > To create table in your custom c

Re: [VOTE] Apache Flink Release 1.9.0, release candidate #2

cause timestamp/date/time are primitive types, and this will break the DDL feature. However, I want to hear more thoughts from the community whether we should recognize it as a blocker. Thanks, Jark [1]: https://issues.apache.org/jira/browse/FLINK-13699 On Mon, 12 Aug 2019 at 22:46, Becket Qin

Re: Flink cannot recognized catalog set by registerCatalog.

Hi Simon, This is a temporary workaround for 1.9 release. We will fix the behavior in 1.10, see FLINK-13461. Regards, Jark On Tue, 13 Aug 2019 at 13:57, Simon Su wrote: > Hi Jark > > Thanks for your reply. > > It’s weird that In this case the tableEnv provide the api called >

Re: [VOTE] Apache Flink Release 1.9.0, release candidate #2

Hi Till, After thinking about we can use VARCHAR as an alternative of timestamp/time/date. I'm fine with not recognize it as a blocker issue. We can fix it into 1.9.1. Thanks, Jark On Tue, 13 Aug 2019 at 15:10, Richard Deurwaarder wrote: > Hello all, > > I noticed the PubSub

Re: [VOTE] Flink Project Bylaws

+1 (non-binding) Best, Jark On Wed, 14 Aug 2019 at 09:22, Kurt Young wrote: > +1 (binding) > > Best, > Kurt > > > On Wed, Aug 14, 2019 at 1:34 AM Yun Tang wrote: > > > +1 (non-binding) > > > > But I have a minor question about "code chang

Re: [VOTE] Apache Flink Release 1.9.0, release candidate #2

better to make these > examples available differently, maybe through Flink's ecosystem website or > maybe a new examples section in Flink's documentation. > > Cheers, > Till > > On Tue, Aug 13, 2019 at 9:43 AM Jark Wu wrote: > > > Hi Till, > > > > A

Re: Unbearably slow Table API time-windowed stream join with RocksDBStateBackend

with poor performance of RocksDBListState. And the relative discussions have been raised several times [1][2]. The root cause is RocsDBStatBackend serialize the whole list as a byte[]. And there were some ideas proposed in the thread. I cc'ed Yu Li who works on statebackend. Thanks, Jark

Re: [ANNOUNCE] Andrey Zagrebin becomes a Flink committer

Congratulations Andrey! Cheers, Jark On Thu, 15 Aug 2019 at 00:57, jincheng sun wrote: > Congrats Andrey! Very happy to have you onboard :) > > Best, Jincheng > > Yu Li 于2019年8月15日周四 上午12:06写道： > > > Congratulations Andrey! Well deserved! > > > > Best Re

Re: [DISCUSS] FLIP-51: Rework of the Expression Design

Best, Jark On Wed, 14 Aug 2019 at 23:34, Timo Walther wrote: > Hi Jingsong, > > thanks for writing down this FLIP. Big +1 from my side to finally get > rid of PlannerExpressions and have consistent and well-defined behavior > for Table API and SQL updated to FLIP-37. > >

Re: flink 1.9 DDL nested json derived

= 'json', 'format.derive-schema' = 'true' ); The kafka message is {"rowtime": "2018-03-12T08:00:00Z", "user_name": "Alice", "event": { "message_type": "WARNING", "message": "

Re: [VOTE] Apache Flink Release 1.9.0, release candidate #2

or in previous versions. Best, Jark On Fri, 16 Aug 2019 at 06:52, Bowen Li wrote: > -1 for RC2. > > I found a bug https://issues.apache.org/jira/browse/FLINK-13741, and I > think it's a blocker. The bug means currently if users call > `tEnv.listUserDefinedFunctions()` in Tab

Re: [DISCUSS] Reducing build times

lding the whole project. Or enable CRON jobs for the pushed branch in contributor's own travis. Besides that, I think FLINK-11464[1] is also a good way to cache distributions to save a lot of download time. Best, Jark [1]: https://issues.apache.org/jira/browse/FLINK-11464 On Thu, 15 Aug 20

Re: [VOTE] FLIP-51: Rework of the Expression Design

+1 from my side. Thanks Jingsong for driving this. Best, Jark On Thu, 15 Aug 2019 at 22:09, Timo Walther wrote: > +1 for this. > > Thanks, > Timo > > Am 15.08.19 um 15:57 schrieb JingsongLee: > > Hi Flink devs, > > > > I would like to start the voting

Re: [DISCUSS] FLIP-54: Evolve ConfigOption and Configuration

thoughts and comments there. Cheers, Jark On Fri, 16 Aug 2019 at 22:30, Zili Chen wrote: > Hi Timo, > > It looks interesting. Thanks for preparing this FLIP! > > Client API enhancement benefit from this evolution which > hopefully provides a better view of configuration of Flin

Re: [VOTE] Apache Flink Release 1.9.0, release candidate #2

some tests around sql and blink planner if the RC3 include this fix. But if the community against to include it, I'm also fine with having it in the next minor release. Thanks, Jark On Mon, 19 Aug 2019 at 16:16, Stephan Ewen wrote: > +1 for Gordon's approach. > > If we do th

Re: [VOTE] Apache Flink 1.9.0, release candidate #3

sink. looks good too. No error in the logs. Cheers, Jark On Wed, 21 Aug 2019 at 04:20, Stephan Ewen wrote: > +1 (binding) > > - Downloaded the binary release tarball > - started a standalone cluster with four nodes > - ran some examples through the Web UI > - checked the l

Re: CiBot Update

Great work! Thanks Chesnay! On Thu, 22 Aug 2019 at 15:42, Xintong Song wrote: > The re-triggering travis feature is so convenient. Thanks Chesnay~! > > Thank you~ > > Xintong Song > > > > On Thu, Aug 22, 2019 at 9:26 AM Stephan Ewen wrote: > > > Nice, thanks! > > > > On Thu, Aug 22, 2019 at 3

Re: [ANNOUNCE] Apache Flink 1.9.0 released

Congratulations! Thanks Gordon and Kurt for being the release manager and thanks a lot to all the contributors. Cheers, Jark On Thu, 22 Aug 2019 at 20:06, Oytun Tez wrote: > Congratulations team; thanks for the update, Gordon. > > --- > Oytun Tez > > *M O T A W O R D* >

Re: [DISCUSS] Use Java's Duration instead of Flink's Time

+1 to use Java's Duration instead of Flink's Time. Regarding to the Duration parsing, we have mentioned this in FLIP-54[1] to use `org.apache.flink.util.TimeUtils` for the parsing. Best, Jark [1]: https://docs.google.com/document/d/1IQ7nwXqmhCy900t2vQLEL3N2HIdMg-JO8vTzo1BtyKU/ed

Re: [DISCUSS] Setup a bui...@flink.apache.org mailing list for travis builds

atting when Travis send Email to builds ML. - The return-path of emails from Travis CI is not constant, which makes it difficult for mailing list to accept it. Cheers, Jark [1]: https://flink.apache.org/community.html#mailing-lists [2]: https://github.com/wuchong/flink-notification-bot [3]: h

Re: [CODE-STYLE] Builder pattern

ost cases, we want users to set the fields eagerly (through the builder) and `setXXX` methods on the main class is duplicate with the methods on the builder. We should avoid that. Regards, Jark On Mon, 26 Aug 2019 at 20:18, Gyula Fóra wrote: > Hi All! > > I would like to start a co

Re: [DISCUSS] Enhance Support for Multicast Communication Pattern

this feature, we might need to: 1) expose collectEvent(CustomEvent) or broadcastEvent(CustomEvent) API to users. 2) support to register the serialization and deserialization of the custom event 3) expose processEvent(int channel, CustomEvent) API to StreamOperator Regards, Jark On Tue, 27 Aug 2

Re: [VOTE] FLIP-54: Evolve ConfigOption and Configuration

+1 to the FLIP. Regards, Jark > 在 2019年8月27日，19:28，Timo Walther 写道： > > Hi everyone, > > thanks for the great feedback we have received for the draft of FLIP-54. The > discussion seems to have reached an agreement. Of course this doesn't mean > that we can't

Re: [VOTE] FLIP-54: Evolve ConfigOption and Configuration

Hi Timo, The new changes looks good to me. +1 to the FLIP. Cheers, Jark On Wed, 28 Aug 2019 at 16:02, Timo Walther wrote: > Hi everyone, > > after some last minute changes yesterday, I would like to start a new > vote on FLIP-54. The discussion seems to have reached an a

Re: [DISCUSS] Setup a bui...@flink.apache.org mailing list for travis builds

Thank you for the suggestion Kurt. I just updated the notification. Best, Jark On Thu, 29 Aug 2019 at 13:56, Kurt Young wrote: > one suggestion: we could also filter all notifications about *Cancelled* > builds. > > Best, > Kurt > > > On Tue, Aug 27, 2019 at 10:53

Re: [VOTE] FLIP-58: Flink Python User-Defined Function for Table API

+1 Thanks for the great work! On Fri, 30 Aug 2019 at 10:04, Xingbo Huang wrote: > Hi Dian, > > +1, > Thanks a lot for driving this. > > Best, > Xingbo > > 在 2019年8月30日，上午9:39，Wei Zhong 写道： > > > > Hi Dian, > > > > +1 non-binding > > Thanks for driving this! > > > > Best, Wei > > > >> 在 2019年8月

Re: [DISCUSS] Releasing Flink 1.8.2

k with you together @Jincheng？ Best, Jark On Fri, 30 Aug 2019 at 18:58, Hequn Cheng wrote: > Hi Jincheng, > > +1 for a 1.8.2 release. > Thanks a lot for raising the discussion. It would be nice to have these > critical fixes. > > Best, Hequn > > > On Fri, Aug 30, 2

Re: [DISCUSS] Releasing Flink 1.8.2

l for the fixing and reviewing. The issues of this release can be tracked here: https://issues.apache.org/jira/projects/FLINK/versions/12345670 Best, Jark On Mon, 2 Sep 2019 at 09:19, Thomas Weise wrote: > +1 for the 1.8.2 release > > I marked https://issues.apache.org/jira/browse/F

Re: [DISCUSS] FLIP-60: Restructure the Table API & SQL documentation

rmance Tuning" chapter. 3) How about restructure SQL chapter a bit like this? SQL - Overview - Data Manipulation Statements (all operations available in SQL) - Data Definition Statements (DDL syntaxes) - Pattern Matching It renames "Full Reference" to "Data Mani

Re: Flink SQL - Support Computed Columns in DDL?

Hi Qi, The computed column is not fully supported in 1.9. We will start a design discussion in the dev mailing list soon. Please stay tuned! Btw, could you share with us what's the case why do you want to use computed column? Best, Jark On Tue, 3 Sep 2019 at 19:25, Danny Chan wrote: &

Re: [DISCUSS] Releasing Flink 1.8.2

Thanks Kostas for the quick fixing. However, I find that FLINK-13940 still target to 1.8.2 as a blocker. If I understand correctly, FLINK-13940 is aiming for a nicer and better solution in the future. So should we update the fixVersion of FLINK-13940? Best, Jark On Tue, 3 Sep 2019 at 21:33

Re: [DISCUSS] Releasing Flink 1.8.2

before that to account for it for the 1.8.2 release. Before cutting the RC1, I think it has chance to merge the ClosureCleaner.clean fix (FLINK-13586), because the review and travis are both passed. Cheers, Jark On Wed, 4 Sep 2019 at 00:45, Kostas Kloudas wrote: > Yes, I will do that J

Re: [DISCUSS] Releasing Flink 1.8.2

Thanks for the work Jincheng! I have moved remaining major issues to 1.8.3 except FLINK-13586. Hi @Aljoscha Krettek , is that possible to merge FLINK-13586 today? Best, Jark On Wed, 4 Sep 2019 at 10:47, jincheng sun wrote: > Thanks for the udpate Jark! > > I have add the new vers

Re: [DISCUSS] FLIP-57 - Rework FunctionCatalog

as Timo suggested above. This gives us the flexibility to add Hive or MySQL or Geo or whatever function set as built-in functions in an easy way. Best, Jark On Wed, 4 Sep 2019 at 17:47, Xuefu Z wrote: > Hi David, > > Thank you for sharing your findings. It seems to me that there is no

Re: [VOTE] FLIP-62: Set default restart delay for FixedDelay- and FailureRateRestartStrategy to 1s

+1 Best, Jark > 在 2019年9月4日，19:43，David Morávek 写道： > > +1 > > On Wed, Sep 4, 2019 at 1:38 PM Till Rohrmann wrote: > >> +1 (binding) >> >> On Wed, Sep 4, 2019 at 12:43 PM Chesnay Schepler >> wrote: >> >>> +1 (binding) >>>

Re: [DISCUSS] Support JSON functions in Flink SQL

oc in the next days. Hi Danny, The new introduced JSON functions are from SQL:2016, not from MySQL. So there no JSON type is needed. According to the SQL:2016, the representation of JSON data can be "character string" which is also the current implementation in Calcite[1]. Best, Ja

[DISCUSS] FLIP-66: Support time attribute in SQL DDL

ted column approach, we will start computed column FLIP soon. FLIP-66: https://docs.google.com/document/d/1-SecocBqzUh7zY6HBYcfMlG_0z-JAcuZkCvsmN3LrOw/edit# Thanks for any feedback! Best, Jark

Re: [DISCUSS] Support notifyOnMaster for notifyCheckpointComplete

I think before we have such interface, maybe we can make task-0 to do the global finalize work. Best, Jark > 在 2019年9月6日，13:39，shimin yang 写道： > > Hi Jingsong, > > Big fan of this idea. We faced the same problem and resolved by adding a > distributed lock. It would be

Is Flink documentation deployment script broken ?

Hi all, I merged several documentation pull requests[1][2][3] days ago. AFAIK, the documentation deployment is scheduled every day. However, I didn't see the changes are available in the Flink doc website[4] until now. The same to Till's PR[5] merged 3 days ago. Best, Jark

Re: Is Flink documentation deployment script broken ?

Thanks Chesnay for reporting this. > 在 2019年9月6日，17:47，Chesnay Schepler 写道： > > The scripts are fine, but the buildbot slave is currently down. > > I've already opened a ticket with INFRA: > https://issues.apache.org/jira/browse/INFRA-18986 > > On 06/09/2019 11

[VOTE] Release 1.8.2, release candidate #1

lease-1.8.2-rc1" [5], * website pull request listing the new release and adding announcement blog post [6]. The vote will be open for at least 72 hours. Please cast your votes before *Sep. 11th 2019, 13:00 UTC*. It is adopted by majority approval, with at least 3 PMC affirmative votes. Thanks

Re: [DISCUSS] Releasing Flink 1.8.2

Hi all, Thanks all of you for fixing issues for 1.8.2 release! The VOTE mail thread of the first RC of 1.8.2 already brought up. I would appreciate if you can help to check the release and VOTE the RC1. Thanks, Jark On Wed, 4 Sep 2019 at 16:57, Aljoscha Krettek wrote: > Hi, > >

Re: [ANNOUNCE] Kostas Kloudas joins the Flink PMC

Congratulations Klou! > 在 2019年9月7日，00:21，zhijiang 写道： > > Congratulations Klou! > > Best, > Zhijiang > -- > From:Zhu Zhu > Send Time:2019年9月6日(星期五) 17:19 > To:dev > Subject:Re: [ANNOUNCE] Kostas Kloudas joins the Flink PMC > >

Re: [DISCUSS] Features for Apache Flink 1.10

Thanks Gary for kicking off the discussion for 1.10 release. +1 for Gary and Yu as release managers. Thank you for you effort. Best, Jark > 在 2019年9月7日，00:52，zhijiang 写道： > > Hi Gary, > > Thanks for kicking off the features for next release 1.10. I am very > supportiv

Re: [DISCUSS] FLIP-66: Support time attribute in SQL DDL

Hi all, Thanks all for so much feedbacks received in the doc so far. I saw a general agreement on using computed column to support proctime attribute and extract timestamps. So we will prepare a computed column FLIP and share in the dev ML soon. Feel free to leave more comments! Best, Jark

Re: [ANNOUNCE] Zili Chen becomes a Flink committer

Congratulations Zili! Best, Jark On Wed, 11 Sep 2019 at 23:06, wrote: > Congratulations, Zili. > > > > Best, > > Xingcan > > > > *From:* SHI Xiaogang > *Sent:* Wednesday, September 11, 2019 7:43 AM > *To:* Guowei Ma > *Cc:* Fabian Hueske ; Biao

Re: [VOTE] Release 1.8.2, release candidate #1

between 1.8.1 and 1.8.2 to check dependencies, looks good Best, Jark On Wed, 11 Sep 2019 at 00:12, Till Rohrmann wrote: > +1 (binding) > > - verified checksums and signatures > - no binary files in source release > - built Flink from source release with Scala 2.12, running all tes

[RESULT] [VOTE] Release 1.8.2, release candidate #1

I'm happy to announce that we have unanimously approved this release. There are 5 approving votes, 3 of which are binding: * jincheng (binding) * Kurt (binding) * Till (binding) * Dian * Jark There are no disapproving votes. Thanks everyone!

Re: Blink Planner HBaseUpsertTableSink Exception

is thrown. IMO, in order to fix this problem, we need to enrich the primary key inference to support all kinds of built-in function/operators. But this is a large work which means it may not happen in 1.9.1. Regards, Jark On Thu, 12 Sep 2019 at 14:39, LakeShen wrote: > Hi community , whe

[ANNOUNCE] Apache Flink 1.8.2 released

in Jira: https://issues.apache.org/jira/projects/FLINK/versions/12345670 We would like to thank all contributors of the Apache Flink community who made this release possible! Great thanks to @Jincheng for the kindly help during this release. Regards, Jark

Re: [DISCUSS] FLIP-57 - Rework FunctionCatalog

“system.system.fun”, it introduces a nonexistent cat & db? And we still need to do special treatment for the dedicated system.system cat & db? Best, Jark > 在 2019年9月18日，06:54，Timo Walther 写道： > > Hi everyone, > > @Xuefu: I would like to avoid adding too many things incrementa

Re: Retention policy | Memory management.

ource and operators in DataStream API. Best, Jark [1]: https://ci.apache.org/projects/flink/flink-docs-master/dev/table/sqlClient.html#environment-files > 在 2019年9月13日，15:43，srikanth flink 写道： > > Hi there, > > I came across Flink and FlinkSQL and using FlinkSQL for stream proce

Re: [DISCUSS] FLIP-66: Support time attribute in SQL DDL

the design doc (it is slightly changed since the initial proposal). Thanks, Jark [1]: https://docs.google.com/document/d/1-SecocBqzUh7zY6HBYcfMlG_0z-JAcuZkCvsmN3LrOw/edit?ts=5d8258cd On Mon, 16 Sep 2019 at 16:12, Kurt Young wrote: > After some review and discussion in the google document

[VOTE] FLIP-66: Support Time Attribute in SQL DDL

Hi all, I would like to start the vote for FLIP-66 [1], which is discussed and reached a consensus in the discussion thread[2]. The vote will be open for at least 72 hours. I'll try to close it after Sep. 24 08:00 UTC, unless there is an objection or not enough votes. Thanks, Jark [1]:

Re: [DISCUSS] FLIP-57 - Rework FunctionCatalog

What will happen if user registers a non-builtin function name under the "system.system" namespace? Besides, I think it doesn't solve the "explode" problem I mentioned at the beginning of this thread. So here is my vote: +1 for #1 0 for #2 -1 for #3 Best, Jark On Thu, 19

Re: [DISCUSS] FLIP-64: Support for Temporary Objects in Table module

s is another story). Currently, it’s not easy to implement a custom connector descriptor. Best, Jark > 在 2019年9月19日，11:37，Dawid Wysakowicz 写道： > > Hi JingsongLee, > From my understanding they can. Underneath they will be CatalogTables. The > difference is the lifetime of the table

Re: [DISCUSS] FLIP-316: Introduce SQL Driver

FLIP. Regarding "K8S doesn't support shipping multiple jars", is that true? Is it possible to support it? Best, Jark On Thu, 1 Jun 2023 at 16:58, Paul Lam wrote: > Hi Weihua, > > You’re right. Distributing the SQLs to the TMs is one of the challenging > parts of th

Re: [DISCUSS] FLIP-315: Support Operator Fusion Codegen for Flink SQL

itive. Best, Jark On Wed, 31 May 2023 at 14:27, liu ron wrote: > Hi, Jinsong > > Thanks for your valuable suggestions. > > Best, > Ron > > Jingsong Li 于2023年5月30日周二 13:22写道： > > > Thanks Ron for your information. > > > > I suggest that it can

Re: [DISCUSS] FLIP 295: Support persistence of Catalog configuration and asynchronous registration

better to mention the changed behavior of CREATE CATALOG statement if FileCatalogStore (or other persisted catalog store) is used. Best, Jark On Thu, 1 Jun 2023 at 11:26, Feng Jin wrote: > Hi ， thanks all for reviewing the flip. > > @Ron > > > Regarding the CatalogStoreFacto

Re: [DISCUSS] Hive dialect shouldn't fall back to Flink's default dialect

+1, I think this can make the grammar more clear. Please remember to add a release note once the issue is finished. Best, Jark On Thu, 1 Jun 2023 at 11:28, yuxia wrote: > Hi, Jingsong. It's hard to provide an option regarding to the fact that we > also want to decouple Hive with fl

[DISCUSS] Update Flink Roadmap

elp verify and remove the accomplished items from the roadmap and update the feature radar. What do you think? Do you have other ideas? Best, Jark & Martijn [1]: https://flink.apache.org/roadmap.html [2]: https://lists.apache.org/thread/o0l3cg6yphxwrww0k7215jgtw3yfoybv [3]: https://cwiki.

Re: [DISCUSS] Update Flink Roadmap

Hi Jing, This thread is for discussing the roadmap for versions 1.18, 2.0, and even more. One of the outcomes of this discussion will be an updated version of the current roadmap. Let's work together on refining the roadmap in this thread. Best, Jark On Thu, 1 Jun 2023 at 23:25, Jing Ge

  1   2   3   4   5   6   7   8   9   10   >