[jira] [Commented] (FLINK-30477) Not properly blocking retries when timeout occurs in AsyncWaitOperator

2023-02-01 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17683254#comment-17683254 ] lincoln lee commented on FLINK-30477: - fixed in 1.16: 8ee93dabf446b28795de431c376b03

[jira] [Updated] (FLINK-30477) Not properly blocking retries when timeout occurs in AsyncWaitOperator

2023-02-01 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-30477: Fix Version/s: 1.16.2 > Not properly blocking retries when timeout occurs in AsyncWaitOperator > -

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #520: [FLINK-27831][example] add apache beam example for operator

2023-02-01 Thread via GitHub
gyfora merged PR #520: URL: https://github.com/apache/flink-kubernetes-operator/pull/520 -- 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: issues-unsubscr

[GitHub] [flink] lincoln-lil merged pull request #21795: [bp-1.16][FLINK-30477][datastream] Fix AsyncWaitOperator that not properly blocking retries when timeout occurs

2023-02-01 Thread via GitHub
lincoln-lil merged PR #21795: URL: https://github.com/apache/flink/pull/21795 -- 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: issues-unsubscr...@flink.a

[GitHub] [flink] lincoln-lil commented on a diff in pull request #21827: [FLINK-30868][table-api] Fix to use origin LongSerializer for seriali…

2023-02-01 Thread via GitHub
lincoln-lil commented on code in PR #21827: URL: https://github.com/apache/flink/pull/21827#discussion_r1094145881 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/TableSchemaUtils.java: ## @@ -98,6 +100,21 @@ public static int[] getPrimaryKeyIndices(

[jira] [Assigned] (FLINK-30875) Remove legacy AdaptiveBatchScheduler configuration call.

2023-02-01 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-30875: --- Assignee: Junrui Li > Remove legacy AdaptiveBatchScheduler configuration call. > -

[jira] [Updated] (FLINK-30875) Remove legacy AdaptiveBatchScheduler configuration call.

2023-02-01 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-30875: -- Summary: Remove legacy AdaptiveBatchScheduler configuration call. (was: Remove legacy AdaptiveBatchS

[jira] [Created] (FLINK-30875) Remove legacy AdaptiveBatchScheduler min parallelism configuration call.

2023-02-01 Thread Junrui Li (Jira)
Junrui Li created FLINK-30875: - Summary: Remove legacy AdaptiveBatchScheduler min parallelism configuration call. Key: FLINK-30875 URL: https://issues.apache.org/jira/browse/FLINK-30875 Project: Flink

[jira] [Commented] (FLINK-30770) OUTER join generates partial results

2023-02-01 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17683252#comment-17683252 ] lincoln lee commented on FLINK-30770: - [~terlenbach] I understand your question, but

[GitHub] [flink] wuchong commented on pull request #21322: [FLINK-30025][table] Unified the max display column width for SqlClient and Table APi in both Streaming and Batch execMode

2023-02-01 Thread via GitHub
wuchong commented on PR #21322: URL: https://github.com/apache/flink/pull/21322#issuecomment-1413248269 Waiting for branch cut. -- 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 comme

[GitHub] [flink] flinkbot commented on pull request #21827: [FLINK-30868][table-api] Fix to use origin LongSerializer for seriali…

2023-02-01 Thread via GitHub
flinkbot commented on PR #21827: URL: https://github.com/apache/flink/pull/21827#issuecomment-1413241024 ## CI report: * 7d92775038f0565d8fbc9c66bf88189d8bee1bfd UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-30868) Revert to use LongSerializer for seralization in the TimeIndicatorTypeInfo

2023-02-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30868: --- Labels: pull-request-available (was: ) > Revert to use LongSerializer for seralization in t

[GitHub] [flink] fsk119 opened a new pull request, #21827: [FLINK-30868][table-api] Fix to use origin LongSerializer for seriali…

2023-02-01 Thread via GitHub
fsk119 opened a new pull request, #21827: URL: https://github.com/apache/flink/pull/21827 …zation in the TimeIndicatorTypeInfo ## What is the purpose of the change *Revert the API change in the #21182 to use the origin LongSerializer.* ## Does this pull reques

[GitHub] [flink] lincoln-lil commented on a diff in pull request #21800: [FLINK-30840][sql-client] Fix resource leak when creating Executor

2023-02-01 Thread via GitHub
lincoln-lil commented on code in PR #21800: URL: https://github.com/apache/flink/pull/21800#discussion_r1094098027 ## flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/ExecutorImpl.java: ## @@ -98,91 +98,85 @@ public class ExecutorImpl implements E

[GitHub] [flink] zlzhang0122 commented on pull request #18523: [FLINK-25068][Runtime/Web] Show the maximum parallelism(number of key groups) of a job in Web UI

2023-02-01 Thread via GitHub
zlzhang0122 commented on PR #18523: URL: https://github.com/apache/flink/pull/18523#issuecomment-1413211193 @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 commen

[jira] [Closed] (FLINK-30803) PyFlink mishandles script dependencies

2023-02-01 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-30803. --- Fix Version/s: 1.17.0 1.15.4 1.16.2 Assignee: Dian Fu R

[GitHub] [flink] zlzhang0122 commented on a diff in pull request #18523: [FLINK-25068][Runtime/Web] Show the maximum parallelism(number of key groups) of a job in Web UI

2023-02-01 Thread via GitHub
zlzhang0122 commented on code in PR #18523: URL: https://github.com/apache/flink/pull/18523#discussion_r1094077538 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/allocator/VertexParallelism.java: ## @@ -30,6 +32,7 @@ * SlotAllocator#tryReserveResour

[GitHub] [flink] dianfu closed pull request #21809: [FLINK-30803][python] Fix command line option '-py' to make it work well in per-job mode

2023-02-01 Thread via GitHub
dianfu closed pull request #21809: [FLINK-30803][python] Fix command line option '-py' to make it work well in per-job mode URL: https://github.com/apache/flink/pull/21809 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use t

[jira] [Commented] (FLINK-24697) Kafka table source cannot change the auto.offset.reset setting for 'group-offsets' startup mode

2023-02-01 Thread Yuan Kui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17683220#comment-17683220 ] Yuan Kui commented on FLINK-24697: -- [~renqs] Thanks your answer,If we keep the default

[GitHub] [flink] LadyForest commented on a diff in pull request #21802: [FLINK-30811][sql-gateway] Fix SqlGateway cannot stop job correctly

2023-02-01 Thread via GitHub
LadyForest commented on code in PR #21802: URL: https://github.com/apache/flink/pull/21802#discussion_r1094004423 ## flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/local/ExecutorImplITCase.java: ## @@ -481,17 +489,35 @@ void testStopJob() throws

[GitHub] [flink] fsk119 commented on a diff in pull request #21802: [FLINK-30811][sql-gateway] Fix SqlGateway cannot stop job correctly

2023-02-01 Thread via GitHub
fsk119 commented on code in PR #21802: URL: https://github.com/apache/flink/pull/21802#discussion_r1093998583 ## flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/local/ExecutorImplITCase.java: ## @@ -481,17 +489,35 @@ void testStopJob() throws Exc

[jira] [Created] (FLINK-30874) Introduce configuration for table store

2023-02-01 Thread Shammon (Jira)
Shammon created FLINK-30874: --- Summary: Introduce configuration for table store Key: FLINK-30874 URL: https://issues.apache.org/jira/browse/FLINK-30874 Project: Flink Issue Type: Sub-task

[GitHub] [flink] zlzhang0122 commented on a diff in pull request #18523: [FLINK-25068][Runtime/Web] Show the maximum parallelism(number of key groups) of a job in Web UI

2023-02-01 Thread via GitHub
zlzhang0122 commented on code in PR #18523: URL: https://github.com/apache/flink/pull/18523#discussion_r1093984069 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultExecutionGraphFactory.java: ## @@ -197,9 +199,23 @@ public ExecutionGraph createAndRestoreE

[jira] [Commented] (FLINK-24697) Kafka table source cannot change the auto.offset.reset setting for 'group-offsets' startup mode

2023-02-01 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17683211#comment-17683211 ] Qingsheng Ren commented on FLINK-24697: --- Thanks for the comment [~hejiefang] [~cat

[jira] [Closed] (FLINK-30750) CompactActionITCase.testBatchCompact in table store is unstable

2023-02-01 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30750. Fix Version/s: table-store-0.4.0 Assignee: yuzelin Resolution: Fixed master: f2b3b

[jira] [Updated] (FLINK-30750) CompactActionITCase.testBatchCompact in table store is unstable

2023-02-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30750: --- Labels: pull-request-available (was: ) > CompactActionITCase.testBatchCompact in table stor

[GitHub] [flink] reswqa commented on pull request #21815: [FLINK-28326][test] fix unstable test testIdleAndBackPressuredTime.

2023-02-01 Thread via GitHub
reswqa commented on PR #21815: URL: https://github.com/apache/flink/pull/21815#issuecomment-1413096924 @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. T

[GitHub] [flink-table-store] JingsongLi merged pull request #495: [FLINK-30750] fix error test in CompactActionITCase

2023-02-01 Thread via GitHub
JingsongLi merged PR #495: URL: https://github.com/apache/flink-table-store/pull/495 -- 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: issues-unsubscr...@

[jira] [Updated] (FLINK-30825) Ingress creation failed on K8s with version < 1.19

2023-02-01 Thread Shang Yuanchun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shang Yuanchun updated FLINK-30825: --- Description: Currently flink-kubernetes-operator only use io.fabric8.kubernetes.api.model.n

[jira] [Updated] (FLINK-30825) Ingress creation failed on K8s with version < 1.19

2023-02-01 Thread Shang Yuanchun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shang Yuanchun updated FLINK-30825: --- Description: Currently flink-kubernetes-operator only use io.fabric8.kubernetes.api.model.n

[GitHub] [flink] zlzhang0122 commented on a diff in pull request #18523: [FLINK-25068][Runtime/Web] Show the maximum parallelism(number of key groups) of a job in Web UI

2023-02-01 Thread via GitHub
zlzhang0122 commented on code in PR #18523: URL: https://github.com/apache/flink/pull/18523#discussion_r1093972004 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/jsonplan/JsonPlanGenerator.java: ## @@ -117,10 +120,25 @@ public static String generatePlan(

[jira] [Closed] (FLINK-29859) TPC-DS end-to-end test with adaptive batch scheduler failed due to oo non-empty .out files.

2023-02-01 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-29859. --- Resolution: Fixed Fixed via master: 19f2230a4758f471305727ad82d36984ebbc7e3a release-1.16: e6a91aa39fc42541

[GitHub] [flink] zhuzhurk closed pull request #21820: [FLINK-29859][e2e] Add new allowed exceptions in logs for speculative execution e2e

2023-02-01 Thread via GitHub
zhuzhurk closed pull request #21820: [FLINK-29859][e2e] Add new allowed exceptions in logs for speculative execution e2e URL: https://github.com/apache/flink/pull/21820 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Comment Edited] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore

2023-02-01 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17682677#comment-17682677 ] Feifan Wang edited comment on FLINK-28440 at 2/2/23 2:54 AM: -

[jira] [Comment Edited] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore

2023-02-01 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17682912#comment-17682912 ] Feifan Wang edited comment on FLINK-28440 at 2/2/23 2:53 AM: -

[GitHub] [flink] swuferhong commented on pull request #21821: [hotfix][table-planner] Fix ITCase IOException due to network buffer insufficient while the default parallelism don't set manually in test

2023-02-01 Thread via GitHub
swuferhong commented on PR #21821: URL: https://github.com/apache/flink/pull/21821#issuecomment-1413073051 @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] ifndef-SleePy commented on pull request #21807: [FLINK-30842][docs] Add document for sink supports speculative execution

2023-02-01 Thread via GitHub
ifndef-SleePy commented on PR #21807: URL: https://github.com/apache/flink/pull/21807#issuecomment-1413067274 @zhuzhurk I've addressed the comments and updated the PR. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use th

[GitHub] [flink] ifndef-SleePy commented on a diff in pull request #21807: [FLINK-30842][docs] Add document for sink supports speculative execution

2023-02-01 Thread via GitHub
ifndef-SleePy commented on code in PR #21807: URL: https://github.com/apache/flink/pull/21807#discussion_r1093948323 ## docs/content.zh/docs/deployment/speculative_execution.md: ## @@ -40,10 +40,6 @@ under the License. ## 使用方法 Review Comment: I checked the master branch. Th

[GitHub] [flink] swuferhong commented on pull request #21821: [hotfix][table-planner] Fix ITCase IOException due to network buffer insufficient while the default parallelism don't set manually in test

2023-02-01 Thread via GitHub
swuferhong commented on PR #21821: URL: https://github.com/apache/flink/pull/21821#issuecomment-1413065105 @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] ifndef-SleePy commented on a diff in pull request #21807: [FLINK-30842][docs] Add document for sink supports speculative execution

2023-02-01 Thread via GitHub
ifndef-SleePy commented on code in PR #21807: URL: https://github.com/apache/flink/pull/21807#discussion_r1093946502 ## docs/content/docs/deployment/speculative_execution.md: ## @@ -92,6 +88,31 @@ No extra change is required for other sources to work with speculative execution

[GitHub] [flink] ifndef-SleePy commented on a diff in pull request #21807: [FLINK-30842][docs] Add document for sink supports speculative execution

2023-02-01 Thread via GitHub
ifndef-SleePy commented on code in PR #21807: URL: https://github.com/apache/flink/pull/21807#discussion_r1093946283 ## docs/content.zh/docs/deployment/speculative_execution.md: ## @@ -83,6 +79,29 @@ public interface SupportsHandleExecutionAttemptSourceEvent { 和 {{< gh_link fi

[GitHub] [flink-ml] vacaly commented on a diff in pull request #192: [FLINK-30451] Add Estimator and Transformer for Swing

2023-02-01 Thread via GitHub
vacaly commented on code in PR #192: URL: https://github.com/apache/flink-ml/pull/192#discussion_r1093937923 ## flink-ml-lib/src/main/java/org/apache/flink/ml/recommendation/swing/Swing.java: ## @@ -0,0 +1,455 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one

[GitHub] [flink-ml] vacaly commented on a diff in pull request #192: [FLINK-30451] Add Estimator and Transformer for Swing

2023-02-01 Thread via GitHub
vacaly commented on code in PR #192: URL: https://github.com/apache/flink-ml/pull/192#discussion_r1093934595 ## flink-ml-lib/src/main/java/org/apache/flink/ml/recommendation/swing/Swing.java: ## @@ -0,0 +1,455 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one

[GitHub] [flink] liyubin117 commented on pull request #21521: [FLINK-30435][table] `SHOW CREATE TABLE` statement shows column comment

2023-02-01 Thread via GitHub
liyubin117 commented on PR #21521: URL: https://github.com/apache/flink/pull/21521#issuecomment-1413037107 @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] swuferhong commented on pull request #21821: [hotfix][table-planner] Fix ITCase IOException due to network buffer insufficient while the default parallelism don't set manually in test

2023-02-01 Thread via GitHub
swuferhong commented on PR #21821: URL: https://github.com/apache/flink/pull/21821#issuecomment-1413000749 @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-30688) Disable Kryo fallback in Flink ML tests

2023-02-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30688: --- Labels: pull-request-available (was: ) > Disable Kryo fallback in Flink ML tests >

[GitHub] [flink-ml] jiangxin369 opened a new pull request, #202: [WIP][FLINK-30688] Disable Kryo fallback in Flink ML tests

2023-02-01 Thread via GitHub
jiangxin369 opened a new pull request, #202: URL: https://github.com/apache/flink-ml/pull/202 ## What is the purpose of the change Disable Kryo fallback in Flink ML tests to ensure that all Flink ML algorithms are not using Kryo. ## Brief change log *(for example

[GitHub] [flink-kubernetes-operator] HuangZhenQiu commented on a diff in pull request #520: [FLINK-27831][example] add apache beam example for operator

2023-02-01 Thread via GitHub
HuangZhenQiu commented on code in PR #520: URL: https://github.com/apache/flink-kubernetes-operator/pull/520#discussion_r1093853751 ## examples/flink-beam-example/README.md: ## @@ -0,0 +1,67 @@ + + +# Flink Kubernetes Operator Beam application example + +## Overview + +This is

[jira] [Closed] (FLINK-28186) Trigger Operator Events on Configuration Changes

2023-02-01 Thread Matyas Orhidi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matyas Orhidi closed FLINK-28186. - Resolution: Duplicate > Trigger Operator Events on Configuration Changes > -

[jira] [Closed] (FLINK-14577) Hortonworks schema registry support for avro deserialization

2023-02-01 Thread Matyas Orhidi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matyas Orhidi closed FLINK-14577. - Resolution: Won't Fix > Hortonworks schema registry support for avro deserialization > -

[GitHub] [flink-connector-jdbc] snuyanzin commented on a diff in pull request #18: [FLINK-30790] Improve performance and extensibility in tests

2023-02-01 Thread via GitHub
snuyanzin commented on code in PR #18: URL: https://github.com/apache/flink-connector-jdbc/pull/18#discussion_r1093770024 ## flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/databases/oracle/OracleMetadata.java: ## @@ -0,0 +1,97 @@ +/* + * Licensed to the Apac

[jira] [Created] (FLINK-30873) FileSystem Table API connector doesn't discover new files when partitions are specified

2023-02-01 Thread Yaroslav Tkachenko (Jira)
Yaroslav Tkachenko created FLINK-30873: -- Summary: FileSystem Table API connector doesn't discover new files when partitions are specified Key: FLINK-30873 URL: https://issues.apache.org/jira/browse/FLINK-3087

[GitHub] [flink] snuyanzin commented on pull request #21811: [FLINK-30855][Connector/Google Cloud PubSub] Remove GCP PubSub connector

2023-02-01 Thread via GitHub
snuyanzin commented on PR #21811: URL: https://github.com/apache/flink/pull/21811#issuecomment-1412618310 > @snuyanzin I've opened https://github.com/apache/flink-connector-gcp-pubsub/pull/3 to move the example :) great! I've checked once more and now not able to find other pu

[GitHub] [flink] MartijnVisser commented on pull request #21811: [FLINK-30855][Connector/Google Cloud PubSub] Remove GCP PubSub connector

2023-02-01 Thread via GitHub
MartijnVisser commented on PR #21811: URL: https://github.com/apache/flink/pull/21811#issuecomment-1412585405 @snuyanzin I've opened https://github.com/apache/flink-connector-gcp-pubsub/pull/3 to move the example :) -- This is an automated message from the Apache Git Service. To respond

[jira] [Created] (FLINK-30872) Move GCP example to GCP connector repo

2023-02-01 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-30872: -- Summary: Move GCP example to GCP connector repo Key: FLINK-30872 URL: https://issues.apache.org/jira/browse/FLINK-30872 Project: Flink Issue Type: Techni

[jira] [Commented] (FLINK-30277) Allow PYTHONPATH of Python Worker configurable

2023-02-01 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17683114#comment-17683114 ] Danny Cranmer commented on FLINK-30277: --- Done > Allow PYTHONPATH of Python Worker

[jira] [Assigned] (FLINK-30277) Allow PYTHONPATH of Python Worker configurable

2023-02-01 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-30277: - Assignee: Samrat Deb (was: Prabhu Joseph) > Allow PYTHONPATH of Python Worker configur

[GitHub] [flink] kristoffSC commented on pull request #21393: [FLINK-27246][TableSQL/Runtime][master] - Include WHILE blocks in split generated java methods

2023-02-01 Thread via GitHub
kristoffSC commented on PR #21393: URL: https://github.com/apache/flink/pull/21393#issuecomment-1412469928 Hi @tsreaper thanks for kind words. I'm really happy that we are getting closer to merge this change. I was using Maciej Bryński's SQL example from FLINK-27246 ticket to veri

[GitHub] [flink] flinkbot commented on pull request #21826: [FLINK-27848][runtime] Fix the problem that ZooKeeperLeaderElectionDriver keeps writing leader information, using up zxid.

2023-02-01 Thread via GitHub
flinkbot commented on PR #21826: URL: https://github.com/apache/flink/pull/21826#issuecomment-1412428476 ## CI report: * e5071be460abf4798215f734c8fb97f7586fa01c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] flinkbot commented on pull request #21825: [FLINK-27848][runtime] Fix the problem that ZooKeeperLeaderElectionDriver keeps writing leader information, using up zxid.

2023-02-01 Thread via GitHub
flinkbot commented on PR #21825: URL: https://github.com/apache/flink/pull/21825#issuecomment-1412427262 ## CI report: * 9de76e438bae56f647b037d3323250e0ee157749 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] XComp opened a new pull request, #21826: [FLINK-27848][runtime] Fix the problem that ZooKeeperLeaderElectionDriver keeps writing leader information, using up zxid.

2023-02-01 Thread via GitHub
XComp opened a new pull request, #21826: URL: https://github.com/apache/flink/pull/21826 1.16 "forwardport" PR for the 1.15 parent PR #19853 Why do we need this? Refactoring the leader election for FLIP-285/[FLINK-26522](https://issues.apache.org/jira/browse/FLINK-26522) is kind o

[GitHub] [flink] XComp opened a new pull request, #21825: [FLINK-27848][runtime] Fix the problem that ZooKeeperLeaderElectionDriver keeps writing leader information, using up zxid.

2023-02-01 Thread via GitHub
XComp opened a new pull request, #21825: URL: https://github.com/apache/flink/pull/21825 1.17 "forwardport" PR for the 1.15 parent PR #19853 Why do we need this? Refactoring the leader election for FLIP-285/[FLINK-26522](https://issues.apache.org/jira/browse/FLINK-26522) is kind o

[jira] [Comment Edited] (FLINK-27848) ZooKeeperLeaderElectionDriver keeps writing leader information, using up zxid

2023-02-01 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17683099#comment-17683099 ] Matthias Pohl edited comment on FLINK-27848 at 2/1/23 5:09 PM: ---

[jira] [Reopened] (FLINK-27848) ZooKeeperLeaderElectionDriver keeps writing leader information, using up zxid

2023-02-01 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reopened FLINK-27848: --- Assignee: Matthias Pohl (was: Weijie Guo) I'm reopening this issue to provide forward(?)p

[jira] [Updated] (FLINK-27848) ZooKeeperLeaderElectionDriver keeps writing leader information, using up zxid

2023-02-01 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-27848: -- Affects Version/s: 1.16.1 1.17.0 > ZooKeeperLeaderElectionDriver keeps

[GitHub] [flink] zentol commented on pull request #21757: [FLINK-30788][runtime] Refactors AbstractHaServices.createLeaderElectionService to return LeaderElectionDriverFactory

2023-02-01 Thread via GitHub
zentol commented on PR #21757: URL: https://github.com/apache/flink/pull/21757#issuecomment-1412380685 @flinkbot run azure There's an HA e2e test failing. -- 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-kubernetes-operator] gyfora commented on a diff in pull request #520: [FLINK-27831][example] add apache beam example for operator

2023-02-01 Thread via GitHub
gyfora commented on code in PR #520: URL: https://github.com/apache/flink-kubernetes-operator/pull/520#discussion_r1093464453 ## examples/flink-beam-example/Dockerfile: ## @@ -0,0 +1,23 @@ + +# Lic

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #520: [FLINK-27831][example] add apache beam example for operator

2023-02-01 Thread via GitHub
gyfora commented on code in PR #520: URL: https://github.com/apache/flink-kubernetes-operator/pull/520#discussion_r1093462817 ## examples/flink-beam-example/Dockerfile: ## @@ -0,0 +1,23 @@ + +# Lic

[jira] [Updated] (FLINK-30871) add bloom filter for orc

2023-02-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30871: --- Labels: pull-request-available (was: ) > add bloom filter for orc > --

[GitHub] [flink-table-store] zhangjun0x01 opened a new pull request, #494: [FLINK-30871] add bloom filter for orc

2023-02-01 Thread via GitHub
zhangjun0x01 opened a new pull request, #494: URL: https://github.com/apache/flink-table-store/pull/494 Because the prefix of `DelegatingConfiguration` is orc, so the `Configuration` with `orc` prefix will be added to the orc writer properties automatically -- This is an automated messa

[GitHub] [flink-connector-aws] boring-cyborg[bot] commented on pull request #52: [FLINK 30777] [Connectors/Kinesis] Allow Kinesis Table API Connector to specify shard assigner

2023-02-01 Thread boring-cyborg
boring-cyborg[bot] commented on PR #52: URL: https://github.com/apache/flink-connector-aws/pull/52#issuecomment-1412320215 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) -- This is an

[GitHub] [flink-connector-aws] karthitect opened a new pull request, #52: [FLINK 30777] [Connectors/Kinesis] Allow Kinesis Table API Connector to specify shard assigner

2023-02-01 Thread via GitHub
karthitect opened a new pull request, #52: URL: https://github.com/apache/flink-connector-aws/pull/52 ## Purpose of the change This pull request allows users of the Kinesis Table API Flink Connector to select from a list of shard assigner. ## Verifying this change Th

[GitHub] [flink-shaded] snuyanzin commented on a diff in pull request #119: Update Flink Shaded dependencies to the latest versions

2023-02-01 Thread via GitHub
snuyanzin commented on code in PR #119: URL: https://github.com/apache/flink-shaded/pull/119#discussion_r1093434026 ## flink-shaded-jackson-parent/flink-shaded-jackson-2/src/main/resources/META-INF/NOTICE: ## @@ -6,11 +6,11 @@ The Apache Software Foundation (http://www.apache.or

[jira] [Created] (FLINK-30871) add bloom filter for orc

2023-02-01 Thread Jun Zhang (Jira)
Jun Zhang created FLINK-30871: - Summary: add bloom filter for orc Key: FLINK-30871 URL: https://issues.apache.org/jira/browse/FLINK-30871 Project: Flink Issue Type: Improvement Compone

[GitHub] [flink] flinkbot commented on pull request #21824: [FLINK-30744][docs]Translate "Window Top-N" page of "Querys"

2023-02-01 Thread via GitHub
flinkbot commented on PR #21824: URL: https://github.com/apache/flink/pull/21824#issuecomment-1412257857 ## CI report: * b5ac5c6c28bb20d9944a7d077ff07f4201b06f0b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] NightRunner closed pull request #21720: [FLINK-30744][docs]Translate "Window Top-N" page of "Querys" into Chi…

2023-02-01 Thread via GitHub
NightRunner closed pull request #21720: [FLINK-30744][docs]Translate "Window Top-N" page of "Querys" into Chi… URL: https://github.com/apache/flink/pull/21720 -- 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] [Comment Edited] (FLINK-30744) Translate "Window Top-N" page of "Querys" into Chinese

2023-02-01 Thread chenhaiyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17678251#comment-17678251 ] chenhaiyang edited comment on FLINK-30744 at 2/1/23 3:20 PM: -

[GitHub] [flink] NightRunner opened a new pull request, #21824: [FLINK-30744][docs]Translate "Window Top-N" page of "Querys"

2023-02-01 Thread via GitHub
NightRunner opened a new pull request, #21824: URL: https://github.com/apache/flink/pull/21824 Translate "Window Top-N" page of "Querys" into Chinese ## What is the purpose of the change Translate /dev/table/sql/queries/window-topn.md ## Brief change log Translate

[GitHub] [flink-connector-jdbc] MartijnVisser commented on pull request #18: [FLINK-30790] Improve performance and extensibility in tests

2023-02-01 Thread via GitHub
MartijnVisser commented on PR #18: URL: https://github.com/apache/flink-connector-jdbc/pull/18#issuecomment-1412234021 @snuyanzin Could you have a look at this one? I think this would also help your PRs since it addresses some of the test stabilities -- This is an automated message from

[GitHub] [flink] flinkbot commented on pull request #21823: [FLINK-30694][docs]Translate "Windowing TVF" page of "Querys" into Ch…

2023-02-01 Thread via GitHub
flinkbot commented on PR #21823: URL: https://github.com/apache/flink/pull/21823#issuecomment-1412225881 ## CI report: * 4bbd1637990e45d7b5a84e7db2510d79a4d0f405 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] NightRunner closed pull request #21709: [FLINK-30694][docs]Translate "Windowing TVF" page of "Querys" into Chinese

2023-02-01 Thread via GitHub
NightRunner closed pull request #21709: [FLINK-30694][docs]Translate "Windowing TVF" page of "Querys" into Chinese URL: https://github.com/apache/flink/pull/21709 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL a

[jira] [Comment Edited] (FLINK-30694) Translate "Windowing TVF" page of "Querys" into Chinese

2023-02-01 Thread chenhaiyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17677137#comment-17677137 ] chenhaiyang edited comment on FLINK-30694 at 2/1/23 3:06 PM: -

[GitHub] [flink] NightRunner opened a new pull request, #21823: [FLINK-30694][docs]Translate "Windowing TVF" page of "Querys" into Ch…

2023-02-01 Thread via GitHub
NightRunner opened a new pull request, #21823: URL: https://github.com/apache/flink/pull/21823 Page "Application Development"/"Table API&SQL"/"SQL"/"Queries"/Windows TVF translate to chinese. ## What is the purpose of the change Translate /dev/table/sql/queries/window-tvf.md

[GitHub] [flink] swuferhong commented on pull request #21821: [hotfix][table-planner] Fix ITCase IOException due to network buffer insufficient while the default parallelism don't set manually in test

2023-02-01 Thread via GitHub
swuferhong commented on PR #21821: URL: https://github.com/apache/flink/pull/21821#issuecomment-1412192245 @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] [Assigned] (FLINK-30858) Kubernetes operator does not update reconciled generation

2023-02-01 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-30858: -- Assignee: Gyula Fora > Kubernetes operator does not update reconciled generation > --

[jira] [Updated] (FLINK-30836) Release FRocksDB 6.20.3-ververica-2.0

2023-02-01 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-30836: --- Fix Version/s: 1.17.0 (was: 1.17) > Release FRocksDB 6.20.3-ververica

[jira] [Updated] (FLINK-30754) Fix ExceptionThrowingDelegationTokenProvider/Receiver multi-threaded test issues

2023-02-01 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-30754: --- Fix Version/s: 1.17.0 (was: 1.17) > Fix ExceptionThrowingDelegationTo

[jira] [Updated] (FLINK-30811) Fix sql gateway can not stop job correctly

2023-02-01 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-30811: --- Fix Version/s: 1.17.0 (was: 1.17) > Fix sql gateway can not stop job

[jira] [Updated] (FLINK-30567) Wrong insert overwrite behavior when the table contains uppercase character with Hive dialect

2023-02-01 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-30567: --- Fix Version/s: 1.17.0 (was: 1.17) > Wrong insert overwrite behavior w

[jira] [Updated] (FLINK-30824) Add document for new introduced hive agg option

2023-02-01 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-30824: --- Fix Version/s: 1.17.0 (was: 1.17) > Add document for new introduced h

[jira] [Commented] (FLINK-30862) Config doc generation should keep @deprecated ConfigOption

2023-02-01 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17683034#comment-17683034 ] Chesnay Schepler commented on FLINK-30862: -- ??The question is why we didn't cle

[jira] [Resolved] (FLINK-30474) DefaultMultipleComponentLeaderElectionService triggers HA backend change even if it's not the leader

2023-02-01 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-30474. --- Fix Version/s: 1.17.0 1.15.4 1.16.2 Resolution:

[jira] [Comment Edited] (FLINK-30474) DefaultMultipleComponentLeaderElectionService triggers HA backend change even if it's not the leader

2023-02-01 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17682947#comment-17682947 ] Matthias Pohl edited comment on FLINK-30474 at 2/1/23 1:42 PM: ---

[GitHub] [flink] XComp merged pull request #21819: [BP-1.16][FLINK-30474][runtime] Propagates leader information change only if the leadership is still acquired

2023-02-01 Thread via GitHub
XComp merged PR #21819: URL: https://github.com/apache/flink/pull/21819 -- 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: issues-unsubscr...@flink.apache.

[GitHub] [flink] XComp merged pull request #21818: [BP-1.15][FLINK-30474][runtime] Propagates leader information change only if the leadership is still acquired

2023-02-01 Thread via GitHub
XComp merged PR #21818: URL: https://github.com/apache/flink/pull/21818 -- 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: issues-unsubscr...@flink.apache.

[jira] [Resolved] (FLINK-30462) DefaultMultipleComponentLeaderElectionService saves wrong leader session ID

2023-02-01 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-30462. --- Fix Version/s: 1.17.0 1.15.4 1.16.2 Resolution:

[jira] [Comment Edited] (FLINK-30462) DefaultMultipleComponentLeaderElectionService saves wrong leader session ID

2023-02-01 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17682946#comment-17682946 ] Matthias Pohl edited comment on FLINK-30462 at 2/1/23 1:41 PM: ---

[GitHub] [flink] XComp merged pull request #21817: [BP-1.15][FLINK-30462][runtime] The leader session ID is now saved properly

2023-02-01 Thread via GitHub
XComp merged PR #21817: URL: https://github.com/apache/flink/pull/21817 -- 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: issues-unsubscr...@flink.apache.

[GitHub] [flink] XComp merged pull request #21816: [BP-1.16][FLINK-30462][runtime] The leader session ID is now saved properly

2023-02-01 Thread via GitHub
XComp merged PR #21816: URL: https://github.com/apache/flink/pull/21816 -- 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: issues-unsubscr...@flink.apache.

[GitHub] [flink-ml] lindong28 commented on a diff in pull request #28: [FLINK-24556] Add Estimator and Transformer for logistic regression

2023-02-01 Thread via GitHub
lindong28 commented on code in PR #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r1093233927 ## flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticRegression.java: ## @@ -0,0 +1,653 @@ +/* + * Licensed to the Apache Software Foundation

  1   2   3   >