[jira] [Created] (FLINK-15032) Remove the eagerly serialization from `RemoteRpcInvocation`

2019-12-02 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-15032: - Summary: Remove the eagerly serialization from `RemoteRpcInvocation` Key: FLINK-15032 URL: https://issues.apache.org/jira/browse/FLINK-15032 Project: Flink

[jira] [Created] (FLINK-15031) Calculate required shuffle memory cases before allocating slots in resources specified

2019-12-02 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-15031: --- Summary: Calculate required shuffle memory cases before allocating slots in resources specified Key: FLINK-15031 URL: https://issues.apache.org/jira/browse/FLINK-15031

[jira] [Created] (FLINK-15030) Potential deadlock for bounded blocking ResultPartition.

2019-12-02 Thread Yingjie Cao (Jira)
Yingjie Cao created FLINK-15030: --- Summary: Potential deadlock for bounded blocking ResultPartition. Key: FLINK-15030 URL: https://issues.apache.org/jira/browse/FLINK-15030 Project: Flink Issue

[jira] [Created] (FLINK-15029) Dependency shading of table modules test failed on travis

2019-12-02 Thread Yu Li (Jira)
Yu Li created FLINK-15029: - Summary: Dependency shading of table modules test failed on travis Key: FLINK-15029 URL: https://issues.apache.org/jira/browse/FLINK-15029 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-15028) YARNSessionFIFOSecuredITCase test failed with java11 on travis

2019-12-02 Thread Yu Li (Jira)
Yu Li created FLINK-15028: - Summary: YARNSessionFIFOSecuredITCase test failed with java11 on travis Key: FLINK-15028 URL: https://issues.apache.org/jira/browse/FLINK-15028 Project: Flink Issue

[jira] [Created] (FLINK-15027) Support alter table DDLs in SQL CLI

2019-12-02 Thread Danny Chen (Jira)
Danny Chen created FLINK-15027: -- Summary: Support alter table DDLs in SQL CLI Key: FLINK-15027 URL: https://issues.apache.org/jira/browse/FLINK-15027 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-15026) Support database DDLs in SQL CLI

2019-12-02 Thread Danny Chen (Jira)
Danny Chen created FLINK-15026: -- Summary: Support database DDLs in SQL CLI Key: FLINK-15026 URL: https://issues.apache.org/jira/browse/FLINK-15026 Project: Flink Issue Type: Sub-task

Re: [VOTE] Release 1.8.3, release candidate #2

2019-12-02 Thread Jingsong Li
Hi Hequn, +1 (non-binding) Thank you for driving this. - Verified signatures and checksums - Maven build from source skip tests (Scala 2.11 and Scala 2.12) - Start local cluster and web ui is accessible (Scala 2.11 and Scala 2.12) - Submit WordCount example of both batch and streaming, good

[jira] [Created] (FLINK-15023) Remove on-heap managed memory

2019-12-02 Thread Xintong Song (Jira)
Xintong Song created FLINK-15023: Summary: Remove on-heap managed memory Key: FLINK-15023 URL: https://issues.apache.org/jira/browse/FLINK-15023 Project: Flink Issue Type: Sub-task

Re: [DISCUSS] Make Managed Memory always off-heap (Adjustment to FLIP-49)

2019-12-02 Thread Xintong Song
Sorry, I just realized that I've send my feedbacks to Jingsong's email address, instead of the dev / user mailing list. Please find my comments below. Thank you~ Xintong Song On Wed, Nov 27, 2019 at 4:32 PM Xintong Song wrote: > As a participant of the discussion yesterday, I'm +1 for the

[jira] [Created] (FLINK-15021) Refactor to remove channelWritabilityChanged from PartitionRequestQueue

2019-12-02 Thread zhijiang (Jira)
zhijiang created FLINK-15021: Summary: Refactor to remove channelWritabilityChanged from PartitionRequestQueue Key: FLINK-15021 URL: https://issues.apache.org/jira/browse/FLINK-15021 Project: Flink

[VOTE] Release 1.8.3, release candidate #2

2019-12-02 Thread Hequn Cheng
Hi everyone, Please review and vote on the release candidate #2 for the version 1.8.3, 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],

[jira] [Created] (FLINK-15019) publish blog and document Flink-Hive benchmark v.s. Hive on MR/Tez

2019-12-02 Thread Bowen Li (Jira)
Bowen Li created FLINK-15019: Summary: publish blog and document Flink-Hive benchmark v.s. Hive on MR/Tez Key: FLINK-15019 URL: https://issues.apache.org/jira/browse/FLINK-15019 Project: Flink

[jira] [Created] (FLINK-15018) Add event time page to Concepts

2019-12-02 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-15018: Summary: Add event time page to Concepts Key: FLINK-15018 URL: https://issues.apache.org/jira/browse/FLINK-15018 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-15017) add a thrift jdbc/odbc server for Flink

2019-12-02 Thread Bowen Li (Jira)
Bowen Li created FLINK-15017: Summary: add a thrift jdbc/odbc server for Flink Key: FLINK-15017 URL: https://issues.apache.org/jira/browse/FLINK-15017 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-15016) Remove unused dependency

2019-12-02 Thread Jira
César Soto Valero created FLINK-15016: - Summary: Remove unused dependency Key: FLINK-15016 URL: https://issues.apache.org/jira/browse/FLINK-15016 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-15015) add documentation for using orc reader in hive connector

2019-12-02 Thread Bowen Li (Jira)
Bowen Li created FLINK-15015: Summary: add documentation for using orc reader in hive connector Key: FLINK-15015 URL: https://issues.apache.org/jira/browse/FLINK-15015 Project: Flink Issue Type:

Re: [DISCUSS] Drop vendor specific deployment documentation.

2019-12-02 Thread Konstantin Knauf
+1 from my side to drop. On Mon, Dec 2, 2019 at 6:34 PM Seth Wiesman wrote: > Hi all, > > I'd like to discuss dropping vendor-specific deployment documentation from > Flink's official docs. To be clear, I am *NOT* suggesting we drop any of > the filesystem documentation, but the following three

[DISCUSS] Drop vendor specific deployment documentation.

2019-12-02 Thread Seth Wiesman
Hi all, I'd like to discuss dropping vendor-specific deployment documentation from Flink's official docs. To be clear, I am *NOT* suggesting we drop any of the filesystem documentation, but the following three pages. AWS:

[jira] [Created] (FLINK-15014) Refactor KeyedStateInputFormat to support multiple types of user functions

2019-12-02 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-15014: Summary: Refactor KeyedStateInputFormat to support multiple types of user functions Key: FLINK-15014 URL: https://issues.apache.org/jira/browse/FLINK-15014 Project:

[jira] [Created] (FLINK-15013) Flink (on YARN) sometimes needs too many slots

2019-12-02 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-15013: Summary: Flink (on YARN) sometimes needs too many slots Key: FLINK-15013 URL: https://issues.apache.org/jira/browse/FLINK-15013 Project: Flink Issue

[jira] [Created] (FLINK-15012) Checkpoint directory not cleaned up

2019-12-02 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-15012: --- Summary: Checkpoint directory not cleaned up Key: FLINK-15012 URL: https://issues.apache.org/jira/browse/FLINK-15012 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-15011) RocksDB temp directory not cleaned up

2019-12-02 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-15011: --- Summary: RocksDB temp directory not cleaned up Key: FLINK-15011 URL: https://issues.apache.org/jira/browse/FLINK-15011 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-15010) Temp directories flink-netty-shuffle-* are not cleaned up

2019-12-02 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-15010: --- Summary: Temp directories flink-netty-shuffle-* are not cleaned up Key: FLINK-15010 URL: https://issues.apache.org/jira/browse/FLINK-15010 Project: Flink

[jira] [Created] (FLINK-15009) Add a utility for creating type inference logic via reflection

2019-12-02 Thread Timo Walther (Jira)
Timo Walther created FLINK-15009: Summary: Add a utility for creating type inference logic via reflection Key: FLINK-15009 URL: https://issues.apache.org/jira/browse/FLINK-15009 Project: Flink

[jira] [Created] (FLINK-15008) Tests in flink-yarn-tests fail with ClassNotFoundException (JDK11)

2019-12-02 Thread Gary Yao (Jira)
Gary Yao created FLINK-15008: Summary: Tests in flink-yarn-tests fail with ClassNotFoundException (JDK11) Key: FLINK-15008 URL: https://issues.apache.org/jira/browse/FLINK-15008 Project: Flink

Re: [DISCUSS] PyFlink User-Defined Function Resource Management

2019-12-02 Thread Jingsong Lee
Hi Dian: Thanks for you explanation. If you can update the document to add explanation for the changes to the table layer, it might be better. (it's just a suggestion, it depends on you) About forwardedInputQueue in AbstractPythonScalarFunctionOperator, Will this queue take up a lot of memory?

Re: [VOTE] Setup a secur...@flink.apache.org mailing list

2019-12-02 Thread Chesnay Schepler
Would security@f.a.o work as any other private ML? Contrary to what Becket said in the discussion thread, secur...@apache.org is not just "another hop"; it provides guiding material, the security team checks for activity and can be pinged easily as they are cc'd in the initial report. I

Re: [VOTE] FLIP-88: PyFlink User-Defined Function Resource Management

2019-12-02 Thread Dian Fu
Hi Jingsong, It's fine. :) Appreciated the comments! I have replied you in the discussion thread as I also think it's better to discuss these in the discussion thread. Thanks, Dian > 在 2019年12月2日,下午3:47,Jingsong Li 写道: > > Sorry for bothering your voting. > Let's discuss in discussion

Re: [DISCUSS] PyFlink User-Defined Function Resource Management

2019-12-02 Thread Dian Fu
Hi Jingsong, Thanks a lot for your comments. Please see my reply inlined below. > 在 2019年12月2日,下午3:47,Jingsong Lee 写道: > > Hi Dian: > > > Thanks for your driving. I have some questions: > > > - Where should these configurations belong? You have mentioned tableApi/SQL, > so should in

[jira] [Created] (FLINK-15007) Flink on YARN does not request required TaskExecutors in some cases

2019-12-02 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-15007: Summary: Flink on YARN does not request required TaskExecutors in some cases Key: FLINK-15007 URL: https://issues.apache.org/jira/browse/FLINK-15007 Project:

[jira] [Created] (FLINK-15006) Add option to close shuffle when dynamic partition inserting

2019-12-02 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-15006: Summary: Add option to close shuffle when dynamic partition inserting Key: FLINK-15006 URL: https://issues.apache.org/jira/browse/FLINK-15006 Project: Flink