[jira] [Assigned] (FLINK-33581) FLIP-381: Deprecate configuration getters/setters that return/set complex Java objects

2023-11-16 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang reassigned FLINK-33581: -- Assignee: Junrui Li > FLIP-381: Deprecate configuration getters/setters that return/set compl

[jira] [Updated] (FLINK-33581) FLIP-381: Deprecate configuration getters/setters that return/set complex Java objects

2023-11-16 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-33581: -- Description: Deprecate he non-ConfigOption objects in the StreamExecutionEnvironment, CheckpointConfig

[jira] [Created] (FLINK-33581) FLIP-381: Deprecate configuration getters/setters that return/set complex Java objects

2023-11-16 Thread Junrui Li (Jira)
Junrui Li created FLINK-33581: - Summary: FLIP-381: Deprecate configuration getters/setters that return/set complex Java objects Key: FLINK-33581 URL: https://issues.apache.org/jira/browse/FLINK-33581 Proj

Re: [PR] [FLINK-33568] Fix NullpointerException in SinkV2MetricsITCase [flink]

2023-11-16 Thread via GitHub
XComp commented on code in PR #23737: URL: https://github.com/apache/flink/pull/23737#discussion_r1396272660 ## flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/SinkV2MetricsITCase.java: ## @@ -228,32 +228,54 @@ private void assertSinkCommitterMetrics(

Re: [PR] [FLINK-33568] Fix NullpointerException in SinkV2MetricsITCase [flink]

2023-11-16 Thread via GitHub
XComp commented on code in PR #23737: URL: https://github.com/apache/flink/pull/23737#discussion_r1396275250 ## flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/SinkV2MetricsITCase.java: ## @@ -228,32 +228,54 @@ private void assertSinkCommitterMetrics(

Re: [PR] [FLINK-33568] Fix NullpointerException in SinkV2MetricsITCase [flink]

2023-11-16 Thread via GitHub
XComp commented on code in PR #23737: URL: https://github.com/apache/flink/pull/23737#discussion_r1396272660 ## flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/SinkV2MetricsITCase.java: ## @@ -228,32 +228,54 @@ private void assertSinkCommitterMetrics(

[jira] [Created] (FLINK-33580) composite actions do not work in release branchs where GHA work wasn't backported

2023-11-16 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-33580: - Summary: composite actions do not work in release branchs where GHA work wasn't backported Key: FLINK-33580 URL: https://issues.apache.org/jira/browse/FLINK-33580 P

Re: [PR] [FLINK-33568] Fix NullpointerException in SinkV2MetricsITCase [flink]

2023-11-16 Thread via GitHub
XComp commented on code in PR #23737: URL: https://github.com/apache/flink/pull/23737#discussion_r1396275250 ## flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/SinkV2MetricsITCase.java: ## @@ -228,32 +228,54 @@ private void assertSinkCommitterMetrics(

[jira] [Commented] (FLINK-33472) Solve the problem that the temporary file of flink-conf.yaml in S3AFileSystem cannot be uploaded

2023-11-16 Thread zhengzhili (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17787059#comment-17787059 ] zhengzhili commented on FLINK-33472: My logs is at this link:  [https://github.com/z

[jira] [Commented] (FLINK-33579) Join sql error

2023-11-16 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17787057#comment-17787057 ] waywtdcc commented on FLINK-33579: -- After I turned on 'table.optimizer.join-reorder-ena

[jira] [Commented] (FLINK-33579) Join sql error

2023-11-16 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17787054#comment-17787054 ] lincoln lee commented on FLINK-33579: - [~waywtdcc] can you have a try to enable the

Re: [PR] [FLINK-33578][ci] Removes scala-2.12 system property [flink]

2023-11-16 Thread via GitHub
flinkbot commented on PR #23738: URL: https://github.com/apache/flink/pull/23738#issuecomment-1815789568 ## CI report: * c305483c86f2b40fce8c5b75fe2dae179ce52cf5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-33578) Remove scala-2.12 system variable

2023-11-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33578: --- Labels: pull-request-available (was: ) > Remove scala-2.12 system variable > --

[PR] [FLINK-33578][ci] Removes scala-2.12 system property [flink]

2023-11-16 Thread via GitHub
XComp opened a new pull request, #23738: URL: https://github.com/apache/flink/pull/23738 ## What is the purpose of the change We're only relying on Scala 2.12 (and the plan is to drop it entirely for 2.x). The Scala prefix is still present in CI, though. This commit cleans it up enti

[jira] [Updated] (FLINK-33579) Join sql error

2023-11-16 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] waywtdcc updated FLINK-33579: - Description:   {code:java} set pipeline.operator-chaining=true;  set execution.runtime-mode=BATCH;   set

[jira] [Updated] (FLINK-33579) Join sql error

2023-11-16 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] waywtdcc updated FLINK-33579: - Description: explain plan for select * from orders, supplier, customer where c_custkey = o_custkey and

[jira] [Created] (FLINK-33579) Join sql error

2023-11-16 Thread waywtdcc (Jira)
waywtdcc created FLINK-33579: Summary: Join sql error Key: FLINK-33579 URL: https://issues.apache.org/jira/browse/FLINK-33579 Project: Flink Issue Type: Bug Affects Versions: 1.17.1

[jira] [Created] (FLINK-33578) Remove scala-2.12 system variable

2023-11-16 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-33578: - Summary: Remove scala-2.12 system variable Key: FLINK-33578 URL: https://issues.apache.org/jira/browse/FLINK-33578 Project: Flink Issue Type: Technical Deb

[jira] [Assigned] (FLINK-33578) Remove scala-2.12 system variable

2023-11-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-33578: - Assignee: Matthias Pohl > Remove scala-2.12 system variable > -

[jira] [Assigned] (FLINK-33576) Introduce new Flink conf file "config.yaml" supporting standard YAML syntax

2023-11-16 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang reassigned FLINK-33576: -- Assignee: Junrui Li > Introduce new Flink conf file "config.yaml" supporting standard YAML sy

[jira] [Assigned] (FLINK-33577) Make "conf.yaml" as the default Flink configuration file

2023-11-16 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang reassigned FLINK-33577: -- Assignee: Junrui Li > Make "conf.yaml" as the default Flink configuration file >

[jira] [Updated] (FLINK-33576) Introduce new Flink conf file "config.yaml" supporting standard YAML syntax

2023-11-16 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-33576: -- Summary: Introduce new Flink conf file "config.yaml" supporting standard YAML syntax (was: Introduce

[jira] [Created] (FLINK-33577) Make "conf.yaml" as the default Flink configuration file

2023-11-16 Thread Junrui Li (Jira)
Junrui Li created FLINK-33577: - Summary: Make "conf.yaml" as the default Flink configuration file Key: FLINK-33577 URL: https://issues.apache.org/jira/browse/FLINK-33577 Project: Flink Issue Type

[jira] [Created] (FLINK-33576) Introduce new Flink conf file config.yaml supporting standard YAML syntax

2023-11-16 Thread Junrui Li (Jira)
Junrui Li created FLINK-33576: - Summary: Introduce new Flink conf file config.yaml supporting standard YAML syntax Key: FLINK-33576 URL: https://issues.apache.org/jira/browse/FLINK-33576 Project: Flink

Re: [PR] [FLINK-33198][Format/Avro] support local timezone timestamp logic type in AVRO [flink]

2023-11-16 Thread via GitHub
HuangZhenQiu commented on PR #23511: URL: https://github.com/apache/flink/pull/23511#issuecomment-1815705378 @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 comme

[jira] [Assigned] (FLINK-33575) FLIP-394: Add Metrics for Connector Agnostic Autoscaling

2023-11-16 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-33575: --- Assignee: Mason Chen > FLIP-394: Add Metrics for Connector Agnostic Autoscaling > -

Re: [PR] [FLINK-33364][core] Introduce standard YAML for flink configuration. [flink]

2023-11-16 Thread via GitHub
JunRuiLee commented on PR #23606: URL: https://github.com/apache/flink/pull/23606#issuecomment-1815663277 @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] [Commented] (FLINK-33397) FLIP-373: Support Configuring Different State TTLs using SQL Hint

2023-11-16 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17787002#comment-17787002 ] xuyang commented on FLINK-33397: Hi, [~caozhen1937] The work is on the way. The code is

[jira] [Closed] (FLINK-33395) The join hint doesn't work when appears in subquery

2023-11-16 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan closed FLINK-33395. - > The join hint doesn't work when appears in subquery > ---

[jira] [Updated] (FLINK-33395) The join hint doesn't work when appears in subquery

2023-11-16 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-33395: -- Fix Version/s: 1.17.2 1.19.0 1.18.1 > The join hint doesn't work

[jira] [Resolved] (FLINK-33395) The join hint doesn't work when appears in subquery

2023-11-16 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan resolved FLINK-33395. --- Resolution: Fixed > The join hint doesn't work when appears in subquery > --

[jira] [Comment Edited] (FLINK-33395) The join hint doesn't work when appears in subquery

2023-11-16 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786143#comment-17786143 ] Jane Chan edited comment on FLINK-33395 at 11/17/23 2:15 AM: -

Re: [PR] [FLINK-33395][table-planner] fix the join hint doesn't work when appears in subquery [flink]

2023-11-16 Thread via GitHub
LadyForest merged PR #23720: URL: https://github.com/apache/flink/pull/23720 -- 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.ap

Re: [PR] [FLINK-33395][table-planner] fix the join hint doesn't work when appears in subquery [flink]

2023-11-16 Thread via GitHub
LadyForest merged PR #23716: URL: https://github.com/apache/flink/pull/23716 -- 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.ap

Re: [PR] [FLINK-33537][docs] Fix missing 1.18 doc link [flink]

2023-11-16 Thread via GitHub
TanYuxin-tyx commented on PR #23715: URL: https://github.com/apache/flink/pull/23715#issuecomment-1815625621 @snuyanzin @RyanSkraba Thanks for your quick review. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

Re: [PR] [FLINK-33546] Implement type inference for order(asc/desc) function [flink]

2023-11-16 Thread via GitHub
liuyongvs commented on code in PR #23733: URL: https://github.com/apache/flink/pull/23733#discussion_r1396577557 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java: ## @@ -2003,14 +2003,16 @@ ANY, and(logical(LogicalT

Re: [PR] [hotfix][build] Remove unnecessary notes element in pom file [flink]

2023-11-16 Thread via GitHub
JingsongLi merged PR #23734: URL: https://github.com/apache/flink/pull/23734 -- 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.ap

[jira] [Created] (FLINK-33575) FLIP-394: Add Metrics for Connector Agnostic Autoscaling

2023-11-16 Thread Mason Chen (Jira)
Mason Chen created FLINK-33575: -- Summary: FLIP-394: Add Metrics for Connector Agnostic Autoscaling Key: FLINK-33575 URL: https://issues.apache.org/jira/browse/FLINK-33575 Project: Flink Issue Ty

Re: [PR] [FLINK-30593][autoscaler] Determine restart time on the fly fo Autoscaler [flink-kubernetes-operator]

2023-11-16 Thread via GitHub
afedulov commented on PR #711: URL: https://github.com/apache/flink-kubernetes-operator/pull/711#issuecomment-1815381974 @mxm @gyfora the PR is ready for review @gyfora me and Max briefly discussed offline and came to the conclusion that starting with evaluating the maximum restart time

Re: [PR] [FLINK-33568] Fix NullpointerException in SinkV2MetricsITCase [flink]

2023-11-16 Thread via GitHub
mbalassi commented on PR #23737: URL: https://github.com/apache/flink/pull/23737#issuecomment-1815347542 Thanks @pvary, lgtm. Will wait for the tests. -- 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

[jira] [Commented] (FLINK-33568) SinkV2MetricsITCase.testCommitterMetrics fails with NullPointerException

2023-11-16 Thread Peter Vary (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786947#comment-17786947 ] Peter Vary commented on FLINK-33568: With the patch it looks like this: !Screenshot

[jira] [Updated] (FLINK-33568) SinkV2MetricsITCase.testCommitterMetrics fails with NullPointerException

2023-11-16 Thread Peter Vary (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peter Vary updated FLINK-33568: --- Attachment: Screenshot 2023-11-16 at 22.30.51.png > SinkV2MetricsITCase.testCommitterMetrics fails w

[jira] [Commented] (FLINK-33545) KafkaSink implementation can cause dataloss during broker issue when not using EXACTLY_ONCE if there's any batching

2023-11-16 Thread Kevin Tseng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786933#comment-17786933 ] Kevin Tseng commented on FLINK-33545: - I'm also aware of the issue FLINK-31305 i do

[jira] [Commented] (FLINK-33545) KafkaSink implementation can cause dataloss during broker issue when not using EXACTLY_ONCE if there's any batching

2023-11-16 Thread Kevin Tseng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786907#comment-17786907 ] Kevin Tseng commented on FLINK-33545: - Hi Tzu-Li, Thanks for the response. Below i

[jira] [Comment Edited] (FLINK-33545) KafkaSink implementation can cause dataloss during broker issue when not using EXACTLY_ONCE if there's any batching

2023-11-16 Thread Kevin Tseng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786907#comment-17786907 ] Kevin Tseng edited comment on FLINK-33545 at 11/16/23 7:06 PM: ---

[jira] [Commented] (FLINK-30112) Improve docs re state compression

2023-11-16 Thread Kenneth William Krugler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786890#comment-17786890 ] Kenneth William Krugler commented on FLINK-30112: - As of https://issues.

[jira] [Commented] (FLINK-18473) Optimize RocksDB disk load balancing strategy

2023-11-16 Thread Yi Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786887#comment-17786887 ] Yi Zhang commented on FLINK-18473: -- Thanks [~masteryhx] for the pointers! yes, round-ro

[jira] [Commented] (FLINK-33545) KafkaSink implementation can cause dataloss during broker issue when not using EXACTLY_ONCE if there's any batching

2023-11-16 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786873#comment-17786873 ] Tzu-Li (Gordon) Tai commented on FLINK-33545: - https://issues.apache.org/jir

[jira] [Commented] (FLINK-33293) Data loss with Kafka Sink

2023-11-16 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786872#comment-17786872 ] Tzu-Li (Gordon) Tai commented on FLINK-33293: - We have a new ticket whose de

[jira] [Comment Edited] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

2023-11-16 Thread Maciej Obuchowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786866#comment-17786866 ] Maciej Obuchowski edited comment on FLINK-31275 at 11/16/23 5:24 PM: -

[jira] [Comment Edited] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

2023-11-16 Thread Maciej Obuchowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786866#comment-17786866 ] Maciej Obuchowski edited comment on FLINK-31275 at 11/16/23 5:23 PM: -

[jira] [Comment Edited] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

2023-11-16 Thread Maciej Obuchowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786866#comment-17786866 ] Maciej Obuchowski edited comment on FLINK-31275 at 11/16/23 5:22 PM: -

[jira] [Commented] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

2023-11-16 Thread Maciej Obuchowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786866#comment-17786866 ] Maciej Obuchowski commented on FLINK-31275: --- [~zjureel] I think this is a step

[jira] [Comment Edited] (FLINK-33545) KafkaSink implementation can cause dataloss during broker issue when not using EXACTLY_ONCE if there's any batching

2023-11-16 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786863#comment-17786863 ] Tzu-Li (Gordon) Tai edited comment on FLINK-33545 at 11/16/23 5:12 PM: ---

[jira] [Commented] (FLINK-33545) KafkaSink implementation can cause dataloss during broker issue when not using EXACTLY_ONCE if there's any batching

2023-11-16 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786863#comment-17786863 ] Tzu-Li (Gordon) Tai commented on FLINK-33545: - {code} In a scenario that:

Re: [PR] [FLINK-33542] Update tests to JUnit5 [flink-connector-hbase]

2023-11-16 Thread via GitHub
ferenc-csaky commented on code in PR #32: URL: https://github.com/apache/flink-connector-hbase/pull/32#discussion_r1396065742 ## flink-connector-hbase-2.2/src/test/java/org/apache/flink/connector/hbase2/HBaseConnectorITCase.java: ## @@ -66,16 +66,13 @@ import static org.apache

Re: [PR] [FLINK-33568] Fix NullpointerException in SinkV2MetricsITCase [flink]

2023-11-16 Thread via GitHub
flinkbot commented on PR #23737: URL: https://github.com/apache/flink/pull/23737#issuecomment-1814856098 ## CI report: * 133dcc09db1acc98de22c0cca7c79962438fa3ef UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-33542] Update tests to JUnit5 [flink-connector-hbase]

2023-11-16 Thread via GitHub
ferenc-csaky commented on code in PR #32: URL: https://github.com/apache/flink-connector-hbase/pull/32#discussion_r1396049215 ## flink-connector-hbase-2.2/src/test/java/org/apache/flink/connector/hbase2/HBaseConnectorITCase.java: ## Review Comment: Yep, good catch, I think

[jira] [Commented] (FLINK-33545) KafkaSink implementation can cause dataloss during broker issue when not using EXACTLY_ONCE if there's any batching

2023-11-16 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786860#comment-17786860 ] Tzu-Li (Gordon) Tai commented on FLINK-33545: - hey [~aeolus811tw], thanks fo

[jira] [Updated] (FLINK-33568) SinkV2MetricsITCase.testCommitterMetrics fails with NullPointerException

2023-11-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33568: --- Labels: pull-request-available (was: ) > SinkV2MetricsITCase.testCommitterMetrics fails wit

[PR] [FLINK-33568] Fix NullpointerException in SinkV2MetricsITCase [flink]

2023-11-16 Thread via GitHub
pvary opened a new pull request, #23737: URL: https://github.com/apache/flink/pull/23737 ## What is the purpose of the change Fix the NullpointerException found by the tests: https://issues.apache.org/jira/browse/FLINK-33568?focusedCommentId=17786726&page=com.atlassian.jira.plugin.sys

[jira] [Commented] (FLINK-32523) NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted fails with timeout on AZP

2023-11-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786858#comment-17786858 ] Matthias Pohl commented on FLINK-32523: --- https://dev.azure.com/apache-flink/apache

[jira] [Assigned] (FLINK-33545) KafkaSink implementation can cause dataloss during broker issue when not using EXACTLY_ONCE if there's any batching

2023-11-16 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-33545: --- Assignee: Tzu-Li (Gordon) Tai > KafkaSink implementation can cause dataloss

[jira] [Assigned] (FLINK-33545) KafkaSink implementation can cause dataloss during broker issue when not using EXACTLY_ONCE if there's any batching

2023-11-16 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-33545: --- Assignee: Kevin Tseng (was: Tzu-Li (Gordon) Tai) > KafkaSink implementatio

[jira] [Resolved] (FLINK-33282) core stage: 137 exit code

2023-11-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-33282. --- Resolution: Duplicate > core stage: 137 exit code > - > >

Re: [PR] [FLINK-33537][docs] Fix missing 1.18 doc link [flink]

2023-11-16 Thread via GitHub
snuyanzin commented on PR #23715: URL: https://github.com/apache/flink/pull/23715#issuecomment-1814805167 thanks for contribution and thanks @RyanSkraba for checking -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use t

Re: [PR] [hotfix] Remove Calcite classes from Hive connector [flink]

2023-11-16 Thread via GitHub
snuyanzin merged PR #23726: URL: https://github.com/apache/flink/pull/23726 -- 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.apa

[jira] [Closed] (FLINK-33537) Docs version nav is missing 1.18 as an option

2023-11-16 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin closed FLINK-33537. --- > Docs version nav is missing 1.18 as an option > -

[jira] [Assigned] (FLINK-33537) Docs version nav is missing 1.18 as an option

2023-11-16 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin reassigned FLINK-33537: --- Assignee: Yuxin Tan (was: yu) > Docs version nav is missing 1.18 as an option > --

[jira] [Resolved] (FLINK-33537) Docs version nav is missing 1.18 as an option

2023-11-16 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-33537. - Fix Version/s: 1.19.0 Resolution: Fixed > Docs version nav is missing 1.18 as an

[jira] [Assigned] (FLINK-33537) Docs version nav is missing 1.18 as an option

2023-11-16 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin reassigned FLINK-33537: --- Assignee: yu > Docs version nav is missing 1.18 as an option >

[jira] [Commented] (FLINK-33537) Docs version nav is missing 1.18 as an option

2023-11-16 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786831#comment-17786831 ] Sergey Nuyanzin commented on FLINK-33537: - Merged as [09c13449b67fe30a658f56b77

Re: [PR] [FLINK-33537][docs] Fix missing 1.18 doc link [flink]

2023-11-16 Thread via GitHub
snuyanzin merged PR #23715: URL: https://github.com/apache/flink/pull/23715 -- 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.apa

[jira] [Closed] (FLINK-33546) Implement type inference for order(asc/desc) function

2023-11-16 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-33546. Resolution: Fixed Implemented in 54906feae0bb2978bbd58bf91c6d458d44262437 > Implement typ

Re: [PR] [FLINK-33546] Implement type inference for order(asc/desc) function [flink]

2023-11-16 Thread via GitHub
dawidwys closed pull request #23733: [FLINK-33546] Implement type inference for order(asc/desc) function URL: https://github.com/apache/flink/pull/23733 -- 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

[jira] [Assigned] (FLINK-30460) Support writing HBase's CEIL TTL metadata

2023-11-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-30460: -- Assignee: tanjialiang > Support writing HBase's CEIL TTL metadata > -

[jira] [Closed] (FLINK-30460) Support writing HBase's CEIL TTL metadata

2023-11-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-30460. -- Fix Version/s: hbase-3.0.1 Resolution: Fixed Fixed in apache/flink-connector-hbase mai

Re: [PR] [FLINK-30460] Support the writable metadata ttl. [flink-connector-hbase]

2023-11-16 Thread via GitHub
MartijnVisser merged PR #33: URL: https://github.com/apache/flink-connector-hbase/pull/33 -- 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-unsubsc

[jira] [Commented] (FLINK-33568) SinkV2MetricsITCase.testCommitterMetrics fails with NullPointerException

2023-11-16 Thread Peter Vary (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786814#comment-17786814 ] Peter Vary commented on FLINK-33568: Checking > SinkV2MetricsITCase.testCommitterMe

[jira] [Commented] (FLINK-31449) Remove DeclarativeSlotManager related logic

2023-11-16 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786805#comment-17786805 ] lincoln lee commented on FLINK-31449: - [~huweihua]thank you for your reply! Can we j

Re: [PR] Bump com.squareup.okio:okio from 1.17.2 to 1.17.6 in /flink-end-to-end-tests/flink-end-to-end-tests-sql [flink]

2023-11-16 Thread via GitHub
flinkbot commented on PR #23736: URL: https://github.com/apache/flink/pull/23736#issuecomment-1814684361 ## CI report: * 58da2788ecb90f71297a440619bf64f2081515ef UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-33531) Nightly Python fails with NPE at metadataHandlerProvider on AZP (StreamDependencyTests.test_add_python_archive)

2023-11-16 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786794#comment-17786794 ] lincoln lee commented on FLINK-33531: - [~hxb] thank you for looking into this! > Ni

[PR] Bump com.squareup.okio:okio from 1.17.2 to 1.17.6 in /flink-end-to-end-tests/flink-end-to-end-tests-sql [flink]

2023-11-16 Thread via GitHub
dependabot[bot] opened a new pull request, #23736: URL: https://github.com/apache/flink/pull/23736 Bumps [com.squareup.okio:okio](https://github.com/square/okio) from 1.17.2 to 1.17.6. Changelog Sourced from https://github.com/square/okio/blob/master/CHANGELOG.md";>com.squareup.oki

Re: [PR] [FLINK-33485][table] Optimize exists subqueries by looking at metadata rowcount [flink]

2023-11-16 Thread via GitHub
snuyanzin commented on PR #23685: URL: https://github.com/apache/flink/pull/23685#issuecomment-1814580495 @lincoln-lil since you are one of the most active contributors in this area, could you please have a look? -- This is an automated message from the Apache Git Service. To respond to t

Re: [PR] [FLINK-13230] [pubsub] Add retry mechanism to acknowledging pubsub me… [flink]

2023-11-16 Thread via GitHub
snuyanzin commented on PR #9388: URL: https://github.com/apache/flink/pull/9388#issuecomment-1814510045 thanks @RyanSkraba yes, since pubsub connector is externalised it makes sense to close it -- This is an automated message from the Apache Git Service. To respond to the message, plea

Re: [PR] [FLINK-13230] [pubsub] Add retry mechanism to acknowledging pubsub me… [flink]

2023-11-16 Thread via GitHub
snuyanzin closed pull request #9388: [FLINK-13230] [pubsub] Add retry mechanism to acknowledging pubsub me… URL: https://github.com/apache/flink/pull/9388 -- 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 g

Re: [PR] [FLINK-33411] Implement type inference for window properties functions [flink]

2023-11-16 Thread via GitHub
dawidwys commented on code in PR #23735: URL: https://github.com/apache/flink/pull/23735#discussion_r1395745935 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/SpecificInputTypeStrategies.java: ## @@ -65,6 +65,11 @@ public static

Re: [PR] [FLINK-33411] Implement type inference for window properties functions [flink]

2023-11-16 Thread via GitHub
dawidwys commented on code in PR #23735: URL: https://github.com/apache/flink/pull/23735#discussion_r1395745935 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/SpecificInputTypeStrategies.java: ## @@ -65,6 +65,11 @@ public static

Re: [PR] [FLINK-33411] Implement type inference for window properties functions [flink]

2023-11-16 Thread via GitHub
jnh5y commented on code in PR #23735: URL: https://github.com/apache/flink/pull/23735#discussion_r1395740589 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/SpecificInputTypeStrategies.java: ## @@ -65,6 +65,11 @@ public static In

Re: [PR] [FLINK-33411] Implement type inference for window properties functions [flink]

2023-11-16 Thread via GitHub
flinkbot commented on PR #23735: URL: https://github.com/apache/flink/pull/23735#issuecomment-1814486869 ## CI report: * d1d1e4b8d3a09f2b48415c607606b45e8edda4dd UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Closed] (FLINK-33331) Upgrade netty to 4.1.93+

2023-11-16 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin closed FLINK-1. --- > Upgrade netty to 4.1.93+ > > > Key: FLINK-1 >

[jira] [Updated] (FLINK-33411) Implement type inference for window properties functions

2023-11-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33411: --- Labels: pull-request-available (was: ) > Implement type inference for window properties fun

[PR] [FLINK-33411] Implement type inference for window properties functions [flink]

2023-11-16 Thread via GitHub
dawidwys opened a new pull request, #23735: URL: https://github.com/apache/flink/pull/23735 ## What is the purpose of the change Implement type inference for WINDOW_START and WINDOW_END ## Verifying this change This change is already covered by existing tests.

[jira] [Commented] (FLINK-33568) SinkV2MetricsITCase.testCommitterMetrics fails with NullPointerException

2023-11-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786758#comment-17786758 ] Matthias Pohl commented on FLINK-33568: --- This issue starts appearing in [20231113

[jira] [Comment Edited] (FLINK-18356) flink-table-planner Exit code 137 returned from process

2023-11-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786742#comment-17786742 ] Matthias Pohl edited comment on FLINK-18356 at 11/16/23 1:34 PM: -

[jira] [Comment Edited] (FLINK-18356) flink-table-planner Exit code 137 returned from process

2023-11-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786742#comment-17786742 ] Matthias Pohl edited comment on FLINK-18356 at 11/16/23 1:34 PM: -

[jira] [Comment Edited] (FLINK-30540) DataSinkTaskTest failed with a 134 exit code

2023-11-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786757#comment-17786757 ] Matthias Pohl edited comment on FLINK-30540 at 11/16/23 1:32 PM: -

[jira] [Commented] (FLINK-30540) DataSinkTaskTest failed with a 134 exit code

2023-11-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786757#comment-17786757 ] Matthias Pohl commented on FLINK-30540: --- https://dev.azure.com/apache-flink/apache

[jira] [Commented] (FLINK-33502) HybridShuffleITCase caused a fatal error

2023-11-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786756#comment-17786756 ] Matthias Pohl commented on FLINK-33502: --- https://dev.azure.com/apache-flink/apache

[jira] [Commented] (FLINK-33502) HybridShuffleITCase caused a fatal error

2023-11-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17786755#comment-17786755 ] Matthias Pohl commented on FLINK-33502: --- https://dev.azure.com/apache-flink/apache

  1   2   3   >