[jira] [Created] (FLINK-12992) All host(s) tried for query failed (tried com.datastax.driver.core.exceptions.TransportException: Error writing...)

yanxiaobin created FLINK-12992: -- Summary: All host(s) tried for query failed (tried com.datastax.driver.core.exceptions.TransportException: Error writing...) Key: FLINK-12992 URL: https://issues.apache.org/jira/brows

[jira] [Created] (FLINK-12991) Correct the implementation of Catalog.get_table_factory

Dian Fu created FLINK-12991: --- Summary: Correct the implementation of Catalog.get_table_factory Key: FLINK-12991 URL: https://issues.apache.org/jira/browse/FLINK-12991 Project: Flink Issue Type: Bug

Re: [ANNOUNCE] Jincheng Sun is now part of the Flink PMC

Thanks everyone :) I hope to help out the community as much as possible, and it has always been great working with you all ! :) Cheers, Jincheng Wei Zhong 于2019年6月26日周三 上午2:39写道： > Congratulations Jincheng! > > Best, > Wei > > > > 在 2019年6月25日，15:18，JingsongLee 写道： > > > > Jincheng, Congratul

[jira] [Created] (FLINK-12990) Date type doesn't consider the local TimeZone

Dian Fu created FLINK-12990: --- Summary: Date type doesn't consider the local TimeZone Key: FLINK-12990 URL: https://issues.apache.org/jira/browse/FLINK-12990 Project: Flink Issue Type: Bug

Re: [DISCUSS] FLIP-44: Support Local Aggregation in Flink

Thanks for the long discussion Vino, Kurt, Hequn, Piotr and others, It seems that we still have some different ideas about the API (localKeyBy()?) and implementation details (reuse window operator? local keyed state?). And the discussion is stalled and mixed with motivation and API and implementat

[jira] [Created] (FLINK-12989) Add implementation of converting Hive catalog table to Hive table sink

Xuefu Zhang created FLINK-12989: --- Summary: Add implementation of converting Hive catalog table to Hive table sink Key: FLINK-12989 URL: https://issues.apache.org/jira/browse/FLINK-12989 Project: Flink

[jira] [Created] (FLINK-12988) restore AbstractCatalogTable as parent for CatalogTableImpl and ConnectorCatalogTable

Bowen Li created FLINK-12988: Summary: restore AbstractCatalogTable as parent for CatalogTableImpl and ConnectorCatalogTable Key: FLINK-12988 URL: https://issues.apache.org/jira/browse/FLINK-12988 Project

[jira] [Created] (FLINK-12987) DescriptiveStatisticsHistogram#getCount does not return the number of elements seen

Nico Kruber created FLINK-12987: --- Summary: DescriptiveStatisticsHistogram#getCount does not return the number of elements seen Key: FLINK-12987 URL: https://issues.apache.org/jira/browse/FLINK-12987 Pro

Re: [ANNOUNCE] Jincheng Sun is now part of the Flink PMC

Congratulations Jincheng! Best, Wei > 在 2019年6月25日，15:18，JingsongLee 写道： > > Jincheng, Congratulations! > > Best, JingsongLee > > > -- > From:Dawid Wysakowicz > Send Time:2019年6月25日(星期二) 14:21 > To:dev > Subject:Re: [ANNOUNCE

Re: [DISCUSS] solve unstable build capacity problem on TravisCI

Want to summarize Chesnay's points for everyone reading this thread: 1) the build resources Flink is currently using belong to ASF INFRA, and 2) we are waiting on ASF INFRA's response on whether we can donate/sponsor extra build resources for Flink. I think it'll be super helpful to pay and secure

Re: [ANNOUNCE] Jincheng Sun is now part of the Flink PMC

Congrats Jincheng! Best, Leesf Guowei Ma 于2019年6月25日周二 下午7:18写道： > Congratulations, Jincheng ! > > Best, > Guowei > > > zhisheng <173855...@qq.com> 于2019年6月25日周二 下午6:32写道： > > > Congratulations, Jincheng > > > > > > > > ---Original--- > > From: "Fan Liya" > > Date: Tue, Jun 25, 2019 18:23 PM >

[jira] [Created] (FLINK-12986) Add alternative implementations for BoundedBlockingSubpartition to address stability issues

Stephan Ewen created FLINK-12986: Summary: Add alternative implementations for BoundedBlockingSubpartition to address stability issues Key: FLINK-12986 URL: https://issues.apache.org/jira/browse/FLINK-12986

[jira] [Created] (FLINK-12985) Move & rename StreamTransformation to org.apache.flink.api.dag.Transformation

Dawid Wysakowicz created FLINK-12985: Summary: Move & rename StreamTransformation to org.apache.flink.api.dag.Transformation Key: FLINK-12985 URL: https://issues.apache.org/jira/browse/FLINK-12985

Re: [ANNOUNCE] Feature freeze for Apache Flink 1.9.0 release

On the fine-grained recovery / batch scheduling side we could make good use of another week. Currently we are on track to have the _feature_ merged, but without having done a great deal of end-to-end testing. On 25/06/2019 15:01, Kurt Young wrote: Hi Aljoscha, I also feel an additional week c

Re: [ANNOUNCE] Feature freeze for Apache Flink 1.9.0 release

+1 on extending one week. Kurt Young 于2019年6月25日周二 下午9:01写道： > Hi Aljoscha, > > I also feel an additional week can make the remaining work more easy. At > least > we don't have to check in lots of commits in both branches (master & > release-1.9). > > Best, > Kurt > > > On Tue, Jun 25, 2019 at

Re: [ANNOUNCE] Feature freeze for Apache Flink 1.9.0 release

Hi Aljoscha, I also feel an additional week can make the remaining work more easy. At least we don't have to check in lots of commits in both branches (master & release-1.9). Best, Kurt On Tue, Jun 25, 2019 at 8:27 PM Aljoscha Krettek wrote: > A few threads are converging around supporting th

[jira] [Created] (FLINK-12984) Only call Histogram#getStatistics() once per set of retrieved statistics

Nico Kruber created FLINK-12984: --- Summary: Only call Histogram#getStatistics() once per set of retrieved statistics Key: FLINK-12984 URL: https://issues.apache.org/jira/browse/FLINK-12984 Project: Flink

[jira] [Created] (FLINK-12983) Replace descriptive histogram's storage back-end

Nico Kruber created FLINK-12983: --- Summary: Replace descriptive histogram's storage back-end Key: FLINK-12983 URL: https://issues.apache.org/jira/browse/FLINK-12983 Project: Flink Issue Type: Su

Re: [ANNOUNCE] Feature freeze for Apache Flink 1.9.0 release

A few threads are converging around supporting the new Blink-based Table API Runner/Planner. I think hitting the currently proposed feature freeze date is hard, if not impossible, and that the work would benefit from an additional week to get everything in with good quality. What do the others

[jira] [Created] (FLINK-12982) Make DescriptiveStatisticsHistogramStatistics a true point-in-time snapshot

Nico Kruber created FLINK-12982: --- Summary: Make DescriptiveStatisticsHistogramStatistics a true point-in-time snapshot Key: FLINK-12982 URL: https://issues.apache.org/jira/browse/FLINK-12982 Project: Fl

[jira] [Created] (FLINK-12981) Ignore NaN values in histogram's percentile implementation

Nico Kruber created FLINK-12981: --- Summary: Ignore NaN values in histogram's percentile implementation Key: FLINK-12981 URL: https://issues.apache.org/jira/browse/FLINK-12981 Project: Flink Issu

Re: [ANNOUNCE] Jincheng Sun is now part of the Flink PMC

Congratulations, Jincheng ! Best, Guowei zhisheng <173855...@qq.com> 于2019年6月25日周二 下午6:32写道： > Congratulations, Jincheng > > > > ---Original--- > From: "Fan Liya" > Date: Tue, Jun 25, 2019 18:23 PM > To: "dev"; > Subject: Re: [ANNOUNCE] Jincheng Sun is now part of the Flink PMC > > > Congratula

[jira] [Created] (FLINK-12980) Getting Started - Add Top-Level Section to Existing Documentation

Konstantin Knauf created FLINK-12980: Summary: Getting Started - Add Top-Level Section to Existing Documentation Key: FLINK-12980 URL: https://issues.apache.org/jira/browse/FLINK-12980 Project: Fl

Re: [ANNOUNCE] Jincheng Sun is now part of the Flink PMC

Congratulations, Jincheng ---Original--- From: "Fan Liya" Date: Tue, Jun 25, 2019 18:23 PM To: "dev"; Subject: Re: [ANNOUNCE] Jincheng Sun is now part of the Flink PMC Congratulations! Best, Liya Fan On Tue, Jun 25, 2019 at 6:21 PM Shaoxuan Wang wrote: > Congratulations, Jincheng! > > On

Re: [ANNOUNCE] Jincheng Sun is now part of the Flink PMC

Congratulations! Best, Liya Fan On Tue, Jun 25, 2019 at 6:21 PM Shaoxuan Wang wrote: > Congratulations, Jincheng! > > On Tue, Jun 25, 2019 at 5:54 PM Fabian Hueske wrote: > > > Congrats Jincheng! > > > > Am Di., 25. Juni 2019 um 11:48 Uhr schrieb Aljoscha Krettek < > > aljos...@apache.org>: >

Re: [ANNOUNCE] Jincheng Sun is now part of the Flink PMC

Congratulations, Jincheng! On Tue, Jun 25, 2019 at 5:54 PM Fabian Hueske wrote: > Congrats Jincheng! > > Am Di., 25. Juni 2019 um 11:48 Uhr schrieb Aljoscha Krettek < > aljos...@apache.org>: > > > Congratulations! :-) > > > > > On 25. Jun 2019, at 11:34, Wei Zhong wrote: > > > > > > Congratulat

Re: [DISCUSS] Connectors and NULL handling

I think actually most of Flink was not designed to handle NULL values and as far as I remember, some people think that Flink shouldn’t handle NULL values. The fact that some parts support NULL values is more by accident than by conscious planning. Aljoscha > On 24. Jun 2019, at 10:07, Becket Q

Re: [ANNOUNCE] Jincheng Sun is now part of the Flink PMC

Congrats Jincheng! Am Di., 25. Juni 2019 um 11:48 Uhr schrieb Aljoscha Krettek < aljos...@apache.org>: > Congratulations! :-) > > > On 25. Jun 2019, at 11:34, Wei Zhong wrote: > > > > Congratulations Jincheng! > > > > Best, > > Wei > > > > > >> 在 2019年6月25日，15:18，JingsongLee 写道： > >> > >> Jinch

Re: [ANNOUNCE] Jincheng Sun is now part of the Flink PMC

Congratulations! :-) > On 25. Jun 2019, at 11:34, Wei Zhong wrote: > > Congratulations Jincheng! > > Best, > Wei > > >> 在 2019年6月25日，15:18，JingsongLee 写道： >> >> Jincheng, Congratulations! >> >> Best, JingsongLee >> >> >> --

[jira] [Created] (FLINK-12979) Sending data to kafka with CsvRowSerializationSchema always adding a "\n", "\r","\r\n" at the end of the message

chaiyongqiang created FLINK-12979: - Summary: Sending data to kafka with CsvRowSerializationSchema always adding a "\n", "\r","\r\n" at the end of the message Key: FLINK-12979 URL: https://issues.apache.org/jira/br

Re: [ANNOUNCE] Jincheng Sun is now part of the Flink PMC

Congratulations Jincheng! Best, Wei > 在 2019年6月25日，15:18，JingsongLee 写道： > > Jincheng, Congratulations! > > Best, JingsongLee > > > -- > From:Dawid Wysakowicz > Send Time:2019年6月25日(星期二) 14:21 > To:dev > Subject:Re: [ANNOUNCE

[jira] [Created] (FLINK-12978) Support LookupableTableSource for CsvTableSource

Jark Wu created FLINK-12978: --- Summary: Support LookupableTableSource for CsvTableSource Key: FLINK-12978 URL: https://issues.apache.org/jira/browse/FLINK-12978 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-12977) Port CsvTableSource and CsvTableSink to api-java-bridge

Jark Wu created FLINK-12977: --- Summary: Port CsvTableSource and CsvTableSink to api-java-bridge Key: FLINK-12977 URL: https://issues.apache.org/jira/browse/FLINK-12977 Project: Flink Issue Type: Tas

Re: Rolling policy when using StreamingFileSink for bulk-encoded output

Hi Ying, You are right! If it is either on checkpoint or on size, then this is doable even with the current state of things. Could you open a JIRA so that we can keep track of the progress? Cheers, Kostas On Tue, Jun 25, 2019 at 9:49 AM Ying Xu wrote: > HI Kostas: > > Thanks for the prompt rep

[jira] [Created] (FLINK-12976) Bump Kafka client version to 2.3.0 for universal Kafka connector

vinoyang created FLINK-12976: Summary: Bump Kafka client version to 2.3.0 for universal Kafka connector Key: FLINK-12976 URL: https://issues.apache.org/jira/browse/FLINK-12976 Project: Flink Iss

[jira] [Created] (FLINK-12975) UserDefinedFunctionUtils should distinguish overload any parameters methods in blink

Jingsong Lee created FLINK-12975: Summary: UserDefinedFunctionUtils should distinguish overload any parameters methods in blink Key: FLINK-12975 URL: https://issues.apache.org/jira/browse/FLINK-12975

[jira] [Created] (FLINK-12974) Bump checkstyle version to 8.14

Biao Liu created FLINK-12974: Summary: Bump checkstyle version to 8.14 Key: FLINK-12974 URL: https://issues.apache.org/jira/browse/FLINK-12974 Project: Flink Issue Type: Improvement Com

Re: [DISCUSS] Releasing Flink 1.8.1

Hi all, Thanks all of you for help fix the blocker of 1.8.1 release!!! The VOTE mail thread of the first RC of 1.8.1 already brought up, I appreciate it if you can help to check the release and VOTE the RC1 !!! Best, Jincheng jincheng sun 于2019年6月25日周二 上午8:36写道： > Due to no new blocker jumps u

Re: [Discuss] FLIP-43: Savepoint Connector

Hi Gordon, The modify max parallelism API looks good to me. Thank you and Seth for the great work on it. Cheers, Jark On Tue, 25 Jun 2019 at 16:01, Tzu-Li (Gordon) Tai wrote: > Hi Jark, > > Thanks for the reminder. I've updated the FLIP name in confluence to match > the new name "State Process

[VOTE] Release 1.8.1, release candidate #1

Hi everyone, Please review and vote on the release candidate 1 for Flink 1.8.1, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) The complete staging area is available for your review, which includes: * JIRA release notes [1], * the of

[jira] [Created] (FLINK-12973) Support reading Hive complex types like array and map

zjuwangg created FLINK-12973: Summary: Support reading Hive complex types like array and map Key: FLINK-12973 URL: https://issues.apache.org/jira/browse/FLINK-12973 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-12972) Ensure calling open/close in join condition of generated functions for blink

Jingsong Lee created FLINK-12972: Summary: Ensure calling open/close in join condition of generated functions for blink Key: FLINK-12972 URL: https://issues.apache.org/jira/browse/FLINK-12972 Project:

Re: [Discuss] FLIP-43: Savepoint Connector

Hi Jark, Thanks for the reminder. I've updated the FLIP name in confluence to match the new name "State Processor API". Concerning an API for changing max parallelism: That is actually in the works and has been considered, and would look something like - ``` ExistingSavepoint savepoint = Savepoin

Re: Join in Apache Flink community

Hi Chance, Welcome to the community! I've gave you contributor permissions in JIRA. Cheers, Gordon On Sat, Jun 22, 2019 at 12:36 AM Chance Li wrote: > Hi Guys, >I want to contribute to Apache Flink. Would you please give me > contributor permission? My JIRA ID: Chance Li, email: chanc...@g

Re: [DISCUSS] solve unstable build capacity problem on TravisCI

On 24/06/2019 23:48, Bowen Li wrote: - Has anyone else experienced the same problem or have similar observation on TravisCI? (I suspect it has things to do with time zone) In Europe we have the same problem. - What pricing plan of TravisCI is Flink currently using? Is it the free plan for op

Re: Rolling policy when using StreamingFileSink for bulk-encoded output

HI Kostas: Thanks for the prompt reply. The file rolling policy mentioned previously is meant to roll files EITHER when a size limited is reached, OR when a checkpoint happens. Looks like every time a file is rolled, the part file is closed

[jira] [Created] (FLINK-12971) Remove the constraint that lookup join needs a primary key or index key

Jark Wu created FLINK-12971: --- Summary: Remove the constraint that lookup join needs a primary key or index key Key: FLINK-12971 URL: https://issues.apache.org/jira/browse/FLINK-12971 Project: Flink

Re: [ANNOUNCE] Jincheng Sun is now part of the Flink PMC

Jincheng, Congratulations! Best, JingsongLee -- From:Dawid Wysakowicz Send Time:2019年6月25日(星期二) 14:21 To:dev Subject:Re: [ANNOUNCE] Jincheng Sun is now part of the Flink PMC Congratulations! On 25/06/2019 08:06, Xingcan Cui wrot