[jira] [Created] (FLINK-20914) Format the description of 'security.ssl.internal.session-cache-size' option

2021-01-10 Thread Ruguo Yu (Jira)
Ruguo Yu created FLINK-20914: Summary: Format the description of 'security.ssl.internal.session-cache-size' option Key: FLINK-20914 URL: https://issues.apache.org/jira/browse/FLINK-20914 Project: Flink

[jira] [Created] (FLINK-20915) Move docker-entrypoint.sh logic into disrtibution

2021-01-10 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-20915: Summary: Move docker-entrypoint.sh logic into disrtibution Key: FLINK-20915 URL: https://issues.apache.org/jira/browse/FLINK-20915 Project: Flink

Re: Re: [DISCUSS] FLIP-147: Support Checkpoints After Tasks Finished

2021-01-10 Thread Khachatryan Roman
Thanks a lot for your answers Yun, > In detail, support we have a job with the graph A -> B -> C, support in one checkpoint A has reported FINISHED, CheckpointCoordinator would > choose B as the new "source" to trigger checkpoint via RPC. For task B, if it received checkpoint trigger, it would

[jira] [Created] (FLINK-20916) Typo in test for CVE-2020-17519

2021-01-10 Thread nate (Jira)
nate created FLINK-20916: Summary: Typo in test for CVE-2020-17519 Key: FLINK-20916 URL: https://issues.apache.org/jira/browse/FLINK-20916 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-20917) can not drop hive partition on flink

2021-01-10 Thread Spongebob (Jira)
Spongebob created FLINK-20917: - Summary: can not drop hive partition on flink Key: FLINK-20917 URL: https://issues.apache.org/jira/browse/FLINK-20917 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20910) Remove restriction on StreamPhysicalGroupWindowAggregate that StreamPhysicalGroupWindowAggregate only support insert-only input node

2021-01-10 Thread Andy (Jira)
Andy created FLINK-20910: Summary: Remove restriction on StreamPhysicalGroupWindowAggregate that StreamPhysicalGroupWindowAggregate only support insert-only input node Key: FLINK-20910 URL:

[jira] [Created] (FLINK-20913) Got TTransportException while querying Hive tables

2021-01-10 Thread Xingxing Di (Jira)
Xingxing Di created FLINK-20913: --- Summary: Got TTransportException while querying Hive tables Key: FLINK-20913 URL: https://issues.apache.org/jira/browse/FLINK-20913 Project: Flink Issue Type:

[jira] [Created] (FLINK-20911) Support to modify RocksDB LOG level

2021-01-10 Thread fanrui (Jira)
fanrui created FLINK-20911: -- Summary: Support to modify RocksDB LOG level Key: FLINK-20911 URL: https://issues.apache.org/jira/browse/FLINK-20911 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-20912) Increase Log and Metric: Time consumed by Checkpoint Restore

2021-01-10 Thread fanrui (Jira)
fanrui created FLINK-20912: -- Summary: Increase Log and Metric: Time consumed by Checkpoint Restore Key: FLINK-20912 URL: https://issues.apache.org/jira/browse/FLINK-20912 Project: Flink Issue

[jira] [Created] (FLINK-20918) Avoid excessive flush of Hadoop output stream

2021-01-10 Thread Paul Lin (Jira)
Paul Lin created FLINK-20918: Summary: Avoid excessive flush of Hadoop output stream Key: FLINK-20918 URL: https://issues.apache.org/jira/browse/FLINK-20918 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20921) Support SqlTimeTypeInfo in Python DataStream

2021-01-10 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-20921: Summary: Support SqlTimeTypeInfo in Python DataStream Key: FLINK-20921 URL: https://issues.apache.org/jira/browse/FLINK-20921 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20919) After the flink batch job is completed, the yarn application cannot be completed.

2021-01-10 Thread Wu (Jira)
Wu created FLINK-20919: -- Summary: After the flink batch job is completed, the yarn application cannot be completed. Key: FLINK-20919 URL: https://issues.apache.org/jira/browse/FLINK-20919 Project: Flink

Re: [VOTE] FLIP-153: Support state access in Python DataStream API

2021-01-10 Thread Becket Qin
+1 (binding) Thanks for driving the FLIP, Shuiqiang. Jiangjie (Becket) Qin On Wed, Jan 6, 2021 at 2:58 PM Yun Tang wrote: > +1 (binding) > > Best > Yun Tang > > From: Wei Zhong > Sent: Wednesday, January 6, 2021 14:07 > To: dev > Subject: Re: [VOTE]

[jira] [Created] (FLINK-20922) row() function cannot accpet . as arguments

2021-01-10 Thread Kevin Ma (Jira)
Kevin Ma created FLINK-20922: - Summary: row() function cannot accpet . as arguments Key: FLINK-20922 URL: https://issues.apache.org/jira/browse/FLINK-20922 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20920) Document how to connect to kerberized HMS

2021-01-10 Thread Rui Li (Jira)
Rui Li created FLINK-20920: -- Summary: Document how to connect to kerberized HMS Key: FLINK-20920 URL: https://issues.apache.org/jira/browse/FLINK-20920 Project: Flink Issue Type: Task