[GitHub] [flink] LadyForest commented on pull request #22478: [FLINK-31917][table-planner] Fix the idempotence lost in JsonSerDe round trip for AggregateCall and RexNode

2023-04-28 Thread via GitHub
LadyForest commented on PR #22478: URL: https://github.com/apache/flink/pull/22478#issuecomment-1528492451 Just rebase master and squash commits to reinvoke CI... -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Commented] (FLINK-31665) Add ARRAY_CONCAT supported in SQL & Table API

2023-04-28 Thread DingGeGe (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717863#comment-17717863 ] DingGeGe commented on FLINK-31665: -- Can i contributing this function ? > Add ARRAY_CONCAT supported in

[jira] [Created] (FLINK-31974) JobManager crashes after KubernetesClientException exception with FatalExitExceptionHandler

2023-04-28 Thread Sergio Sainz (Jira)
Sergio Sainz created FLINK-31974: Summary: JobManager crashes after KubernetesClientException exception with FatalExitExceptionHandler Key: FLINK-31974 URL: https://issues.apache.org/jira/browse/FLINK-31974

[GitHub] [flink] pgaref commented on a diff in pull request #22467: [FLINK-31888] Introduce interfaces and utils for loading and executing enrichers

2023-04-28 Thread via GitHub
pgaref commented on code in PR #22467: URL: https://github.com/apache/flink/pull/22467#discussion_r1180845401 ## flink-runtime/src/test/java/org/apache/flink/runtime/failure/FailureEnricherUtilsTest.java: ## @@ -0,0 +1,275 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [flink] pgaref commented on a diff in pull request #22467: [FLINK-31888] Introduce interfaces and utils for loading and executing enrichers

2023-04-28 Thread via GitHub
pgaref commented on code in PR #22467: URL: https://github.com/apache/flink/pull/22467#discussion_r1180844255 ## flink-core/src/main/java/org/apache/flink/core/failure/FailureEnricher.java: ## @@ -0,0 +1,128 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one

[GitHub] [flink] pgaref commented on a diff in pull request #22467: [FLINK-31888] Introduce interfaces and utils for loading and executing enrichers

2023-04-28 Thread via GitHub
pgaref commented on code in PR #22467: URL: https://github.com/apache/flink/pull/22467#discussion_r1180842815 ## flink-core/src/main/java/org/apache/flink/configuration/JobManagerOptions.java: ## @@ -263,6 +263,30 @@ public class JobManagerOptions {

[GitHub] [flink] nateab commented on a diff in pull request #22467: [FLINK-31888] Introduce interfaces and utils for loading and executing enrichers

2023-04-28 Thread via GitHub
nateab commented on code in PR #22467: URL: https://github.com/apache/flink/pull/22467#discussion_r1180829385 ## flink-core/src/main/java/org/apache/flink/configuration/JobManagerOptions.java: ## @@ -263,6 +263,30 @@ public class JobManagerOptions {

[jira] [Commented] (FLINK-31495) Improve metrics tab on flink ui

2023-04-28 Thread Vladimir Matveev (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717793#comment-17717793 ] Vladimir Matveev commented on FLINK-31495: -- This is a big usability issue, and apparently there

[jira] [Commented] (FLINK-31828) List field in a POJO data stream results in table program compilation failure

2023-04-28 Thread Vladimir Matveev (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717792#comment-17717792 ] Vladimir Matveev commented on FLINK-31828: -- Cool, thank you very much! > List field in a POJO

[GitHub] [flink] nateab commented on pull request #22359: [FLINK-31660][table] add jayway json path dependency to table-planner

2023-04-28 Thread via GitHub
nateab commented on PR #22359: URL: https://github.com/apache/flink/pull/22359#issuecomment-1527980162 CI was failing upstream because of an outdated library, which was fixed in this commit https://github.com/apache/flink/commit/ed7ca22efc68203d4882887a3856434137e6980f, gonna rerun the CI

[jira] [Commented] (FLINK-31963) java.lang.ArrayIndexOutOfBoundsException when scale down via autoscaler

2023-04-28 Thread Tan Kim (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717771#comment-17717771 ] Tan Kim commented on FLINK-31963: - A question unrelated to this ticket, but if the subtasks that exist

[jira] [Commented] (FLINK-31963) java.lang.ArrayIndexOutOfBoundsException when scale down via autoscaler

2023-04-28 Thread Tan Kim (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717767#comment-17717767 ] Tan Kim commented on FLINK-31963: - Thank you for responding, [~pnowojski]. * It happens a couple of

[jira] [Updated] (FLINK-31963) java.lang.ArrayIndexOutOfBoundsException when scale down via autoscaler

2023-04-28 Thread Tan Kim (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tan Kim updated FLINK-31963: Attachment: image-2023-04-29-02-49-05-607.png > java.lang.ArrayIndexOutOfBoundsException when scale down

[jira] [Updated] (FLINK-31963) java.lang.ArrayIndexOutOfBoundsException when scale down via autoscaler

2023-04-28 Thread Tan Kim (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tan Kim updated FLINK-31963: Attachment: image-2023-04-29-02-48-46-279.png > java.lang.ArrayIndexOutOfBoundsException when scale down

[jira] [Created] (FLINK-31973) Introduce Managed table support in glue catalog

2023-04-28 Thread Samrat Deb (Jira)
Samrat Deb created FLINK-31973: -- Summary: Introduce Managed table support in glue catalog Key: FLINK-31973 URL: https://issues.apache.org/jira/browse/FLINK-31973 Project: Flink Issue Type:

[GitHub] [flink] flinkbot commented on pull request #22504: [FLINK-31971][tests] Drop HadoopRecoverableWriterOldHadoopWithNoTruncateSupportTest

2023-04-28 Thread via GitHub
flinkbot commented on PR #22504: URL: https://github.com/apache/flink/pull/22504#issuecomment-1527834568 ## CI report: * c892c7f842a8259c203fc16c09a53c304c88293d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] flinkbot commented on pull request #22503: [FLINK-31792][tests] Remove powermock whitebox usages

2023-04-28 Thread via GitHub
flinkbot commented on PR #22503: URL: https://github.com/apache/flink/pull/22503#issuecomment-1527834416 ## CI report: * bdd1da6407d915cbe021b5894175536b31c28606 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] dmvk commented on pull request #22467: [FLINK-31888] Introduce interfaces and utils for loading and executing enrichers

2023-04-28 Thread via GitHub
dmvk commented on PR #22467: URL: https://github.com/apache/flink/pull/22467#issuecomment-1527829037 @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. To

[jira] [Updated] (FLINK-31971) Drop HadoopRecoverableWriterOldHadoopWithNoTruncateSupportTest

2023-04-28 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-31971: - Parent: FLINK-31954 Issue Type: Sub-task (was: Technical Debt) > Drop

[jira] [Updated] (FLINK-31971) Drop HadoopRecoverableWriterOldHadoopWithNoTruncateSupportTest

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

[GitHub] [flink] zentol opened a new pull request, #22504: [FLINK-31971][tests] Drop HadoopRecoverableWriterOldHadoopWithNoTruncateSupportTest

2023-04-28 Thread via GitHub
zentol opened a new pull request, #22504: URL: https://github.com/apache/flink/pull/22504 Tests behavior for an unsupported hadoop version. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[jira] [Created] (FLINK-31972) Remove powermock whitebox usages

2023-04-28 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-31972: Summary: Remove powermock whitebox usages Key: FLINK-31972 URL: https://issues.apache.org/jira/browse/FLINK-31972 Project: Flink Issue Type:

[jira] [Updated] (FLINK-31954) Prevent Mockito/Powermock usage for the new code with Checkstyle

2023-04-28 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-31954: - Summary: Prevent Mockito/Powermock usage for the new code with Checkstyle (was:

[jira] [Closed] (FLINK-31933) Remove Whitebox usage in ExpressionKeysTest

2023-04-28 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-31933. Resolution: Fixed master: 1102fc62b8c87d6c01dbfd51e82e689dd1bffaf5 > Remove Whitebox

[GitHub] [flink] zentol merged pull request #22482: [FLINK-31933][core][tests] Remove reflective access

2023-04-28 Thread via GitHub
zentol merged PR #22482: URL: https://github.com/apache/flink/pull/22482 -- 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] LadyForest commented on pull request #22478: [FLINK-31917][table-planner] Fix the idempotence lost in JsonSerDe round trip for AggregateCall and RexNode

2023-04-28 Thread via GitHub
LadyForest commented on PR #22478: URL: https://github.com/apache/flink/pull/22478#issuecomment-1527740669 @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-training] ness-vaibhavtyagi closed pull request #60: Branch changes afer review comment

2023-04-28 Thread via GitHub
ness-vaibhavtyagi closed pull request #60: Branch changes afer review comment URL: https://github.com/apache/flink-training/pull/60 -- 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-31968) [PyFlink] 1.17.0 version on M1 processor

2023-04-28 Thread Yury Smirnov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717712#comment-17717712 ] Yury Smirnov commented on FLINK-31968: -- [~martijnvisser] you are right. This is my report in the

[jira] [Created] (FLINK-31971) Drop HadoopRecoverableWriterOldHadoopWithNoTruncateSupportTest

2023-04-28 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-31971: Summary: Drop HadoopRecoverableWriterOldHadoopWithNoTruncateSupportTest Key: FLINK-31971 URL: https://issues.apache.org/jira/browse/FLINK-31971 Project:

[jira] [Assigned] (FLINK-31080) Idle slots are not released due to a mismatch in time between DeclarativeSlotPoolService and SlotSharingSlotAllocator

2023-04-28 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-31080: -- Assignee: Samrat Deb (was: Weijie Guo) > Idle slots are not released due to a mismatch in

[jira] [Closed] (FLINK-31873) Add setMaxParallelism to the DataStreamSink Class

2023-04-28 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-31873. -- Fix Version/s: 1.18.0 Resolution: Fixed master(1.18) via

[GitHub] [flink] reswqa merged pull request #22438: [FLINK-31873][API / DataStream] Add method setMaxParallelism to DataStreamSink.

2023-04-28 Thread via GitHub
reswqa merged PR #22438: URL: https://github.com/apache/flink/pull/22438 -- 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] flinkbot commented on pull request #22502: [FLINK-28215][Buildsystem] Update Maven Surefire plugin to 3.0.0

2023-04-28 Thread via GitHub
flinkbot commented on PR #22502: URL: https://github.com/apache/flink/pull/22502#issuecomment-1527641593 ## CI report: * e84dd560a0299f947d7c7c7e3b645d83553eb71e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Closed] (FLINK-25292) Azure failed due to unable to fetch some archives

2023-04-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-25292. -- Resolution: Fixed > Azure failed due to unable to fetch some archives >

[jira] [Updated] (FLINK-25292) Azure failed due to unable to fetch some archives

2023-04-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-25292: --- Fix Version/s: (was: 1.15.0) (was: 1.13.6)

[jira] [Comment Edited] (FLINK-31967) SQL with LAG function NullPointerException

2023-04-28 Thread padavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717688#comment-17717688 ] padavan edited comment on FLINK-31967 at 4/28/23 2:12 PM: -- [~martijnvisser] 

[jira] [Closed] (FLINK-27474) Use Hugo build information to derive current branch for externally hosted documentation

2023-04-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-27474. -- Resolution: Won't Fix No longer needed > Use Hugo build information to derive current branch

[GitHub] [flink] MartijnVisser opened a new pull request, #22502: [FLINK-28215][Buildsystem] Update Maven Surefire plugin to 3.0.0

2023-04-28 Thread via GitHub
MartijnVisser opened a new pull request, #22502: URL: https://github.com/apache/flink/pull/22502 Successor of https://github.com/apache/flink/pull/20055 (which can't be re-opened) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Commented] (FLINK-31967) SQL with LAG function NullPointerException

2023-04-28 Thread padavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717688#comment-17717688 ] padavan commented on FLINK-31967: - [~martijnvisser]  Add Project [^simpleFlinkKafkaLag.zip] with two

[jira] [Updated] (FLINK-31967) SQL with LAG function NullPointerException

2023-04-28 Thread padavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] padavan updated FLINK-31967: Attachment: image-2023-04-28-17-06-20-737.png > SQL with LAG function NullPointerException >

[jira] [Assigned] (FLINK-28215) Bump Maven Surefire plugin to 3.0.0-M7

2023-04-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-28215: -- Assignee: Martijn Visser > Bump Maven Surefire plugin to 3.0.0-M7 >

[jira] [Updated] (FLINK-28215) Bump Maven Surefire plugin to 3.0.0

2023-04-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-28215: --- Summary: Bump Maven Surefire plugin to 3.0.0 (was: Bump Maven Surefire plugin to 3.0.0-M7)

[jira] [Updated] (FLINK-31967) SQL with LAG function NullPointerException

2023-04-28 Thread padavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] padavan updated FLINK-31967: Attachment: simpleFlinkKafkaLag.zip > SQL with LAG function NullPointerException >

[jira] [Assigned] (FLINK-28215) Bump Maven Surefire plugin to 3.0.0-M7

2023-04-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-28215: -- Assignee: (was: Martijn Visser) > Bump Maven Surefire plugin to 3.0.0-M7 >

[jira] [Closed] (FLINK-29538) Setup CI based on the new Elasticsearch CI setup

2023-04-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-29538. -- Resolution: Fixed > Setup CI based on the new Elasticsearch CI setup >

[jira] [Closed] (FLINK-30534) Discuss / migrate People section to Hugo

2023-04-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-30534. -- Resolution: Won't Fix > Discuss / migrate People section to Hugo >

[jira] [Assigned] (FLINK-28641) Remove StreamingFileSink

2023-04-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-28641: -- Assignee: (was: Martijn Visser) > Remove StreamingFileSink >

[jira] [Closed] (FLINK-30794) Disable dependency convergence check for night connector builds

2023-04-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-30794. -- Resolution: Fixed > Disable dependency convergence check for night connector builds >

[jira] [Closed] (FLINK-26981) [Umbrella] Make Flink work on Apple M1 ARM chipset

2023-04-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-26981. -- Fix Version/s: (was: 1.18.0) Resolution: Fixed All subtickets are fixed, marking

[jira] [Assigned] (FLINK-29284) Bump derby in flink-connector-hive to v10.14.2.0

2023-04-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-29284: -- Assignee: (was: Martijn Visser) > Bump derby in flink-connector-hive to

[jira] [Commented] (FLINK-31970) "Key group 0 is not in KeyGroupRange" when using CheckpointedFunction

2023-04-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717685#comment-17717685 ] Martijn Visser commented on FLINK-31970: [~pnowojski] WDYT? > "Key group 0 is not in

[GitHub] [flink-benchmarks] link3280 commented on pull request #70: [FLINK-31965] Fix ClassNotFoundException in benchmarks

2023-04-28 Thread via GitHub
link3280 commented on PR #70: URL: https://github.com/apache/flink-benchmarks/pull/70#issuecomment-1527607271 @pnowojski Rebased. Thank you. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[jira] [Created] (FLINK-31970) "Key group 0 is not in KeyGroupRange" when using CheckpointedFunction

2023-04-28 Thread Yordan Pavlov (Jira)
Yordan Pavlov created FLINK-31970: - Summary: "Key group 0 is not in KeyGroupRange" when using CheckpointedFunction Key: FLINK-31970 URL: https://issues.apache.org/jira/browse/FLINK-31970 Project:

[jira] [Assigned] (FLINK-31954) Prevent Mockito usage for the new code with Checkstyle

2023-04-28 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-31954: Assignee: Chesnay Schepler > Prevent Mockito usage for the new code with

[jira] [Commented] (FLINK-31967) SQL with LAG function NullPointerException

2023-04-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717675#comment-17717675 ] Martijn Visser commented on FLINK-31967: That would be great for debugging, yes. > SQL with

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

2023-04-28 Thread via GitHub
Myasuka commented on code in PR #21822: URL: https://github.com/apache/flink/pull/21822#discussion_r1180408546 ## flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/FsStateChangelogWriter.java: ## @@ -394,18 +394,14 @@ public void confirm(SequenceNumber from,

[GitHub] [flink] Myasuka commented on a diff in pull request #22458: [FLINK-31743][statebackend/rocksdb] disable rocksdb log relocating wh…

2023-04-28 Thread via GitHub
Myasuka commented on code in PR #22458: URL: https://github.com/apache/flink/pull/22458#discussion_r1180397914 ## flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBResourceContainer.java: ## @@ -114,14 +117,18 @@

[jira] [Commented] (FLINK-31967) SQL with LAG function NullPointerException

2023-04-28 Thread padavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717672#comment-17717672 ] padavan commented on FLINK-31967: - [~martijnvisser]  wow , intresting if use DataGen then all work

[GitHub] [flink] ericxiao251 commented on pull request #22438: [FLINK-31873][API / DataStream] Add method setMaxParallelism to DataStreamSink.

2023-04-28 Thread via GitHub
ericxiao251 commented on PR #22438: URL: https://github.com/apache/flink/pull/22438#issuecomment-1527509022 CI passed :D. -- 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-connector-jdbc] MartijnVisser commented on pull request #22: [FLINK-30790] Add DatabaseExtension with TableManaged for testing

2023-04-28 Thread via GitHub
MartijnVisser commented on PR #22: URL: https://github.com/apache/flink-connector-jdbc/pull/22#issuecomment-1527500961 @eskabetxe I see that the CI fails with `WARNING: ConnectionID:1 ClientConnectionId: 012104c1-3f1a-4a4b-88af-5f623f5288e9 Prelogin error: host localhost port 32801

[jira] [Commented] (FLINK-31967) SQL with LAG function NullPointerException

2023-04-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717652#comment-17717652 ] Martijn Visser commented on FLINK-31967: I can't reproduce it. You're using Kafka Source, so it

[GitHub] [flink-benchmarks] pnowojski commented on pull request #70: [FLINK-31965] Fix ClassNotFoundException in benchmarks

2023-04-28 Thread via GitHub
pnowojski commented on PR #70: URL: https://github.com/apache/flink-benchmarks/pull/70#issuecomment-1527485877 Hey @link3280 , could you rebase the change to pull your other hotfix fixing CI? -- This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Comment Edited] (FLINK-31967) SQL with LAG function NullPointerException

2023-04-28 Thread padavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717647#comment-17717647 ] padavan edited comment on FLINK-31967 at 4/28/23 12:17 PM: --- [~martijnvisser] 

[jira] [Commented] (FLINK-31967) SQL with LAG function NullPointerException

2023-04-28 Thread padavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717647#comment-17717647 ] padavan commented on FLINK-31967: - [~martijnvisser]  i sync to latest version  1.17.0 nothing change ,

[jira] [Updated] (FLINK-31967) SQL with LAG function NullPointerException

2023-04-28 Thread padavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] padavan updated FLINK-31967: Attachment: image-2023-04-28-15-14-58-788.png > SQL with LAG function NullPointerException >

[jira] [Closed] (FLINK-31899) Upgrade Flink version of Flink ML to 1.17.0

2023-04-28 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-31899. Resolution: Fixed > Upgrade Flink version of Flink ML to 1.17.0 >

[jira] (FLINK-31967) SQL with LAG function NullPointerException

2023-04-28 Thread padavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31967 ] padavan deleted comment on FLINK-31967: - was (Author: JIRAUSER287909): [~martijnvisser]  Since there is no flink-table-api-java-1.17.0 . I downgrade all packages to the last same 1.16.1. The

[jira] [Assigned] (FLINK-31899) Upgrade Flink version of Flink ML to 1.17.0

2023-04-28 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned FLINK-31899: Assignee: Jiang Xin > Upgrade Flink version of Flink ML to 1.17.0 >

[jira] [Commented] (FLINK-31899) Upgrade Flink version of Flink ML to 1.17.0

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

[GitHub] [flink-ml] lindong28 merged pull request #235: [FLINK-31899] Upgrade Flink version of Flink ML to 1.17.0

2023-04-28 Thread via GitHub
lindong28 merged PR #235: URL: https://github.com/apache/flink-ml/pull/235 -- 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 #235: [FLINK-31899] Upgrade Flink version of Flink ML to 1.17.0

2023-04-28 Thread via GitHub
lindong28 commented on PR #235: URL: https://github.com/apache/flink-ml/pull/235#issuecomment-1527475429 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] [Comment Edited] (FLINK-31967) SQL with LAG function NullPointerException

2023-04-28 Thread padavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717642#comment-17717642 ] padavan edited comment on FLINK-31967 at 4/28/23 12:09 PM: --- [~martijnvisser] 

[jira] [Commented] (FLINK-31967) SQL with LAG function NullPointerException

2023-04-28 Thread padavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717642#comment-17717642 ] padavan commented on FLINK-31967: - [~martijnvisser]  Since there is no flink-table-api-1.17.0 . I

[jira] [Updated] (FLINK-31967) SQL with LAG function NullPointerException

2023-04-28 Thread padavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] padavan updated FLINK-31967: Attachment: image-2023-04-28-15-06-48-184.png > SQL with LAG function NullPointerException >

[jira] [Commented] (FLINK-31964) Improve the document of Autoscaler as 1.17.0 is released

2023-04-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717635#comment-17717635 ] Gyula Fora commented on FLINK-31964: In addition we should also improve the docs for the upcoming

[jira] [Commented] (FLINK-31967) SQL with LAG function NullPointerException

2023-04-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717636#comment-17717636 ] Martijn Visser commented on FLINK-31967: [~padavan] You are mixing different versions of Flink

[jira] [Commented] (FLINK-31900) Fix some typo in java doc, comments and assertion message

2023-04-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717631#comment-17717631 ] Martijn Visser commented on FLINK-31900: [~Feifan Wang] Keep in mind for future PRs that

[jira] [Comment Edited] (FLINK-31967) SQL with LAG function NullPointerException

2023-04-28 Thread padavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717628#comment-17717628 ] padavan edited comment on FLINK-31967 at 4/28/23 11:47 AM: --- [~martijnvisser] 

[jira] [Comment Edited] (FLINK-31967) SQL with LAG function NullPointerException

2023-04-28 Thread padavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717628#comment-17717628 ] padavan edited comment on FLINK-31967 at 4/28/23 11:46 AM: --- [~martijnvisser] 

[jira] [Commented] (FLINK-31906) typeof should only return type exclude nullable

2023-04-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717630#comment-17717630 ] Martijn Visser commented on FLINK-31906: +1 to Jark's comment > typeof should only return type

[jira] [Assigned] (FLINK-31951) Mix schema record source creates corrupt record

2023-04-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-31951: -- Assignee: Kevin Tseng > Mix schema record source creates corrupt record >

[jira] [Comment Edited] (FLINK-31967) SQL with LAG function NullPointerException

2023-04-28 Thread padavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717628#comment-17717628 ] padavan edited comment on FLINK-31967 at 4/28/23 11:45 AM: --- [~martijnvisser] 

[jira] [Commented] (FLINK-31967) SQL with LAG function NullPointerException

2023-04-28 Thread padavan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717628#comment-17717628 ] padavan commented on FLINK-31967: - [~martijnvisser]  /usr/lib/jvm/java-1.11.0-openjdk-amd64/    

[GitHub] [flink-connector-gcp-pubsub] MartijnVisser merged pull request #5: PubSubSink doc example correction

2023-04-28 Thread via GitHub
MartijnVisser merged PR #5: URL: https://github.com/apache/flink-connector-gcp-pubsub/pull/5 -- 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-gcp-pubsub] boring-cyborg[bot] commented on pull request #5: PubSubSink doc example correction

2023-04-28 Thread via GitHub
boring-cyborg[bot] commented on PR #5: URL: https://github.com/apache/flink-connector-gcp-pubsub/pull/5#issuecomment-1527430832 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

[GitHub] [flink-connector-hbase] boring-cyborg[bot] commented on pull request #9: Revert "[FLINK-30360][Connectors/HBase] When specified the partial columns, ignore all empty columns"

2023-04-28 Thread via GitHub
boring-cyborg[bot] commented on PR #9: URL: https://github.com/apache/flink-connector-hbase/pull/9#issuecomment-1527429700 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-hbase] MartijnVisser merged pull request #9: Revert "[FLINK-30360][Connectors/HBase] When specified the partial columns, ignore all empty columns"

2023-04-28 Thread via GitHub
MartijnVisser merged PR #9: URL: https://github.com/apache/flink-connector-hbase/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:

[GitHub] [flink-connector-hbase] MartijnVisser commented on pull request #6: [FLINK-30360][Connectors/HBase] When specified the partial columns, ignore all empty columns

2023-04-28 Thread via GitHub
MartijnVisser commented on PR #6: URL: https://github.com/apache/flink-connector-hbase/pull/6#issuecomment-1527429502 @wjc920 I misread, since the HBase connector isn't externalized yet, it doesn't make sense to merge this. I'll revert the change. -- This is an automated message from

[GitHub] [flink-connector-hbase] MartijnVisser opened a new pull request, #9: Revert "[FLINK-30360][Connectors/HBase] When specified the partial columns, ignore all empty columns"

2023-04-28 Thread via GitHub
MartijnVisser opened a new pull request, #9: URL: https://github.com/apache/flink-connector-hbase/pull/9 Reverts apache/flink-connector-hbase#6 -- 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

[GitHub] [flink-connector-hbase] MartijnVisser merged pull request #6: [FLINK-30360][Connectors/HBase] When specified the partial columns, ignore all empty columns

2023-04-28 Thread via GitHub
MartijnVisser merged PR #6: URL: https://github.com/apache/flink-connector-hbase/pull/6 -- 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-hbase] boring-cyborg[bot] commented on pull request #6: [FLINK-30360][Connectors/HBase] When specified the partial columns, ignore all empty columns

2023-04-28 Thread via GitHub
boring-cyborg[bot] commented on PR #6: URL: https://github.com/apache/flink-connector-hbase/pull/6#issuecomment-1527428771 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-kafka] MartijnVisser commented on pull request #9: [FLINK-31559][connector/kafka] Update the flink version to 1.18-SNAPSHOT and drop support for 1.16

2023-04-28 Thread via GitHub
MartijnVisser commented on PR #9: URL: https://github.com/apache/flink-connector-kafka/pull/9#issuecomment-1527414205 > I believe we want to always develop against the latest stable Flink version, even in `main` branch. @tzulitai Ideally yes, but there can be situations where we

[jira] [Assigned] (FLINK-31749) The Using Hadoop OutputFormats example is not avaliable for DataStream

2023-04-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-31749: -- Assignee: Etienne Chauchot > The Using Hadoop OutputFormats example is not avaliable

[jira] [Closed] (FLINK-31885) Trigger events on autoscaler errors

2023-04-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-31885. -- Resolution: Fixed merged to main 41f753fec40121274c8d0b27f327ffbd52500cf7 > Trigger events on

[GitHub] [flink] pnowojski commented on a diff in pull request #22432: [FLINK-18808][runtime] Include side outputs in numRecordsOut metric

2023-04-28 Thread via GitHub
pnowojski commented on code in PR #22432: URL: https://github.com/apache/flink/pull/22432#discussion_r1180210194 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OutputWithRecordsCountCheck.java: ## @@ -0,0 +1,43 @@ +/* + * Licensed to the Apache

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #575: [FLINK-31885] Trigger event on autoscaler error

2023-04-28 Thread via GitHub
gyfora merged PR #575: URL: https://github.com/apache/flink-kubernetes-operator/pull/575 -- 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] [Reopened] (FLINK-31937) Failing Unit Test: ClientTest.testClientServerIntegration "Connection leak"

2023-04-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reopened FLINK-31937: > Failing Unit Test: ClientTest.testClientServerIntegration "Connection leak" >

[jira] [Closed] (FLINK-31937) Failing Unit Test: ClientTest.testClientServerIntegration "Connection leak"

2023-04-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-31937. -- Resolution: Invalid > Failing Unit Test: ClientTest.testClientServerIntegration "Connection

[jira] [Created] (FLINK-31969) Remove all local recovery files immediately when local recovery fail

2023-04-28 Thread Yanfei Lei (Jira)
Yanfei Lei created FLINK-31969: -- Summary: Remove all local recovery files immediately when local recovery fail Key: FLINK-31969 URL: https://issues.apache.org/jira/browse/FLINK-31969 Project: Flink

[GitHub] [flink] MartijnVisser commented on pull request #22500: [FLINK-31928][build] Upgrade okhttp3 to 4.11.0

2023-04-28 Thread via GitHub
MartijnVisser commented on PR #22500: URL: https://github.com/apache/flink/pull/22500#issuecomment-1527361900 I would be inclined to say that we can't support this in a patch version, given the size of the upgrade. -- This is an automated message from the Apache Git Service. To respond

  1   2   >