Apply for being a contributor

Hi PMCs, Good afternoon ! This is Jeff Yang ,Now it is Beijing time 13:36:20PM, I am from China , and I want to contribute to Apache Flink. Would you please give me the permission as a contributor? My JIRA ID is Jeff Yang and username is highfei2...@126.com . Thanks. Best, Jeff Yang

Re: [DISCUSS] Create a Flink ecosystem website

Robert and Daryl, thanks for the great work, I tried the website and filed some issues on Github. Best, Congxian Robert Metzger 于2019年7月17日周三 下午11:28写道： > Hey all, > > Daryl and I have great news to share. We are about to finish adding the > basic features to the ecosystem page. > We are at a

Re: [DISCUSS] Flink project bylaws

Hi Becket, Thanks for the proposal. Regarding the vote of FLIP, preferably at least includes a PMC vote. Because FLIP is usually a big change or affects the user's interface changes. What do you think? (I leave the comment in the wiki.) Best, Jincheng Dawid Wysakowicz 于2019年7月17日周三 下午9:12写道：

[jira] [Created] (FLINK-13315) Port wmstrategies to api-java

Jingsong Lee created FLINK-13315: Summary: Port wmstrategies to api-java Key: FLINK-13315 URL: https://issues.apache.org/jira/browse/FLINK-13315 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-13314) Correct resultType of some PlannerExpression when operands contains DecimalTypeInfo or BigDecimalTypeInfo in Blink planner

Jing Zhang created FLINK-13314: -- Summary: Correct resultType of some PlannerExpression when operands contains DecimalTypeInfo or BigDecimalTypeInfo in Blink planner Key: FLINK-13314 URL:

Re: flink-python failed on Travis

Hi Dian Nice fix! Best, tison. Dian Fu 于2019年7月18日周四 上午9:27写道： > Hi all, > > This issue has been fixed in > https://github.com/apache/flink/commit/200a5bf9dca9d398cf07879d4d1e407a2f41d839 > < > https://github.com/apache/flink/commit/200a5bf9dca9d398cf07879d4d1e407a2f41d839>. > Thanks for

Re: flink-python failed on Travis

Hi all, This issue has been fixed in https://github.com/apache/flink/commit/200a5bf9dca9d398cf07879d4d1e407a2f41d839 . Thanks for @WeiZhong's fix. Regards, Dian > 在 2019年7月18日，上午2:41，Bowen Li 写道： > > Hi Dian,

[jira] [Created] (FLINK-13313) create CatalogTableBuilder to support building CatalogTable from descriptors

Bowen Li created FLINK-13313: Summary: create CatalogTableBuilder to support building CatalogTable from descriptors Key: FLINK-13313 URL: https://issues.apache.org/jira/browse/FLINK-13313 Project: Flink

[jira] [Created] (FLINK-13312) move tests for data type mappings between Flink and Hive into its own test class

Bowen Li created FLINK-13312: Summary: move tests for data type mappings between Flink and Hive into its own test class Key: FLINK-13312 URL: https://issues.apache.org/jira/browse/FLINK-13312 Project:

Re: flink-python failed on Travis

Hi Dian, Is there any update on this? It seems have been failing for a day. On Tue, Jul 16, 2019 at 9:35 PM Dian Fu wrote: > Thanks for reporting this issue. I will take a look at it. > > > 在 2019年7月17日，上午11:50，Danny Chan 写道： > > > > I have the same issue ~~ > > > > Best, > > Danny Chan > >

Re: instable checkpointing after migration to flink 1.8

Hi Congxian,Yes we have incremental checkpointing enabled on RocksDBBackend.For further investigation, I have logged into one task manager node which had 15 min long snapshotting and found the logs under some /tmp directory.Attaching 2 logs files, one for a long/problematic snapshotting and one

Re: [DISCUSS] Create a Flink ecosystem website

Hey all, Daryl and I have great news to share. We are about to finish adding the basic features to the ecosystem page. We are at a stage where it is ready to be reviewed and made public. You can either check out a development instance of the ecosystem page here:

Re: Add relative path support in Savepoint Connector

Hi Konstantin, Thank you for your feedback. You’re right that this part belongs to the savepoint desrializing. This is an old issue which should be resolve before 1.3 version according to the comments. Anyway, I’m going to keep following this. Best Regards, Jiayi Liao Original Message

Re: instable checkpointing after migration to flink 1.8

Hi Bekir Sorry for the previous message, I didn't see the second image of your first message :( >From the second image of your first message, seems the sync part consumes too much time. 5715:40:24(acknowledgement Time) 15m53s (End to End Duration) 464m(State size) 15M48s(Checkpoint

Re: [DISCUSS] Flink project bylaws

Hi all, Sorry for joining late. I just wanted to say that I really like the proposed bylaws! One comment, I also have the same concerns as expressed by few people before that the "committer +1" on code change might be hard to achieve currently. On the other hand I would say this would be

[jira] [Created] (FLINK-13311) flink-table section outdated in NOTICE-binary

Chesnay Schepler created FLINK-13311: Summary: flink-table section outdated in NOTICE-binary Key: FLINK-13311 URL: https://issues.apache.org/jira/browse/FLINK-13311 Project: Flink Issue

[jira] [Created] (FLINK-13310) Remove shade-plugin configuration in hive-connector

Chesnay Schepler created FLINK-13310: Summary: Remove shade-plugin configuration in hive-connector Key: FLINK-13310 URL: https://issues.apache.org/jira/browse/FLINK-13310 Project: Flink

[jira] [Created] (FLINK-13309) flink-shaded-netty-tcnative-dynamic missing from NOTICE-binary

Chesnay Schepler created FLINK-13309: Summary: flink-shaded-netty-tcnative-dynamic missing from NOTICE-binary Key: FLINK-13309 URL: https://issues.apache.org/jira/browse/FLINK-13309 Project:

[jira] [Created] (FLINK-13308) flink-python releases 2 jars

Chesnay Schepler created FLINK-13308: Summary: flink-python releases 2 jars Key: FLINK-13308 URL: https://issues.apache.org/jira/browse/FLINK-13308 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-13307) SourceStreamTaskTest test instability.

Kostas Kloudas created FLINK-13307: -- Summary: SourceStreamTaskTest test instability. Key: FLINK-13307 URL: https://issues.apache.org/jira/browse/FLINK-13307 Project: Flink Issue Type:

[jira] [Created] (FLINK-13306) flink-examples-streaming-gcp-pubsub is missing NOTICE

Chesnay Schepler created FLINK-13306: Summary: flink-examples-streaming-gcp-pubsub is missing NOTICE Key: FLINK-13306 URL: https://issues.apache.org/jira/browse/FLINK-13306 Project: Flink

Re: Flink "allow lateness" for tables

Hi Ramya, Are you looking for "allow lateness" for tumbling window in Flink SQL? If yes, Flink SQL doesn't provide such things currently. However, blink planner (the new runner of Flink SQL) will support this maybe in the next release (v1.10). Actually, we already implemented it in blink planner

Flink "allow lateness" for tables

Hi, I would like to know if there is some configuration which enabled to configure allow lateness in table. The documentation mentions about streams and not tables. If this is not present, is there a way to collect it on a side output for tables. Today, we see some late packet drops in Flink,

[jira] [Created] (FLINK-13305) YARN rest commands not documented

Chesnay Schepler created FLINK-13305: Summary: YARN rest commands not documented Key: FLINK-13305 URL: https://issues.apache.org/jira/browse/FLINK-13305 Project: Flink Issue Type: Bug

Re: Add relative path support in Savepoint Connector

Hi Jiayi, I think, this is not an issue with the State Processor API specifically, but with savepoints in general. The _metadata file of a savepoint uses absolute path references. There is a pretty old Jira ticket, which already mentioned this limitation [1]. Stefan (cc) might know more about

[jira] [Created] (FLINK-13304) Fix implementation of getString and getBinary method in NestedRow

Caizhi Weng created FLINK-13304: --- Summary: Fix implementation of getString and getBinary method in NestedRow Key: FLINK-13304 URL: https://issues.apache.org/jira/browse/FLINK-13304 Project: Flink

[jira] [Created] (FLINK-13303) Add e2e test for hive connector

Rui Li created FLINK-13303: -- Summary: Add e2e test for hive connector Key: FLINK-13303 URL: https://issues.apache.org/jira/browse/FLINK-13303 Project: Flink Issue Type: Bug Components:

Re: instable checkpointing after migration to flink 1.8

Hi Bekir First of all, I think there is something wrong. the state size is almost the same, but the duration is different so much. The checkpoint for RocksDBStatebackend is dump sst files, then copy the needed sst files(if you enable incremental checkpoint, the sst files already on remote will

[jira] [Created] (FLINK-13302) DateTimeUtils.unixDateCeil returns the same value as unixDateFloor does

Zhenghua Gao created FLINK-13302: Summary: DateTimeUtils.unixDateCeil returns the same value as unixDateFloor does Key: FLINK-13302 URL: https://issues.apache.org/jira/browse/FLINK-13302 Project:

Application for contributor permission

Hi?? I want to conrtibute to Apache Flink. Would you please give me the contributor permission? My JIRA ID is zhiyezou.

[jira] [Created] (FLINK-13301) Some PlannerExpression resultType is not consistent with Calcite Type inference

Jing Zhang created FLINK-13301: -- Summary: Some PlannerExpression resultType is not consistent with Calcite Type inference Key: FLINK-13301 URL: https://issues.apache.org/jira/browse/FLINK-13301 Project:

Re: Add relative path support in Savepoint Connector

Hi again, Anyone has any opinion on this topic? Best Regards, Jiayi Liao Original Message Sender:bupt_ljybupt_...@163.com Recipient:dev...@flink.apache.org Cc:Tzu-Li (Gordon) taitzuli...@apache.org Date:Tuesday, Jul 16, 2019 15:24 Subject:Add relative path support in Savepoint Connector Hi