Re: I create a hotfix pull request in `MiniCluster.java`, thanks!

2020-11-25 Thread 左元
Hi Jark Thanks for advcing!Wish I can contribute more for flink project! Yuan Zuo | | 左元 | | 邮箱:zuoyua...@126.com | On 11/26/2020 13:57, Jark Wu wrote: Hi Yuan, Thanks for contributing to Flink. I have helped to merge this PR. For the pull requests without JIRA id, it would be better to

[jira] [Created] (FLINK-20367) Show the in-use config of job to users

2020-11-25 Thread zlzhang0122 (Jira)
zlzhang0122 created FLINK-20367: --- Summary: Show the in-use config of job to users Key: FLINK-20367 URL: https://issues.apache.org/jira/browse/FLINK-20367 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-20366) ColumnIntervalUtil#getColumnIntervalWithFilter does not consider the case when the predicate is a false constant

2020-11-25 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-20366: --- Summary: ColumnIntervalUtil#getColumnIntervalWithFilter does not consider the case when the predicate is a false constant Key: FLINK-20366 URL:

[ANNOUNCE] release-1.12 branch cut

2020-11-25 Thread Dian Fu
Hi all, We have already cut the release-1.12 branch from the master branch based on c008907d2a629449c8d0ad9725d13b0604fc2141 commit. Please make sure that the PR is merged to both master and release-1.12 branch if you want it to be present in 1.12.0. Please also set the correct fix version in

Re: I create a hotfix pull request in `MiniCluster.java`, thanks!

2020-11-25 Thread Jark Wu
Hi Yuan, Thanks for contributing to Flink. I have helped to merge this PR. For the pull requests without JIRA id, it would be better to ping/request review from the committers in the PR (there is a suggestion reviewer in the right sidebar). Because such pull requests usually can't be notified to

[jira] [Created] (FLINK-20365) The native k8s cluster could not be unregistered when executing Python DataStream application attachedly.

2020-11-25 Thread Shuiqiang Chen (Jira)
Shuiqiang Chen created FLINK-20365: -- Summary: The native k8s cluster could not be unregistered when executing Python DataStream application attachedly. Key: FLINK-20365 URL:

[jira] [Created] (FLINK-20364) Add support for scheduling with slot sharing

2020-11-25 Thread Guruh Fajar Samudra (Jira)
Guruh Fajar Samudra created FLINK-20364: --- Summary: Add support for scheduling with slot sharing Key: FLINK-20364 URL: https://issues.apache.org/jira/browse/FLINK-20364 Project: Flink

[jira] [Created] (FLINK-20363) "Batch SQL end-to-end test" failed during shutdown

2020-11-25 Thread Dian Fu (Jira)
Dian Fu created FLINK-20363: --- Summary: "Batch SQL end-to-end test" failed during shutdown Key: FLINK-20363 URL: https://issues.apache.org/jira/browse/FLINK-20363 Project: Flink Issue Type: Test

[jira] [Created] (FLINK-20362) Broken Link in dev/table/sourceSinks.zh.md

2020-11-25 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-20362: Summary: Broken Link in dev/table/sourceSinks.zh.md Key: FLINK-20362 URL: https://issues.apache.org/jira/browse/FLINK-20362 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20361) Using sliding window with duration of hours in Table API returns wrong time

2020-11-25 Thread Aleksandra Cz (Jira)
Aleksandra Cz created FLINK-20361: - Summary: Using sliding window with duration of hours in Table API returns wrong time Key: FLINK-20361 URL: https://issues.apache.org/jira/browse/FLINK-20361

[jira] [Created] (FLINK-20360) AbstractFetcherWatermarksTest$PeriodicWatermarksSuite.testPeriodicWatermarks is unstable

2020-11-25 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-20360: -- Summary: AbstractFetcherWatermarksTest$PeriodicWatermarksSuite.testPeriodicWatermarks is unstable Key: FLINK-20360 URL: https://issues.apache.org/jira/browse/FLINK-20360

[jira] [Created] (FLINK-20359) Support adding Owner Reference to Job Manager in native kubernetes setup

2020-11-25 Thread Boris Lublinsky (Jira)
Boris Lublinsky created FLINK-20359: --- Summary: Support adding Owner Reference to Job Manager in native kubernetes setup Key: FLINK-20359 URL: https://issues.apache.org/jira/browse/FLINK-20359

[jira] [Created] (FLINK-20358) Support adding Owner Reference to Job Manager in native kubernetes setup

2020-11-25 Thread Boris Lublinsky (Jira)
Boris Lublinsky created FLINK-20358: --- Summary: Support adding Owner Reference to Job Manager in native kubernetes setup Key: FLINK-20358 URL: https://issues.apache.org/jira/browse/FLINK-20358

[jira] [Created] (FLINK-20357) Rework HA documentation page

2020-11-25 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-20357: - Summary: Rework HA documentation page Key: FLINK-20357 URL: https://issues.apache.org/jira/browse/FLINK-20357 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-20356) Rework Mesos deployment documentation page

2020-11-25 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-20356: - Summary: Rework Mesos deployment documentation page Key: FLINK-20356 URL: https://issues.apache.org/jira/browse/FLINK-20356 Project: Flink Issue Type:

[jira] [Created] (FLINK-20355) Rework K8s deployment documentation page

2020-11-25 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-20355: - Summary: Rework K8s deployment documentation page Key: FLINK-20355 URL: https://issues.apache.org/jira/browse/FLINK-20355 Project: Flink Issue Type:

[jira] [Created] (FLINK-20354) Rework standalone deployment documentation page

2020-11-25 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-20354: - Summary: Rework standalone deployment documentation page Key: FLINK-20354 URL: https://issues.apache.org/jira/browse/FLINK-20354 Project: Flink Issue

[jira] [Created] (FLINK-20353) Rework logging documentation page

2020-11-25 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-20353: - Summary: Rework logging documentation page Key: FLINK-20353 URL: https://issues.apache.org/jira/browse/FLINK-20353 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-20352) Rework command line interface documentation page

2020-11-25 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-20352: - Summary: Rework command line interface documentation page Key: FLINK-20352 URL: https://issues.apache.org/jira/browse/FLINK-20352 Project: Flink Issue

[jira] [Created] (FLINK-20351) Execution.transitionState does not properly log slot location

2020-11-25 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-20351: - Summary: Execution.transitionState does not properly log slot location Key: FLINK-20351 URL: https://issues.apache.org/jira/browse/FLINK-20351 Project: Flink

[jira] [Created] (FLINK-20350) [Kinesis][GCP PubSub] Incompatible Connectors due to Guava conflict

2020-11-25 Thread Danny Cranmer (Jira)
Danny Cranmer created FLINK-20350: - Summary: [Kinesis][GCP PubSub] Incompatible Connectors due to Guava conflict Key: FLINK-20350 URL: https://issues.apache.org/jira/browse/FLINK-20350 Project: Flink

[jira] [Created] (FLINK-20349) Query fails with "A conflict is detected. This is unexpected."

2020-11-25 Thread Rui Li (Jira)
Rui Li created FLINK-20349: -- Summary: Query fails with "A conflict is detected. This is unexpected." Key: FLINK-20349 URL: https://issues.apache.org/jira/browse/FLINK-20349 Project: Flink Issue

[jira] [Created] (FLINK-20348) Make "schema-registry.subject" optional for Kafka sink with avro-confluent format

2020-11-25 Thread Jark Wu (Jira)
Jark Wu created FLINK-20348: --- Summary: Make "schema-registry.subject" optional for Kafka sink with avro-confluent format Key: FLINK-20348 URL: https://issues.apache.org/jira/browse/FLINK-20348 Project:

[jira] [Created] (FLINK-20347) Rework YARN deployment documentation page

2020-11-25 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-20347: -- Summary: Rework YARN deployment documentation page Key: FLINK-20347 URL: https://issues.apache.org/jira/browse/FLINK-20347 Project: Flink Issue Type:

[jira] [Created] (FLINK-20346) Explain ChangelogMode for sinks

2020-11-25 Thread Timo Walther (Jira)
Timo Walther created FLINK-20346: Summary: Explain ChangelogMode for sinks Key: FLINK-20346 URL: https://issues.apache.org/jira/browse/FLINK-20346 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-20345) Adds an Expand node only when there are more then one distinct aggregate function in an Aggregate when executes SplitAggregateRule

2020-11-25 Thread zhangqingru (Jira)
zhangqingru created FLINK-20345: --- Summary: Adds an Expand node only when there are more then one distinct aggregate function in an Aggregate when executes SplitAggregateRule Key: FLINK-20345 URL:

[jira] [Created] (FLINK-20344) Modify the default value of the flink-conf savepoint folder to distinguish the checkpoint folder

2020-11-25 Thread OpenOpened (Jira)
OpenOpened created FLINK-20344: -- Summary: Modify the default value of the flink-conf savepoint folder to distinguish the checkpoint folder Key: FLINK-20344 URL: https://issues.apache.org/jira/browse/FLINK-20344

[jira] [Created] (FLINK-20343) Add overview / reference architecture page

2020-11-25 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-20343: -- Summary: Add overview / reference architecture page Key: FLINK-20343 URL: https://issues.apache.org/jira/browse/FLINK-20343 Project: Flink Issue Type:

[jira] [Created] (FLINK-20342) Revisit page structure

2020-11-25 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-20342: -- Summary: Revisit page structure Key: FLINK-20342 URL: https://issues.apache.org/jira/browse/FLINK-20342 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-20341) Rework Deployment / Coordination Documentation

2020-11-25 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-20341: -- Summary: Rework Deployment / Coordination Documentation Key: FLINK-20341 URL: https://issues.apache.org/jira/browse/FLINK-20341 Project: Flink Issue

I create a hotfix pull request in `MiniCluster.java`, thanks!

2020-11-25 Thread 左元
The Pull Request Number is #14211. Fix typo `dispatcherResourceManagreComponentRpcServiceFactory` -> `dispatcherResourceManagerComponentRpcServiceFactory` in `MiniCluster.java`