[GitHub] [flink] huwh commented on a diff in pull request #21612: [FLINK-30471][network] Optimize the enriching network memory process in SsgNetworkMemoryCalculationUtils

2023-01-12 Thread GitBox
huwh commented on code in PR #21612: URL: https://github.com/apache/flink/pull/21612#discussion_r1067805999 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SsgNetworkMemoryCalculationUtils.java: ## @@ -93,28 +93,27 @@ public static void enrichNetworkMemory(

[GitHub] [flink] LadyForest commented on pull request #21647: [FLINK-22320][docs][table] Add documentation for new introduced ALTER TABLE statements

2023-01-12 Thread GitBox
LadyForest commented on PR #21647: URL: https://github.com/apache/flink/pull/21647#issuecomment-1379943694 @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-30641) docs_404_check fail

2023-01-12 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17675854#comment-17675854 ] Danny Cranmer commented on FLINK-30641: --- The issue is (was) that I had deleted the

[jira] [Comment Edited] (FLINK-30641) docs_404_check fail

2023-01-12 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17675854#comment-17675854 ] Danny Cranmer edited comment on FLINK-30641 at 1/12/23 8:14 AM: --

[jira] (FLINK-30601) Omit "setKeyContextElement" call for non-keyed stream/operators to improve performance

2023-01-12 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30601 ] Lijie Wang deleted comment on FLINK-30601: was (Author: wanglijie95): As discussed in [PR21621|https://github.com/apache/flink/pull/21621], it needs to change the {{@PublicEvolving}} {{Abstr

[GitHub] [flink] flinkbot commented on pull request #21654: [hotfix][javadocs] Fix javadoc of PackagedProgram

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

[GitHub] [flink-table-store] zjureel opened a new pull request, #480: [FLINK-27845] Support column type evolution for file data

2023-01-12 Thread GitBox
zjureel opened a new pull request, #480: URL: https://github.com/apache/flink-table-store/pull/480 This PR aims to support column type evolution for file data in Table Store. For example, the fields of underlying data is [(1, a, int), (2, b, int), (3, c, int), (4, d, int)] and the data is (

[GitHub] [flink] dianfu opened a new pull request, #21655: [FLINK-29231][python] Fix the issue that Python UDAF may produce multiple results for the same window

2023-01-12 Thread GitBox
dianfu opened a new pull request, #21655: URL: https://github.com/apache/flink/pull/21655 ## What is the purpose of the change *This pull request fixes the issue that Python UDAF may produce multiple results for the same window.* ## Brief change log *(for example:)*

[jira] [Updated] (FLINK-29231) PyFlink udtaf produces different results in the same sliding window

2023-01-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29231: --- Labels: pull-request-available (was: ) > PyFlink udtaf produces different results in the sa

[GitHub] [flink] flinkbot commented on pull request #21655: [FLINK-29231][python] Fix the issue that Python UDAF may produce multiple results for the same window

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

[jira] [Updated] (FLINK-29231) PyFlink UDAF produces different results in the same sliding window

2023-01-12 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-29231: Summary: PyFlink UDAF produces different results in the same sliding window (was: PyFlink udtaf produces

[jira] [Created] (FLINK-30642) CsvFileCompactionITCase>CompactionITCaseBase.testPartition timed out

2023-01-12 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-30642: -- Summary: CsvFileCompactionITCase>CompactionITCaseBase.testPartition timed out Key: FLINK-30642 URL: https://issues.apache.org/jira/browse/FLINK-30642 Project: Fli

[jira] [Created] (FLINK-30643) docs_check fails

2023-01-12 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-30643: - Summary: docs_check fails Key: FLINK-30643 URL: https://issues.apache.org/jira/browse/FLINK-30643 Project: Flink Issue Type: Bug Components: Docu

[jira] [Updated] (FLINK-30643) docs_check fails

2023-01-12 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-30643: -- Labels: test-stability (was: ) > docs_check fails > > > Key:

[jira] [Closed] (FLINK-30643) docs_check fails

2023-01-12 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-30643. -- Resolution: Duplicate > docs_check fails > > > Key: FLINK-306

[jira] [Created] (FLINK-30644) ChangelogCompatibilityITCase.testRestore fails due to CheckpointCoordinator being shutdown

2023-01-12 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-30644: - Summary: ChangelogCompatibilityITCase.testRestore fails due to CheckpointCoordinator being shutdown Key: FLINK-30644 URL: https://issues.apache.org/jira/browse/FLINK-30644

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

2023-01-12 Thread GitBox
kristoffSC commented on code in PR #21393: URL: https://github.com/apache/flink/pull/21393#discussion_r1067856440 ## flink-table/flink-table-code-splitter/src/main/java/org/apache/flink/table/codesplit/BlockStatementGrouper.java: ## @@ -0,0 +1,432 @@ +/* + * Licensed to the Apac

[GitHub] [flink] reswqa commented on a diff in pull request #21603: [FLINK-30332] HsFileDataIndex supports caching and spilling index entry

2023-01-12 Thread GitBox
reswqa commented on code in PR #21603: URL: https://github.com/apache/flink/pull/21603#discussion_r1067858483 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsFileDataIndexSpilledRegionManagerImpl.java: ## @@ -0,0 +1,288 @@ +/* + * Licensed t

[jira] [Commented] (FLINK-30644) ChangelogCompatibilityITCase.testRestore fails due to CheckpointCoordinator being shutdown

2023-01-12 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17675877#comment-17675877 ] Martijn Visser commented on FLINK-30644: In the logs the following stacktrace is

[jira] [Commented] (FLINK-30643) docs_check fails

2023-01-12 Thread Ahmed Hamdy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17675878#comment-17675878 ] Ahmed Hamdy commented on FLINK-30643: - Hello This is due to migration of AWS connect

[jira] [Commented] (FLINK-30644) ChangelogCompatibilityITCase.testRestore fails due to CheckpointCoordinator being shutdown

2023-01-12 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17675879#comment-17675879 ] Martijn Visser commented on FLINK-30644: The above comment is actually related t

[jira] [Commented] (FLINK-28424) JdbcExactlyOnceSinkE2eTest hangs on Azure

2023-01-12 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17675881#comment-17675881 ] Martijn Visser commented on FLINK-28424: release-1.16: https://dev.azure.com/ap

[GitHub] [flink] MartijnVisser commented on pull request #21653: [FLINK-27640][Connector/Hive][SQL Client] Exclude Pentaho dependency

2023-01-12 Thread GitBox
MartijnVisser commented on PR #21653: URL: https://github.com/apache/flink/pull/21653#issuecomment-1380018577 @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 comm

[jira] [Created] (FLINK-30645) [FLIP-286] The scope/stability annotation in AbstractStreamOperator are inconsistent.

2023-01-12 Thread Jiangjie Qin (Jira)
Jiangjie Qin created FLINK-30645: Summary: [FLIP-286] The scope/stability annotation in AbstractStreamOperator are inconsistent. Key: FLINK-30645 URL: https://issues.apache.org/jira/browse/FLINK-30645

[GitHub] [flink] dianfu closed pull request #21644: [FLINK-14023][python] Support accessing job parameters in Python user-defined functions

2023-01-12 Thread GitBox
dianfu closed pull request #21644: [FLINK-14023][python] Support accessing job parameters in Python user-defined functions URL: https://github.com/apache/flink/pull/21644 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use th

[jira] [Closed] (FLINK-14023) Support accessing job parameters in Python user-defined functions

2023-01-12 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-14023. --- Fix Version/s: 1.17.0 Resolution: Fixed Merged to master via 5cb434c36dab9b3d1c73d0407fe09248c96de63c

[GitHub] [flink] MartijnVisser commented on pull request #21630: [FLINK-30166][Connector/FileSystem] Refactor tests that use the deprecated StreamingFileSink instead of FileSink

2023-01-12 Thread GitBox
MartijnVisser commented on PR #21630: URL: https://github.com/apache/flink/pull/21630#issuecomment-1380023964 > Should we get rid of those as well? We can't yet due to https://issues.apache.org/jira/browse/FLINK-30627 -- This is an automated message from the Apache Git Service. To r

[GitHub] [flink] MartijnVisser closed pull request #21386: [FLINK-30190][FLINK-30191][FLINK-30192][Python] Update cython, py4j and python-dateutil

2023-01-12 Thread GitBox
MartijnVisser closed pull request #21386: [FLINK-30190][FLINK-30191][FLINK-30192][Python] Update cython, py4j and python-dateutil URL: https://github.com/apache/flink/pull/21386 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub an

[jira] [Closed] (FLINK-30190) Update Cython from 0.29.24 to 0.29.32

2023-01-12 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-30190. -- Resolution: Later Is a breaking change, will be done later > Update Cython from 0.29.24 to 0.

[GitHub] [flink-connector-aws] zch93 opened a new pull request, #46: [FLINK-30578][build] Publish SBOM for externalized connectors

2023-01-12 Thread GitBox
zch93 opened a new pull request, #46: URL: https://github.com/apache/flink-connector-aws/pull/46 ## What is the purpose of the change The original PR which modified the flink-parent: #https://github.com/apache/flink/pull/21606 This PR aims to publish SBOM artifacts. - Here i

[GitHub] [flink-connector-aws] boring-cyborg[bot] commented on pull request #46: [FLINK-30578][build] Publish SBOM for externalized connectors

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

[jira] [Commented] (FLINK-30518) [flink-operator] Kubernetes HA Service not working with standalone mode

2023-01-12 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17675907#comment-17675907 ] Yang Wang commented on FLINK-30518: --- Really sorry for the late response. For native K8

[jira] [Commented] (FLINK-30518) [flink-operator] Kubernetes HA Service not working with standalone mode

2023-01-12 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17675911#comment-17675911 ] Gyula Fora commented on FLINK-30518: [~usamj] could you please take a look? > [flin

[GitHub] [flink] link3280 commented on pull request #21581: [FLINK-30538][SQL gateway/client] Improve error handling of stop job operation

2023-01-12 Thread GitBox
link3280 commented on PR #21581: URL: https://github.com/apache/flink/pull/21581#issuecomment-1380069596 @fsk119 CI turned green. Please kindly take a look at your convenience. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub a

[jira] [Commented] (FLINK-30639) Publish SBOM for externalized connectors

2023-01-12 Thread Zsombor Chikan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17675916#comment-17675916 ] Zsombor Chikan commented on FLINK-30639: Opened draft PR against flink-connector

[jira] [Updated] (FLINK-30629) ClientHeartbeatTest.testJobRunningIfClientReportHeartbeat is unstable

2023-01-12 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-30629: Attachment: ClientHeartbeatTestLog.txt > ClientHeartbeatTest.testJobRunningIfClientReportHeartbeat is unstable > -

[jira] [Commented] (FLINK-30629) ClientHeartbeatTest.testJobRunningIfClientReportHeartbeat is unstable

2023-01-12 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17675921#comment-17675921 ] Liu commented on FLINK-30629: - [~xtsong] I have reproduced the failure locally and upload th

[GitHub] [flink-table-store] zjureel commented on a diff in pull request #479: [FLINK-30632] Introduce DataType for table store

2023-01-12 Thread GitBox
zjureel commented on code in PR #479: URL: https://github.com/apache/flink-table-store/pull/479#discussion_r1067932747 ## flink-table-store-benchmark/flink-table-store-micro-benchmarks/src/main/java/org/apache/flink/table/store/benchmark/file/mergetree/MergeTreeBenchmark.java: #

[jira] [Comment Edited] (FLINK-30629) ClientHeartbeatTest.testJobRunningIfClientReportHeartbeat is unstable

2023-01-12 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17675921#comment-17675921 ] Liu edited comment on FLINK-30629 at 1/12/23 10:10 AM: --- [~xtsong]

[GitHub] [flink-table-store] zjureel commented on a diff in pull request #479: [FLINK-30632] Introduce DataType for table store

2023-01-12 Thread GitBox
zjureel commented on code in PR #479: URL: https://github.com/apache/flink-table-store/pull/479#discussion_r1067935055 ## flink-table-store-common/pom.xml: ## @@ -46,6 +46,12 @@ under the License. provided + +org.apache.flink +

[jira] [Created] (FLINK-30646) Table Store Hive catalog throws ClassNotFoundException when custom hive-site.xml is presented

2023-01-12 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-30646: --- Summary: Table Store Hive catalog throws ClassNotFoundException when custom hive-site.xml is presented Key: FLINK-30646 URL: https://issues.apache.org/jira/browse/FLINK-30646

[jira] [Updated] (FLINK-30646) Table Store Hive catalog throws ClassNotFoundException when custom hive-site.xml is presented

2023-01-12 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-30646: Description: For Hive 2.3.9, if a custom {{hive-site.xml}} is presented in {{$HIVE_HOME/conf}}, w

[jira] [Resolved] (FLINK-30641) docs_404_check fail

2023-01-12 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-30641. --- Resolution: Fixed > docs_404_check fail > --- > > Key: FLINK

[GitHub] [flink-table-store] tsreaper opened a new pull request, #481: [FLINK-30646] Table Store Hive catalog throws ClassNotFoundException when custom hive-site.xml is presented

2023-01-12 Thread GitBox
tsreaper opened a new pull request, #481: URL: https://github.com/apache/flink-table-store/pull/481 For Hive 2.3.9, if a custom `hive-site.xml` is presented in `$HIVE_HOME/conf`, when creating Table Store Hive catalog in Flink, the following exception will be thrown. ``` Caused by

[jira] [Updated] (FLINK-30646) Table Store Hive catalog throws ClassNotFoundException when custom hive-site.xml is presented

2023-01-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30646: --- Labels: pull-request-available (was: ) > Table Store Hive catalog throws ClassNotFoundExcep

[GitHub] [flink-web] carp84 commented on a diff in pull request #601: Table Store Release 0.3.0

2023-01-12 Thread GitBox
carp84 commented on code in PR #601: URL: https://github.com/apache/flink-web/pull/601#discussion_r1067958425 ## _posts/2023-01-15-release-table-store-0.3.0.md: ## @@ -0,0 +1,238 @@ +--- +layout: post +title: "Apache Flink Table Store 0.3.0 Release Announcement" +date: 2023-01-

[jira] [Updated] (FLINK-30637) In linux-aarch64 environment, using “is” judgment to match the window type of overwindow have returned incorrect matching results

2023-01-12 Thread Xin Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xin Chen updated FLINK-30637: - Description: In  linux-arch64 environment, “window_type is OverWindow.ROW_UNBOUNDED_FOLLOWING” in  in t

[jira] [Assigned] (FLINK-29705) Document the least access with RBAC setting for native K8s integration

2023-01-12 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reassigned FLINK-29705: - Assignee: ouyangwulin > Document the least access with RBAC setting for native K8s integration

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #479: [FLINK-30632] Introduce DataType for table store

2023-01-12 Thread GitBox
JingsongLi commented on code in PR #479: URL: https://github.com/apache/flink-table-store/pull/479#discussion_r1068003714 ## flink-table-store-benchmark/flink-table-store-micro-benchmarks/src/main/java/org/apache/flink/table/store/benchmark/file/mergetree/MergeTreeBenchmark.java: ##

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #479: [FLINK-30632] Introduce DataType for table store

2023-01-12 Thread GitBox
JingsongLi commented on code in PR #479: URL: https://github.com/apache/flink-table-store/pull/479#discussion_r1068004313 ## flink-table-store-common/pom.xml: ## @@ -46,6 +46,12 @@ under the License. provided + +org.apache.flink +

[GitHub] [flink] fsk119 merged pull request #21502: [FLINK-29950] Refactor ResultSet to an interface

2023-01-12 Thread GitBox
fsk119 merged PR #21502: URL: https://github.com/apache/flink/pull/21502 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache

[jira] [Resolved] (FLINK-29950) Refactor ResultSet to an interface

2023-01-12 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang resolved FLINK-29950. --- Fix Version/s: 1.17.0 Resolution: Implemented Merged into master: 6a15b7e9b2459f2bb39

[jira] [Created] (FLINK-30647) Add human readable datetime of watermark column in the web for better debug experience

2023-01-12 Thread Yun Tang (Jira)
Yun Tang created FLINK-30647: Summary: Add human readable datetime of watermark column in the web for better debug experience Key: FLINK-30647 URL: https://issues.apache.org/jira/browse/FLINK-30647 Projec

[jira] [Updated] (FLINK-30637) In linux-aarch64 environment, using “is” judgment to match the window type of overwindow have returned incorrect matching results

2023-01-12 Thread Xin Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xin Chen updated FLINK-30637: - Description: In  linux-arch64 environment, “window_type is OverWindow.ROW_UNBOUNDED_FOLLOWING” in  in t

[jira] [Assigned] (FLINK-30647) Add human readable datetime of watermark column in the web for better debug experience

2023-01-12 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-30647: Assignee: Yu Chen > Add human readable datetime of watermark column in the web for better debug

[jira] [Commented] (FLINK-30513) HA storage dir leaks on cluster termination

2023-01-12 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17675967#comment-17675967 ] Yang Wang commented on FLINK-30513: --- Given that the cluster-id is configured to k8s-ap

[GitHub] [flink] yuchen-ecnu opened a new pull request, #21656: [FLINK-30647] Add readable datetime column for watermark in WEB UI

2023-01-12 Thread GitBox
yuchen-ecnu opened a new pull request, #21656: URL: https://github.com/apache/flink/pull/21656 ## What is the purpose of the change This pull request adds a new column called `Date of Watermark Timestamp` in the Watermark Tab of Flink Web. It helps users to have a more intuitive vi

[jira] [Updated] (FLINK-30647) Add human readable datetime of watermark column in the web for better debug experience

2023-01-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30647: --- Labels: pull-request-available (was: ) > Add human readable datetime of watermark column in

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #502: [FLINK-30574] Detect ineffective scale up operations to avoid scaling further

2023-01-12 Thread GitBox
gyfora merged PR #502: URL: https://github.com/apache/flink-kubernetes-operator/pull/502 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr

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

2023-01-12 Thread GitBox
tsreaper commented on code in PR #21393: URL: https://github.com/apache/flink/pull/21393#discussion_r1067994477 ## flink-table/flink-table-code-splitter/src/main/java/org/apache/flink/table/codesplit/BlockStatementGrouper.java: ## @@ -0,0 +1,432 @@ +/* + * Licensed to the Apache

[GitHub] [flink] flinkbot commented on pull request #21656: [FLINK-30647] Add readable datetime column for watermark in WEB UI

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

[GitHub] [flink] Myasuka commented on a diff in pull request #21656: [FLINK-30647] Add readable datetime column for watermark in WEB UI

2023-01-12 Thread GitBox
Myasuka commented on code in PR #21656: URL: https://github.com/apache/flink/pull/21656#discussion_r1068037154 ## flink-runtime-web/web-dashboard/src/app/components/humanize-watermark.pipe.ts: ## @@ -35,3 +35,19 @@ export class HumanizeWatermarkPipe implements PipeTransform {

[jira] [Created] (FLINK-30648) [Umbrella]FLIP-282 Introduce Delete/Update API

2023-01-12 Thread luoyuxia (Jira)
luoyuxia created FLINK-30648: Summary: [Umbrella]FLIP-282 Introduce Delete/Update API Key: FLINK-30648 URL: https://issues.apache.org/jira/browse/FLINK-30648 Project: Flink Issue Type: New Featur

[jira] [Updated] (FLINK-30637) In linux-aarch64 environment, using “is” judgment to match the window type of overwindow have returned incorrect matching results

2023-01-12 Thread Xin Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xin Chen updated FLINK-30637: - Description: In  linux-arch64 environment, “window_type is OverWindow.ROW_UNBOUNDED_FOLLOWING” in  in t

[GitHub] [flink] MartijnVisser merged pull request #21653: [FLINK-27640][Connector/Hive][SQL Client] Exclude Pentaho dependency

2023-01-12 Thread GitBox
MartijnVisser merged PR #21653: URL: https://github.com/apache/flink/pull/21653 -- 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

[jira] [Assigned] (FLINK-27640) Flink not compiling, flink-connector-hive_2.12 is missing jhyde pentaho-aggdesigner-algorithm:jar:5.1.5-jhyde

2023-01-12 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-27640: -- Assignee: Chen Qin (was: Martijn Visser) > Flink not compiling, flink-connector-hive

[jira] [Updated] (FLINK-30625) Performance regression in tumblingWindow on 06.01.2023

2023-01-12 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-30625: --- Component/s: (was: Table SQL / Planner) > Performance regression in tumblingWindow on 06

[jira] [Updated] (FLINK-30625) Performance regression in tumblingWindow on 06.01.2023

2023-01-12 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-30625: --- Priority: Blocker (was: Major) > Performance regression in tumblingWindow on 06.01.2023 > -

[jira] [Updated] (FLINK-30637) In linux-aarch64 environment, using “is” judgment to match the window type of overwindow have returned incorrect matching results

2023-01-12 Thread Xin Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xin Chen updated FLINK-30637: - Description: In  linux-arch64 environment, “window_type is OverWindow.ROW_UNBOUNDED_FOLLOWING” in  in t

[jira] [Closed] (FLINK-27640) Flink not compiling, flink-connector-hive_2.12 is missing jhyde pentaho-aggdesigner-algorithm:jar:5.1.5-jhyde

2023-01-12 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-27640. -- Resolution: Fixed Fixed in master: 881627dcda9f5cdea9e095d7aff854fbf9508785 > Flink not compi

[GitHub] [flink] XComp commented on pull request #21630: [FLINK-30166][Connector/FileSystem] Refactor tests that use the deprecated StreamingFileSink instead of FileSink

2023-01-12 Thread GitBox
XComp commented on PR #21630: URL: https://github.com/apache/flink/pull/21630#issuecomment-1380258947 Sorry for being picky on that one. But even with knowing these details, it becomes kind of hard for me to review this PR. There are still code location where I have questions but which are

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

2023-01-12 Thread GitBox
kristoffSC commented on code in PR #21393: URL: https://github.com/apache/flink/pull/21393#discussion_r1068067248 ## flink-table/flink-table-code-splitter/src/main/java/org/apache/flink/table/codesplit/BlockStatementGrouper.java: ## @@ -0,0 +1,432 @@ +/* + * Licensed to the Apac

[GitHub] [flink] MartijnVisser commented on pull request #21630: [FLINK-30166][Connector/FileSystem] Refactor tests that use the deprecated StreamingFileSink instead of FileSink

2023-01-12 Thread GitBox
MartijnVisser commented on PR #21630: URL: https://github.com/apache/flink/pull/21630#issuecomment-1380261028 > Alternatively, if you really want to push for it, it might be more reasonable to ask @JingsongLi for a review or someone more related to whether the partial cleanup is to his liki

[jira] [Commented] (FLINK-29427) LookupJoinITCase failed with classloader problem

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

[jira] [Created] (FLINK-30649) Run kubernetes session test (default input) failed with a timeout

2023-01-12 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-30649: - Summary: Run kubernetes session test (default input) failed with a timeout Key: FLINK-30649 URL: https://issues.apache.org/jira/browse/FLINK-30649 Project: Flink

[GitHub] [flink-table-store] JingsongLi closed pull request #477: [FLINK-30628] Kerberos in HiveCatalog is not work

2023-01-12 Thread GitBox
JingsongLi closed pull request #477: [FLINK-30628] Kerberos in HiveCatalog is not work URL: https://github.com/apache/flink-table-store/pull/477 -- 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 s

[GitHub] [flink-table-store] JingsongLi commented on pull request #476: [FLINK-30628] Kerberos in HiveCatalog is not work

2023-01-12 Thread GitBox
JingsongLi commented on PR #476: URL: https://github.com/apache/flink-table-store/pull/476#issuecomment-1380282492 I'm not sure if this successfully solves the problem -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use t

[GitHub] [flink-table-store] JingsongLi closed pull request #476: [FLINK-30628] Kerberos in HiveCatalog is not work

2023-01-12 Thread GitBox
JingsongLi closed pull request #476: [FLINK-30628] Kerberos in HiveCatalog is not work URL: https://github.com/apache/flink-table-store/pull/476 -- 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 s

[GitHub] [flink-table-store] JingsongLi commented on pull request #477: [FLINK-30628] Kerberos in HiveCatalog is not work

2023-01-12 Thread GitBox
JingsongLi commented on PR #477: URL: https://github.com/apache/flink-table-store/pull/477#issuecomment-1380282408 I'm not sure if this successfully solves the problem -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use t

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #471: [FLINK-30608] support rename table

2023-01-12 Thread GitBox
JingsongLi commented on code in PR #471: URL: https://github.com/apache/flink-table-store/pull/471#discussion_r1068080415 ## flink-table-store-hive/flink-table-store-hive-catalog/src/test/java/org/apache/flink/table/store/hive/HiveCatalogITCase.java: ## @@ -276,6 +279,36 @@ publ

[GitHub] [flink] yuchen-ecnu commented on a diff in pull request #21656: [FLINK-30647] Add readable datetime column for watermark in WEB UI

2023-01-12 Thread GitBox
yuchen-ecnu commented on code in PR #21656: URL: https://github.com/apache/flink/pull/21656#discussion_r1068081828 ## flink-runtime-web/web-dashboard/src/app/components/humanize-watermark.pipe.ts: ## @@ -35,3 +35,19 @@ export class HumanizeWatermarkPipe implements PipeTransform

[GitHub] [flink] yuchen-ecnu commented on a diff in pull request #21656: [FLINK-30647] Add readable datetime column for watermark in WEB UI

2023-01-12 Thread GitBox
yuchen-ecnu commented on code in PR #21656: URL: https://github.com/apache/flink/pull/21656#discussion_r1068082134 ## flink-runtime-web/web-dashboard/src/app/components/humanize-watermark.pipe.ts: ## @@ -35,3 +35,19 @@ export class HumanizeWatermarkPipe implements PipeTransform

[GitHub] [flink] yuchen-ecnu commented on a diff in pull request #21656: [FLINK-30647] Add readable datetime column for watermark in WEB UI

2023-01-12 Thread GitBox
yuchen-ecnu commented on code in PR #21656: URL: https://github.com/apache/flink/pull/21656#discussion_r1068082786 ## flink-runtime-web/web-dashboard/src/app/components/humanize-watermark.pipe.ts: ## @@ -35,3 +35,19 @@ export class HumanizeWatermarkPipe implements PipeTransform

[jira] [Updated] (FLINK-30603) CompactActionITCase in table store is unstable

2023-01-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-30603: - Fix Version/s: table-store-0.4.0 table-store-0.3.1 > CompactActionITCase in t

[jira] [Updated] (FLINK-30611) Expire snapshot should be reentrant

2023-01-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-30611: - Fix Version/s: table-store-0.4.0 table-store-0.3.1 (was

[jira] [Updated] (FLINK-30628) Kerberos in HiveCatalog is not work

2023-01-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-30628: - Fix Version/s: table-store-0.4.0 (was: table-store-0.3.0) > Kerberos in H

[jira] [Updated] (FLINK-30620) Table Store Hive catalog supports specifying custom Hive metastore client

2023-01-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-30620: - Fix Version/s: table-store-0.3.1 (was: table-store-0.3.0) > Table Store H

[jira] [Updated] (FLINK-30628) Kerberos in HiveCatalog is not work

2023-01-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-30628: - Fix Version/s: table-store-0.3.1 > Kerberos in HiveCatalog is not work > ---

[jira] [Updated] (FLINK-30646) Table Store Hive catalog throws ClassNotFoundException when custom hive-site.xml is presented

2023-01-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-30646: - Fix Version/s: table-store-0.3.1 (was: table-store-0.3.0) > Table Store H

[jira] [Commented] (FLINK-30637) In linux-aarch64 environment, using “is” judgment to match the window type of overwindow have returned incorrect matching results

2023-01-12 Thread Xin Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17675993#comment-17675993 ] Xin Chen commented on FLINK-30637: -- Why the window_type's memory address from serialize

[jira] [Updated] (FLINK-30623) Performance regression in checkpointSingleInput.UNALIGNED on 04.01.2023

2023-01-12 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-30623: --- Priority: Blocker (was: Critical) > Performance regression in checkpointSingleInput.UNALIGN

[jira] [Commented] (FLINK-30623) Performance regression in checkpointSingleInput.UNALIGNED on 04.01.2023

2023-01-12 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17676002#comment-17676002 ] Piotr Nowojski commented on FLINK-30623: I have some doubts about FLINK-30533 de

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

2023-01-12 Thread GitBox
kristoffSC commented on code in PR #21393: URL: https://github.com/apache/flink/pull/21393#discussion_r1068106734 ## flink-table/flink-table-code-splitter/src/main/java/org/apache/flink/table/codesplit/BlockStatementGrouper.java: ## @@ -0,0 +1,432 @@ +/* + * Licensed to the Apac

[GitHub] [flink] wanglijie95 commented on pull request #21626: [FLINK-30604][runtime] Remove the limitation that parallelism decided by adaptive batch scheduler is always a power of two

2023-01-12 Thread GitBox
wanglijie95 commented on PR #21626: URL: https://github.com/apache/flink/pull/21626#issuecomment-1380365637 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific commen

[jira] [Created] (FLINK-30650) FLIP-280: Introduce EXPLAIN PLAN_ADVICE to provide SQL advice

2023-01-12 Thread Jane Chan (Jira)
Jane Chan created FLINK-30650: - Summary: FLIP-280: Introduce EXPLAIN PLAN_ADVICE to provide SQL advice Key: FLINK-30650 URL: https://issues.apache.org/jira/browse/FLINK-30650 Project: Flink Issu

[jira] [Created] (FLINK-30651) Move util methods to CatalogTest and remove CatalogTestUtils class

2023-01-12 Thread Samrat Deb (Jira)
Samrat Deb created FLINK-30651: -- Summary: Move util methods to CatalogTest and remove CatalogTestUtils class Key: FLINK-30651 URL: https://issues.apache.org/jira/browse/FLINK-30651 Project: Flink

[GitHub] [flink] zentol commented on pull request #21532: FLINK-30455 [core] Excluding java.lang.String and primitive types from closure cleaning

2023-01-12 Thread GitBox
zentol commented on PR #21532: URL: https://github.com/apache/flink/pull/21532#issuecomment-1380386791 I'm curious what the endgame of this approach is supposed to be. Sure, fixing it for Strings isn't _bad_, but it's still a problem for virtually every other JDK type; BigDecimals, list/map

[jira] [Closed] (FLINK-30574) Do not scale further up if last scaling was ineffective

2023-01-12 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-30574. -- Fix Version/s: kubernetes-operator-1.4.0 Resolution: Fixed merged to main ed6acd453c6e14f7fdb32

[jira] [Created] (FLINK-30652) Use max busytime instead of average to compute true processing rate

2023-01-12 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-30652: -- Summary: Use max busytime instead of average to compute true processing rate Key: FLINK-30652 URL: https://issues.apache.org/jira/browse/FLINK-30652 Project: Flink

[jira] [Commented] (FLINK-30651) Move util methods to CatalogTest and remove CatalogTestUtils class

2023-01-12 Thread Samrat Deb (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17676028#comment-17676028 ] Samrat Deb commented on FLINK-30651: i would like to work on this issue  > Move uti

  1   2   3   >