[jira] [Created] (FLINK-23733) sdsd

2021-08-11 Thread kaohaonan (Jira)
kaohaonan created FLINK-23733: - Summary: sdsd Key: FLINK-23733 URL: https://issues.apache.org/jira/browse/FLINK-23733 Project: Flink Issue Type: Improvement Affects Versions: 1.14.0

[jira] [Created] (FLINK-23732) StatefulJobSavepointMigrationITCase.testRestoreSavepoint fails due to LoggerInitializationException

2021-08-11 Thread Xintong Song (Jira)
Xintong Song created FLINK-23732: Summary: StatefulJobSavepointMigrationITCase.testRestoreSavepoint fails due to LoggerInitializationException Key: FLINK-23732 URL:

[jira] [Created] (FLINK-23731) Streaming File Sink s3 end-to-end test fail due to timeout

2021-08-11 Thread Xintong Song (Jira)
Xintong Song created FLINK-23731: Summary: Streaming File Sink s3 end-to-end test fail due to timeout Key: FLINK-23731 URL: https://issues.apache.org/jira/browse/FLINK-23731 Project: Flink

[jira] [Created] (FLINK-23730) Source from hive sink hbase lost data

2021-08-11 Thread Carl (Jira)
Carl created FLINK-23730: Summary: Source from hive sink hbase lost data Key: FLINK-23730 URL: https://issues.apache.org/jira/browse/FLINK-23730 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-23729) sql-client.sh fails on Git Bash for Windows, MinGW & MSYS2

2021-08-11 Thread Derek Moore (Jira)
Derek Moore created FLINK-23729: --- Summary: sql-client.sh fails on Git Bash for Windows, MinGW & MSYS2 Key: FLINK-23729 URL: https://issues.apache.org/jira/browse/FLINK-23729 Project: Flink

[jira] [Created] (FLINK-23728) Support new state backend factory stack in State Processor API

2021-08-11 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-23728: Summary: Support new state backend factory stack in State Processor API Key: FLINK-23728 URL: https://issues.apache.org/jira/browse/FLINK-23728 Project: Flink

[jira] [Created] (FLINK-23727) Skip null values in SimpleStringSchema

2021-08-11 Thread Paul Lin (Jira)
Paul Lin created FLINK-23727: Summary: Skip null values in SimpleStringSchema Key: FLINK-23727 URL: https://issues.apache.org/jira/browse/FLINK-23727 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-23726) Buffer debloat configuration is taken from the wrong configuration

2021-08-11 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-23726: - Summary: Buffer debloat configuration is taken from the wrong configuration Key: FLINK-23726 URL: https://issues.apache.org/jira/browse/FLINK-23726

[jira] [Created] (FLINK-23725) HadoopFsCommitter, Prompt for file rename failure

2021-08-11 Thread todd (Jira)
todd created FLINK-23725: Summary: HadoopFsCommitter, Prompt for file rename failure Key: FLINK-23725 URL: https://issues.apache.org/jira/browse/FLINK-23725 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-23724) Network buffer leak when ResultPartition is released (failover)

2021-08-11 Thread Yingjie Cao (Jira)
Yingjie Cao created FLINK-23724: --- Summary: Network buffer leak when ResultPartition is released (failover) Key: FLINK-23724 URL: https://issues.apache.org/jira/browse/FLINK-23724 Project: Flink

Re:Re: [ANNOUNCE] RocksDB Version Upgrade and Performance

2021-08-11 Thread 张蛟
Hi, Nico and yun: Thanks for your great work and detail description on rocksdb version upgrade and performance. About 800 jobs are using rocksdb state backend in our production environment, and we plan to upgrade more aim to solve the gc problems caused by large states.Because of

[jira] [Created] (FLINK-23723) Look up join support PROCTIME() function

2021-08-11 Thread silence (Jira)
silence created FLINK-23723: --- Summary: Look up join support PROCTIME() function Key: FLINK-23723 URL: https://issues.apache.org/jira/browse/FLINK-23723 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-23722) S3 Tests fail on AZP: Unable to find a region via the region provider chain. Must provide an explicit region in the builder or setup environment to supply a region.

2021-08-11 Thread Arvid Heise (Jira)
Arvid Heise created FLINK-23722: --- Summary: S3 Tests fail on AZP: Unable to find a region via the region provider chain. Must provide an explicit region in the builder or setup environment to supply a region. Key: FLINK-23722

[jira] [Created] (FLINK-23721) Flink SQL state TTL has no effect when using non-incremental RocksDBStateBackend

2021-08-11 Thread Q Kang (Jira)
Q Kang created FLINK-23721: -- Summary: Flink SQL state TTL has no effect when using non-incremental RocksDBStateBackend Key: FLINK-23721 URL: https://issues.apache.org/jira/browse/FLINK-23721 Project: Flink

Re: [DISCUSS] FLIP-173: Support DAG of algorithms (Flink ML)

2021-08-11 Thread Becket Qin
Hi Zhipeng, It looks like there are three different but potentially related things here. 1. How to describe multiple output of a node in the DAG. 2. How to construct / describe the DAG. 3. Do we need an encapsulation class of a DAG, e.g. the Graph class in option 1? It is much easier to discuss

[jira] [Created] (FLINK-23720) Migrate ModuleFactory to the new factory stack

2021-08-11 Thread Jira
Ingo Bürk created FLINK-23720: - Summary: Migrate ModuleFactory to the new factory stack Key: FLINK-23720 URL: https://issues.apache.org/jira/browse/FLINK-23720 Project: Flink Issue Type: