[jira] [Updated] (FLINK-27285) CassandraConnectorITCase failed on azure due to NoHostAvailableException

2023-01-19 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-27285: -- Affects Version/s: cassandra-3.0.0 > CassandraConnectorITCase failed on azure due to

[jira] [Updated] (FLINK-27285) CassandraConnectorITCase failed on azure due to NoHostAvailableException

2023-01-19 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-27285: -- Priority: Critical (was: Minor) > CassandraConnectorITCase failed on azure due to

[jira] [Commented] (FLINK-27285) CassandraConnectorITCase failed on azure due to NoHostAvailableException

2023-01-19 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17679032#comment-17679032 ] Matthias Pohl commented on FLINK-27285: --- This error also appears in 1.15.

[jira] [Updated] (FLINK-27285) CassandraConnectorITCase failed on azure due to NoHostAvailableException

2023-01-19 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-27285: -- Affects Version/s: 1.15.3 > CassandraConnectorITCase failed on azure due to

[jira] [Commented] (FLINK-30619) AdaptiveSchedulerTest.testStatusMetrics is not stable

2023-01-19 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17679029#comment-17679029 ] Matthias Pohl commented on FLINK-30619: ---

[jira] [Commented] (FLINK-30727) JoinReorderITCase.testBushyTreeJoinReorder failed due to IOException

2023-01-19 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17679028#comment-17679028 ] Matthias Pohl commented on FLINK-30727: ---

[jira] [Commented] (FLINK-30727) JoinReorderITCase.testBushyTreeJoinReorder failed due to IOException

2023-01-19 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17679027#comment-17679027 ] Matthias Pohl commented on FLINK-30727: ---

[GitHub] [flink] ZhongFuCheng3y commented on pull request #21553: [FLINK-30492][doc] fix incorrect dependency artifactId in hive overview.

2023-01-19 Thread GitBox
ZhongFuCheng3y commented on PR #21553: URL: https://github.com/apache/flink/pull/21553#issuecomment-1398010881 > @reswqa @ZhongFuCheng3y Hive requires the `flink-table-planner_2.12-.jar`, so for example ` flink-table-planner_2.12-1.16.0.jar`. See

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

2023-01-19 Thread Shammon (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shammon updated FLINK-30750: Description: https://github.com/apache/flink-table-store/actions/runs/3954989166/jobs/6772877033

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

2023-01-19 Thread Shammon (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shammon updated FLINK-30750: Description: https://github.com/apache/flink-table-store/actions/runs/3954989166/jobs/6772877033

[jira] [Commented] (FLINK-26428) Translate "Stateful Stream Processing" to Chinese

2023-01-19 Thread chenhaiyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17679008#comment-17679008 ] chenhaiyang commented on FLINK-26428: - Hi [~martijnvisser] ,I find this issue and PR when want

[GitHub] [flink] flinkbot commented on pull request #21736: [FLINK-27518][tests] Refactor migration tests to support version update automatically

2023-01-19 Thread GitBox
flinkbot commented on PR #21736: URL: https://github.com/apache/flink/pull/21736#issuecomment-1397936174 ## CI report: * f7edc0bb36dda4c6144c97a73c8167c0e2bf0a0e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] gaoyunhaii commented on pull request #21736: [FLINK-27518][tests] Refactor migration tests to support version update automatically

2023-01-19 Thread GitBox
gaoyunhaii commented on PR #21736: URL: https://github.com/apache/flink/pull/21736#issuecomment-1397934193 @XComp could you have a look at the PR? Very thanks! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Updated] (FLINK-27518) Refactor migration tests to support version update automatically

2023-01-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27518: --- Labels: pull-request-available (was: ) > Refactor migration tests to support version

[GitHub] [flink] gaoyunhaii opened a new pull request, #21736: [FLINK-27518][tests] Refactor migration tests to support version update automatically

2023-01-19 Thread GitBox
gaoyunhaii opened a new pull request, #21736: URL: https://github.com/apache/flink/pull/21736 ## What is the purpose of the change This PR refactors the state migration tests so that when cutting branch, we need only add new version and could generates the states of stale version

[GitHub] [flink] swuferhong commented on a diff in pull request #21724: [FLINK-30727][table-planner] Fix JoinReorderITCaseBase.testBushyTreeJoinReorder failed

2023-01-19 Thread GitBox
swuferhong commented on code in PR #21724: URL: https://github.com/apache/flink/pull/21724#discussion_r1082114927 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/sql/join/JoinReorderITCase.java: ## @@ -42,6 +45,12 @@ public class

[GitHub] [flink] swuferhong commented on pull request #21724: [FLINK-30727][table-planner] Fix JoinReorderITCaseBase.testBushyTreeJoinReorder failed

2023-01-19 Thread GitBox
swuferhong commented on PR #21724: URL: https://github.com/apache/flink/pull/21724#issuecomment-1397929362 @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

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

2023-01-19 Thread GitBox
JingGe commented on code in PR #21322: URL: https://github.com/apache/flink/pull/21322#discussion_r1082088415 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java: ## @@ -926,7 +926,7 @@ private TableResultInternal

[jira] [Created] (FLINK-30758) Remove sql-client.display.max-column-width

2023-01-19 Thread Jing Ge (Jira)
Jing Ge created FLINK-30758: --- Summary: Remove sql-client.display.max-column-width Key: FLINK-30758 URL: https://issues.apache.org/jira/browse/FLINK-30758 Project: Flink Issue Type: Improvement

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

2023-01-19 Thread GitBox
JingGe commented on code in PR #21322: URL: https://github.com/apache/flink/pull/21322#discussion_r1082086891 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/TableConfigOptions.java: ## @@ -102,6 +102,16 @@ private TableConfigOptions() {}

[jira] [Commented] (FLINK-30680) Consider using the autoscaler to detect slow taskmanagers

2023-01-19 Thread Matt Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17678973#comment-17678973 ] Matt Wang commented on FLINK-30680: --- [~gyfora] When we designed it internally, we also considered that

[GitHub] [flink] LadyForest commented on pull request #21727: [FLINK-30752][python] Support 'EXPLAIN PLAN_ADVICE' statement in PyFlink

2023-01-19 Thread GitBox
LadyForest commented on PR #21727: URL: https://github.com/apache/flink/pull/21727#issuecomment-1397885340 @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

[jira] [Closed] (FLINK-30662) Add support for Delete

2023-01-19 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-30662. --- Resolution: Fixed fixed in master: b7d32069c0971fba1c33950aa373624bb6018505 > Add support for

[GitHub] [flink] lincoln-lil closed pull request #21676: [FLINK-30662][table] Planner supports delete

2023-01-19 Thread GitBox
lincoln-lil closed pull request #21676: [FLINK-30662][table] Planner supports delete URL: https://github.com/apache/flink/pull/21676 -- 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] fsk119 commented on a diff in pull request #21717: [FLINK-29945][sql-client] Supports to submit SQL to a embedded SQL Ga…

2023-01-19 Thread GitBox
fsk119 commented on code in PR #21717: URL: https://github.com/apache/flink/pull/21717#discussion_r1082055861 ## flink-table/flink-sql-client/src/test/resources/sql/table.q: ## @@ -79,7 +79,10 @@ show tables; # test SHOW CREATE TABLE show create table orders; -CREATE TABLE

[GitHub] [flink-ml] jiangxin369 commented on pull request #201: [FLINK-27716] Add Python API docs in ML

2023-01-19 Thread GitBox
jiangxin369 commented on PR #201: URL: https://github.com/apache/flink-ml/pull/201#issuecomment-1397846787 @lindong28 Could you help to 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

[jira] [Commented] (FLINK-26088) Add Elasticsearch 8.0 support

2023-01-19 Thread Matheus Felisberto (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17678955#comment-17678955 ] Matheus Felisberto commented on FLINK-26088: Thank you very much. I will be happy to work on

[GitHub] [flink] 1996fanrui commented on a diff in pull request #20151: [FLINK-26803][checkpoint] Merging channel state files

2023-01-19 Thread GitBox
1996fanrui commented on code in PR #20151: URL: https://github.com/apache/flink/pull/20151#discussion_r1082041845 ## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestExecutorImpl.java: ## @@ -51,27 +66,40 @@ class

[GitHub] [flink] 1996fanrui commented on a diff in pull request #20151: [FLINK-26803][checkpoint] Merging channel state files

2023-01-19 Thread GitBox
1996fanrui commented on code in PR #20151: URL: https://github.com/apache/flink/pull/20151#discussion_r1082043383 ## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestExecutorImpl.java: ## @@ -107,49 +119,78 @@ void run() {

[GitHub] [flink] 1996fanrui commented on a diff in pull request #20151: [FLINK-26803][checkpoint] Merging channel state files

2023-01-19 Thread GitBox
1996fanrui commented on code in PR #20151: URL: https://github.com/apache/flink/pull/20151#discussion_r1082043383 ## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestExecutorImpl.java: ## @@ -107,49 +119,78 @@ void run() {

[GitHub] [flink-connector-kafka] mas-chen commented on pull request #1: [FLINK-30052][Connectors/Kafka] Move existing Kafka connector code from Flink repo to dedicated Kafka repo

2023-01-19 Thread GitBox
mas-chen commented on PR #1: URL: https://github.com/apache/flink-connector-kafka/pull/1#issuecomment-1397828588 CI now passes on my fork -- 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

[GitHub] [flink] 1996fanrui commented on a diff in pull request #20151: [FLINK-26803][checkpoint] Merging channel state files

2023-01-19 Thread GitBox
1996fanrui commented on code in PR #20151: URL: https://github.com/apache/flink/pull/20151#discussion_r1082041845 ## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestExecutorImpl.java: ## @@ -51,27 +66,40 @@ class

[GitHub] [flink] flinkbot commented on pull request #21735: [hotfix] [docs] Fix a typo in a query that erroneously tries to perform an aggregation on a string column

2023-01-19 Thread GitBox
flinkbot commented on PR #21735: URL: https://github.com/apache/flink/pull/21735#issuecomment-1397810857 ## CI report: * 37175760368c64b665e16e5cf8b7eb4f4e951fee UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] karanasher opened a new pull request, #21735: [hotfix] [docs] Fix a typo in a query that erroneously tries to perform an aggregation on a string column

2023-01-19 Thread GitBox
karanasher opened a new pull request, #21735: URL: https://github.com/apache/flink/pull/21735 Fix a typo in a query that erroneously tries to perform an aggregation on a string column. -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] 1996fanrui commented on a diff in pull request #20151: [FLINK-26803][checkpoint] Merging channel state files

2023-01-19 Thread GitBox
1996fanrui commented on code in PR #20151: URL: https://github.com/apache/flink/pull/20151#discussion_r1082023420 ## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestExecutorImpl.java: ## @@ -51,27 +66,40 @@ class

[jira] [Commented] (FLINK-30727) JoinReorderITCase.testBushyTreeJoinReorder failed due to IOException

2023-01-19 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17678947#comment-17678947 ] lincoln lee commented on FLINK-30727: - [~337361...@qq.com] I also encountered this failure in a

[GitHub] [flink-kubernetes-operator] morhidi closed pull request #463: [FLINK-30119] Breaking change: Flink Kubernetes Operator should store…

2023-01-19 Thread GitBox
morhidi closed pull request #463: [FLINK-30119] Breaking change: Flink Kubernetes Operator should store… URL: https://github.com/apache/flink-kubernetes-operator/pull/463 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink-kubernetes-operator] morhidi commented on pull request #463: [FLINK-30119] Breaking change: Flink Kubernetes Operator should store…

2023-01-19 Thread GitBox
morhidi commented on PR #463: URL: https://github.com/apache/flink-kubernetes-operator/pull/463#issuecomment-1397797194 After discussing it with Clara, I'm colsing this for the time being. -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] dchristle commented on pull request #21729: [FLINK-30751] [docs] Remove references to disableDataSync in RocksDB documentation

2023-01-19 Thread GitBox
dchristle commented on PR #21729: URL: https://github.com/apache/flink/pull/21729#issuecomment-1397381115 Hi @Myasuka, Thanks for reviewing this PR! I split the changes into separate commits. The first commit removes `disableDataSync`, and the last commit aligns the PyFlink RocksDB

[GitHub] [flink] dchristle commented on a diff in pull request #21729: [FLINK-30751] [docs] Remove references to disableDataSync in RocksDB documentation

2023-01-19 Thread GitBox
dchristle commented on code in PR #21729: URL: https://github.com/apache/flink/pull/21729#discussion_r1081619201 ## flink-python/pyflink/datastream/state_backend.py: ## @@ -956,16 +956,20 @@ class PredefinedOptions(Enum): determined to be beneficial for performance under

[GitHub] [flink] RyanSkraba commented on pull request #19970: [FLINK-27970][tests][JUnit5 migration] flink-hadoop-bulk

2023-01-19 Thread GitBox
RyanSkraba commented on PR #19970: URL: https://github.com/apache/flink/pull/19970#issuecomment-1397364945 Hello! I've rebased this PR to master and fixed the merge conflicts in the meantime. I will be mostly away from my computer for a couple of weeks, but I'll check in if

[GitHub] [flink] RyanSkraba commented on pull request #21289: [FLINK-29452] Allow unit tests to be executed independently

2023-01-19 Thread GitBox
RyanSkraba commented on PR #21289: URL: https://github.com/apache/flink/pull/21289#issuecomment-1397363704 Hello! I've rebased this PR to master. I don't believe there are any remaining requested changes that I haven't addressed (by comment or other). I will be mostly away from my

[GitHub] [flink] dchristle commented on a diff in pull request #21729: [FLINK-30751] [docs] Remove references to disableDataSync in RocksDB documentation

2023-01-19 Thread GitBox
dchristle commented on code in PR #21729: URL: https://github.com/apache/flink/pull/21729#discussion_r1081578012 ## flink-python/pyflink/datastream/state_backend.py: ## @@ -1000,21 +1000,24 @@ class PredefinedOptions(Enum): The following options are set: +-

[GitHub] [flink] RyanSkraba commented on pull request #19897: [FLINK-27885][tests][JUnit5 migration] flink-csv

2023-01-19 Thread GitBox
RyanSkraba commented on PR #19897: URL: https://github.com/apache/flink/pull/19897#issuecomment-1397317096 Hello! I've rebased this PR to master. I don't believe there are any remaining requested changes that I haven't addressed (by comment or other). I will be mostly away from my

[GitHub] [flink] mbalassi commented on pull request #21732: [FLINK-30754][tests] Fix ExceptionThrowingDelegationTokenProvider/Receiver multi-threaded test issues

2023-01-19 Thread GitBox
mbalassi commented on PR #21732: URL: https://github.com/apache/flink/pull/21732#issuecomment-1397310760 @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] dawidwys commented on a diff in pull request #21635: [FLINK-30613] Improve resolving schema compatibility -- Milestone one

2023-01-19 Thread GitBox
dawidwys commented on code in PR #21635: URL: https://github.com/apache/flink/pull/21635#discussion_r1081546445 ## flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/MapDataSerializer.java: ## @@ -227,25 +225,22 @@ public void

[GitHub] [flink] dawidwys commented on a diff in pull request #21635: [FLINK-30613] Improve resolving schema compatibility -- Milestone one

2023-01-19 Thread GitBox
dawidwys commented on code in PR #21635: URL: https://github.com/apache/flink/pull/21635#discussion_r1081544400 ## flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/RowDataSerializer.java: ## @@ -194,31 +193,33 @@ public void

[GitHub] [flink] dawidwys commented on a diff in pull request #21635: [FLINK-30613] Improve resolving schema compatibility -- Milestone one

2023-01-19 Thread GitBox
dawidwys commented on code in PR #21635: URL: https://github.com/apache/flink/pull/21635#discussion_r1081541284 ## flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/ScalaEnumSerializerSnapshot.scala: ## @@ -80,25 +80,26 @@ class ScalaEnumSerializerSnapshot[E <:

[GitHub] [flink] dawidwys commented on a diff in pull request #21635: [FLINK-30613] Improve resolving schema compatibility -- Milestone one

2023-01-19 Thread GitBox
dawidwys commented on code in PR #21635: URL: https://github.com/apache/flink/pull/21635#discussion_r1081540937 ## flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/ScalaEnumSerializerSnapshot.scala: ## @@ -80,25 +80,26 @@ class ScalaEnumSerializerSnapshot[E <:

[GitHub] [flink] dawidwys commented on a diff in pull request #21635: [FLINK-30613] Improve resolving schema compatibility -- Milestone one

2023-01-19 Thread GitBox
dawidwys commented on code in PR #21635: URL: https://github.com/apache/flink/pull/21635#discussion_r1081536771 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/typeutils/RowDataSerializer.java: ## @@ -328,26 +327,27 @@ public void

[jira] [Comment Edited] (FLINK-30378) Rework sql_download_table shortcode

2023-01-19 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17678793#comment-17678793 ] Chesnay Schepler edited comment on FLINK-30378 at 1/19/23 4:16 PM: ---

[jira] [Closed] (FLINK-30378) Rework sql_download_table shortcode

2023-01-19 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-30378. Resolution: Fixed master: 8d5cfe60335f655f7196a0e744d7bbbf8f10ca8a

[GitHub] [flink-connector-aws] boring-cyborg[bot] commented on pull request #36: [FLINK-30378][docs] Use modified sql_connector_download_table shortcode

2023-01-19 Thread GitBox
boring-cyborg[bot] commented on PR #36: URL: https://github.com/apache/flink-connector-aws/pull/36#issuecomment-1397233856 Awesome work, congrats on your first merged pull request! -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink-connector-aws] zentol merged pull request #36: [FLINK-30378][docs] Use modified sql_connector_download_table shortcode

2023-01-19 Thread GitBox
zentol merged PR #36: URL: https://github.com/apache/flink-connector-aws/pull/36 -- 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] zentol merged pull request #21492: [FLINK-30378][docs] Add v2 sql_connector_download_table shortcode

2023-01-19 Thread GitBox
zentol merged PR #21492: URL: https://github.com/apache/flink/pull/21492 -- 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-30757) Ugrade busybox version to a pinned version for operator

2023-01-19 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi updated FLINK-30757: -- Priority: Minor (was: Major) > Ugrade busybox version to a pinned version for operator >

[jira] [Created] (FLINK-30757) Ugrade busybox version to a pinned version for operator

2023-01-19 Thread Gabor Somogyi (Jira)
Gabor Somogyi created FLINK-30757: - Summary: Ugrade busybox version to a pinned version for operator Key: FLINK-30757 URL: https://issues.apache.org/jira/browse/FLINK-30757 Project: Flink

[GitHub] [flink] zentol commented on pull request #17834: [FLINK-24941][datadog] Support Boolean gauges

2023-01-19 Thread GitBox
zentol commented on PR #17834: URL: https://github.com/apache/flink/pull/17834#issuecomment-1397207313 So gauges are a bit annoying. Ideally we would only have Number gauges because really nothing else is properly supported by a majority of systems. Boolean gauges are usually a

[jira] [Commented] (FLINK-13414) Add support for Scala 2.13

2023-01-19 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17678786#comment-17678786 ] Martijn Visser commented on FLINK-13414: [~novakov.alex] We keep the docs for earlier released

[GitHub] [flink-connector-cassandra] echauchot commented on a diff in pull request #3: [FLINK-26822] Add Cassandra Source

2023-01-19 Thread GitBox
echauchot commented on code in PR #3: URL: https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1081463284 ## flink-connector-cassandra/src/main/java/org/apache/flink/connector/cassandra/source/split/CassandraSplitSerializer.java: ## @@ -0,0 +1,63 @@ +/* + *

[GitHub] [flink] luoyuxia commented on a diff in pull request #21703: [FLINK-29880][hive] Introduce auto compaction for Hive sink in batch mode

2023-01-19 Thread GitBox
luoyuxia commented on code in PR #21703: URL: https://github.com/apache/flink/pull/21703#discussion_r1081459459 ## flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableCompactSinkITCase.java: ## @@ -0,0 +1,209 @@ +/* + * Licensed to the

[GitHub] [flink] luoyuxia commented on a diff in pull request #21703: [FLINK-29880][hive] Introduce auto compaction for Hive sink in batch mode

2023-01-19 Thread GitBox
luoyuxia commented on code in PR #21703: URL: https://github.com/apache/flink/pull/21703#discussion_r1081459459 ## flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableCompactSinkITCase.java: ## @@ -0,0 +1,209 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-13414) Add support for Scala 2.13

2023-01-19 Thread Alexey Novakov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17678777#comment-17678777 ] Alexey Novakov commented on FLINK-13414: Thanks guys. Provided links are useful as well. (y) It

[GitHub] [flink] healchow commented on a diff in pull request #21726: [FLINK-30748][docs]Translate "Overview" page of "Querys" into Chinese

2023-01-19 Thread GitBox
healchow commented on code in PR #21726: URL: https://github.com/apache/flink/pull/21726#discussion_r1081454537 ## docs/content.zh/docs/dev/table/sql/queries/overview.md: ## @@ -155,110 +158,116 @@ sink_descriptor = TableDescriptor.for_connector("filesystem")

[GitHub] [flink] healchow commented on a diff in pull request #21726: [FLINK-30748][docs]Translate "Overview" page of "Querys" into Chinese

2023-01-19 Thread GitBox
healchow commented on code in PR #21726: URL: https://github.com/apache/flink/pull/21726#discussion_r1081454537 ## docs/content.zh/docs/dev/table/sql/queries/overview.md: ## @@ -155,110 +158,116 @@ sink_descriptor = TableDescriptor.for_connector("filesystem")

[GitHub] [flink] healchow commented on a diff in pull request #21726: [FLINK-30748][docs]Translate "Overview" page of "Querys" into Chinese

2023-01-19 Thread GitBox
healchow commented on code in PR #21726: URL: https://github.com/apache/flink/pull/21726#discussion_r1081453260 ## docs/content.zh/docs/dev/table/sql/queries/overview.md: ## @@ -155,110 +158,116 @@ sink_descriptor = TableDescriptor.for_connector("filesystem")

[jira] [Updated] (FLINK-30749) Delegation token provider enabled flag documentation is wrong

2023-01-19 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-30749: - Component/s: Documentation > Delegation token provider enabled flag documentation is

[jira] [Closed] (FLINK-30749) Delegation token provider enabled flag documentation is wrong

2023-01-19 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-30749. Fix Version/s: 1.17.0 Resolution: Fixed master:

[GitHub] [flink] zentol merged pull request #21723: [FLINK-30749][security][runtime] Fix delegation token provider enabled flag documentation

2023-01-19 Thread GitBox
zentol merged PR #21723: URL: https://github.com/apache/flink/pull/21723 -- 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-cassandra] echauchot commented on pull request #3: [FLINK-26822] Add Cassandra Source

2023-01-19 Thread GitBox
echauchot commented on PR #3: URL: https://github.com/apache/flink-connector-cassandra/pull/3#issuecomment-1397142509 > > I did not author the RingRange and SplitsGenerator classes. I got them from the Apache Beam Cassandra connector. > > If you're copying stuff from other projects

[GitHub] [flink] LadyForest commented on pull request #21717: [FLINK-29945][sql-client] Supports to submit SQL to a embedded SQL Ga…

2023-01-19 Thread GitBox
LadyForest commented on PR #21717: URL: https://github.com/apache/flink/pull/21717#issuecomment-1397141360 P.S. Wrong cmd will get CLI blocked forever. The stacktrace is attached ```text Flink SQL> desc extended foo; Exception in thread "main"

[GitHub] [flink] LadyForest commented on a diff in pull request #21717: [FLINK-29945][sql-client] Supports to submit SQL to a embedded SQL Ga…

2023-01-19 Thread GitBox
LadyForest commented on code in PR #21717: URL: https://github.com/apache/flink/pull/21717#discussion_r1081032613 ## flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/parser/SqlCommandParserImpl.java: ## @@ -18,35 +18,136 @@ package

[GitHub] [flink] luoyuxia commented on a diff in pull request #21703: [FLINK-29880][hive] Introduce auto compaction for Hive sink in batch mode

2023-01-19 Thread GitBox
luoyuxia commented on code in PR #21703: URL: https://github.com/apache/flink/pull/21703#discussion_r1081412503 ## docs/content/docs/connectors/table/hive/hive_read_write.md: ## @@ -558,6 +558,70 @@ use more threads to speed the gathering. **NOTE:** - Only `BATCH` mode

[GitHub] [flink] luoyuxia commented on a diff in pull request #21601: [FLINK-29720][hive] Supports native avg function for hive dialect

2023-01-19 Thread GitBox
luoyuxia commented on code in PR #21601: URL: https://github.com/apache/flink/pull/21601#discussion_r1081360275 ## docs/content.zh/docs/connectors/table/hive/hive_functions.md: ## @@ -73,6 +73,31 @@ Some Hive built-in functions in older versions have [thread safety

[GitHub] [flink] dawidwys commented on a diff in pull request #21635: [FLINK-30613] Improve resolving schema compatibility -- Milestone one

2023-01-19 Thread GitBox
dawidwys commented on code in PR #21635: URL: https://github.com/apache/flink/pull/21635#discussion_r1081388117 ## flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/PojoSerializerSnapshot.java: ## @@ -56,6 +55,9 @@ /** Contains the actual content for the

[jira] [Closed] (FLINK-30672) Support 'EXPLAIN PLAN_ADVICE' statement

2023-01-19 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-30672. --- Resolution: Fixed fixed in master: 6f88d7a973731ad961a2eb7f56608807766169ca > Support 'EXPLAIN

[GitHub] [flink] dawidwys commented on a diff in pull request #21635: [FLINK-30613] Improve resolving schema compatibility -- Milestone one

2023-01-19 Thread GitBox
dawidwys commented on code in PR #21635: URL: https://github.com/apache/flink/pull/21635#discussion_r1081243028 ## flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/PojoSerializerSnapshot.java: ## @@ -56,6 +55,9 @@ /** Contains the actual content for the

[GitHub] [flink] lincoln-lil closed pull request #21683: [FLINK-30672][table] Support 'EXPLAIN PLAN_ADVICE' statement

2023-01-19 Thread GitBox
lincoln-lil closed pull request #21683: [FLINK-30672][table] Support 'EXPLAIN PLAN_ADVICE' statement URL: https://github.com/apache/flink/pull/21683 -- 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

[jira] [Closed] (FLINK-29000) Support python UDF in the SQL Gateway

2023-01-19 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-29000. - Resolution: Implemented > Support python UDF in the SQL Gateway >

[jira] [Commented] (FLINK-29000) Support python UDF in the SQL Gateway

2023-01-19 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17678745#comment-17678745 ] Shengkai Fang commented on FLINK-29000: --- Merged into master:

[GitHub] [flink] luoyuxia commented on pull request #21676: [FLINK-30662][table] Planner supports delete

2023-01-19 Thread GitBox
luoyuxia commented on PR #21676: URL: https://github.com/apache/flink/pull/21676#issuecomment-1397093090 Thanks for the detail check. Sorry for missing some thing while merge these commits to two commit. Now, I fix it, each commit should compile and pass test sucessfully. Thank you

[GitHub] [flink] fsk119 merged pull request #21725: [FLINK-29000][python] Support python UDF in the SQL Gateway

2023-01-19 Thread GitBox
fsk119 merged PR #21725: URL: https://github.com/apache/flink/pull/21725 -- 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] XComp closed pull request #21734: [FLINK-30756] Revert "[FLINK-30191][python] Update net.sf.py4j:py4j dependency to 0.10.9.7"

2023-01-19 Thread GitBox
XComp closed pull request #21734: [FLINK-30756] Revert "[FLINK-30191][python] Update net.sf.py4j:py4j dependency to 0.10.9.7" URL: https://github.com/apache/flink/pull/21734 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] XComp commented on pull request #21734: [FLINK-30756] Revert "[FLINK-30191][python] Update net.sf.py4j:py4j dependency to 0.10.9.7"

2023-01-19 Thread GitBox
XComp commented on PR #21734: URL: https://github.com/apache/flink/pull/21734#issuecomment-1397074229 The issue was already fixed through PR #21730. No revert necessary. See succeeding build

[jira] [Closed] (FLINK-30756) StreamTableExplainTests.test_explain fails

2023-01-19 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl closed FLINK-30756. - Resolution: Won't Fix FLINK-30753 fixes the issue. See related CI build

[jira] [Updated] (FLINK-30756) StreamTableExplainTests.test_explain fails

2023-01-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30756: --- Labels: pull-request-available test-stability (was: test-stability) >

[GitHub] [flink] flinkbot commented on pull request #21734: [FLINK-30756] Revert "[FLINK-30191][python] Update net.sf.py4j:py4j dependency to 0.10.9.7"

2023-01-19 Thread GitBox
flinkbot commented on PR #21734: URL: https://github.com/apache/flink/pull/21734#issuecomment-1397054878 ## CI report: * e5764802ea403f6a0226ef5577c9ad2ab7393c6d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] XComp opened a new pull request, #21734: Revert "[FLINK-30191][python] Update net.sf.py4j:py4j dependency to 0.10.9.7"

2023-01-19 Thread GitBox
XComp opened a new pull request, #21734: URL: https://github.com/apache/flink/pull/21734 ## What is the purpose of the change This reverts commit 0bbc7b1e9fed89b8c3e8ec67b7b0dad5999c2c01 to PR #21680 to stabilize master again. ## Brief change log `git revert

[jira] [Commented] (FLINK-30328) TaskManagerWideRocksDbMemorySharingITCase.testBlockCache failed

2023-01-19 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17678727#comment-17678727 ] Roman Khachatryan commented on FLINK-30328: --- Sorry for the late reply, [~mapohl]  I've

[GitHub] [flink] flinkbot commented on pull request #21733: [WIP] assert that memory usage deviation is within bounds instead of …

2023-01-19 Thread GitBox
flinkbot commented on PR #21733: URL: https://github.com/apache/flink/pull/21733#issuecomment-1397030682 ## CI report: * 6e994eed6d8f7d4a96cf64b05aaed8ac6b5e9c3f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-30756) StreamTableExplainTests.test_explain fails

2023-01-19 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17678721#comment-17678721 ] Matthias Pohl commented on FLINK-30756: --- 0bbc7b1e9fed89b8c3e8ec67b7b0dad5999c2c01 was added as the

[GitHub] [flink] rkhachatryan opened a new pull request, #21733: [WIP] assert that memory usage deviation is within bounds instead of …

2023-01-19 Thread GitBox
rkhachatryan opened a new pull request, #21733: URL: https://github.com/apache/flink/pull/21733 …min/max ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid

[jira] [Commented] (FLINK-30756) StreamTableExplainTests.test_explain fails

2023-01-19 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17678719#comment-17678719 ] Matthias Pohl commented on FLINK-30756: ---

[GitHub] [flink] flinkbot commented on pull request #21732: [FLINK-30754][tests] Fix ExceptionThrowingDelegationTokenProvider/Receiver multi-threaded test issues

2023-01-19 Thread GitBox
flinkbot commented on PR #21732: URL: https://github.com/apache/flink/pull/21732#issuecomment-1397021603 ## CI report: * 66179da2139a8a1678ff53416661c4c744fa8ed1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-30733) The AzureCI Slack bot does not list all failed builds in the Slack channel

2023-01-19 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-30733: -- Description: We've experienced failing builds not being reported by the AzureCI Slack bot in

[jira] [Commented] (FLINK-30756) StreamTableExplainTests.test_explain fails

2023-01-19 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17678717#comment-17678717 ] Matthias Pohl commented on FLINK-30756: ---

[jira] [Updated] (FLINK-30756) StreamTableExplainTests.test_explain fails

2023-01-19 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-30756: -- Description: We observed StreamTableExplainTests.test_explain failing on {{{}master{}}}. I'm

[GitHub] [flink] gaborgsomogyi commented on pull request #21732: [FLINK-30754][tests] Fix ExceptionThrowingDelegationTokenProvider/Receiver multi-threaded test issues

2023-01-19 Thread GitBox
gaborgsomogyi commented on PR #21732: URL: https://github.com/apache/flink/pull/21732#issuecomment-1397011089 cc @gyfora @mbalassi -- 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

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

2023-01-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30754: --- Labels: pull-request-available (was: ) > Fix

[GitHub] [flink] gaborgsomogyi opened a new pull request, #21732: [FLINK-30754][tests] Fix ExceptionThrowingDelegationTokenProvider/Receiver multi-threaded test issues

2023-01-19 Thread GitBox
gaborgsomogyi opened a new pull request, #21732: URL: https://github.com/apache/flink/pull/21732 ## What is the purpose of the change At the moment tests using `ExceptionThrowingDelegationTokenProvider` and `ExceptionThrowingDelegationTokenReceiver` are not thread safe because of the

  1   2   3   >