[GitHub] [flink] zhuzhurk commented on a diff in pull request #21199: [FLINK-29767] Adaptive batch scheduler supports hybrid shuffle

2022-12-07 Thread GitBox
zhuzhurk commented on code in PR #21199: URL: https://github.com/apache/flink/pull/21199#discussion_r1042889689 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/InputConsumableDecider.java: ## @@ -33,14 +33,14 @@ public interface InputConsumableDecider

[jira] [Updated] (FLINK-30334) SourceCoordinator error splitRequest check cause HybridSource loss of data and hang

2022-12-07 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ran Tao updated FLINK-30334: Description: If we use hybrid source, for example, filesystem source A read a.csv, filesystem B read

[jira] [Commented] (FLINK-25806) Remove legacy high availability services

2022-12-07 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644648#comment-17644648 ] Chesnay Schepler commented on FLINK-25806: -- The (Zookeeper)LeaderElectionTest is still using

[jira] [Updated] (FLINK-30334) SourceCoordinator error splitRequest check cause HybridSource loss of data and hang

2022-12-07 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ran Tao updated FLINK-30334: Summary: SourceCoordinator error splitRequest check cause HybridSource loss of data and hang (was:

[jira] [Commented] (FLINK-30334) SourceCoordinator error splitRequest check cause HybridSource hang

2022-12-07 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644642#comment-17644642 ] Ran Tao commented on FLINK-30334: - Hi. [~zhuzh] [~thw]  please take a look?   I think this question is

[GitHub] [flink] flinkbot commented on pull request #21464: [FLINK-30334] Reset SourceCoordinator#handleRequestSplitEvent without violent hasNoMoreSplits check

2022-12-07 Thread GitBox
flinkbot commented on PR #21464: URL: https://github.com/apache/flink/pull/21464#issuecomment-1342213006 ## CI report: * 93544b92ead50eb7b9ab0d9728b1ad5a0531642c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] snuyanzin commented on pull request #21459: [hotfix] Replace deprecated Calcite's APIs

2022-12-07 Thread GitBox
snuyanzin commented on PR #21459: URL: https://github.com/apache/flink/pull/21459#issuecomment-1342207355 Thanks for the feedback. I updated the rest of `AggregateCall.create` and also updated some more deprecated methods (updated in description)

[jira] [Updated] (FLINK-30334) SourceCoordinator error splitRequest check cause HybridSource hang

2022-12-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30334: --- Labels: pull-request-available (was: ) > SourceCoordinator error splitRequest check cause

[GitHub] [flink] chucheng92 opened a new pull request, #21464: [FLINK-30334] Reset SourceCoordinator#handleRequestSplitEvent without…

2022-12-07 Thread GitBox
chucheng92 opened a new pull request, #21464: URL: https://github.com/apache/flink/pull/21464 ## What is the purpose of the change SourceCoordinator#handleRequestSplitEvent hasNoMoreSplits check not consider the HybridSource situation. It will cause HybridSource do not read next

[jira] [Updated] (FLINK-30333) Supports lookup a partial-update table

2022-12-07 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-30333: - Summary: Supports lookup a partial-update table (was: Supports lookup a partial-update table

[jira] [Updated] (FLINK-30333) Supports lookup a partial-update table with full compaction

2022-12-07 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-30333: - Description: The lookup uses streaming read for reading table. (In TableStreamingReader) - We

[jira] [Commented] (FLINK-25806) Remove legacy high availability services

2022-12-07 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644639#comment-17644639 ] Chesnay Schepler commented on FLINK-25806: -- We probably just missed them. Let's double-check

[jira] [Updated] (FLINK-30334) SourceCoordinator error splitRequest check cause HybridSource hang

2022-12-07 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ran Tao updated FLINK-30334: Description: If we use hybrid source, for example, filesystem source A read a.csv, filesystem B read

[jira] [Updated] (FLINK-30334) SourceCoordinator error splitRequest check cause HybridSource hang

2022-12-07 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ran Tao updated FLINK-30334: Description: If we use hybrid source, for example, filesystem source A read a.csv, filesystem B read

[jira] [Created] (FLINK-30334) SourceCoordinator error split check cause HybridSource hang

2022-12-07 Thread Ran Tao (Jira)
Ran Tao created FLINK-30334: --- Summary: SourceCoordinator error split check cause HybridSource hang Key: FLINK-30334 URL: https://issues.apache.org/jira/browse/FLINK-30334 Project: Flink Issue

[jira] [Updated] (FLINK-30334) SourceCoordinator error splitRequest check cause HybridSource hang

2022-12-07 Thread Ran Tao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ran Tao updated FLINK-30334: Summary: SourceCoordinator error splitRequest check cause HybridSource hang (was: SourceCoordinator

[jira] [Closed] (FLINK-30319) Validate illegal column name in table store

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

[GitHub] [flink-table-store] JingsongLi merged pull request #424: [FLINK-30319] Validate column name in ddl

2022-12-07 Thread GitBox
JingsongLi merged PR #424: URL: https://github.com/apache/flink-table-store/pull/424 -- 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] [Created] (FLINK-30333) Supports lookup a partial-update table with full compaction

2022-12-07 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-30333: Summary: Supports lookup a partial-update table with full compaction Key: FLINK-30333 URL: https://issues.apache.org/jira/browse/FLINK-30333 Project: Flink

[jira] [Commented] (FLINK-30317) Create table in FTS catalog with s3 warehouse throws DatabaseNotExistException

2022-12-07 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644628#comment-17644628 ] Jingsong Lee commented on FLINK-30317: -- Thanks [~Ge] for reporting. We should check and create

[GitHub] [flink] 1996fanrui commented on a diff in pull request #21443: [FLINK-30213] Change ForwardPartitioner to RebalancePartitioner on parallelism changes

2022-12-07 Thread GitBox
1996fanrui commented on code in PR #21443: URL: https://github.com/apache/flink/pull/21443#discussion_r1042919428 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java: ## @@ -1614,6 +1617,15 @@ List>>> createRecordWriters

[jira] [Assigned] (FLINK-30246) Registering the same metric object with different name and group will conflict in metric reporter

2022-12-07 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-30246: --- Assignee: xingbe > Registering the same metric object with different name and group will >

[jira] [Commented] (FLINK-30246) Registering the same metric object with different name and group will conflict in metric reporter

2022-12-07 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644595#comment-17644595 ] Zhu Zhu commented on FLINK-30246: - Thanks for volunteering to take this ticket! I have assigned you the

[jira] [Commented] (FLINK-30246) Registering the same metric object with different name and group will conflict in metric reporter

2022-12-07 Thread xingbe (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644592#comment-17644592 ] xingbe commented on FLINK-30246: Hi, I would like to work on this issue, could you assign this ticket to

[jira] [Created] (FLINK-30332) HsFileDataIndex should supports spill to file

2022-12-07 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-30332: -- Summary: HsFileDataIndex should supports spill to file Key: FLINK-30332 URL: https://issues.apache.org/jira/browse/FLINK-30332 Project: Flink Issue Type:

[jira] [Created] (FLINK-30331) Further improvement of production availability of hybrid shuffle

2022-12-07 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-30331: -- Summary: Further improvement of production availability of hybrid shuffle Key: FLINK-30331 URL: https://issues.apache.org/jira/browse/FLINK-30331 Project: Flink

[GitHub] [flink] liyubin117 commented on pull request #21182: [FLINK-29679][table] Migrate to new schema framework & show column comment

2022-12-07 Thread GitBox
liyubin117 commented on PR #21182: URL: https://github.com/apache/flink/pull/21182#issuecomment-1341934897 @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] luoyuxia commented on pull request #21149: [FLINK-29527][formats/parquet] Make unknownFieldsIndices work for single ParquetReader

2022-12-07 Thread GitBox
luoyuxia commented on PR #21149: URL: https://github.com/apache/flink/pull/21149#issuecomment-1341903988 @saLeox The code changes looks good to me. But after an offline discussion with @Tartarus0zm, I have some other conerns about this pr. > However, some fields may only be nonexistent

[jira] [Closed] (FLINK-29732) Support configuring session with SQL statement

2022-12-07 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-29732. - Resolution: Fixed Merged into master at: e6215d4f7ede96f1225921f2b0f322c87a5040cd > Support

[GitHub] [flink] fsk119 closed pull request #21133: [FLINK-29732][sql-gateway] support configuring session with SQL statement.

2022-12-07 Thread GitBox
fsk119 closed pull request #21133: [FLINK-29732][sql-gateway] support configuring session with SQL statement. URL: https://github.com/apache/flink/pull/21133 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above

[GitHub] [flink] fredia commented on pull request #21405: [FLINK-23035][state/changelog] Add explicit append() to StateChangelogWriter to write metadata

2022-12-07 Thread GitBox
fredia commented on PR #21405: URL: https://github.com/apache/flink/pull/21405#issuecomment-1341890756 @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-30325) the column lost comments, also find some issue ,but that commit is not mr. i have some diff solution

2022-12-07 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644569#comment-17644569 ] luoyuxia commented on FLINK-30325: -- FYI: FLINK-29679 is going to fix the comment loss issue. But

[jira] [Commented] (FLINK-30318) sql-client failed to load jar passed with -j args in flink 1.16.0

2022-12-07 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644565#comment-17644565 ] luoyuxia commented on FLINK-30318: -- [~samrat007] Thanks for the investigation, I had a quick look of

[GitHub] [flink-web] morhidi opened a new pull request, #593: Kubernetes Operator Release 1.3.0

2022-12-07 Thread GitBox
morhidi opened a new pull request, #593: URL: https://github.com/apache/flink-web/pull/593 Kubernetes Operator Release 1.3.0 -- 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] [Created] (FLINK-30330) Exclude .github from source release(s)

2022-12-07 Thread Matyas Orhidi (Jira)
Matyas Orhidi created FLINK-30330: - Summary: Exclude .github from source release(s) Key: FLINK-30330 URL: https://issues.apache.org/jira/browse/FLINK-30330 Project: Flink Issue Type: Bug

[GitHub] [flink] steveniemitz commented on pull request #21457: [FLINK-30309][runtime] Allow users to supply custom SslContexts

2022-12-07 Thread GitBox
steveniemitz commented on PR #21457: URL: https://github.com/apache/flink/pull/21457#issuecomment-1341681036 Just wanted to ping on this, I've tested the new interfaces on our cluster and its working well! -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Updated] (FLINK-30306) Audit utils can expose potentially sensitive information

2022-12-07 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30306: --- Fix Version/s: (was: kubernetes-operator-1.3.0) > Audit utils can expose potentially sensitive

[jira] [Updated] (FLINK-30306) Audit utils can expose potentially sensitive information

2022-12-07 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30306: --- Issue Type: Improvement (was: Bug) > Audit utils can expose potentially sensitive information >

[jira] [Updated] (FLINK-30306) Audit utils can expose potentially sensitive information

2022-12-07 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30306: --- Fix Version/s: kubernetes-operator-1.3.0 > Audit utils can expose potentially sensitive information

[jira] [Updated] (FLINK-30329) flink-kubernetes-operator helm chart does not work with dynamic config because of use of volumeMount subPath

2022-12-07 Thread Andrew Otto (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Otto updated FLINK-30329: Summary: flink-kubernetes-operator helm chart does not work with dynamic config because of use of

[jira] [Updated] (FLINK-30329) flink-kubernetes-operator helm chart does not work with dynamic config because of use of ConfigMap subPath

2022-12-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30329: --- Labels: pull-request-available (was: ) > flink-kubernetes-operator helm chart does not

[GitHub] [flink-kubernetes-operator] ottomata opened a new pull request, #478: [FLINK-30329] Mount flink-operator-config-volume at /opt/flink/conf without subPath

2022-12-07 Thread GitBox
ottomata opened a new pull request, #478: URL: https://github.com/apache/flink-kubernetes-operator/pull/478 When mounted volumes use subPath, the volume that uses them is not updated automatically. So, even you do update the ConfigMap in k8s, the flink-conf.yaml file will never see those

[jira] [Updated] (FLINK-30329) flink-kubernetes-operator helm chart does not work with dynamic config because of use of ConfigMap subPath

2022-12-07 Thread Andrew Otto (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Otto updated FLINK-30329: Description: flink-kubernetes-operator supports dynamic configuration when

[jira] [Created] (FLINK-30329) flink-kubernetes-operator helm chart does not work with dynamic config because of use of ConfigMap subPath

2022-12-07 Thread Andrew Otto (Jira)
Andrew Otto created FLINK-30329: --- Summary: flink-kubernetes-operator helm chart does not work with dynamic config because of use of ConfigMap subPath Key: FLINK-30329 URL:

[GitHub] [flink-connector-opensearch] reta commented on pull request #1: [FLINK-25756] [connectors/opensearch] Dedicated Opensearch connectors

2022-12-07 Thread GitBox
reta commented on PR #1: URL: https://github.com/apache/flink-connector-opensearch/pull/1#issuecomment-1341465914 > It would be amazing if this could be based on the opensearch-java client rather than RHLC, since that is where all of the improvements are going. Is that how this is set up?

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

2022-12-07 Thread GitBox
mas-chen commented on PR #1: URL: https://github.com/apache/flink-connector-kafka/pull/1#issuecomment-1341424894 @MartijnVisser CI is passing, sorry committed something unintentionally -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink-connector-opensearch] wbeckler commented on pull request #1: [FLINK-25756] [connectors/opensearch] Dedicated Opensearch connectors

2022-12-07 Thread GitBox
wbeckler commented on PR #1: URL: https://github.com/apache/flink-connector-opensearch/pull/1#issuecomment-1341413162 It would be amazing if this could be based on the opensearch-java client rather than RHLC, since that is where all of the improvements are going. Is that how this is set

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

2022-12-07 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644423#comment-17644423 ] Matthias Pohl commented on FLINK-30328: --- The test failure appeared in a CI run for [hotfix PR

[GitHub] [flink] XComp commented on pull request #21459: [hotfix] Replace deprecated Calcite's APIs

2022-12-07 Thread GitBox
XComp commented on PR #21459: URL: https://github.com/apache/flink/pull/21459#issuecomment-1341241595 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

[GitHub] [flink] XComp commented on pull request #21459: [hotfix] Replace deprecated Calcite's APIs

2022-12-07 Thread GitBox
XComp commented on PR #21459: URL: https://github.com/apache/flink/pull/21459#issuecomment-1341241270 Created FLINK-30328 to cover the test failure -- 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-30328) TaskManagerWideRocksDbMemorySharingITCase.testBlockCache failed

2022-12-07 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644422#comment-17644422 ] Matthias Pohl commented on FLINK-30328: --- [~roman] is there anyone else I could ping on these

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

2022-12-07 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-30328: - Summary: TaskManagerWideRocksDbMemorySharingITCase.testBlockCache failed Key: FLINK-30328 URL: https://issues.apache.org/jira/browse/FLINK-30328 Project: Flink

[jira] [Resolved] (FLINK-30316) [JUnit5 Migration] Migrate flink-statebackend-common

2022-12-07 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-30316. --- Fix Version/s: 1.17.0 Assignee: Sergey Nuyanzin Resolution: Fixed master:

[GitHub] [flink] XComp merged pull request #21461: [FLINK-30316][statebackend] Migrate tests to JUnit5

2022-12-07 Thread GitBox
XComp merged PR #21461: URL: https://github.com/apache/flink/pull/21461 -- 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] mxm commented on a diff in pull request #21443: [FLINK-30213] Change ForwardPartitioner to RebalancePartitioner on parallelism changes

2022-12-07 Thread GitBox
mxm commented on code in PR #21443: URL: https://github.com/apache/flink/pull/21443#discussion_r1042409667 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java: ## @@ -1614,6 +1617,15 @@ List>>> createRecordWriters return

[GitHub] [flink] flinkbot commented on pull request #21463: [FLINK-30299][core] Adds thread dump creation to FatalExitExceptionHandler

2022-12-07 Thread GitBox
flinkbot commented on PR #21463: URL: https://github.com/apache/flink/pull/21463#issuecomment-1341204246 ## CI report: * a8d8602cf06e6fad4d0472b2b8f49eb934c5693f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-30299) TaskManagerRunnerTest fails with 239 exit code (i.e. FatalExitExceptionHandler was called)

2022-12-07 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644405#comment-17644405 ] Matthias Pohl commented on FLINK-30299: --- I provided a PR that adds thread dump generation to the

[jira] [Updated] (FLINK-30299) TaskManagerRunnerTest fails with 239 exit code (i.e. FatalExitExceptionHandler was called)

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

[GitHub] [flink] XComp opened a new pull request, #21463: [FLINK-30299][core] Adds thread dump creation to FatalExitExceptionHandler

2022-12-07 Thread GitBox
XComp opened a new pull request, #21463: URL: https://github.com/apache/flink/pull/21463 ## What is the purpose of the change It's hard to investigate FLINK-30299. Adding the thread dump might help us identlifying the cause or at least having a pointer what to focus on. ##

[jira] [Closed] (FLINK-30046) Cannot use digest in Helm chart to reference image

2022-12-07 Thread Matyas Orhidi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matyas Orhidi closed FLINK-30046. - Resolution: Fixed added to main via 0365416773390ae7a4946ba7180abb9e66b0dd86 > Cannot use

[jira] [Commented] (FLINK-30313) Flink Kubernetes Operator seems to rely on 1.15 k8s HA code but 1.16 config code

2022-12-07 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644379#comment-17644379 ] Matthias Pohl commented on FLINK-30313: --- Thanks for looking into it. It might be worth it

[jira] [Closed] (FLINK-30313) Flink Kubernetes Operator seems to rely on 1.15 k8s HA code but 1.16 config code

2022-12-07 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-30313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-30313. -- Resolution: Cannot Reproduce We jumped on a call to try to reproduce this with [~gyfora]. 

[jira] [Assigned] (FLINK-30313) Flink Kubernetes Operator seems to rely on 1.15 k8s HA code but 1.16 config code

2022-12-07 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-30313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-30313: -- Assignee: Martin Ellis > Flink Kubernetes Operator seems to rely on 1.15 k8s HA code

[jira] [Assigned] (FLINK-30313) Flink Kubernetes Operator seems to rely on 1.15 k8s HA code but 1.16 config code

2022-12-07 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-30313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-30313: -- Assignee: Márton Balassi (was: Martin Ellis) > Flink Kubernetes Operator seems to

[jira] [Created] (FLINK-30327) Adding a values.schema.json to the Helm chart source to support schema validation on Helm chart configuration

2022-12-07 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-30327: - Summary: Adding a values.schema.json to the Helm chart source to support schema validation on Helm chart configuration Key: FLINK-30327 URL:

[jira] [Commented] (FLINK-30313) Flink Kubernetes Operator seems to rely on 1.15 k8s HA code but 1.16 config code

2022-12-07 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-30313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644356#comment-17644356 ] Márton Balassi commented on FLINK-30313: The operator depends on 1.15.3 of flink-core:

[jira] [Closed] (FLINK-30286) Run rat plugin in validate phase

2022-12-07 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-30286. Resolution: Fixed master: a798e52ab41ee438db52b0e272f984c8508fb395 > Run rat plugin in

[GitHub] [flink] zentol merged pull request #21446: [FLINK-30286][build] Run rat-plugin in validate phase

2022-12-07 Thread GitBox
zentol merged PR #21446: URL: https://github.com/apache/flink/pull/21446 -- 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-table-store] SteNicholas commented on a diff in pull request #413: [FLINK-30255] Throw exception when names are upper case in HiveCatalog

2022-12-07 Thread GitBox
SteNicholas commented on code in PR #413: URL: https://github.com/apache/flink-table-store/pull/413#discussion_r1042224954 ## flink-table-store-hive/flink-table-store-hive-catalog/src/test/java/org/apache/flink/table/store/hive/HiveCatalogITCase.java: ## @@ -317,6 +318,25 @@

[GitHub] [flink-table-store] SteNicholas commented on a diff in pull request #413: [FLINK-30255] Throw exception when names are upper case in HiveCatalog

2022-12-07 Thread GitBox
SteNicholas commented on code in PR #413: URL: https://github.com/apache/flink-table-store/pull/413#discussion_r1042223986 ## flink-table-store-hive/flink-table-store-hive-catalog/src/main/java/org/apache/flink/table/store/hive/HiveCatalog.java: ## @@ -269,6 +271,26 @@

[GitHub] [flink] XComp commented on a diff in pull request #20919: [FLINK-29405] Fix unstable test InputFormatCacheLoaderTest

2022-12-07 Thread GitBox
XComp commented on code in PR #20919: URL: https://github.com/apache/flink/pull/20919#discussion_r1042146547 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/table/lookup/fullcache/CacheLoader.java: ## @@ -59,11 +65,11 @@ public abstract

[GitHub] [flink-ml] jiangxin369 commented on a diff in pull request #183: [FLINK-29603] Add Transformer for StopWordsRemover

2022-12-07 Thread GitBox
jiangxin369 commented on code in PR #183: URL: https://github.com/apache/flink-ml/pull/183#discussion_r1042170078 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/stopwordsremover/StopWordsRemoverBase.java: ## @@ -0,0 +1,118 @@ +/* + * Licensed to the Apache Software

[jira] [Commented] (FLINK-30326) SQL Client should not create table directory structure

2022-12-07 Thread Alex Sorokoumov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644323#comment-17644323 ] Alex Sorokoumov commented on FLINK-30326: - [~lzljs3620320] [~TsReaper] Could you please comment

[jira] [Comment Edited] (FLINK-30326) SQL Client should not create table directory structure

2022-12-07 Thread Alex Sorokoumov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644312#comment-17644312 ] Alex Sorokoumov edited comment on FLINK-30326 at 12/7/22 12:57 PM: --- I

[jira] [Commented] (FLINK-30326) SQL Client should not create table directory structure

2022-12-07 Thread Alex Sorokoumov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644312#comment-17644312 ] Alex Sorokoumov commented on FLINK-30326: - I used the following example to conclude that the SQL

[jira] [Created] (FLINK-30326) SQL Client should not create table directory structure

2022-12-07 Thread Alex Sorokoumov (Jira)
Alex Sorokoumov created FLINK-30326: --- Summary: SQL Client should not create table directory structure Key: FLINK-30326 URL: https://issues.apache.org/jira/browse/FLINK-30326 Project: Flink

[jira] [Commented] (FLINK-28766) UnalignedCheckpointStressITCase.runStressTest failed with NoSuchFileException

2022-12-07 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644310#comment-17644310 ] Matthias Pohl commented on FLINK-28766: --- Cool, thanks for approving the PR. Here's the summary of

[jira] [Resolved] (FLINK-28766) UnalignedCheckpointStressITCase.runStressTest failed with NoSuchFileException

2022-12-07 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-28766. --- Resolution: Fixed > UnalignedCheckpointStressITCase.runStressTest failed with

[jira] [Updated] (FLINK-28766) UnalignedCheckpointStressITCase.runStressTest failed with NoSuchFileException

2022-12-07 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-28766: -- Fix Version/s: 1.16.1 > UnalignedCheckpointStressITCase.runStressTest failed with

[GitHub] [flink] XComp merged pull request #21456: [BP-1.16][FLINK-28766][tests] Safe iterate over checkpoint files in order to avoid exception during parallel savepoint deletion

2022-12-07 Thread GitBox
XComp merged PR #21456: URL: https://github.com/apache/flink/pull/21456 -- 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] [Commented] (FLINK-30313) Flink Kubernetes Operator seems to rely on 1.15 k8s HA code but 1.16 config code

2022-12-07 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644308#comment-17644308 ] Matthias Pohl commented on FLINK-30313: --- Ok, thanks for clarification. I couldn't find any hints

[jira] [Comment Edited] (FLINK-30313) Flink Kubernetes Operator seems to rely on 1.15 k8s HA code but 1.16 config code

2022-12-07 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644308#comment-17644308 ] Matthias Pohl edited comment on FLINK-30313 at 12/7/22 12:24 PM: - Ok,

[jira] [Updated] (FLINK-30313) Flink Kubernetes Operator seems to rely on 1.15 k8s HA code but 1.16 config code

2022-12-07 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30313: --- Priority: Critical (was: Major) > Flink Kubernetes Operator seems to rely on 1.15 k8s HA code but

[jira] [Updated] (FLINK-30313) Flink Kubernetes Operator seems to rely on 1.15 k8s HA code but 1.16 config code

2022-12-07 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30313: --- Fix Version/s: kubernetes-operator-1.3.0 > Flink Kubernetes Operator seems to rely on 1.15 k8s HA

[jira] [Commented] (FLINK-30313) Flink Kubernetes Operator seems to rely on 1.15 k8s HA code but 1.16 config code

2022-12-07 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644306#comment-17644306 ] Gyula Fora commented on FLINK-30313: [~mapohl] coild you reproduce this locally? maybe you could do

[jira] [Commented] (FLINK-30313) Flink Kubernetes Operator seems to rely on 1.15 k8s HA code but 1.16 config code

2022-12-07 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644302#comment-17644302 ] Gyula Fora commented on FLINK-30313: At this point operator should not contain any 1.16 dependencies

[jira] [Commented] (FLINK-30295) Develop MariaDbCatalog to connect Flink with MariaDb tables and ecosystem

2022-12-07 Thread Samrat Deb (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644300#comment-17644300 ] Samrat Deb commented on FLINK-30295: i will like to work on this.  > Develop MariaDbCatalog to

[GitHub] [flink] yuzelin commented on pull request #21133: [FLINK-29732][sql-gateway] support configuring session with SQL statement.

2022-12-07 Thread GitBox
yuzelin commented on PR #21133: URL: https://github.com/apache/flink/pull/21133#issuecomment-1340844259 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

[GitHub] [flink] yuzelin commented on pull request #21133: [FLINK-29732][sql-gateway] support configuring session with SQL statement.

2022-12-07 Thread GitBox
yuzelin commented on PR #21133: URL: https://github.com/apache/flink/pull/21133#issuecomment-1340843902 > @yuzelin I add a commit to imporve codes. Please cc LGTM. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] czy006 commented on pull request #21448: [FLINK-30116][rest] Don't Show Env Vars in Web UI

2022-12-07 Thread GitBox
czy006 commented on PR #21448: URL: https://github.com/apache/flink/pull/21448#issuecomment-1340841170 Sorry, I am correcting now -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[jira] [Updated] (FLINK-19716) Unable to use Assume Role with EFO record publisher

2022-12-07 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-19716: -- Summary: Unable to use Assume Role with EFO record publisher (was: [Kinesis][EFO] Unable to

[GitHub] [flink] godfreyhe commented on a diff in pull request #21219: [FLINK-29849][table-planner] Fix event time temporal join on an upsert source may produce incorrect execution plan

2022-12-07 Thread GitBox
godfreyhe commented on code in PR #21219: URL: https://github.com/apache/flink/pull/21219#discussion_r1042030876 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/stream/sql/join/TemporalJoinTest.scala: ## @@ -570,6 +585,52 @@ class

[GitHub] [flink] godfreyhe commented on a diff in pull request #21219: [FLINK-29849][table-planner] Fix event time temporal join on an upsert source may produce incorrect execution plan

2022-12-07 Thread GitBox
godfreyhe commented on code in PR #21219: URL: https://github.com/apache/flink/pull/21219#discussion_r1042030143 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/nodes/logical/FlinkLogicalTableSourceScan.scala: ## @@ -46,20 +46,38 @@ class

[jira] [Updated] (FLINK-30323) Add statistics and support table statistics in table store

2022-12-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30323: --- Labels: pull-request-available (was: ) > Add statistics and support table statistics in

[GitHub] [flink-table-store] zjureel opened a new pull request, #426: [FLINK-30323] Support table statistics in table store

2022-12-07 Thread GitBox
zjureel opened a new pull request, #426: URL: https://github.com/apache/flink-table-store/pull/426 Support table statistics in table store -- 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-30325) the column lost comments, also find some issue ,but that commit is not mr. i have some diff solution

2022-12-07 Thread blackpighe (Jira)
blackpighe created FLINK-30325: -- Summary: the column lost comments, also find some issue ,but that commit is not mr. i have some diff solution Key: FLINK-30325 URL: https://issues.apache.org/jira/browse/FLINK-30325

[jira] [Created] (FLINK-30324) Support column/partition statistics in table store

2022-12-07 Thread Shammon (Jira)
Shammon created FLINK-30324: --- Summary: Support column/partition statistics in table store Key: FLINK-30324 URL: https://issues.apache.org/jira/browse/FLINK-30324 Project: Flink Issue Type:

[jira] [Created] (FLINK-30323) Add statistics and support table statistics in table store

2022-12-07 Thread Shammon (Jira)
Shammon created FLINK-30323: --- Summary: Add statistics and support table statistics in table store Key: FLINK-30323 URL: https://issues.apache.org/jira/browse/FLINK-30323 Project: Flink Issue Type:

[jira] [Created] (FLINK-30322) Support table/column/partition statistics in table store

2022-12-07 Thread Shammon (Jira)
Shammon created FLINK-30322: --- Summary: Support table/column/partition statistics in table store Key: FLINK-30322 URL: https://issues.apache.org/jira/browse/FLINK-30322 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-30321) Upgrade ZLIB of FRocksDB to 1.2.13

2022-12-07 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei reassigned FLINK-30321: -- Assignee: Yanfei Lei > Upgrade ZLIB of FRocksDB to 1.2.13 >

  1   2   >