[jira] [Commented] (FLINK-30245) NPE thrown when filtering decimal(18, 4) values after calling DecimalDataUtils.subtract method

2022-12-05 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17643704#comment-17643704 ] Jark Wu commented on FLINK-30245: - [~zhongwei] could you open PRs for release-1.16 and release-1.15

[jira] [Closed] (FLINK-30245) NPE thrown when filtering decimal(18, 4) values after calling DecimalDataUtils.subtract method

2022-12-05 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-30245. --- Fix Version/s: 1.17.0 Assignee: Wei Zhong Resolution: Fixed Fixed in - master:

[GitHub] [flink] wuchong merged pull request #21429: [FLINK-30245][table-runtime] Fix the NPE thrown when filtering decimal(18, x) values after calling DecimalDataUtils.subtract method.

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

[jira] [Closed] (FLINK-30294) Change table property key 'log.scan' to 'startup.mode' and add a default startup mode in Table Store

2022-12-05 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-30294. --- Resolution: Fixed master: dadd735d362d355d60b737bf2c9669cb2fc880f6 > Change table property key

[GitHub] [flink-table-store] tsreaper merged pull request #422: [FLINK-30294] Change table property key 'log.scan' to 'scan.mode' and add a default startup mode in Table Store

2022-12-05 Thread GitBox
tsreaper merged PR #422: URL: https://github.com/apache/flink-table-store/pull/422 -- 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 #21458: [FLINK-28513][hotfix] stream.sync is not supported for all fileformats

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

[jira] [Updated] (FLINK-28513) Flink Table API CSV streaming sink throws SerializedThrowable exception

2022-12-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28513: --- Labels: pull-request-available (was: ) > Flink Table API CSV streaming sink throws

[GitHub] [flink] Samrat002 opened a new pull request, #21458: [FLINK-28513][hotfix] stream.sync is not supported for all fileformats

2022-12-05 Thread GitBox
Samrat002 opened a new pull request, #21458: URL: https://github.com/apache/flink/pull/21458 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them

[GitHub] [flink-kubernetes-operator] gaborgsomogyi commented on a diff in pull request #472: [hotfix][FLINK-30307] Turn off e2e test error check temporarily

2022-12-05 Thread GitBox
gaborgsomogyi commented on code in PR #472: URL: https://github.com/apache/flink-kubernetes-operator/pull/472#discussion_r1040573555 ## e2e-tests/utils.sh: ## @@ -132,6 +132,9 @@ function retry_times() { function check_operator_log_for_errors { echo "Checking for

[jira] [Assigned] (FLINK-30310) Re-enable e2e test error check

2022-12-05 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-30310: - Assignee: Gabor Somogyi > Re-enable e2e test error check >

[jira] [Created] (FLINK-30310) Re-enable e2e test error check

2022-12-05 Thread Gabor Somogyi (Jira)
Gabor Somogyi created FLINK-30310: - Summary: Re-enable e2e test error check Key: FLINK-30310 URL: https://issues.apache.org/jira/browse/FLINK-30310 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-30154) flinkConfiguration in SessionJob is not accepted

2022-12-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30154: --- Labels: pull-request-available (was: ) > flinkConfiguration in SessionJob is not accepted

[GitHub] [flink-kubernetes-operator] gaborgsomogyi opened a new pull request, #473: [FLINK-30154] Allow to set flinkConfiguration in SessionJob

2022-12-05 Thread GitBox
gaborgsomogyi opened a new pull request, #473: URL: https://github.com/apache/flink-kubernetes-operator/pull/473 ## What is the purpose of the change At the moment it's not possible to add any flinkConfiguration in SessionJob which is blocking to submit session jobs. I can imagine

[GitHub] [flink] xintongsong commented on a diff in pull request #21233: [FLINK-29870] [ResourceManager]Split ResourceActions to ResourceAllocator and ResourceEventListener.

2022-12-05 Thread GitBox
xintongsong commented on code in PR #21233: URL: https://github.com/apache/flink/pull/21233#discussion_r1040542541 ## flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/NonSupportedResourceAllocatorImpl.java: ## @@ -18,11 +18,14 @@ package

[jira] [Commented] (FLINK-28558) HistoryServer log retrieval configuration improvement

2022-12-05 Thread JackYan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17643678#comment-17643678 ] JackYan commented on FLINK-28558: - How can I use those two configuations to browse the taskmanagers log

[jira] [Comment Edited] (FLINK-30128) Introduce Azure Data Lake Gen2 APIs in the Hadoop Recoverable path

2022-12-05 Thread ramkrishna.s.vasudevan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17643653#comment-17643653 ] ramkrishna.s.vasudevan edited comment on FLINK-30128 at 12/6/22 4:36 AM:

[jira] [Commented] (FLINK-30128) Introduce Azure Data Lake Gen2 APIs in the Hadoop Recoverable path

2022-12-05 Thread ramkrishna.s.vasudevan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17643653#comment-17643653 ] ramkrishna.s.vasudevan commented on FLINK-30128: Trying to add tests for Azure fs, seems

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

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

[jira] [Updated] (FLINK-30309) Add the ability to supply custom SslContexts for netty client/servers.

2022-12-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30309: --- Labels: pull-request-available (was: ) > Add the ability to supply custom SslContexts for

[GitHub] [flink] steveniemitz opened a new pull request, #21457: [FLINK-30309][runtime] Allow users to supply custom SslContexts

2022-12-05 Thread GitBox
steveniemitz opened a new pull request, #21457: URL: https://github.com/apache/flink/pull/21457 ## What is the purpose of the change This change allows users/operators to override the default SslContext configuration/creation with a custom implementation. For more advanced TLS

[jira] [Created] (FLINK-30309) Add the ability to supply custom SslContexts for netty client/servers.

2022-12-05 Thread Steve Niemitz (Jira)
Steve Niemitz created FLINK-30309: - Summary: Add the ability to supply custom SslContexts for netty client/servers. Key: FLINK-30309 URL: https://issues.apache.org/jira/browse/FLINK-30309 Project:

[GitHub] [flink] reswqa commented on a diff in pull request #21419: [FLINK-30233] Hybrid full result partition should also work with speculative execution

2022-12-05 Thread GitBox
reswqa commented on code in PR #21419: URL: https://github.com/apache/flink/pull/21419#discussion_r1040387708 ## flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/IntermediateResultPartition.java: ## @@ -46,7 +46,7 @@ public class IntermediateResultPartition {

[jira] [Updated] (FLINK-30294) Change table property key 'log.scan' to 'startup.mode' and add a default startup mode in Table Store

2022-12-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30294: --- Labels: pull-request-available (was: ) > Change table property key 'log.scan' to

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #422: [FLINK-30294] Change table property key 'log.scan' to 'startup.mode' and add a default startup mode in Table Store

2022-12-05 Thread GitBox
JingsongLi commented on code in PR #422: URL: https://github.com/apache/flink-table-store/pull/422#discussion_r1040392229 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/CoreOptions.java: ## @@ -327,16 +327,18 @@ public class CoreOptions implements

[GitHub] [flink] reswqa commented on a diff in pull request #21419: [FLINK-30233] Hybrid full result partition should also work with speculative execution

2022-12-05 Thread GitBox
reswqa commented on code in PR #21419: URL: https://github.com/apache/flink/pull/21419#discussion_r1040387708 ## flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/IntermediateResultPartition.java: ## @@ -46,7 +46,7 @@ public class IntermediateResultPartition {

[GitHub] [flink] xintongsong commented on a diff in pull request #21419: [FLINK-30233] Hybrid full result partition should also work with speculative execution

2022-12-05 Thread GitBox
xintongsong commented on code in PR #21419: URL: https://github.com/apache/flink/pull/21419#discussion_r1040349304 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsMemoryDataManager.java: ## @@ -181,18 +188,33 @@ public HsDataView

[jira] [Closed] (FLINK-30263) Introduce schemas meta table

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

[GitHub] [flink-table-store] JingsongLi merged pull request #414: [FLINK-30263] Introduce schemas table in table store

2022-12-05 Thread GitBox
JingsongLi merged PR #414: URL: https://github.com/apache/flink-table-store/pull/414 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Closed] (FLINK-30273) Introduce RecordReaderUtils.transform to transform RecordReader

2022-12-05 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30273. Resolution: Fixed master: 7a1eeae236f39eeaccde76e46fcca6ac6f9d9469 > Introduce

[jira] [Closed] (FLINK-30271) Introduce Table.copy from dynamic options

2022-12-05 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30271. Resolution: Fixed master: 925186e0904b1eec8d571168ab96706344201211 > Introduce Table.copy from

[GitHub] [flink-table-store] JingsongLi merged pull request #416: [FLINK-30271] Introduce Table.copy from dynamic options

2022-12-05 Thread GitBox
JingsongLi merged PR #416: URL: https://github.com/apache/flink-table-store/pull/416 -- 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] JingsongLi merged pull request #418: [FLINK-30273] Introduce RecordReaderUtils.transform to transform RecordReader

2022-12-05 Thread GitBox
JingsongLi merged PR #418: URL: https://github.com/apache/flink-table-store/pull/418 -- 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] JingsongLi merged pull request #420: [FLINK-30288] Introduce FunctionVisitor

2022-12-05 Thread GitBox
JingsongLi merged PR #420: URL: https://github.com/apache/flink-table-store/pull/420 -- 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-30308) ClassCastException: class java.io.ObjectStreamClass$Caches$1 cannot be cast to class java.util.Map is showing in the logging when the job shutdown

2022-12-05 Thread Dian Fu (Jira)
Dian Fu created FLINK-30308: --- Summary: ClassCastException: class java.io.ObjectStreamClass$Caches$1 cannot be cast to class java.util.Map is showing in the logging when the job shutdown Key: FLINK-30308 URL:

[GitHub] [flink] LadyForest commented on pull request #21452: [FLINK-30282] Fix Logical type ROW lost inner field's nullability after converting to RelDataType

2022-12-05 Thread GitBox
LadyForest commented on PR #21452: URL: https://github.com/apache/flink/pull/21452#issuecomment-1338630142 @fsk119 would you spare some time to take a look? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] FlechazoW commented on pull request #21454: [Improve] Use 'isEmpty()' replace '<= 0'.

2022-12-05 Thread GitBox
FlechazoW commented on PR #21454: URL: https://github.com/apache/flink/pull/21454#issuecomment-1338613804 @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] FlechazoW closed pull request #21454: [Improve] Use 'isEmpty()' replace '<= 0'.

2022-12-05 Thread GitBox
FlechazoW closed pull request #21454: [Improve] Use 'isEmpty()' replace '<= 0'. URL: https://github.com/apache/flink/pull/21454 -- 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-kubernetes-operator] tedhtchang commented on pull request #458: [FLINK-27852] Add OLM bundle generator

2022-12-05 Thread GitBox
tedhtchang commented on PR #458: URL: https://github.com/apache/flink-kubernetes-operator/pull/458#issuecomment-1338582538 Hi @morhidi Could you test on a m1 mac again. Thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink-table-store] zjureel closed pull request #421: [FLINK-30293] Add static snapshot enumerator

2022-12-05 Thread GitBox
zjureel closed pull request #421: [FLINK-30293] Add static snapshot enumerator URL: https://github.com/apache/flink-table-store/pull/421 -- 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-table-store] zjureel commented on pull request #421: [FLINK-30293] Add static snapshot enumerator

2022-12-05 Thread GitBox
zjureel commented on PR #421: URL: https://github.com/apache/flink-table-store/pull/421#issuecomment-1338520955 Hi @tsreaper I close this PR according to our discussion -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink-kubernetes-operator] morhidi merged pull request #445: [FLINK-29939]Add metrics for Kubernetes Client Response 5xx count and…

2022-12-05 Thread GitBox
morhidi merged PR #445: URL: https://github.com/apache/flink-kubernetes-operator/pull/445 -- 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] lincoln-lil commented on pull request #21219: [FLINK-29849][table-planner] Fix event time temporal join on an upsert source may produce incorrect execution plan

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

[jira] [Commented] (FLINK-30305) Operator deletes HA metadata during stateful upgrade, preventing potential manual rollback

2022-12-05 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17643615#comment-17643615 ] Gyula Fora commented on FLINK-30305: When you execute stop with savepoint operation in Flink, the

[jira] [Updated] (FLINK-30288) Use visitor to convert predicate for orc

2022-12-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30288: --- Labels: pull-request-available (was: ) > Use visitor to convert predicate for orc >

[GitHub] [flink-table-store] zjureel commented on pull request #420: [FLINK-30288] Introduce FunctionVisitor

2022-12-05 Thread GitBox
zjureel commented on PR #420: URL: https://github.com/apache/flink-table-store/pull/420#issuecomment-1338498712 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 comment. To

[GitHub] [flink-table-store] zjureel commented on pull request #419: [FLINK-30288] Use PredicateVisitor to convert predicate for orc

2022-12-05 Thread GitBox
zjureel commented on PR #419: URL: https://github.com/apache/flink-table-store/pull/419#issuecomment-1338498509 > Nice, I think it's better to implement orc visitor here on `FunctionVisitor` -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink-table-store] zjureel commented on pull request #416: [FLINK-30271] Introduce Table.copy from dynamic options

2022-12-05 Thread GitBox
zjureel commented on PR #416: URL: https://github.com/apache/flink-table-store/pull/416#issuecomment-1338483239  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 comment. To

[GitHub] [flink-table-store] zjureel commented on pull request #418: [FLINK-30273] Introduce RecordReaderUtils.transform to transform RecordReader

2022-12-05 Thread GitBox
zjureel commented on PR #418: URL: https://github.com/apache/flink-table-store/pull/418#issuecomment-1338482009 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 comment. To

[jira] [Commented] (FLINK-30305) Operator deletes HA metadata during stateful upgrade, preventing potential manual rollback

2022-12-05 Thread Alexis Sarda-Espinosa (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17643599#comment-17643599 ] Alexis Sarda-Espinosa commented on FLINK-30305: --- I briefly looked through the code on the

[GitHub] [flink-kubernetes-operator] usamj commented on a diff in pull request #468: [FLINK-30287] Delete job manager deployment first when cleaning up standalone cluster

2022-12-05 Thread GitBox
usamj commented on code in PR #468: URL: https://github.com/apache/flink-kubernetes-operator/pull/468#discussion_r1040209873 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/StandaloneFlinkService.java: ## @@ -134,20 +134,20 @@ protected

[GitHub] [flink-kubernetes-operator] usamj commented on pull request #468: [FLINK-30287] Delete job manager deployment first when cleaning up standalone cluster

2022-12-05 Thread GitBox
usamj commented on PR #468: URL: https://github.com/apache/flink-kubernetes-operator/pull/468#issuecomment-1338337905 This seems like a reasonable change -- 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-kubernetes-operator] gyfora commented on a diff in pull request #468: [FLINK-30287] Delete job manager deployment first when cleaning up standalone cluster

2022-12-05 Thread GitBox
gyfora commented on code in PR #468: URL: https://github.com/apache/flink-kubernetes-operator/pull/468#discussion_r1040194289 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/StandaloneFlinkService.java: ## @@ -134,20 +134,20 @@ protected

[jira] [Closed] (FLINK-30266) Recovery reconciliation loop fails if no checkpoint has been created yet

2022-12-05 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-30266. -- Resolution: Fixed Merged to main 72ad3639e60fbf27dd408dabbe69f46d69ff52f9 > Recovery reconciliation

[jira] [Updated] (FLINK-30304) Possible Deadlock in Kinesis/Firehose/DynamoDB Connector

2022-12-05 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-30304: -- Attachment: sink-deadlock-1.png > Possible Deadlock in Kinesis/Firehose/DynamoDB Connector >

[jira] [Updated] (FLINK-30304) Possible Deadlock in Kinesis/Firehose/DynamoDB Connector

2022-12-05 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-30304: -- Attachment: (was: sink-deadlock-1.png) > Possible Deadlock in Kinesis/Firehose/DynamoDB

[jira] [Updated] (FLINK-30304) Possible Deadlock in Kinesis/Firehose/DynamoDB Connector

2022-12-05 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-30304: -- Description: AWS Sinks based on Async Sink can enter a deadlock situation if the AWS async

[jira] [Updated] (FLINK-30304) Possible Deadlock in Kinesis/Firehose/DynamoDB Connector

2022-12-05 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-30304: -- Description: AWS Sinks based on Async Sink can enter a deadlock situation if the AWS async

[jira] [Updated] (FLINK-30304) Possible Deadlock in Kinesis/Firehose/DynamoDB Connector

2022-12-05 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-30304: -- Attachment: sink-deadlock.png > Possible Deadlock in Kinesis/Firehose/DynamoDB Connector >

[jira] [Commented] (FLINK-30304) Possible Deadlock in Kinesis/Firehose/DynamoDB Connector

2022-12-05 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17643583#comment-17643583 ] Danny Cranmer commented on FLINK-30304: --- I do not think we can do anything about this besides wait

[GitHub] [flink-kubernetes-operator] jiangzho commented on pull request #445: [FLINK-29939]Add metrics for Kubernetes Client Response 5xx count and…

2022-12-05 Thread GitBox
jiangzho commented on PR #445: URL: https://github.com/apache/flink-kubernetes-operator/pull/445#issuecomment-1338275577 @morhidi - IMO this includes all the entitled needs . Thx foe checking in. -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-30305) Operator deletes HA metadata during stateful upgrade, preventing potential manual rollback

2022-12-05 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17643573#comment-17643573 ] Gyula Fora commented on FLINK-30305: I recommend checking the getAvailableUpgradeMode method of the

[jira] [Commented] (FLINK-30305) Operator deletes HA metadata during stateful upgrade, preventing potential manual rollback

2022-12-05 Thread Alexis Sarda-Espinosa (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17643566#comment-17643566 ] Alexis Sarda-Espinosa commented on FLINK-30305: --- I understand why this is complex for all

[jira] [Commented] (FLINK-29940) ExecutionGraph logs job state change at ERROR level when job fails

2022-12-05 Thread Mingliang Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17643536#comment-17643536 ] Mingliang Liu commented on FLINK-29940: --- Yeah, WARN will be much better than INFO. I can update

[jira] [Updated] (FLINK-30304) Possible Deadlock in Kinesis/Firehose/DynamoDB Connector

2022-12-05 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-30304: -- Description: AWS Sinks based on Async Sink can enter a deadlock situation if the AWS async

[GitHub] [flink-kubernetes-operator] morhidi commented on pull request #468: [FLINK-30287] Delete job manager deployment first when cleaning up standalone cluster

2022-12-05 Thread GitBox
morhidi commented on PR #468: URL: https://github.com/apache/flink-kubernetes-operator/pull/468#issuecomment-1337983383 cc @usamj WDYT? -- 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

[GitHub] [flink-kubernetes-operator] morhidi commented on pull request #471: [FLINK-30151] Remove AuditUtils from error log check whitelist

2022-12-05 Thread GitBox
morhidi commented on PR #471: URL: https://github.com/apache/flink-kubernetes-operator/pull/471#issuecomment-1337974711 +1 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] [Commented] (FLINK-30305) Operator deletes HA metadata during stateful upgrade, preventing potential manual rollback

2022-12-05 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17643495#comment-17643495 ] Gyula Fora commented on FLINK-30305: We haven’t yet found a completely reliable way to detect if the

[jira] [Comment Edited] (FLINK-30305) Operator deletes HA metadata during stateful upgrade, preventing potential manual rollback

2022-12-05 Thread Alexis Sarda-Espinosa (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17643494#comment-17643494 ] Alexis Sarda-Espinosa edited comment on FLINK-30305 at 12/5/22 6:17 PM:

[jira] [Commented] (FLINK-30305) Operator deletes HA metadata during stateful upgrade, preventing potential manual rollback

2022-12-05 Thread Alexis Sarda-Espinosa (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17643494#comment-17643494 ] Alexis Sarda-Espinosa commented on FLINK-30305: --- Since I saw "Deleting JobManager

[jira] [Commented] (FLINK-30305) Operator deletes HA metadata during stateful upgrade, preventing potential manual rollback

2022-12-05 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17643489#comment-17643489 ] Gyula Fora commented on FLINK-30305: You could try doing the same flow but originally using the

[jira] [Commented] (FLINK-30305) Operator deletes HA metadata during stateful upgrade, preventing potential manual rollback

2022-12-05 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17643488#comment-17643488 ] Gyula Fora commented on FLINK-30305: I think there are a mix of things happening here. And it may

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

2022-12-05 Thread Alexis Sarda-Espinosa (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17643485#comment-17643485 ] Alexis Sarda-Espinosa edited comment on FLINK-30306 at 12/5/22 6:05 PM:

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

2022-12-05 Thread Alexis Sarda-Espinosa (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17643485#comment-17643485 ] Alexis Sarda-Espinosa commented on FLINK-30306: --- In my case, there are some passwords that

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

2022-12-05 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17643479#comment-17643479 ] Gyula Fora commented on FLINK-30306: Why would the spec contain injected sensitive info? Wouldn’t

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

2022-12-05 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17643478#comment-17643478 ] Gyula Fora commented on FLINK-30306: Cc @morhidi  > Audit utils can expose potentially sensitive

[GitHub] [flink-kubernetes-operator] mbalassi commented on a diff in pull request #472: [hotfix][FLINK-30307] Turn off e2e test error check temporarily

2022-12-05 Thread GitBox
mbalassi commented on code in PR #472: URL: https://github.com/apache/flink-kubernetes-operator/pull/472#discussion_r1039880108 ## e2e-tests/utils.sh: ## @@ -132,6 +132,9 @@ function retry_times() { function check_operator_log_for_errors { echo "Checking for operator log

[GitHub] [flink] zentol commented on pull request #21438: [FLINK-29420][build] Upgrade Zookeeper to 3.7.1

2022-12-05 Thread GitBox
zentol commented on PR #21438: URL: https://github.com/apache/flink/pull/21438#issuecomment-1337756213 @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-kubernetes-operator] morhidi commented on pull request #445: [FLINK-29939]Add metrics for Kubernetes Client Response 5xx count and…

2022-12-05 Thread GitBox
morhidi commented on PR #445: URL: https://github.com/apache/flink-kubernetes-operator/pull/445#issuecomment-1337732982 Thanks @jiangzho this PR appears to be complete know, is there anything else you want to add to it? -- This is an automated message from the Apache Git Service. To

[GitHub] [flink-kubernetes-operator] pvary closed pull request #470: Just for testing

2022-12-05 Thread GitBox
pvary closed pull request #470: Just for testing URL: https://github.com/apache/flink-kubernetes-operator/pull/470 -- 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] [Assigned] (FLINK-30307) Turn off e2e test error check temporarily

2022-12-05 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-30307: - Assignee: Gabor Somogyi > Turn off e2e test error check temporarily >

[GitHub] [flink] 1996fanrui commented on pull request #21368: [FLINK-30165][runtime][JUnit5 Migration] Migrate unaligned checkpoint related tests under flink-runtime module to junit5

2022-12-05 Thread GitBox
1996fanrui commented on PR #21368: URL: https://github.com/apache/flink/pull/21368#issuecomment-1337695133 @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] 1996fanrui commented on pull request #21368: [FLINK-30165][runtime][JUnit5 Migration] Migrate unaligned checkpoint related tests under flink-runtime module to junit5

2022-12-05 Thread GitBox
1996fanrui commented on PR #21368: URL: https://github.com/apache/flink/pull/21368#issuecomment-1337693383 > Thanks for addressing my comments. The PR looks good.  > > @1996fanrui just as hint for future PRs. It helps to add new commits while being in the review process and only do

[jira] [Updated] (FLINK-30307) Turn off e2e test error check temporarily

2022-12-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30307: --- Labels: pull-request-available (was: ) > Turn off e2e test error check temporarily >

[GitHub] [flink-kubernetes-operator] gaborgsomogyi commented on pull request #472: [hotfix][FLINK-30307] Turn off e2e test error check temporarily

2022-12-05 Thread GitBox
gaborgsomogyi commented on PR #472: URL: https://github.com/apache/flink-kubernetes-operator/pull/472#issuecomment-1337685674 cc @morhidi -- 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

[GitHub] [flink-kubernetes-operator] gaborgsomogyi opened a new pull request, #472: [hotfix][FLINK-30307] Turn off e2e test error check temporarily

2022-12-05 Thread GitBox
gaborgsomogyi opened a new pull request, #472: URL: https://github.com/apache/flink-kubernetes-operator/pull/472 ## What is the purpose of the change E22 tests are failing because several errors appear in the operator log. We've sorted out lot of issues but we're turning it off for

[jira] [Updated] (FLINK-30305) Operator deletes HA metadata during stateful upgrade, preventing potential manual rollback

2022-12-05 Thread Alexis Sarda-Espinosa (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Sarda-Espinosa updated FLINK-30305: -- Description: I was testing resiliency of jobs with Kubernetes-based HA

[jira] [Created] (FLINK-30307) Turn off e2e test error check temporarily

2022-12-05 Thread Gabor Somogyi (Jira)
Gabor Somogyi created FLINK-30307: - Summary: Turn off e2e test error check temporarily Key: FLINK-30307 URL: https://issues.apache.org/jira/browse/FLINK-30307 Project: Flink Issue Type: Bug

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

2022-12-05 Thread Alexis Sarda-Espinosa (Jira)
Alexis Sarda-Espinosa created FLINK-30306: - Summary: Audit utils can expose potentially sensitive information Key: FLINK-30306 URL: https://issues.apache.org/jira/browse/FLINK-30306 Project:

[jira] [Created] (FLINK-30305) Operator deletes HA metadata during stateful upgrade, preventing potential manual rollback

2022-12-05 Thread Alexis Sarda-Espinosa (Jira)
Alexis Sarda-Espinosa created FLINK-30305: - Summary: Operator deletes HA metadata during stateful upgrade, preventing potential manual rollback Key: FLINK-30305 URL:

[jira] [Updated] (FLINK-28875) Add FlinkSessionJobControllerTest

2022-12-05 Thread Matyas Orhidi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matyas Orhidi updated FLINK-28875: -- Fix Version/s: kubernetes-operator-1.4.0 (was:

[jira] [Updated] (FLINK-30199) Add a script to run Kubernetes Operator e2e tests manually

2022-12-05 Thread Matyas Orhidi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matyas Orhidi updated FLINK-30199: -- Fix Version/s: kubernetes-operator-1.4.0 (was:

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

2022-12-05 Thread Matyas Orhidi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17643439#comment-17643439 ] Matyas Orhidi commented on FLINK-30046: --- [~mbalassi] are we keeping this in 1.3? > Cannot use

[jira] [Commented] (FLINK-30280) Default operator logging configuration is broken

2022-12-05 Thread Matyas Orhidi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17643438#comment-17643438 ] Matyas Orhidi commented on FLINK-30280: --- [~mxm] are you planning to change anything in the current

[jira] [Updated] (FLINK-30304) Possible Deadlock in Kinesis/Firehose/DynamoDB Connector

2022-12-05 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-30304: -- Affects Version/s: aws-connector-3.0.0 1.15.3

[jira] [Assigned] (FLINK-30304) Possible Deadlock in Kinesis/Firehose/DynamoDB Connector

2022-12-05 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-30304: - Assignee: Danny Cranmer > Possible Deadlock in Kinesis/Firehose/DynamoDB Connector >

[jira] [Updated] (FLINK-28875) Add FlinkSessionJobControllerTest

2022-12-05 Thread Matyas Orhidi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matyas Orhidi updated FLINK-28875: -- Priority: Major (was: Critical) > Add FlinkSessionJobControllerTest >

[jira] [Updated] (FLINK-30304) Possible Deadlock in Kinesis/Firehose/DynamoDB Connector

2022-12-05 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-30304: -- Component/s: Connectors / DynamoDB Connectors / Firehose

[jira] [Updated] (FLINK-30304) Possible Deadlock in Kinesis/Firehose/DynamoDB Connector

2022-12-05 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-30304: -- Issue Type: Bug (was: Technical Debt) > Possible Deadlock in Kinesis/Firehose/DynamoDB

[jira] [Commented] (FLINK-30266) Recovery reconciliation loop fails if no checkpoint has been created yet

2022-12-05 Thread Matyas Orhidi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17643435#comment-17643435 ] Matyas Orhidi commented on FLINK-30266: --- [~gyfora], can this be closed? > Recovery reconciliation

[jira] [Updated] (FLINK-30304) Possible Deadlock in Kinesis/Firehose/DynamoDB Connector

2022-12-05 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-30304: -- Fix Version/s: 1.17.0 1.16.1 1.15.4

  1   2   3   >