Re: [DISCUSS] Planning Flink 1.12

2020-08-13 Thread Dian Fu
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

Re: [DISCUSS] Planning Flink 1.12

2020-08-13 Thread rodrigobrochado
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]

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

2020-08-13 Thread Peng (Jira)
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: Kinesis Performance Issue (was [VOTE] Release 1.11.0, release candidate #4)

2020-08-13 Thread Thomas Weise
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

[Announce] Flink Forward Global Program is now Live

2020-08-13 Thread Seth Wiesman
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,

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

2020-08-13 Thread jack sun (Jira)
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:

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

2020-08-13 Thread Shengnan YU (Jira)
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

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

2020-08-13 Thread Roman Khachatryan
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

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

2020-08-13 Thread Zhu Zhu
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, >

[DISCUSS] flink authorization supports

2020-08-13 Thread Jacky Lau
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

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

2020-08-13 Thread Till Rohrmann
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

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

2020-08-13 Thread Jark Wu (Jira)
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

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

2020-08-13 Thread Wei Zhong (Jira)
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

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

2020-08-13 Thread Timo Walther (Jira)
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-18935) CompletedOperationCache accepts new operations after closeAsync has been called

2020-08-13 Thread Till Rohrmann (Jira)
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

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

2020-08-13 Thread Truong Duc Kien (Jira)
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-18932) Add a "Overview" document under the "Python API" section

2020-08-13 Thread Wei Zhong (Jira)
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

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

2020-08-13 Thread Wei Zhong (Jira)
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:

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

2020-08-13 Thread Rui Li (Jira)
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

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

2020-08-13 Thread Rui Li (Jira)
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

[jira] [Created] (FLINK-18929) Add a "API Docs" link (linked to the generated sphinx docs) under the "Python API" section

2020-08-13 Thread Wei Zhong (Jira)
Wei Zhong created FLINK-18929: - Summary: Add a "API Docs" link (linked to the generated sphinx docs) under the "Python API" section Key: FLINK-18929 URL: https://issues.apache.org/jira/browse/FLINK-18929

[jira] [Created] (FLINK-18928) Move the "Common Questions" document from the old Python Table API documentation to the "Python API" section with a new name "FAQ"

2020-08-13 Thread Wei Zhong (Jira)
Wei Zhong created FLINK-18928: - Summary: Move the "Common Questions" document from the old Python Table API documentation to the "Python API" section with a new name "FAQ" Key: FLINK-18928 URL:

[jira] [Created] (FLINK-18927) Add a "Debugging" document under the "Python API" -> "User Guide" -> "Table API" section

2020-08-13 Thread Wei Zhong (Jira)
Wei Zhong created FLINK-18927: - Summary: Add a "Debugging" document under the "Python API" -> "User Guide" -> "Table API" section Key: FLINK-18927 URL: https://issues.apache.org/jira/browse/FLINK-18927

[jira] [Created] (FLINK-18926) Add a "Environment Variables" document under the "Python API" -> "User Guide" -> "Table API" section

2020-08-13 Thread Wei Zhong (Jira)
Wei Zhong created FLINK-18926: - Summary: Add a "Environment Variables" document under the "Python API" -> "User Guide" -> "Table API" section Key: FLINK-18926 URL: https://issues.apache.org/jira/browse/FLINK-18926

[jira] [Created] (FLINK-18925) Move the "Configuration" document from the old Python Table API documentation to the "Python API" -> "User Guide" -> "Table API" section

2020-08-13 Thread Wei Zhong (Jira)
Wei Zhong created FLINK-18925: - Summary: Move the "Configuration" document from the old Python Table API documentation to the "Python API" -> "User Guide" -> "Table API" section Key: FLINK-18925 URL:

[jira] [Created] (FLINK-18924) Move the "Metrics" document from the old Python Table API documentation to the "Python API" -> "User Guide" -> "Table API" section

2020-08-13 Thread Wei Zhong (Jira)
Wei Zhong created FLINK-18924: - Summary: Move the "Metrics" document from the old Python Table API documentation to the "Python API" -> "User Guide" -> "Table API" section Key: FLINK-18924 URL:

[jira] [Created] (FLINK-18923) Add a "CEP" document under the "Python API" -> "User Guide" section

2020-08-13 Thread Wei Zhong (Jira)
Wei Zhong created FLINK-18923: - Summary: Add a "CEP" document under the "Python API" -> "User Guide" section Key: FLINK-18923 URL: https://issues.apache.org/jira/browse/FLINK-18923 Project: Flink

[jira] [Created] (FLINK-18922) Add a "Catalogs" link (linked to dev/table/catalogs.md) under the "Python API" -> "User Guide" section

2020-08-13 Thread Wei Zhong (Jira)
Wei Zhong created FLINK-18922: - Summary: Add a "Catalogs" link (linked to dev/table/catalogs.md) under the "Python API" -> "User Guide" section Key: FLINK-18922 URL: https://issues.apache.org/jira/browse/FLINK-18922

[jira] [Created] (FLINK-18921) Add a "SQL" link (linked to dev/table/sql/index.md) under the "Python API" -> "User Guide" section

2020-08-13 Thread Wei Zhong (Jira)
Wei Zhong created FLINK-18921: - Summary: Add a "SQL" link (linked to dev/table/sql/index.md) under the "Python API" -> "User Guide" section Key: FLINK-18921 URL: https://issues.apache.org/jira/browse/FLINK-18921

[jira] [Created] (FLINK-18920) Move the "Dependency Management" document from the old Python Table API documentation to the "Python API" -> "GettingStart" section

2020-08-13 Thread Wei Zhong (Jira)
Wei Zhong created FLINK-18920: - Summary: Move the "Dependency Management" document from the old Python Table API documentation to the "Python API" -> "GettingStart" section Key: FLINK-18920 URL:

[jira] [Created] (FLINK-18919) Move the "User Defined Functions" document and "Vectorized User Defined Functions" document from the old Python Table API documentation to the "Python API" -> "User Guid

2020-08-13 Thread Wei Zhong (Jira)
Wei Zhong created FLINK-18919: - Summary: Move the "User Defined Functions" document and "Vectorized User Defined Functions" document from the old Python Table API documentation to the "Python API" -> "User Guide" section Key:

[jira] [Created] (FLINK-18918) Add a "Connectors" document under the "Python API" -> "User Guide" section

2020-08-13 Thread Wei Zhong (Jira)
Wei Zhong created FLINK-18918: - Summary: Add a "Connectors" document under the "Python API" -> "User Guide" section Key: FLINK-18918 URL: https://issues.apache.org/jira/browse/FLINK-18918 Project: Flink

[jira] [Created] (FLINK-18917) Add a "Built-in Functions" link (linked to dev/table/functions/systemFunctions.md) under the "Python API" -> "User Guide" section

2020-08-13 Thread Wei Zhong (Jira)
Wei Zhong created FLINK-18917: - Summary: Add a "Built-in Functions" link (linked to dev/table/functions/systemFunctions.md) under the "Python API" -> "User Guide" section Key: FLINK-18917 URL:

[jira] [Created] (FLINK-18916) Add a "Operations" link(linked to dev/table/tableApi.md) under the "Python API" -> "User Guide" section

2020-08-13 Thread Wei Zhong (Jira)
Wei Zhong created FLINK-18916: - Summary: Add a "Operations" link(linked to dev/table/tableApi.md) under the "Python API" -> "User Guide" section Key: FLINK-18916 URL: https://issues.apache.org/jira/browse/FLINK-18916