[jira] [Created] (FLINK-18930) Translate "Hive Dialect" page of "Hive Integration" into Chinese

Rui Li created FLINK-18930: -- Summary: Translate "Hive Dialect" page of "Hive Integration" into Chinese Key: FLINK-18930 URL: https://issues.apache.org/jira/browse/FLINK-18930 Project: Flink Issue T

[jira] [Created] (FLINK-18931) Translate "Hive Streaming" page of "Hive Integration" into Chinese

Rui Li created FLINK-18931: -- Summary: Translate "Hive Streaming" page of "Hive Integration" into Chinese Key: FLINK-18931 URL: https://issues.apache.org/jira/browse/FLINK-18931 Project: Flink Issue

[jira] [Created] (FLINK-18933) Delete the old Python Table API document section

Wei Zhong created FLINK-18933: - Summary: Delete the old Python Table API document section Key: FLINK-18933 URL: https://issues.apache.org/jira/browse/FLINK-18933 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-18932) Add a "Overview" document under the "Python API" section

Wei Zhong created FLINK-18932: - Summary: Add a "Overview" document under the "Python API" section Key: FLINK-18932 URL: https://issues.apache.org/jira/browse/FLINK-18932 Project: Flink Issue Typ

[jira] [Created] (FLINK-18934) Idle stream does not advance watermark in connected stream

Truong Duc Kien created FLINK-18934: --- Summary: Idle stream does not advance watermark in connected stream Key: FLINK-18934 URL: https://issues.apache.org/jira/browse/FLINK-18934 Project: Flink

[jira] [Created] (FLINK-18935) CompletedOperationCache accepts new operations after closeAsync has been called

Till Rohrmann created FLINK-18935: - Summary: CompletedOperationCache accepts new operations after closeAsync has been called Key: FLINK-18935 URL: https://issues.apache.org/jira/browse/FLINK-18935 Pro

[jira] [Created] (FLINK-18936) Update documentation about user-defined aggregate functions

Timo Walther created FLINK-18936: Summary: Update documentation about user-defined aggregate functions Key: FLINK-18936 URL: https://issues.apache.org/jira/browse/FLINK-18936 Project: Flink

[jira] [Created] (FLINK-18937) Add a "Environment Setup" section to the "Installation" document

Wei Zhong created FLINK-18937: - Summary: Add a "Environment Setup" section to the "Installation" document Key: FLINK-18937 URL: https://issues.apache.org/jira/browse/FLINK-18937 Project: Flink I

[jira] [Created] (FLINK-18938) Throw better exception message for quering sink-only connector

Jark Wu created FLINK-18938: --- Summary: Throw better exception message for quering sink-only connector Key: FLINK-18938 URL: https://issues.apache.org/jira/browse/FLINK-18938 Project: Flink Issue T

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

FLINK-18902 and FLINK-18646 have been merged into the release-1.10 branch. >From my side you are good to go to create the next RC now. Cheers, Till On Wed, Aug 12, 2020 at 7:03 PM Zhu Zhu wrote: > Thank you all for the efforts verifying the RC. And thanks @Till Rohrmann > for the information o

[DISCUSS] flink authorization supports

Hi all! i want to integrate flink with ranger in our project. And i have some investigation about hive/spark/hbase/hadoop ranger. And found that hbase/hive/hadoop all have interface for authorization while spark sql does it with inject spark rules. You can find it here https://github.com/yaooqinn/

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

Thanks for the updates and the efforts to fix the issues @Till Will start to create RC2. Thanks, Zhu Zhu Till Rohrmann 于2020年8月13日周四 下午4:20写道： > FLINK-18902 and FLINK-18646 have been merged into the release-1.10 branch. > From my side you are good to go to create the next RC now. > > Cheers, >

Re: Kinesis Performance Issue (was [VOTE] Release 1.11.0, release candidate #4)

Hi Thomas, The fix is now merged to master and to release-1.11. So if you'd like you can check if it solves your problem (it would be helpful for us too). On Sat, Aug 8, 2020 at 9:26 AM Roman Khachatryan wrote: > Hi Thomas, > > Thanks a lot for the detailed information. > > I think the problem

[jira] [Created] (FLINK-18939) Sort-partition result is incorrect when use Bigdecimal as Key

Shengnan YU created FLINK-18939: --- Summary: Sort-partition result is incorrect when use Bigdecimal as Key Key: FLINK-18939 URL: https://issues.apache.org/jira/browse/FLINK-18939 Project: Flink

[jira] [Created] (FLINK-18940) Cannot cast "org.apache.flink.table.data.RowData" to "org.apache.flink.table.data.binary.BinaryStringData"

jack sun created FLINK-18940: Summary: Cannot cast "org.apache.flink.table.data.RowData" to "org.apache.flink.table.data.binary.BinaryStringData" Key: FLINK-18940 URL: https://issues.apache.org/jira/browse/FLINK-18940

[Announce] Flink Forward Global Program is now Live

Hi Everyone *The Flink Forward Global 2020 program is now online* and with 2 full days of exciting Apache Flink content, curated by our program committee[1]! Join us on October 21-22 to learn more about the newest technology updates, and hear use cases from Intel, Razorpay, Workday, Microsoft, a

Re: Kinesis Performance Issue (was [VOTE] Release 1.11.0, release candidate #4)

Hi Roman, Thanks for working on this! I deployed the change and it appears to be working as expected. Will monitor over a period of time to compare the checkpoint counts and get back to you if there are still issues. Thomas On Thu, Aug 13, 2020 at 3:41 AM Roman Khachatryan wrote: > Hi Thomas

[jira] [Created] (FLINK-18941) There are some typos in "Set up JobManager Memory"

Peng created FLINK-18941: Summary: There are some typos in "Set up JobManager Memory" Key: FLINK-18941 URL: https://issues.apache.org/jira/browse/FLINK-18941 Project: Flink Issue Type: Bug

Re: [DISCUSS] Planning Flink 1.12

Hi, I hope it's not too late to ask, but would FLIP-130 [1] and FLIP-133 [2] be considered? I think that it would be nice to have some details of pyFlink Datastreams API (FLIP-130) on the roadmap, giving us (users) more insights into what we can expect from pyFlink in the near future. [1] http:/

Re: [DISCUSS] Planning Flink 1.12

Hi Rodrigo, Both FLIP-130 and FLIP-133 will be in the list of 1.12. Besides, there are also some other features from PyFlink side in 1.12. More details could be found in the wiki page(https://cwiki.apache.org/confluence/display/FLINK/1.12+Release

[jira] [Created] (FLINK-18942) HiveTableSink shouldn't try to create BulkWriter factory when using MR writer

Rui Li created FLINK-18942: -- Summary: HiveTableSink shouldn't try to create BulkWriter factory when using MR writer Key: FLINK-18942 URL: https://issues.apache.org/jira/browse/FLINK-18942 Project: Flink