[GitHub] [flink] liuzhuang2017 commented on pull request #20640: [hotfix][docs] Fix some formatting errors in Chinese documents.

2022-09-29 Thread GitBox
liuzhuang2017 commented on PR #20640: URL: https://github.com/apache/flink/pull/20640#issuecomment-1263123390 @MartijnVisser , Sorry to bother you again, can you help me review this pull request? grateful. -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Commented] (FLINK-29479) support whether using system env for pythonpath

2022-09-29 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611359#comment-17611359 ] jackylau commented on FLINK-29479: -- {code:java} // conf like /** Whether preserves system env of

[jira] [Commented] (FLINK-29479) support whether using system env for pythonpath

2022-09-29 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611358#comment-17611358 ] jackylau commented on FLINK-29479: -- hi [~dianfu] [~hxbks2ks] , what do you think? > support whether

[jira] [Created] (FLINK-29479) support whether using system env for pythonpath

2022-09-29 Thread jackylau (Jira)
jackylau created FLINK-29479: Summary: support whether using system env for pythonpath Key: FLINK-29479 URL: https://issues.apache.org/jira/browse/FLINK-29479 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot commented on pull request #20928: [FLINK-29477][python] ClassCastException when collecting primitive array

2022-09-29 Thread GitBox
flinkbot commented on PR #20928: URL: https://github.com/apache/flink/pull/20928#issuecomment-1263110105 ## CI report: * 5923197261c4e8576634c8947636c5ccce501a43 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-29477) ClassCastException when collect primitive array to Python

2022-09-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29477: --- Labels: pull-request-available (was: ) > ClassCastException when collect primitive array

[GitHub] [flink] Vancior opened a new pull request, #20928: [FLINK-29477][python] ClassCastException when collecting primitive array

2022-09-29 Thread GitBox
Vancior opened a new pull request, #20928: URL: https://github.com/apache/flink/pull/20928 ## What is the purpose of the change This PR fixes a bug that throwing ClassCastException when `execute_and_collect` Java primitive array back to Python. ## Verifying this change

[jira] [Created] (FLINK-29478) Flink sql Connector hive to support 3.1.3

2022-09-29 Thread Samrat Deb (Jira)
Samrat Deb created FLINK-29478: -- Summary: Flink sql Connector hive to support 3.1.3 Key: FLINK-29478 URL: https://issues.apache.org/jira/browse/FLINK-29478 Project: Flink Issue Type:

[jira] [Closed] (FLINK-29381) Key_Shared subscription isn't works in the latest Pulsar connector

2022-09-29 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-29381. - Assignee: Yufan Sheng Resolution: Fixed > Key_Shared subscription isn't works in the latest

[jira] [Updated] (FLINK-26182) E2E test for PulsarSink on new Flink sink testing tools

2022-09-29 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-26182: -- Fix Version/s: 1.16.0 > E2E test for PulsarSink on new Flink sink testing tools >

[jira] [Closed] (FLINK-26182) E2E test for PulsarSink on new Flink sink testing tools

2022-09-29 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-26182. - Resolution: Fixed > E2E test for PulsarSink on new Flink sink testing tools >

[jira] [Updated] (FLINK-29381) Key_Shared subscription isn't works in the latest Pulsar connector

2022-09-29 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-29381: -- Affects Version/s: 1.15.2 (was: 1.15.3) > Key_Shared subscription isn't

[jira] [Updated] (FLINK-29381) Key_Shared subscription isn't works in the latest Pulsar connector

2022-09-29 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-29381: -- Fix Version/s: 1.15.3 > Key_Shared subscription isn't works in the latest Pulsar connector >

[jira] [Updated] (FLINK-26182) E2E test for PulsarSink on new Flink sink testing tools

2022-09-29 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-26182: -- Fix Version/s: 1.15.3 (was: 1.17.0) > E2E test for PulsarSink on new Flink

[GitHub] [flink] tisonkun merged pull request #20915: [BK-1.16][FLINK-26182][Connector/pulsar] Create a e2e tests for Pulsar sink.

2022-09-29 Thread GitBox
tisonkun merged PR #20915: URL: https://github.com/apache/flink/pull/20915 -- 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. To unsubscribe, e-mail:

[jira] [Commented] (FLINK-29308) NoResourceAvailableException fails the batch job

2022-09-29 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611349#comment-17611349 ] Zhu Zhu commented on FLINK-29308: - It's possible that the released resource cannot fulfill the new slot

[GitHub] [flink] HuangXingBo commented on pull request #20915: [BK-1.16][FLINK-26182][Connector/pulsar] Create a e2e tests for Pulsar sink.

2022-09-29 Thread GitBox
HuangXingBo commented on PR #20915: URL: https://github.com/apache/flink/pull/20915#issuecomment-1263069145 Yes. Make sense to me. -- 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

[GitHub] [flink] tisonkun merged pull request #20916: [BK-1.15][FLINK-26182][Connector/pulsar] Create a e2e tests for Pulsar sink.

2022-09-29 Thread GitBox
tisonkun merged PR #20916: URL: https://github.com/apache/flink/pull/20916 -- 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. To unsubscribe, e-mail:

[GitHub] [flink] tisonkun commented on pull request #20915: [BK-1.16][FLINK-26182][Connector/pulsar] Create a e2e tests for Pulsar sink.

2022-09-29 Thread GitBox
tisonkun commented on PR #20915: URL: https://github.com/apache/flink/pull/20915#issuecomment-1263068281 > Does this PR need to cancel rc1 No. Then I think I can merge this patch as a testing coverage improvement and bugfix now while you can still vote on the rc1 you made

[jira] [Commented] (FLINK-29088) Project push down cause the source reuse can not work

2022-09-29 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611341#comment-17611341 ] Aitozi commented on FLINK-29088: Hi, [~twalthr] looking forward to your feedback, thanks :) > Project

[jira] [Commented] (FLINK-28875) Add FlinkSessionJobControllerTest

2022-09-29 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611338#comment-17611338 ] Aitozi commented on FLINK-28875: Sorry [~gyfora], I have not start this work yet, I will try to push a

[jira] [Commented] (FLINK-29308) NoResourceAvailableException fails the batch job

2022-09-29 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611337#comment-17611337 ] Aitozi commented on FLINK-29308: In our use case, we just ignore the {{NoResourceAvailableException}} 

[jira] [Commented] (FLINK-29308) NoResourceAvailableException fails the batch job

2022-09-29 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611336#comment-17611336 ] Aitozi commented on FLINK-29308: Yes, but actually the job can keep to run when other slot finished and

[jira] [Comment Edited] (FLINK-29308) NoResourceAvailableException fails the batch job

2022-09-29 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611332#comment-17611332 ] Zhu Zhu edited comment on FLINK-29308 at 9/30/22 3:34 AM: -- That may be the

[GitHub] [flink] HuangXingBo commented on pull request #20915: [BK-1.16][FLINK-26182][Connector/pulsar] Create a e2e tests for Pulsar sink.

2022-09-29 Thread GitBox
HuangXingBo commented on PR #20915: URL: https://github.com/apache/flink/pull/20915#issuecomment-1263059241 @tisonkun Thanks a lot for the info. I prepared rc1 and have pushed the tag yesterday. When the release announcement is ready in the form of PR, I will send the vote email today.

[jira] [Commented] (FLINK-29308) NoResourceAvailableException fails the batch job

2022-09-29 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611332#comment-17611332 ] Zhu Zhu commented on FLINK-29308: - That may be the cause. If using fine grained resource,

[GitHub] [flink] dianfu commented on a diff in pull request #20742: [FLINK-29156]Support LISTAGG in the Table API

2022-09-29 Thread GitBox
dianfu commented on code in PR #20742: URL: https://github.com/apache/flink/pull/20742#discussion_r984165780 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/table/AggregateITCase.scala: ## @@ -259,6 +259,30 @@ class

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #156: [FLINK-29323] Refine Transformer for VectorAssembler

2022-09-29 Thread GitBox
yunfengzhou-hub commented on code in PR #156: URL: https://github.com/apache/flink-ml/pull/156#discussion_r984140802 ## docs/content/docs/operators/feature/vectorassembler.md: ## @@ -27,8 +27,10 @@ under the License. Review Comment: I found that `VectorSizeHint` is also

[jira] [Created] (FLINK-29477) ClassCastException when collect primitive array to Python

2022-09-29 Thread Juntao Hu (Jira)
Juntao Hu created FLINK-29477: - Summary: ClassCastException when collect primitive array to Python Key: FLINK-29477 URL: https://issues.apache.org/jira/browse/FLINK-29477 Project: Flink Issue

[jira] [Closed] (FLINK-29445) When the decimal table column field is printed,program is error

2022-09-29 Thread liuzhiyong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liuzhiyong closed FLINK-29445. -- Resolution: Abandoned > When the decimal table column field is printed,program is error >

[jira] [Commented] (FLINK-29445) When the decimal table column field is printed,program is error

2022-09-29 Thread liuzhiyong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611323#comment-17611323 ] liuzhiyong commented on FLINK-29445: ok I will try. > When the decimal table column field is

[GitHub] [flink] tisonkun commented on pull request #20915: [BK-1.16][FLINK-26182][Connector/pulsar] Create a e2e tests for Pulsar sink.

2022-09-29 Thread GitBox
tisonkun commented on PR #20915: URL: https://github.com/apache/flink/pull/20915#issuecomment-1263012489 @HuangXingBo This patch adds end-to-end tests for Flink Pulsar connector and I think it's good for backporting to 1.16. However, to pass the end-to-end tests it adjusts some production

[GitHub] [flink] tisonkun commented on pull request #20916: [BK-1.15][FLINK-26182][Connector/pulsar] Create a e2e tests for Pulsar sink.

2022-09-29 Thread GitBox
tisonkun commented on PR #20916: URL: https://github.com/apache/flink/pull/20916#issuecomment-1263010622 @flinkbot run azure -- 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.

[jira] [Updated] (FLINK-26182) E2E test for PulsarSink on new Flink sink testing tools

2022-09-29 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-26182: -- Fix Version/s: 1.17.0 > E2E test for PulsarSink on new Flink sink testing tools >

[GitHub] [flink] tisonkun merged pull request #20584: [FLINK-26182][Connector/pulsar] Create a e2e tests for Pulsar sink.

2022-09-29 Thread GitBox
tisonkun merged PR #20584: URL: https://github.com/apache/flink/pull/20584 -- 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. To unsubscribe, e-mail:

[jira] [Closed] (FLINK-29460) HsResultPartitionTest.testRelease failed with AssertionFailedError

2022-09-29 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-29460. Fix Version/s: 1.16.0 Resolution: Fixed - master (1.17):

[GitHub] [flink] xintongsong closed pull request #20918: [FLINK-29460] fix the unstable test HsResultPartitionTest.testRelease

2022-09-29 Thread GitBox
xintongsong closed pull request #20918: [FLINK-29460] fix the unstable test HsResultPartitionTest.testRelease URL: https://github.com/apache/flink/pull/20918 -- 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

[GitHub] [flink-ml] jiangxin369 commented on a diff in pull request #158: [FLINK-29409] Add Transformer and Estimator for VarianceThresholdSelector

2022-09-29 Thread GitBox
jiangxin369 commented on code in PR #158: URL: https://github.com/apache/flink-ml/pull/158#discussion_r984129745 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/variancethresholdselector/VarianceThresholdSelector.java: ## @@ -0,0 +1,218 @@ +/* + * Licensed to the

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #392: Backport 1.2.0 blockers

2022-09-29 Thread GitBox
gyfora merged PR #392: URL: https://github.com/apache/flink-kubernetes-operator/pull/392 -- 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. To unsubscribe, e-mail:

[GitHub] [flink-connector-elasticsearch] zentol commented on a diff in pull request #40: [FLINK-29471] Use connector parent pom

2022-09-29 Thread GitBox
zentol commented on code in PR #40: URL: https://github.com/apache/flink-connector-elasticsearch/pull/40#discussion_r983962292 ## pom.xml: ## @@ -408,380 +370,15 @@ under the License. flink-sql-connector-elasticsearch7

[GitHub] [flink-connector-elasticsearch] zentol commented on a diff in pull request #40: [FLINK-29471] Use connector parent pom

2022-09-29 Thread GitBox
zentol commented on code in PR #40: URL: https://github.com/apache/flink-connector-elasticsearch/pull/40#discussion_r983963215 ## pom.xml: ## @@ -901,484 +417,25 @@ under the License. maven-compiler-plugin -

[GitHub] [flink-connector-elasticsearch] zentol commented on a diff in pull request #40: [FLINK-29471] Use connector parent pom

2022-09-29 Thread GitBox
zentol commented on code in PR #40: URL: https://github.com/apache/flink-connector-elasticsearch/pull/40#discussion_r983961297 ## pom.xml: ## @@ -68,45 +50,25 @@ under the License. - UTF-8 - UTF-8 -

[GitHub] [flink-connector-elasticsearch] zentol commented on a diff in pull request #40: [FLINK-29471] Use connector parent pom

2022-09-29 Thread GitBox
zentol commented on code in PR #40: URL: https://github.com/apache/flink-connector-elasticsearch/pull/40#discussion_r983961607 ## pom.xml: ## @@ -408,380 +370,15 @@ under the License. flink-sql-connector-elasticsearch7

[GitHub] [flink-connector-elasticsearch] zentol commented on a diff in pull request #40: [FLINK-29471] Use connector parent pom

2022-09-29 Thread GitBox
zentol commented on code in PR #40: URL: https://github.com/apache/flink-connector-elasticsearch/pull/40#discussion_r983959761 ## pom.xml: ## @@ -68,45 +50,25 @@ under the License. - UTF-8 - UTF-8 -

[jira] [Updated] (FLINK-28645) Clean up logging in FlinkService / Reconciler

2022-09-29 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-28645: --- Fix Version/s: kubernetes-operator-1.3.0 (was: kubernetes-operator-1.2.0) >

[jira] [Updated] (FLINK-28875) Add FlinkSessionJobControllerTest

2022-09-29 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-28875: --- Fix Version/s: kubernetes-operator-1.3.0 (was: kubernetes-operator-1.2.0) >

[GitHub] [flink-connector-elasticsearch] zentol commented on a diff in pull request #40: [FLINK-29471] Use connector parent pom

2022-09-29 Thread GitBox
zentol commented on code in PR #40: URL: https://github.com/apache/flink-connector-elasticsearch/pull/40#discussion_r983955227 ## .github/workflows/ci.yml: ## @@ -69,7 +69,7 @@ jobs: - name: Check licensing run: | - mvn ${MVN_COMMON_OPTIONS}

[jira] [Updated] (FLINK-29471) Create a flink-connector-parent pom

2022-09-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29471: --- Labels: pull-request-available (was: ) > Create a flink-connector-parent pom >

[GitHub] [flink-connector-elasticsearch] zentol commented on a diff in pull request #40: [FLINK-29471] Use connector parent pom

2022-09-29 Thread GitBox
zentol commented on code in PR #40: URL: https://github.com/apache/flink-connector-elasticsearch/pull/40#discussion_r98392 ## pom.xml: ## @@ -20,9 +20,9 @@ under the License. xmlns="http://maven.apache.org/POM/4.0.0;

[GitHub] [flink-connector-elasticsearch] zentol opened a new pull request, #40: [FLINK-29471] Use connector parent pom

2022-09-29 Thread GitBox
zentol opened a new pull request, #40: URL: https://github.com/apache/flink-connector-elasticsearch/pull/40 Also increases CI timeouts a little bit since they are too strict. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Commented] (FLINK-29474) Name collision: Group already contains a Metric with the name

2022-09-29 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611200#comment-17611200 ] Gyula Fora commented on FLINK-29474: merged to main 3ae66dbddd4126a19c1e8f0105027bc370f5e753 > Name

[jira] [Closed] (FLINK-29474) Name collision: Group already contains a Metric with the name

2022-09-29 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-29474. -- Resolution: Fixed > Name collision: Group already contains a Metric with the name >

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #391: [FLINK-29474] Fix global lifecycle metrics group to include resource type

2022-09-29 Thread GitBox
gyfora merged PR #391: URL: https://github.com/apache/flink-kubernetes-operator/pull/391 -- 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. To unsubscribe, e-mail:

[GitHub] [flink] tisonkun commented on pull request #20584: [FLINK-26182][Connector/pulsar] Create a e2e tests for Pulsar sink.

2022-09-29 Thread GitBox
tisonkun commented on PR #20584: URL: https://github.com/apache/flink/pull/20584#issuecomment-1262707166 Root cause located: https://github.com/apache/pulsar/issues/17876. Workaround pushed by @syhily -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] tisonkun commented on pull request #20584: [FLINK-26182][Connector/pulsar] Create a e2e tests for Pulsar sink.

2022-09-29 Thread GitBox
tisonkun commented on PR #20584: URL: https://github.com/apache/flink/pull/20584#issuecomment-1262706618 @flinkbot run azure -- 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.

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #387: [docs] Prometheus/Grafana credentials via command

2022-09-29 Thread GitBox
gyfora merged PR #387: URL: https://github.com/apache/flink-kubernetes-operator/pull/387 -- 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. To unsubscribe, e-mail:

[jira] [Closed] (FLINK-29469) Generate noop.jar instead of committing into source

2022-09-29 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-29469. -- Resolution: Fixed merged to main ed433cea2b2ea079b9966fa15c31dc5177e46961 > Generate noop.jar

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #390: [FLINK-29469] Generate empty sessionjob jar programatically

2022-09-29 Thread GitBox
gyfora merged PR #390: URL: https://github.com/apache/flink-kubernetes-operator/pull/390 -- 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. To unsubscribe, e-mail:

[jira] [Closed] (FLINK-29464) JobID generation logic could lead to state loss

2022-09-29 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-29464. -- Resolution: Fixed merged to main c33e3ef06296974af47b24f499aef71944c60a4d > JobID generation logic

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #389: [FLINK-29464] Persist generated jobid in status before deploy attempt

2022-09-29 Thread GitBox
gyfora merged PR #389: URL: https://github.com/apache/flink-kubernetes-operator/pull/389 -- 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. To unsubscribe, e-mail:

[jira] [Updated] (FLINK-29474) Name collision: Group already contains a Metric with the name

2022-09-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29474: --- Labels: pull-request-available (was: ) > Name collision: Group already contains a Metric

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #391: [FLINK-29474] Fix global lifecycle metrics group to include resource type

2022-09-29 Thread GitBox
gyfora commented on PR #391: URL: https://github.com/apache/flink-kubernetes-operator/pull/391#issuecomment-1262609759 cc @morhidi -- 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

[GitHub] [flink-kubernetes-operator] gyfora opened a new pull request, #391: [FLINK-29474] Fix global lifecycle metrics group to include resource type

2022-09-29 Thread GitBox
gyfora opened a new pull request, #391: URL: https://github.com/apache/flink-kubernetes-operator/pull/391 ## What is the purpose of the change Fix the metric group of the global lifecycle metric histograms to contain resource type and thus avoid collision. ## Brief change log

[GitHub] [flink-kubernetes-operator] sap1ens commented on pull request #390: [FLINK-29469] Generate empty sessionjob jar programatically

2022-09-29 Thread GitBox
sap1ens commented on PR #390: URL: https://github.com/apache/flink-kubernetes-operator/pull/390#issuecomment-1262585572 Perfect, thanks  It does look pretty easy. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink-kubernetes-operator] morhidi commented on pull request #390: [FLINK-29469] Generate empty sessionjob jar programatically

2022-09-29 Thread GitBox
morhidi commented on PR #390: URL: https://github.com/apache/flink-kubernetes-operator/pull/390#issuecomment-1262563044 +1 LGTM -- 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

[GitHub] [flink] XComp commented on a diff in pull request #19914: [FLINK-27942][tests] Migrate flink-connectors-rabbitmq to JUnit5

2022-09-29 Thread GitBox
XComp commented on code in PR #19914: URL: https://github.com/apache/flink/pull/19914#discussion_r983676804 ## flink-connectors/flink-connector-rabbitmq/src/test/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSourceITCase.java: ## @@ -112,7 +117,8 @@ public void setUp()

[GitHub] [flink] flinkbot commented on pull request #20927: [FLINK-29476][connector][kinesis] Retry connection termination with EOFException

2022-09-29 Thread GitBox
flinkbot commented on PR #20927: URL: https://github.com/apache/flink/pull/20927#issuecomment-1262444930 ## CI report: * c73d31e82e125a65cd3f79a0394291302511e084 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-29476) Kinesis Connector retry mechanism not applied to EOFException

2022-09-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29476: --- Labels: pull-request-available (was: ) > Kinesis Connector retry mechanism not applied to

[GitHub] [flink] afedulov opened a new pull request, #20927: [FLINK-29476][connector][kinesis] Retry connection termination with EOFException

2022-09-29 Thread GitBox
afedulov opened a new pull request, #20927: URL: https://github.com/apache/flink/pull/20927 This PR addresses [FLINK-29476](https://issues.apache.org/jira/browse/FLINK-29476). A new test is added. -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] XComp commented on a diff in pull request #19915: [FLINK-27938][tests] Migrate flink-connectors-hbase-base to JUnit5

2022-09-29 Thread GitBox
XComp commented on code in PR #19915: URL: https://github.com/apache/flink/pull/19915#discussion_r983658962 ## flink-connectors/flink-connector-hbase-base/src/test/java/org/apache/flink/connector/hbase/util/HBaseConfigLoadingTest.java: ## @@ -64,13 +63,13 @@ public void

[jira] [Assigned] (FLINK-29474) Name collision: Group already contains a Metric with the name

2022-09-29 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-29474: -- Assignee: Gyula Fora > Name collision: Group already contains a Metric with the name >

[jira] [Updated] (FLINK-29476) Kinesis Connector retry mechanism not applied to EOFException

2022-09-29 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-29476: -- Affects Version/s: 1.15.2 > Kinesis Connector retry mechanism not applied to

[jira] [Assigned] (FLINK-29476) Kinesis Connector retry mechanism not applied to EOFException

2022-09-29 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov reassigned FLINK-29476: - Assignee: Alexander Fedulov > Kinesis Connector retry mechanism not applied to

[jira] [Updated] (FLINK-29476) Kinesis Connector retry mechanism not applied to EOFException

2022-09-29 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-29476: -- Component/s: Connectors / Kinesis > Kinesis Connector retry mechanism not applied to

[jira] [Created] (FLINK-29476) Kinesis Connector retry mechanism not applied to EOFException

2022-09-29 Thread Alexander Fedulov (Jira)
Alexander Fedulov created FLINK-29476: - Summary: Kinesis Connector retry mechanism not applied to EOFException Key: FLINK-29476 URL: https://issues.apache.org/jira/browse/FLINK-29476 Project:

[GitHub] [flink] zentol commented on a diff in pull request #20859: [release] release notes for the 1.16 release

2022-09-29 Thread GitBox
zentol commented on code in PR #20859: URL: https://github.com/apache/flink/pull/20859#discussion_r983597745 ## docs/content.zh/release-notes/flink-1.16.md: ## @@ -0,0 +1,206 @@ +--- +title: "Release Notes - Flink 1.16" +--- + + +# Release notes - Flink 1.16 + +These release

[jira] [Updated] (FLINK-19358) HA should not always use jobid 0000000000

2022-09-29 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-19358: - Release Note: The JobID in application mode is no longer 0... but instead based on

[jira] [Updated] (FLINK-29051) Disable dependency-reduced-pom creation in quickstarts

2022-09-29 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-29051: - Summary: Disable dependency-reduced-pom creation in quickstarts (was: Disable

[jira] [Comment Edited] (FLINK-18647) How to handle processing time timers with bounded input

2022-09-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611059#comment-17611059 ] Piotr Nowojski edited comment on FLINK-18647 at 9/29/22 2:20 PM: -

[jira] [Commented] (FLINK-18647) How to handle processing time timers with bounded input

2022-09-29 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611059#comment-17611059 ] Piotr Nowojski commented on FLINK-18647: {quote} I tend to we directly head to the final

[jira] [Updated] (FLINK-27667) YARNHighAvailabilityITCase fails with "Failed to delete temp directory /tmp/junit1681"

2022-09-29 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-27667: - Issue Type: Technical Debt (was: Bug) > YARNHighAvailabilityITCase fails with "Failed

[jira] [Updated] (FLINK-28735) Deprecate host/web-ui-port parameter of jobmanager.sh

2022-09-29 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28735: - Release Note: The host/web-ui-port parameters of the jobmanager.sh script have been

[jira] [Updated] (FLINK-27599) Setup flink-connector-rabbitmq repository

2022-09-29 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-27599: - Fix Version/s: (was: 1.16.0) > Setup flink-connector-rabbitmq repository >

[jira] [Assigned] (FLINK-29475) Add WARNING/ERROR checker for the operator in e2e tests

2022-09-29 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-29475: - Assignee: Gabor Somogyi > Add WARNING/ERROR checker for the operator in e2e tests >

[jira] [Updated] (FLINK-27472) Setup flink-connector-redis repository

2022-09-29 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-27472: - Fix Version/s: (was: 1.16.0) > Setup flink-connector-redis repository >

[jira] [Created] (FLINK-29475) Add WARNING/ERROR checker for the operator in e2e tests

2022-09-29 Thread Matyas Orhidi (Jira)
Matyas Orhidi created FLINK-29475: - Summary: Add WARNING/ERROR checker for the operator in e2e tests Key: FLINK-29475 URL: https://issues.apache.org/jira/browse/FLINK-29475 Project: Flink

[GitHub] [flink] zentol closed pull request #19871: [FLINK-27886][pom] Fix the error way for skipping shade plugin in sub-modules

2022-09-29 Thread GitBox
zentol closed pull request #19871: [FLINK-27886][pom] Fix the error way for skipping shade plugin in sub-modules URL: https://github.com/apache/flink/pull/19871 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] zentol commented on pull request #19871: [FLINK-27886][pom] Fix the error way for skipping shade plugin in sub-modules

2022-09-29 Thread GitBox
zentol commented on PR #19871: URL: https://github.com/apache/flink/pull/19871#issuecomment-1262330761 IMO this goes in the wrong direction. -- 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

[jira] [Commented] (FLINK-29396) Race condition in JobMaster shutdown can leak resource requirements

2022-09-29 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611045#comment-17611045 ] Chesnay Schepler commented on FLINK-29396: -- Yes it shouldn't be a blocker. > Race condition in

[jira] [Updated] (FLINK-29396) Race condition in JobMaster shutdown can leak resource requirements

2022-09-29 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-29396: - Priority: Critical (was: Blocker) > Race condition in JobMaster shutdown can leak

[GitHub] [flink] XComp commented on a diff in pull request #19915: [FLINK-27938][tests] Migrate flink-connectors-hbase-base to JUnit5

2022-09-29 Thread GitBox
XComp commented on code in PR #19915: URL: https://github.com/apache/flink/pull/19915#discussion_r983556714 ## flink-connectors/flink-connector-hbase-base/src/test/java/org/apache/flink/connector/hbase/util/HBaseSerdeTest.java: ## @@ -71,16 +69,15 @@ public void

[jira] [Created] (FLINK-29474) Name collision: Group already contains a Metric with the name

2022-09-29 Thread Matyas Orhidi (Jira)
Matyas Orhidi created FLINK-29474: - Summary: Name collision: Group already contains a Metric with the name Key: FLINK-29474 URL: https://issues.apache.org/jira/browse/FLINK-29474 Project: Flink

[GitHub] [flink] snuyanzin commented on pull request #20925: [FLINK-29468][connectors][filesystems][formats] Update Jackson-BOM to 2.13.4

2022-09-29 Thread GitBox
snuyanzin commented on PR #20925: URL: https://github.com/apache/flink/pull/20925#issuecomment-1262291692 cc @MartijnVisser since you are dealing with version update things -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] syhily commented on pull request #20584: [FLINK-26182][Connector/pulsar] Create a e2e tests for Pulsar sink.

2022-09-29 Thread GitBox
syhily commented on PR #20584: URL: https://github.com/apache/flink/pull/20584#issuecomment-1262263399 > Observe potential Pulsar transaction issue that causes unstable test cases. -1 to prevent unintentional merge. I have change the `defaultNumberOfNamespaceBundles` to 1 in Docker

[GitHub] [flink] flinkbot commented on pull request #20926: Update ch temporal_table_function.md

2022-09-29 Thread GitBox
flinkbot commented on PR #20926: URL: https://github.com/apache/flink/pull/20926#issuecomment-1262247907 ## CI report: * 6b78c0f6d2f9464931953f9f80d9b9c8f99d9f54 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] zentol closed pull request #20827: [backport][FLINK-28733][scripts] jobmanager.sh supports dynamic parameters

2022-09-29 Thread GitBox
zentol closed pull request #20827: [backport][FLINK-28733][scripts] jobmanager.sh supports dynamic parameters URL: https://github.com/apache/flink/pull/20827 -- 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

[jira] [Updated] (FLINK-28733) jobmanager.sh should support dynamic properties

2022-09-29 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28733: - Fix Version/s: 1.15.3 > jobmanager.sh should support dynamic properties >

[jira] [Comment Edited] (FLINK-28733) jobmanager.sh should support dynamic properties

2022-09-29 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17576059#comment-17576059 ] Chesnay Schepler edited comment on FLINK-28733 at 9/29/22 1:01 PM: ---

[GitHub] [flink] zentol merged pull request #20716: [backport][FLINK-28733][scripts] jobmanager.sh supports dynamic parameters

2022-09-29 Thread GitBox
zentol merged PR #20716: URL: https://github.com/apache/flink/pull/20716 -- 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. To unsubscribe, e-mail:

[jira] [Created] (FLINK-29473) Move Flink CI utils into separate project

2022-09-29 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29473: Summary: Move Flink CI utils into separate project Key: FLINK-29473 URL: https://issues.apache.org/jira/browse/FLINK-29473 Project: Flink Issue

  1   2   >