[jira] [Created] (FLINK-31427) Pulsar Catalog support with Schema translation

2023-03-13 Thread Yufan Sheng (Jira)
Yufan Sheng created FLINK-31427: --- Summary: Pulsar Catalog support with Schema translation Key: FLINK-31427 URL: https://issues.apache.org/jira/browse/FLINK-31427 Project: Flink Issue Type:

[jira] [Commented] (FLINK-31371) Stream failure if the topic doesn't exist

2023-03-13 Thread Yufan Sheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699764#comment-17699764 ] Yufan Sheng commented on FLINK-31371: - [~guoweijie] Can you assign this ticket to me? > Stream

[jira] [Commented] (FLINK-31371) Stream failure if the topic doesn't exist

2023-03-13 Thread Yufan Sheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699762#comment-17699762 ] Yufan Sheng commented on FLINK-31371: - Hi [~enzodechaene], the old fix in

[GitHub] [flink] Aitozi commented on pull request #21522: [FLINK-29585][hive] Migrate TableSchema to Schema for Hive connector

2023-03-13 Thread via GitHub
Aitozi commented on PR #21522: URL: https://github.com/apache/flink/pull/21522#issuecomment-1466522390 Hi @luoyuxia , Most of your comments have be solved. PTAL again. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] Aitozi commented on a diff in pull request #21522: [FLINK-29585][hive] Migrate TableSchema to Schema for Hive connector

2023-03-13 Thread via GitHub
Aitozi commented on code in PR #21522: URL: https://github.com/apache/flink/pull/21522#discussion_r1134309529 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveSourceBuilder.java: ## @@ -281,12 +278,12 @@ public HiveSourceBuilder

[GitHub] [flink] Aitozi commented on a diff in pull request #21522: [FLINK-29585][hive] Migrate TableSchema to Schema for Hive connector

2023-03-13 Thread via GitHub
Aitozi commented on code in PR #21522: URL: https://github.com/apache/flink/pull/21522#discussion_r1134283226 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/OperationConverterUtils.java: ## @@ -69,67 +69,75 @@ private

[GitHub] [flink] Aitozi commented on a diff in pull request #21522: [FLINK-29585][hive] Migrate TableSchema to Schema for Hive connector

2023-03-13 Thread via GitHub
Aitozi commented on code in PR #21522: URL: https://github.com/apache/flink/pull/21522#discussion_r1134279553 ## flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/catalog/hive/HiveCatalogMetadataTestBase.java: ## @@ -60,4 +65,50 @@ public void

[GitHub] [flink] jiexray commented on a diff in pull request #21822: [FLINK-30863][state] Register local recovery files of changelog before notifyCheckpointComplete()

2023-03-13 Thread via GitHub
jiexray commented on code in PR #21822: URL: https://github.com/apache/flink/pull/21822#discussion_r1134272846 ## flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java: ## @@ -455,12 +467,23 @@ private

[GitHub] [flink] Aitozi commented on a diff in pull request #21522: [FLINK-29585][hive] Migrate TableSchema to Schema for Hive connector

2023-03-13 Thread via GitHub
Aitozi commented on code in PR #21522: URL: https://github.com/apache/flink/pull/21522#discussion_r1134269897 ## flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveLookupJoinITCase.java: ## @@ -205,10 +208,22 @@ public void

[GitHub] [flink] Aitozi commented on a diff in pull request #21522: [FLINK-29585][hive] Migrate TableSchema to Schema for Hive connector

2023-03-13 Thread via GitHub
Aitozi commented on code in PR #21522: URL: https://github.com/apache/flink/pull/21522#discussion_r1134257301 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/HiveParserCalcitePlanner.java: ## @@ -821,13 +823,15 @@ private

[GitHub] [flink-connector-shared-utils] MartijnVisser merged pull request #9: [FLINK-31416][CI] Allow skipping of dependency convergence check

2023-03-13 Thread via GitHub
MartijnVisser merged PR #9: URL: https://github.com/apache/flink-connector-shared-utils/pull/9 -- 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-31416) Allow skipping of dependency convergence check

2023-03-13 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-31416. -- Resolution: Fixed Fixed in flink-connector-shared-utils@ci_utils:

[GitHub] [flink] Aitozi commented on a diff in pull request #21522: [FLINK-29585][hive] Migrate TableSchema to Schema for Hive connector

2023-03-13 Thread via GitHub
Aitozi commented on code in PR #21522: URL: https://github.com/apache/flink/pull/21522#discussion_r1134248086 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/util/HiveTableUtil.java: ## @@ -97,7 +102,54 @@ public class HiveTableUtil {

[GitHub] [flink] Aitozi commented on a diff in pull request #21522: [FLINK-29585][hive] Migrate TableSchema to Schema for Hive connector

2023-03-13 Thread via GitHub
Aitozi commented on code in PR #21522: URL: https://github.com/apache/flink/pull/21522#discussion_r1134219628 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveCatalog.java: ## @@ -763,7 +783,7 @@ CatalogBaseTable

[jira] [Created] (FLINK-31426) Upgrade the deprecated UniqueConstraint to the new one

2023-03-13 Thread Aitozi (Jira)
Aitozi created FLINK-31426: -- Summary: Upgrade the deprecated UniqueConstraint to the new one Key: FLINK-31426 URL: https://issues.apache.org/jira/browse/FLINK-31426 Project: Flink Issue Type:

[GitHub] [flink] Aitozi commented on a diff in pull request #21522: [FLINK-29585][hive] Migrate TableSchema to Schema for Hive connector

2023-03-13 Thread via GitHub
Aitozi commented on code in PR #21522: URL: https://github.com/apache/flink/pull/21522#discussion_r1134212972 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveCatalog.java: ## @@ -473,27 +476,37 @@ public void createTable(ObjectPath

[jira] [Created] (FLINK-31425) Support submitting a job with streamgraph

2023-03-13 Thread Jeff (Jira)
Jeff created FLINK-31425: Summary: Support submitting a job with streamgraph Key: FLINK-31425 URL: https://issues.apache.org/jira/browse/FLINK-31425 Project: Flink Issue Type: New Feature

[GitHub] [flink] flinkbot commented on pull request #22171: [FLINK-31420][test] Fix unstable test ThreadInfoRequestCoordinatorTest.

2023-03-13 Thread via GitHub
flinkbot commented on PR #22171: URL: https://github.com/apache/flink/pull/22171#issuecomment-1466367972 ## CI report: * 4b1a56e806a42eae0a4b6915b1290d50179321f9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-31420) ThreadInfoRequestCoordinatorTest.testShutDown failed on CI

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

[GitHub] [flink] reswqa opened a new pull request, #22171: [FLINK-31420] Fix unstable test ThreadInfoRequestCoordinatorTest.

2023-03-13 Thread via GitHub
reswqa opened a new pull request, #22171: URL: https://github.com/apache/flink/pull/22171 ## What is the purpose of the change *`ThreadInfoRequestCoordinatorTest#testShutDown` using two gateways contains a `timeout gateway` but expected all `request futures` not done before

[jira] [Comment Edited] (FLINK-31420) ThreadInfoRequestCoordinatorTest.testShutDown failed on CI

2023-03-13 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699671#comment-17699671 ] Weijie Guo edited comment on FLINK-31420 at 3/13/23 3:19 PM: - After checking

[jira] [Updated] (FLINK-31424) NullPointer when using StatementSet for multiple sinks

2023-03-13 Thread jirawech.s (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jirawech.s updated FLINK-31424: --- Description: I got following error when i tried to execute multiple sinks using StatementSet. I am

[jira] [Updated] (FLINK-31424) NullPointer when using StatementSet for multiple sinks

2023-03-13 Thread jirawech.s (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jirawech.s updated FLINK-31424: --- Description: I got following error when i tried to execute multiple sinks using StatementSet. I am

[jira] [Created] (FLINK-31424) NullPointer when using StatementSet for multiple sinks

2023-03-13 Thread jirawech.s (Jira)
jirawech.s created FLINK-31424: -- Summary: NullPointer when using StatementSet for multiple sinks Key: FLINK-31424 URL: https://issues.apache.org/jira/browse/FLINK-31424 Project: Flink Issue

[GitHub] [flink] swuferhong commented on pull request #22049: [FLINK-31273][table-planner] Fix left join with IS_NULL filter be wrongly pushed down and get wrong join results

2023-03-13 Thread via GitHub
swuferhong commented on PR #22049: URL: https://github.com/apache/flink/pull/22049#issuecomment-1466306222 @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] [Commented] (FLINK-26051) one sql has row_number =1 and the subsequent SQL has "case when" and "where" statement result Exception : The window can only be ordered in ASCENDING mode

2023-03-13 Thread Krzysztof Chmielewski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699685#comment-17699685 ] Krzysztof Chmielewski commented on FLINK-26051: --- Hi [~qingyue] I would like to help with

[jira] [Updated] (FLINK-31416) Allow skipping of dependency convergence check

2023-03-13 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-31416: --- Description: In order to resolve FLINK-30794 we need a mechanism that allows us to skip the

[jira] [Updated] (FLINK-31416) Allow skipping of dependency convergence check

2023-03-13 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-31416: --- Summary: Allow skipping of dependency convergence check (was: Recognize if Github Action

[jira] [Updated] (FLINK-31423) Update external connector workflow to use actions that use Node16 instead of Node12 under the hood

2023-03-13 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-31423: --- Summary: Update external connector workflow to use actions that use Node16 instead of

[jira] [Created] (FLINK-31423) Update external connector workflow to use Node16 instead of Node12 actions

2023-03-13 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-31423: -- Summary: Update external connector workflow to use Node16 instead of Node12 actions Key: FLINK-31423 URL: https://issues.apache.org/jira/browse/FLINK-31423

[jira] [Comment Edited] (FLINK-31420) ThreadInfoRequestCoordinatorTest.testShutDown failed on CI

2023-03-13 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699671#comment-17699671 ] Weijie Guo edited comment on FLINK-31420 at 3/13/23 2:22 PM: - After checking

[GitHub] [flink-connector-shared-utils] MartijnVisser commented on pull request #9: [FLINK-31416][CI] Allow skipping of dependency convergence check

2023-03-13 Thread via GitHub
MartijnVisser commented on PR #9: URL: https://github.com/apache/flink-connector-shared-utils/pull/9#issuecomment-1466234345 > Do you have a build that shows this working correctly? It's now running at

[jira] [Commented] (FLINK-31420) ThreadInfoRequestCoordinatorTest.testShutDown failed on CI

2023-03-13 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699671#comment-17699671 ] Weijie Guo commented on FLINK-31420: After checking the code, I found that this is a test code

[jira] [Assigned] (FLINK-31420) ThreadInfoRequestCoordinatorTest.testShutDown failed on CI

2023-03-13 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-31420: -- Assignee: Weijie Guo > ThreadInfoRequestCoordinatorTest.testShutDown failed on CI >

[GitHub] [flink-connector-shared-utils] zentol merged pull request #8: Move cache save after is downloaded

2023-03-13 Thread via GitHub
zentol merged PR #8: URL: https://github.com/apache/flink-connector-shared-utils/pull/8 -- 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 commented on a diff in pull request #22169: [FLINK-31399] AdaptiveScheduler is able to handle changes in job resource requirements.

2023-03-13 Thread via GitHub
zentol commented on code in PR #22169: URL: https://github.com/apache/flink/pull/22169#discussion_r1133979237 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveScheduler.java: ## @@ -1255,4 +1268,17 @@ T transitionToState(StateFactory

[GitHub] [flink] zentol commented on a diff in pull request #22169: [FLINK-31399] AdaptiveScheduler is able to handle changes in job resource requirements.

2023-03-13 Thread via GitHub
zentol commented on code in PR #22169: URL: https://github.com/apache/flink/pull/22169#discussion_r1133985330 ## flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerTest.java: ## @@ -1474,6 +1477,68 @@ public void

[GitHub] [flink] zentol commented on a diff in pull request #22169: [FLINK-31399] AdaptiveScheduler is able to handle changes in job resource requirements.

2023-03-13 Thread via GitHub
zentol commented on code in PR #22169: URL: https://github.com/apache/flink/pull/22169#discussion_r1133979237 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveScheduler.java: ## @@ -1255,4 +1268,17 @@ T transitionToState(StateFactory

[jira] [Commented] (FLINK-31144) Slow scheduling on large-scale batch jobs

2023-03-13 Thread Weihua Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699644#comment-17699644 ] Weihua Hu commented on FLINK-31144: --- [~martijnvisser], yes, this change will improve the performance

[GitHub] [flink] zentol commented on a diff in pull request #22169: [FLINK-31399] AdaptiveScheduler is able to handle changes in job resource requirements.

2023-03-13 Thread via GitHub
zentol commented on code in PR #22169: URL: https://github.com/apache/flink/pull/22169#discussion_r1133956427 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultVertexParallelismStore.java: ## @@ -18,14 +18,51 @@ package

[GitHub] [flink-connector-shared-utils] eskabetxe commented on pull request #8: Move cache save after is downloaded

2023-03-13 Thread via GitHub
eskabetxe commented on PR #8: URL: https://github.com/apache/flink-connector-shared-utils/pull/8#issuecomment-1466174109 I already have that change, but if tests fails, the save step is not done. I'm only moving the step "Cache Flink Binary" before "Compile and test" -- This is an

[GitHub] [flink-connector-shared-utils] MartijnVisser commented on pull request #8: Move cache save after is downloaded

2023-03-13 Thread via GitHub
MartijnVisser commented on PR #8: URL: https://github.com/apache/flink-connector-shared-utils/pull/8#issuecomment-1466164219 @eskabetxe I think @zentol had a similar idea with https://github.com/apache/flink-connector-shared-utils/commit/2f47df76f83d5e07e5e736b0344585d77cf51c85 -- This

[jira] [Commented] (FLINK-31144) Slow scheduling on large-scale batch jobs

2023-03-13 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699633#comment-17699633 ] Martijn Visser commented on FLINK-31144: [~zhuzh] Not 100% sure but I think this PR has resulted

[jira] [Updated] (FLINK-31144) Slow scheduling on large-scale batch jobs

2023-03-13 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-31144: --- Attachment: Screenshot 2023-03-13 at 14.22.27.png > Slow scheduling on large-scale batch

[jira] [Commented] (FLINK-31095) FileSink doesn't work with s3a on EKS

2023-03-13 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699630#comment-17699630 ] Martijn Visser commented on FLINK-31095: [~linqyd218] From the original PR that introduced IRSA,

[jira] [Commented] (FLINK-31368) Move operation execution logic out from TableEnvironmentImpl

2023-03-13 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699627#comment-17699627 ] Timo Walther commented on FLINK-31368: -- I like the {{ExecutableOperation}} interface. However, a

[GitHub] [flink] liuyongvs commented on pull request #22144: [FLINK-31102][table] Add ARRAY_REMOVE function.

2023-03-13 Thread via GitHub
liuyongvs commented on PR #22144: URL: https://github.com/apache/flink/pull/22144#issuecomment-1466116542 hi @snuyanzin could you have time to help review it -- 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] WencongLiu commented on pull request #22121: [FLINK-27051] fix CompletedCheckpoint.DiscardObject.discard is not idempotent

2023-03-13 Thread via GitHub
WencongLiu commented on PR #22121: URL: https://github.com/apache/flink/pull/22121#issuecomment-1466115969 cc @XComp -- 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

[jira] [Comment Edited] (FLINK-30863) Register local recovery files of changelog before notifyCheckpointComplete()

2023-03-13 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699621#comment-17699621 ] Yanfei Lei edited comment on FLINK-30863 at 3/13/23 1:01 PM: - [~assassinj]

[jira] [Commented] (FLINK-30863) Register local recovery files of changelog before notifyCheckpointComplete()

2023-03-13 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699621#comment-17699621 ] Yanfei Lei commented on FLINK-30863: [~assassinj] Thanks for sharing a new situation, I think it's

[GitHub] [flink] rkhachatryan commented on a diff in pull request #22153: [FLINK-31317] Introduce JobResourceRequirements and JobVertexResourceRequirements data structures.

2023-03-13 Thread via GitHub
rkhachatryan commented on code in PR #22153: URL: https://github.com/apache/flink/pull/22153#discussion_r1133891543 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobResourceRequirements.java: ## @@ -0,0 +1,222 @@ +/* + * Licensed to the Apache Software

[jira] [Created] (FLINK-31422) Add Servable for Logistic Regression Model

2023-03-13 Thread Jiang Xin (Jira)
Jiang Xin created FLINK-31422: - Summary: Add Servable for Logistic Regression Model Key: FLINK-31422 URL: https://issues.apache.org/jira/browse/FLINK-31422 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-28538) Eagerly emit a watermark the first time we exceed Long.MIN_VALUE

2023-03-13 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699613#comment-17699613 ] Wencong Liu commented on FLINK-28538: - Hello [~chesnay] , I think the

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #596: [FLINK-31415] Support target alias and using ddls to create source

2023-03-13 Thread via GitHub
JingsongLi commented on code in PR #596: URL: https://github.com/apache/flink-table-store/pull/596#discussion_r1133866492 ## flink-table-store-flink/flink-table-store-flink-common/src/test/java/org/apache/flink/table/store/connector/action/MergeIntoActionITCase.java: ## @@

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #596: [FLINK-31415] Support target alias and using ddls to create source

2023-03-13 Thread via GitHub
JingsongLi commented on code in PR #596: URL: https://github.com/apache/flink-table-store/pull/596#discussion_r1133859177 ## docs/content/docs/how-to/writing-tables.md: ## @@ -326,6 +328,8 @@ Run the following command to submit a 'merge-into' job for the table.

[GitHub] [flink] luoyuxia commented on a diff in pull request #21522: [FLINK-29585][hive] Migrate TableSchema to Schema for Hive connector

2023-03-13 Thread via GitHub
luoyuxia commented on code in PR #21522: URL: https://github.com/apache/flink/pull/21522#discussion_r1133615408 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveSourceBuilder.java: ## @@ -84,11 +82,12 @@ public class HiveSourceBuilder

[jira] [Updated] (FLINK-31273) Left join with IS_NULL filter be wrongly pushed down and get wrong join results

2023-03-13 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-31273: --- Priority: Critical (was: Blocker) > Left join with IS_NULL filter be wrongly pushed down

[jira] [Updated] (FLINK-31273) Left join with IS_NULL filter be wrongly pushed down and get wrong join results

2023-03-13 Thread Yunhong Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunhong Zheng updated FLINK-31273: -- Fix Version/s: 1.17.0 (was: 1.17.1) > Left join with IS_NULL filter be

[jira] [Updated] (FLINK-31273) Left join with IS_NULL filter be wrongly pushed down and get wrong join results

2023-03-13 Thread Yunhong Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunhong Zheng updated FLINK-31273: -- Priority: Blocker (was: Major) > Left join with IS_NULL filter be wrongly pushed down and

[jira] [Closed] (FLINK-31306) Add Servable for PipelineModel

2023-03-13 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-31306. Resolution: Fixed > Add Servable for PipelineModel > -- > >

[jira] [Commented] (FLINK-31306) Add Servable for PipelineModel

2023-03-13 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699594#comment-17699594 ] Dong Lin commented on FLINK-31306: -- Merged to apache/flink-ml master branch

[jira] [Updated] (FLINK-31306) Add Servable for PipelineModel

2023-03-13 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-31306: - Description: Add servable for PipelineModel based on FLIP-289 [1]. [1]

[jira] [Assigned] (FLINK-31306) Add Servable for PipelineModel

2023-03-13 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned FLINK-31306: Assignee: Jiang Xin > Add Servable for PipelineModel > -- > >

[GitHub] [flink-ml] lindong28 merged pull request #218: [FLINK-31306] Add Servable for PipelineModel

2023-03-13 Thread via GitHub
lindong28 merged PR #218: URL: https://github.com/apache/flink-ml/pull/218 -- 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-ml] lindong28 commented on pull request #218: [FLINK-31306] Add Servable for PipelineModel

2023-03-13 Thread via GitHub
lindong28 commented on PR #218: URL: https://github.com/apache/flink-ml/pull/218#issuecomment-1466025161 Thanks for the update. 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

[jira] [Closed] (FLINK-31412) HiveCatalog rollback schema if alter table failed in table store

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

[GitHub] [flink-table-store] JingsongLi merged pull request #595: [FLINK-31412] HiveCatalog rollbacks schema in dfs if it alters table failed

2023-03-13 Thread via GitHub
JingsongLi merged PR #595: URL: https://github.com/apache/flink-table-store/pull/595 -- 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-ml] alberta0714 opened a new pull request, #224: univariatefeatureselector.md:101:1": failed to extract shortcode: sho…

2023-03-13 Thread via GitHub
alberta0714 opened a new pull request, #224: URL: https://github.com/apache/flink-ml/pull/224 …rtcode "tab" must be closed or self-closed ## What is the purpose of the change *(For example: This pull request adds the implementation of Naive Bayes algorithm.)* ##

[jira] [Comment Edited] (FLINK-30863) Register local recovery files of changelog before notifyCheckpointComplete()

2023-03-13 Thread jinghaihang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699585#comment-17699585 ] jinghaihang edited comment on FLINK-30863 at 3/13/23 11:55 AM: --- Hello

[jira] [Commented] (FLINK-30863) Register local recovery files of changelog before notifyCheckpointComplete()

2023-03-13 Thread jinghaihang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699586#comment-17699586 ] jinghaihang commented on FLINK-30863: - The above description can be simplified to the following

[jira] [Commented] (FLINK-30863) Register local recovery files of changelog before notifyCheckpointComplete()

2023-03-13 Thread jinghaihang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699585#comment-17699585 ] jinghaihang commented on FLINK-30863: - Hello Yanfei Lei, I found another situation that also

[GitHub] [flink-ml] jiangxin369 commented on pull request #218: [FLINK-31306] Add Servable for PipelineModel

2023-03-13 Thread via GitHub
jiangxin369 commented on PR #218: URL: https://github.com/apache/flink-ml/pull/218#issuecomment-1465977728 @lindong28 Thanks for the review, I've 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 the URL

[jira] [Commented] (FLINK-28853) FLIP-217 Support watermark alignment of source splits

2023-03-13 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699574#comment-17699574 ] Maximilian Michels commented on FLINK-28853: Thanks [~leonard]! I see there was already a

[GitHub] [flink] snuyanzin commented on pull request #22146: [FLINK-31157][release] Add release note for version 1.17

2023-03-13 Thread via GitHub
snuyanzin commented on PR #22146: URL: https://github.com/apache/flink/pull/22146#issuecomment-1465950320 thanks for addressing comments, lgtm from my side -- 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] snuyanzin commented on a diff in pull request #22146: [FLINK-31157][release] Add release note for version 1.17

2023-03-13 Thread via GitHub
snuyanzin commented on code in PR #22146: URL: https://github.com/apache/flink/pull/22146#discussion_r1133775105 ## docs/content/release-notes/flink-1.17.md: ## @@ -0,0 +1,203 @@ +--- +title: "Release Notes - Flink 1.17" +--- + + +# Release notes - Flink 1.17 + +These release

[GitHub] [flink] snuyanzin commented on a diff in pull request #22146: [FLINK-31157][release] Add release note for version 1.17

2023-03-13 Thread via GitHub
snuyanzin commented on code in PR #22146: URL: https://github.com/apache/flink/pull/22146#discussion_r1133756421 ## docs/content.zh/release-notes/flink-1.17.md: ## @@ -0,0 +1,203 @@ +--- +title: "Release Notes - Flink 1.17" +--- + + +# Release notes - Flink 1.17 + +These

[jira] [Commented] (FLINK-30433) HiveDialectITCase#testCreateDatabase fails with "Could not execute CREATE DATABASE"

2023-03-13 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699565#comment-17699565 ] Qingsheng Ren commented on FLINK-30433: --- [~luoyuxia] Any idea on this one?  >

[jira] [Commented] (FLINK-18696) Java 14 Records are not recognized as POJOs

2023-03-13 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699564#comment-17699564 ] Timo Walther commented on FLINK-18696: -- [~ungureanuserg] this is still an issue and actually a very

[jira] [Commented] (FLINK-30433) HiveDialectITCase#testCreateDatabase fails with "Could not execute CREATE DATABASE"

2023-03-13 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699563#comment-17699563 ] Qingsheng Ren commented on FLINK-30433: --- {{HiveDialectITCase.testAlterDatabase}} this time:

[jira] [Comment Edited] (FLINK-31418) SortMergeResultPartitionReadSchedulerTest.testRequestBufferTimeout failed on CI

2023-03-13 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699561#comment-17699561 ] Yingjie Cao edited comment on FLINK-31418 at 3/13/23 10:51 AM: --- I will

[jira] [Updated] (FLINK-31416) Recognize if Github Action workflow is for Push, PR or Nightly Builds

2023-03-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31416: --- Labels: pull-request-available (was: ) > Recognize if Github Action workflow is for Push,

[GitHub] [flink-connector-shared-utils] zentol commented on a diff in pull request #9: [FLINK-31416][CI] Allow skipping of dependency convergence check

2023-03-13 Thread via GitHub
zentol commented on code in PR #9: URL: https://github.com/apache/flink-connector-shared-utils/pull/9#discussion_r1133743956 ## .github/workflows/ci.yml: ## @@ -73,6 +79,14 @@ jobs: with: maven-version: 3.8.6 + - name: "Determine if dependency

[jira] [Commented] (FLINK-31418) SortMergeResultPartitionReadSchedulerTest.testRequestBufferTimeout failed on CI

2023-03-13 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699561#comment-17699561 ] Yingjie Cao commented on FLINK-31418: - I will also try to reproduce it. If it can reproduce, let's

[jira] [Commented] (FLINK-31421) DataGeneratorSourceITCase.testGatedRateLimiter failed on CI

2023-03-13 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699560#comment-17699560 ] Qingsheng Ren commented on FLINK-31421: --- [~chesnay] may you take a look at this? Thanks >

[jira] [Created] (FLINK-31421) DataGeneratorSourceITCase.testGatedRateLimiter failed on CI

2023-03-13 Thread Qingsheng Ren (Jira)
Qingsheng Ren created FLINK-31421: - Summary: DataGeneratorSourceITCase.testGatedRateLimiter failed on CI Key: FLINK-31421 URL: https://issues.apache.org/jira/browse/FLINK-31421 Project: Flink

[jira] [Commented] (FLINK-31358) Display consumed split/partition/queue info on Web UI

2023-03-13 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699559#comment-17699559 ] Wencong Liu commented on FLINK-31358: - I seems a specific design for source subtasks. It's necessary

[GitHub] [flink-table-store] FangYongs commented on a diff in pull request #595: [FLINK-31412] HiveCatalog rollbacks schema in dfs if it alters table failed

2023-03-13 Thread via GitHub
FangYongs commented on code in PR #595: URL: https://github.com/apache/flink-table-store/pull/595#discussion_r1133744411 ## flink-table-store-hive/flink-table-store-hive-catalog/src/main/java/org/apache/flink/table/store/hive/HiveCatalog.java: ## @@ -297,13 +297,20 @@ public

[jira] [Comment Edited] (FLINK-31418) SortMergeResultPartitionReadSchedulerTest.testRequestBufferTimeout failed on CI

2023-03-13 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699556#comment-17699556 ] Yuxin Tan edited comment on FLINK-31418 at 3/13/23 10:43 AM: - I think

[jira] [Comment Edited] (FLINK-31418) SortMergeResultPartitionReadSchedulerTest.testRequestBufferTimeout failed on CI

2023-03-13 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699556#comment-17699556 ] Yuxin Tan edited comment on FLINK-31418 at 3/13/23 10:42 AM: - I think

[jira] [Comment Edited] (FLINK-30275) TaskExecutorTest.testSharedResourcesLifecycle fails

2023-03-13 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699557#comment-17699557 ] Qingsheng Ren edited comment on FLINK-30275 at 3/13/23 10:41 AM: - Looks

[jira] [Updated] (FLINK-30275) TaskExecutorTest.testSharedResourcesLifecycle fails

2023-03-13 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-30275: -- Affects Version/s: 1.18.0 > TaskExecutorTest.testSharedResourcesLifecycle fails >

[jira] [Commented] (FLINK-31418) SortMergeResultPartitionReadSchedulerTest.testRequestBufferTimeout failed on CI

2023-03-13 Thread Yuxin Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699556#comment-17699556 ] Yuxin Tan commented on FLINK-31418: --- I think https://issues.apache.org/jira/browse/FLINK-31418 may

[jira] [Commented] (FLINK-30275) TaskExecutorTest.testSharedResourcesLifecycle fails

2023-03-13 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699557#comment-17699557 ] Qingsheng Ren commented on FLINK-30275: --- Looks like the issue pops up again:

[jira] [Updated] (FLINK-31227) Remove 'scala version' from file sink modules

2023-03-13 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-31227: - Component/s: Documentation > Remove 'scala version' from file sink modules >

[jira] [Reopened] (FLINK-30275) TaskExecutorTest.testSharedResourcesLifecycle fails

2023-03-13 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reopened FLINK-30275: --- > TaskExecutorTest.testSharedResourcesLifecycle fails >

[jira] [Commented] (FLINK-26808) [flink v1.14.2] Submit jobs via REST API not working after set web.submit.enable: false

2023-03-13 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699553#comment-17699553 ] Chesnay Schepler commented on FLINK-26808: -- What the docs are referring to is the job

[jira] [Commented] (FLINK-26515) RetryingExecutorTest. testDiscardOnTimeout failed on azure

2023-03-13 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699551#comment-17699551 ] Qingsheng Ren commented on FLINK-26515: --- 1.16:

[jira] [Commented] (FLINK-31419) Flink-JDBC should allow . in field names

2023-03-13 Thread Woong Wen Tat (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699548#comment-17699548 ] Woong Wen Tat commented on FLINK-31419: --- Fix is to add the period to be recognized as a legal

[jira] [Created] (FLINK-31420) ThreadInfoRequestCoordinatorTest.testShutDown failed on CI

2023-03-13 Thread Qingsheng Ren (Jira)
Qingsheng Ren created FLINK-31420: - Summary: ThreadInfoRequestCoordinatorTest.testShutDown failed on CI Key: FLINK-31420 URL: https://issues.apache.org/jira/browse/FLINK-31420 Project: Flink

[jira] [Commented] (FLINK-31420) ThreadInfoRequestCoordinatorTest.testShutDown failed on CI

2023-03-13 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699547#comment-17699547 ] Qingsheng Ren commented on FLINK-31420: --- [~fanrui] Could you take a look on this one? Thanks >

<    1   2   3   >