[jira] [Created] (FLINK-22059) add a new option is rocksdb statebackend to enable job threads setting

2021-03-30 Thread xiaogang zhou (Jira)
xiaogang zhou created FLINK-22059: - Summary: add a new option is rocksdb statebackend to enable job threads setting Key: FLINK-22059 URL: https://issues.apache.org/jira/browse/FLINK-22059 Project:

[jira] [Created] (FLINK-22058) Support FLIP-27 based NumberSequenceSource connector in PyFlink DataStream API

2021-03-30 Thread Dian Fu (Jira)
Dian Fu created FLINK-22058: --- Summary: Support FLIP-27 based NumberSequenceSource connector in PyFlink DataStream API Key: FLINK-22058 URL: https://issues.apache.org/jira/browse/FLINK-22058 Project: Flink

[jira] [Created] (FLINK-22057) Flink client submitting Flink job remotely to Flink cluster through Loadbalancer rest service

2021-03-30 Thread Bhagi (Jira)
Bhagi created FLINK-22057: - Summary: Flink client submitting Flink job remotely to Flink cluster through Loadbalancer rest service Key: FLINK-22057 URL: https://issues.apache.org/jira/browse/FLINK-22057

[jira] [Created] (FLINK-22056) FlinkKafkaProducerITCase failed because of "producer leak".

2021-03-30 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-22056: - Summary: FlinkKafkaProducerITCase failed because of "producer leak". Key: FLINK-22056 URL: https://issues.apache.org/jira/browse/FLINK-22056 Project: Flink Issue

[jira] [Created] (FLINK-22055) RPC main thread executor may schedule commands with wrong time unit of delay

2021-03-30 Thread Xintong Song (Jira)
Xintong Song created FLINK-22055: Summary: RPC main thread executor may schedule commands with wrong time unit of delay Key: FLINK-22055 URL: https://issues.apache.org/jira/browse/FLINK-22055

[jira] [Created] (FLINK-22054) Using a shared watcher for ConfigMap watching

2021-03-30 Thread Yi Tang (Jira)
Yi Tang created FLINK-22054: --- Summary: Using a shared watcher for ConfigMap watching Key: FLINK-22054 URL: https://issues.apache.org/jira/browse/FLINK-22054 Project: Flink Issue Type: Improvement

[GitHub] [flink-ml] lindong28 commented on pull request #2: [FLINK-22013] Add Github Actions to flink-ml for every push and pull request

2021-03-30 Thread GitBox
lindong28 commented on pull request #2: URL: https://github.com/apache/flink-ml/pull/2#issuecomment-810706284 @becketqin Could you review this PR? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [flink-ml] lindong28 opened a new pull request #2: [FLINK-22013] Add Github Actions to flink-ml for every push and pull request

2021-03-30 Thread GitBox
lindong28 opened a new pull request #2: URL: https://github.com/apache/flink-ml/pull/2 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service,

Re: Flink job cannot find recover path after using entropy injection for s3 file systems

2021-03-30 Thread chenqin
link fix pr here https://github.com/apache/flink/pull/15442 we might need someone help review and merge meanwhile. -- Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/

[jira] [Created] (FLINK-22053) Recovery of a completed split in NumberSequenceSource causes fatal exception.

2021-03-30 Thread Arvid Heise (Jira)
Arvid Heise created FLINK-22053: --- Summary: Recovery of a completed split in NumberSequenceSource causes fatal exception. Key: FLINK-22053 URL: https://issues.apache.org/jira/browse/FLINK-22053 Project:

[jira] [Created] (FLINK-22052) Add FLIP-142 changes to PyFlink

2021-03-30 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-22052: Summary: Add FLIP-142 changes to PyFlink Key: FLINK-22052 URL: https://issues.apache.org/jira/browse/FLINK-22052 Project: Flink Issue Type: Sub-task

Re: flink 1.11 class loading question

2021-03-30 Thread chenqin
Hi Till, We did some investigation and found this memory usage point to rocksdbstatebackend running on managed memory. So far we have seen this bug in rocksdbstatebackend on managed memory. we followed suggestion [1] and disabled managed memory management so far not seeing issue. I felt this

Re: Glob support on file access

2021-03-30 Thread Etienne Chauchot
Hi, FYI: I just submitted the small PR to support this: https://github.com/apache/flink/pull/15436 Best Etienne On 29/03/2021 20:05, Arvid Heise wrote: Hi Etienne, In general, any small PR on this subject is very welcome. I don't think that the community as a whole will invest much into

[jira] [Created] (FLINK-22051) Better document the distinction between stop-with-savepoint and stop-with-savepoint-with-drain

2021-03-30 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-22051: - Summary: Better document the distinction between stop-with-savepoint and stop-with-savepoint-with-drain Key: FLINK-22051 URL: https://issues.apache.org/jira/browse/FLINK-22051

[jira] [Created] (FLINK-22050) Failed to release input gate (IllegalReferenceCountException)

2021-03-30 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-22050: - Summary: Failed to release input gate (IllegalReferenceCountException) Key: FLINK-22050 URL: https://issues.apache.org/jira/browse/FLINK-22050 Project:

[jira] [Created] (FLINK-22049) Simplify calculating the starting index of the local key-group range in InternalTimerServiceImpl constructor.

2021-03-30 Thread ZhangWei (Jira)
ZhangWei created FLINK-22049: Summary: Simplify calculating the starting index of the local key-group range in InternalTimerServiceImpl constructor. Key: FLINK-22049 URL:

[jira] [Created] (FLINK-22048) Remove unnecessary akka.transport.* configuration options

2021-03-30 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-22048: - Summary: Remove unnecessary akka.transport.* configuration options Key: FLINK-22048 URL: https://issues.apache.org/jira/browse/FLINK-22048 Project: Flink

[jira] [Created] (FLINK-22047) Could not find FLINSHED Flink job and can't submit job

2021-03-30 Thread hayden zhou (Jira)
hayden zhou created FLINK-22047: --- Summary: Could not find FLINSHED Flink job and can't submit job Key: FLINK-22047 URL: https://issues.apache.org/jira/browse/FLINK-22047 Project: Flink Issue

[jira] [Created] (FLINK-22046) org.apache.flink.cep.nfa.State#toString() may has a abnormal format

2021-03-30 Thread shiqihao (Jira)
shiqihao created FLINK-22046: Summary: org.apache.flink.cep.nfa.State#toString() may has a abnormal format Key: FLINK-22046 URL: https://issues.apache.org/jira/browse/FLINK-22046 Project: Flink

[jira] [Created] (FLINK-22045) Set log level for shaded zookeeper logger

2021-03-30 Thread Matthias (Jira)
Matthias created FLINK-22045: Summary: Set log level for shaded zookeeper logger Key: FLINK-22045 URL: https://issues.apache.org/jira/browse/FLINK-22045 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-22044) running job from Flink client(cli) from outside Flink jobmanager pod

2021-03-30 Thread Bhagi (Jira)
Bhagi created FLINK-22044: - Summary: running job from Flink client(cli) from outside Flink jobmanager pod Key: FLINK-22044 URL: https://issues.apache.org/jira/browse/FLINK-22044 Project: Flink

[jira] [Created] (FLINK-22043) Introduce thrift format to (de)serialize thrift message only with table

2021-03-30 Thread jinfeng (Jira)
jinfeng created FLINK-22043: --- Summary: Introduce thrift format to (de)serialize thrift message only with table Key: FLINK-22043 URL: https://issues.apache.org/jira/browse/FLINK-22043 Project: Flink

Re: [DISCUSS] Releasing Stateful Functions 3.0.0

2021-03-30 Thread Tzu-Li (Gordon) Tai
@Konstantin Knauf Yes, we'll make sure that migration docs are added before finalizing the release. I've proceeded to create RC1 for StateFun 3.0.0. Voting is happening on a separate thread. On Tue, Mar 30, 2021 at 3:06 AM Robert Metzger wrote: > Wow, the feature list sounds really exciting!

[VOTE] Apache Flink Stateful Functions 3.0.0, release candidate #1

2021-03-30 Thread Tzu-Li (Gordon) Tai
Hi everyone, Please review and vote on the release candidate #1 for the version 3.0.0 of Apache Flink Stateful Functions, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) **Testing Guideline** You can find here [1] a page in the

[jira] [Created] (FLINK-22042) Fix reading bigint(20) UNSIGNED type field cannot be cast

2021-03-30 Thread jingzi (Jira)
jingzi created FLINK-22042: -- Summary: Fix reading bigint(20) UNSIGNED type field cannot be cast Key: FLINK-22042 URL: https://issues.apache.org/jira/browse/FLINK-22042 Project: Flink Issue Type:

[jira] [Created] (FLINK-22041) Configure DataStreamAllroundTest via Configuration instead of ParameterTool

2021-03-30 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-22041: - Summary: Configure DataStreamAllroundTest via Configuration instead of ParameterTool Key: FLINK-22041 URL: https://issues.apache.org/jira/browse/FLINK-22041

[jira] [Created] (FLINK-22040) Maven: Entry has not been leased from this pool / fix for e2e tests

2021-03-30 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-22040: -- Summary: Maven: Entry has not been leased from this pool / fix for e2e tests Key: FLINK-22040 URL: https://issues.apache.org/jira/browse/FLINK-22040 Project:

[jira] [Created] (FLINK-22038) Update TopN node to be without rowNumber if rowNumber field is projected out after TopN

2021-03-30 Thread Andy (Jira)
Andy created FLINK-22038: Summary: Update TopN node to be without rowNumber if rowNumber field is projected out after TopN Key: FLINK-22038 URL: https://issues.apache.org/jira/browse/FLINK-22038 Project:

[jira] [Created] (FLINK-22037) Remove the redundant blocking queue from DeployingTasksBenchmarkBase

2021-03-30 Thread Zhilong Hong (Jira)
Zhilong Hong created FLINK-22037: Summary: Remove the redundant blocking queue from DeployingTasksBenchmarkBase Key: FLINK-22037 URL: https://issues.apache.org/jira/browse/FLINK-22037 Project: Flink

[jira] [Created] (FLINK-22036) Document Jira Bot in Flink Confluence

2021-03-30 Thread Konstantin Knauf (Jira)
Konstantin Knauf created FLINK-22036: Summary: Document Jira Bot in Flink Confluence Key: FLINK-22036 URL: https://issues.apache.org/jira/browse/FLINK-22036 Project: Flink Issue Type:

[jira] [Created] (FLINK-22034) Add Rule 1

2021-03-30 Thread Konstantin Knauf (Jira)
Konstantin Knauf created FLINK-22034: Summary: Add Rule 1 Key: FLINK-22034 URL: https://issues.apache.org/jira/browse/FLINK-22034 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-22035) Run Jira Bot periodically with Github Actions

2021-03-30 Thread Konstantin Knauf (Jira)
Konstantin Knauf created FLINK-22035: Summary: Run Jira Bot periodically with Github Actions Key: FLINK-22035 URL: https://issues.apache.org/jira/browse/FLINK-22035 Project: Flink Issue

[jira] [Created] (FLINK-22033) Add Rule 2

2021-03-30 Thread Konstantin Knauf (Jira)
Konstantin Knauf created FLINK-22033: Summary: Add Rule 2 Key: FLINK-22033 URL: https://issues.apache.org/jira/browse/FLINK-22033 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-22032) Implement Rule 3 First (Simplest Rule)

2021-03-30 Thread Konstantin Knauf (Jira)
Konstantin Knauf created FLINK-22032: Summary: Implement Rule 3 First (Simplest Rule) Key: FLINK-22032 URL: https://issues.apache.org/jira/browse/FLINK-22032 Project: Flink Issue Type:

[jira] [Created] (FLINK-22030) Add Technical Debt Issue Type

2021-03-30 Thread Konstantin Knauf (Jira)
Konstantin Knauf created FLINK-22030: Summary: Add Technical Debt Issue Type Key: FLINK-22030 URL: https://issues.apache.org/jira/browse/FLINK-22030 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-22029) Remove "Task", "Wish" and "Test" Issue Types

2021-03-30 Thread Konstantin Knauf (Jira)
Konstantin Knauf created FLINK-22029: Summary: Remove "Task", "Wish" and "Test" Issue Types Key: FLINK-22029 URL: https://issues.apache.org/jira/browse/FLINK-22029 Project: Flink Issue

[jira] [Created] (FLINK-22028) Remove "Trivial" Ticket Priority

2021-03-30 Thread Konstantin Knauf (Jira)
Konstantin Knauf created FLINK-22028: Summary: Remove "Trivial" Ticket Priority Key: FLINK-22028 URL: https://issues.apache.org/jira/browse/FLINK-22028 Project: Flink Issue Type:

[jira] [Created] (FLINK-22027) Create separate repository for Jira Bot

2021-03-30 Thread Konstantin Knauf (Jira)
Konstantin Knauf created FLINK-22027: Summary: Create separate repository for Jira Bot Key: FLINK-22027 URL: https://issues.apache.org/jira/browse/FLINK-22027 Project: Flink Issue Type:

[jira] [Created] (FLINK-22026) Improved Jira Process & Bot

2021-03-30 Thread Konstantin Knauf (Jira)
Konstantin Knauf created FLINK-22026: Summary: Improved Jira Process & Bot Key: FLINK-22026 URL: https://issues.apache.org/jira/browse/FLINK-22026 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-22025) SurefireBooterForkException: ExecutionException Error occurred in starting fork

2021-03-30 Thread Matthias (Jira)
Matthias created FLINK-22025: Summary: SurefireBooterForkException: ExecutionException Error occurred in starting fork Key: FLINK-22025 URL: https://issues.apache.org/jira/browse/FLINK-22025 Project:

[jira] [Created] (FLINK-22024) Maven: Entry has not been leased from this pool

2021-03-30 Thread Matthias (Jira)
Matthias created FLINK-22024: Summary: Maven: Entry has not been leased from this pool Key: FLINK-22024 URL: https://issues.apache.org/jira/browse/FLINK-22024 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-22023) Remove outdated StateFun quickstart archetype

2021-03-30 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-22023: --- Summary: Remove outdated StateFun quickstart archetype Key: FLINK-22023 URL: https://issues.apache.org/jira/browse/FLINK-22023 Project: Flink