[jira] [Commented] (FLINK-29698) Job Manager fails with FileAlreadyExistsException if java.io.tmpdir points to a symbolic link

2022-10-19 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620794#comment-17620794 ] Weijie Guo commented on FLINK-29698: Yes, I agree with you that this is a serious pr

[jira] [Commented] (FLINK-29698) Job Manager fails with FileAlreadyExistsException if java.io.tmpdir points to a symbolic link

2022-10-19 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620787#comment-17620787 ] Caizhi Weng commented on FLINK-29698: - [~Weijie Guo] Yes it is, sorry for the duplic

[jira] [Commented] (FLINK-26402) MinioTestContainerTest.testS3EndpointNeedsToBeSpecifiedBeforeInitializingFileSyste failed due to Container startup failed

2022-10-19 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620783#comment-17620783 ] Xingbo Huang commented on FLINK-26402: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-29698) Job Manager fails with FileAlreadyExistsException if java.io.tmpdir points to a symbolic link

2022-10-19 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620782#comment-17620782 ] Weijie Guo commented on FLINK-29698: Maybe this is duplicated with FLINK-28102 > Jo

[jira] [Commented] (FLINK-29629) FlameGraph is empty for Legacy Source Threads

2022-10-19 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620781#comment-17620781 ] Zhu Zhu commented on FLINK-29629: - [~pvary] Flink is turning to [new Sources|https://gi

[jira] [Closed] (FLINK-28324) JUnit5 Migration] Module: flink-sql-client

2022-10-19 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28324. --- Resolution: Done master: 7f639a8ce4741f072621ac87976aa2589e9cfae0 > JUnit5 Migration] Module: flink-sql-cli

[GitHub] [flink] zhuzhurk closed pull request #20168: [FLINK-28324][flink-sql-client][JUnit5 Migration] Module: flink-sql-client

2022-10-19 Thread GitBox
zhuzhurk closed pull request #20168: [FLINK-28324][flink-sql-client][JUnit5 Migration] Module: flink-sql-client URL: https://github.com/apache/flink/pull/20168 -- 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

[jira] [Updated] (FLINK-28324) JUnit5 Migration] Module: flink-sql-client

2022-10-19 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-28324: Fix Version/s: 1.17.0 > JUnit5 Migration] Module: flink-sql-client > -

[GitHub] [flink] zhuzhurk commented on pull request #20168: [FLINK-28324][flink-sql-client][JUnit5 Migration] Module: flink-sql-client

2022-10-19 Thread GitBox
zhuzhurk commented on PR #20168: URL: https://github.com/apache/flink/pull/20168#issuecomment-1284980784 Thanks for working on this! @zhoulii And thanks for the thorough review! @snuyanzin Merging. -- This is an automated message from the Apache Git Service. To respond to the messa

[jira] [Commented] (FLINK-29615) MetricStore does not remove metrics of nonexistent subtasks when adaptive scheduler lowers job parallelism

2022-10-19 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620760#comment-17620760 ] Zhanghao Chen commented on FLINK-29615: --- Hi, [~xtsong]. Could you help take a look

[jira] [Updated] (FLINK-29615) MetricStore does not remove metrics of nonexistent subtasks when adaptive scheduler lowers job parallelism

2022-10-19 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-29615: -- Description: We are exploring autoscaling Flink with Reactive mode using metrics from Flink R

[jira] [Updated] (FLINK-29615) MetricStore does not remove metrics of nonexistent subtasks when adaptive scheduler lowers job parallelism

2022-10-19 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-29615: -- Description: We are exploring autoscaling Flink with Reactive mode using metrics from Flink R

[jira] [Comment Edited] (FLINK-29638) Update jackson bom because of CVE-2022-42003

2022-10-19 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620744#comment-17620744 ] Matthias Pohl edited comment on FLINK-29638 at 10/20/22 5:22 AM: -

[jira] [Comment Edited] (FLINK-29638) Update jackson bom because of CVE-2022-42003

2022-10-19 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620744#comment-17620744 ] Matthias Pohl edited comment on FLINK-29638 at 10/20/22 5:19 AM: -

[jira] [Commented] (FLINK-29638) Update jackson bom because of CVE-2022-42003

2022-10-19 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620744#comment-17620744 ] Matthias Pohl commented on FLINK-29638: --- [~hxbks2ks] I marked it for 1.16.1. But f

[jira] [Commented] (FLINK-29696) [Doc] Operator helm install command points to wrong repo

2022-10-19 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620743#comment-17620743 ] Gyula Fora commented on FLINK-29696: Those two docs refer to two different ways of i

[GitHub] [flink-table-store] JingsongLi commented on pull request #320: [FLINK-29636] Add micro benchmarks module

2022-10-19 Thread GitBox
JingsongLi commented on PR #320: URL: https://github.com/apache/flink-table-store/pull/320#issuecomment-1284921980 Can you create a separate PR for module refactor? Then this pr is just to introduce micro benchmark. -- This is an automated message from the Apache Git Service. To respon

[jira] [Updated] (FLINK-29685) Add JM info into ExecutionGraph

2022-10-19 Thread LI Mingkun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LI Mingkun updated FLINK-29685: --- Description: h1. Backgroud Web UI didn't show all JM info if enable JM HA now. h1. Example JM will

[jira] [Updated] (FLINK-29698) Job Manager fails with FileAlreadyExistsException if java.io.tmpdir points to a symbolic link

2022-10-19 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-29698: Affects Version/s: 1.17.0 > Job Manager fails with FileAlreadyExistsException if java.io.tmpdir po

[jira] [Created] (FLINK-29698) Job Manager fails with FileAlreadyExistsException if java.io.tmpdir points to a symbolic link

2022-10-19 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-29698: --- Summary: Job Manager fails with FileAlreadyExistsException if java.io.tmpdir points to a symbolic link Key: FLINK-29698 URL: https://issues.apache.org/jira/browse/FLINK-29698

[GitHub] [flink] flinkbot commented on pull request #21123: [hotfix][table] Fix misleading state cleared message in SinkUpsertMaterializer

2022-10-19 Thread GitBox
flinkbot commented on PR #21123: URL: https://github.com/apache/flink/pull/21123#issuecomment-1284898979 ## CI report: * 0ef270ef9b35f0c9555fa222e746088a6c876e45 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink-table-store] tsreaper merged pull request #315: [FLINK-29586] Let write buffer spillable

2022-10-19 Thread GitBox
tsreaper merged PR #315: URL: https://github.com/apache/flink-table-store/pull/315 -- 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...@fl

[GitHub] [flink] kylemeow opened a new pull request, #21123: [hotfix][table] Fix misleading state cleared message in SinkUpsertMaterializer

2022-10-19 Thread GitBox
kylemeow opened a new pull request, #21123: URL: https://github.com/apache/flink/pull/21123 ## What is the purpose of the change When non-deterministic functions (like `UUID()`) or some special metadata fields (like `op_type`) are used in the source or sink fields, the `SinkUpsertMat

[jira] [Closed] (FLINK-29690) listTables in HiveCatalog should only return table store tables

2022-10-19 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29690. Assignee: Nicholas Jiang Resolution: Fixed master: 997682a9507ccf9165e7d2ff4e95aca8c56df113

[GitHub] [flink-table-store] JingsongLi commented on pull request #320: [FLINK-29636] Add micro benchmarks module

2022-10-19 Thread GitBox
JingsongLi commented on PR #320: URL: https://github.com/apache/flink-table-store/pull/320#issuecomment-1284885082 👍🏻 I will 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 above to go to the spec

[GitHub] [flink-table-store] zjureel commented on pull request #305: [FLINK-28256] Move the write and prepareCommit logic of AbstractTableWrite to FileStoreWrite

2022-10-19 Thread GitBox
zjureel commented on PR #305: URL: https://github.com/apache/flink-table-store/pull/305#issuecomment-1284884866 Hi @JingsongLi I have rename `WriteFunction` and rebase the codes from master to fix conflicts -- This is an automated message from the Apache Git Service. To respond to the m

[GitHub] [flink-table-store] JingsongLi merged pull request #322: [FLINK-29690] listTables in HiveCatalog should only return table store tables

2022-10-19 Thread GitBox
JingsongLi merged PR #322: URL: https://github.com/apache/flink-table-store/pull/322 -- 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...@

[jira] [Comment Edited] (FLINK-29577) Disable rocksdb wal when restore from full snapshot

2022-10-19 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620706#comment-17620706 ] Yuan Mei edited comment on FLINK-29577 at 10/20/22 3:51 AM:

[jira] [Created] (FLINK-29697) Flaky test failure KafkaShuffleExactlyOnceITCase.testAssignedToPartitionFailureRecoveryEventTime

2022-10-19 Thread Samrat Deb (Jira)
Samrat Deb created FLINK-29697: -- Summary: Flaky test failure KafkaShuffleExactlyOnceITCase.testAssignedToPartitionFailureRecoveryEventTime Key: FLINK-29697 URL: https://issues.apache.org/jira/browse/FLINK-29697

[jira] [Comment Edited] (FLINK-29577) Disable rocksdb wal when restore from full snapshot

2022-10-19 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620706#comment-17620706 ] Yuan Mei edited comment on FLINK-29577 at 10/20/22 3:48 AM:

[jira] [Commented] (FLINK-29577) Disable rocksdb wal when restore from full snapshot

2022-10-19 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620706#comment-17620706 ] Yuan Mei commented on FLINK-29577: -- [~cailiuyang]  Would you share some performance nu

[GitHub] [flink] Samrat002 commented on pull request #20937: [FLINK-29478][flink-connector/hive] Flink connector hive upgrade to 3.1.3

2022-10-19 Thread GitBox
Samrat002 commented on PR #20937: URL: https://github.com/apache/flink/pull/20937#issuecomment-1284874067 @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-ml] lindong28 commented on a diff in pull request #164: [FLINK-29115] Improve python quickstart document

2022-10-19 Thread GitBox
lindong28 commented on code in PR #164: URL: https://github.com/apache/flink-ml/pull/164#discussion_r1000106258 ## docs/content/docs/try-flink-ml/java/build-your-own-project.md: ## @@ -28,7 +28,7 @@ under the License. This document provides a quick introduction to using Flink

[GitHub] [flink] flinkbot commented on pull request #21122: [FLINK-28889] Hybrid shuffle supports multiple consumer and broadcast optimization

2022-10-19 Thread GitBox
flinkbot commented on PR #21122: URL: https://github.com/apache/flink/pull/21122#issuecomment-1284837792 ## CI report: * 8ec5ea591f2a80d0bbf1be8ea56b18df82b0c11b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] flinkbot commented on pull request #21121: [FLINK-29684] chore: bump runtime web Angular to v14

2022-10-19 Thread GitBox
flinkbot commented on PR #21121: URL: https://github.com/apache/flink/pull/21121#issuecomment-1284833285 ## CI report: * e37c9e8390b811b9c2481012ef93d26e177c228f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-29468) Update jackson-bom to 2.13.4

2022-10-19 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29468: - Fix Version/s: 1.16.0 (was: 1.16.1) > Update jackson-bom to 2.13.4 >

[jira] [Updated] (FLINK-29638) Update jackson bom because of CVE-2022-42003

2022-10-19 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29638: - Fix Version/s: (was: 1.16.1) 1.16.0 > Update jackson bom because of CVE-2

[jira] [Updated] (FLINK-28889) Hybrid shuffle should supports multiple consumer

2022-10-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28889: --- Labels: pull-request-available (was: ) > Hybrid shuffle should supports multiple consumer >

[GitHub] [flink] reswqa opened a new pull request, #21122: [FLINK-28889] Hybrid shuffle supports multiple consumer and broadcast optimization

2022-10-19 Thread GitBox
reswqa opened a new pull request, #21122: URL: https://github.com/apache/flink/pull/21122 ## What is the purpose of the change *Hybrid shuffle does not support multiple consumer for single subpartition data. This will bring some defects, such as the inability to support partition reu

[jira] [Updated] (FLINK-29613) Wrong message size assertion in Pulsar's batch message

2022-10-19 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29613: - Fix Version/s: 1.16.0 (was: 1.16.1) > Wrong message size assertion in Pul

[jira] [Updated] (FLINK-29512) Align SubtaskCommittableManager checkpointId with CheckpointCommittableManagerImpl checkpointId during recovery

2022-10-19 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29512: - Fix Version/s: 1.16.0 (was: 1.16.1) > Align SubtaskCommittableManager che

[jira] [Updated] (FLINK-29509) Set correct subtaskId during recovery of committables

2022-10-19 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29509: - Fix Version/s: 1.16.0 (was: 1.16.1) > Set correct subtaskId during recove

[jira] [Updated] (FLINK-28889) Hybrid shuffle should supports multiple consumer

2022-10-19 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-28889: --- Description: Hybrid shuffle does not support multiple consumer for single subpartition data. This wi

[jira] [Updated] (FLINK-28889) Hybrid shuffle writes multiple copies of broadcast data

2022-10-19 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-28889: --- Description: Hybrid shuffle does not support multiple consumer for single subpartition data. This wi

[jira] [Updated] (FLINK-22243) Reactive Mode parallelism changes are not shown in the job graph visualization in the UI

2022-10-19 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-22243: - Fix Version/s: 1.16.0 (was: 1.16.1) > Reactive Mode parallelism changes a

[jira] [Updated] (FLINK-28889) Hybrid shuffle should supports multiple consumer

2022-10-19 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-28889: --- Summary: Hybrid shuffle should supports multiple consumer (was: Hybrid shuffle writes multiple copi

[jira] [Updated] (FLINK-29504) Jar upload spec should define a schema

2022-10-19 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29504: - Fix Version/s: 1.16.0 (was: 1.16.1) > Jar upload spec should define a sch

[jira] [Updated] (FLINK-29408) HiveCatalogITCase failed with NPE

2022-10-19 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29408: - Fix Version/s: 1.16.0 (was: 1.17.0) (was: 1.16.1)

[jira] [Updated] (FLINK-29503) Add backpressureLevel field without hyphens

2022-10-19 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29503: - Fix Version/s: 1.16.0 (was: 1.16.1) > Add backpressureLevel field without

[jira] [Updated] (FLINK-29395) [Kinesis][EFO] Issue using EFO consumer at timestamp with empty shard

2022-10-19 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29395: - Fix Version/s: 1.16.0 (was: 1.16.1) > [Kinesis][EFO] Issue using EFO cons

[jira] [Updated] (FLINK-29562) JM/SQl gateway OpenAPI specs should have different titles

2022-10-19 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29562: - Fix Version/s: 1.16.0 (was: 1.16.1) > JM/SQl gateway OpenAPI specs should

[jira] [Updated] (FLINK-29483) flink python udf arrow in thread model bug

2022-10-19 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29483: - Fix Version/s: 1.16.0 (was: 1.16.1) > flink python udf arrow in thread mo

[jira] [Updated] (FLINK-29532) Update Pulsar dependency to 2.10.1

2022-10-19 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29532: - Fix Version/s: 1.16.0 (was: 1.16.1) > Update Pulsar dependency to 2.10.1

[jira] [Updated] (FLINK-29500) InitializeOnMaster uses wrong parallelism with AdaptiveScheduler

2022-10-19 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29500: - Fix Version/s: 1.16.0 (was: 1.16.1) > InitializeOnMaster uses wrong paral

[jira] [Updated] (FLINK-26469) Adaptive job shows error in WebUI when not enough resource are available

2022-10-19 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-26469: - Fix Version/s: 1.16.0 (was: 1.16.1) > Adaptive job shows error in WebUI w

[jira] [Updated] (FLINK-29476) Kinesis Connector retry mechanism not applied to EOFException

2022-10-19 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29476: - Fix Version/s: 1.16.0 (was: 1.16.1) > Kinesis Connector retry mechanism n

[jira] [Updated] (FLINK-29552) Fix documentation usage examples for DAYOFYEAR, DAYOFMONTH, and DAYOFWEEK functions

2022-10-19 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29552: - Fix Version/s: 1.16.0 (was: 1.16.1) > Fix documentation usage examples fo

[jira] [Updated] (FLINK-29684) [UI] Upgrade runtime web Angular framework and associated deps to v14

2022-10-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29684: --- Labels: pull-request-available (was: ) > [UI] Upgrade runtime web Angular framework and ass

[GitHub] [flink] yangjunhan opened a new pull request, #21121: [FLINK-29684] chore: bump runtime web Angular to v14

2022-10-19 Thread GitBox
yangjunhan opened a new pull request, #21121: URL: https://github.com/apache/flink/pull/21121 ## What is the purpose of the change Bump FE framework to the latest major version (FLINK-29684). ## Brief change log Update necessary dependencies. ## Verifyi

[jira] [Updated] (FLINK-29646) SQL Gateway should return a simpler error message

2022-10-19 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-29646: -- Fix Version/s: 1.17 (was: 1.16.0) > SQL Gateway should return a simpler

[jira] [Updated] (FLINK-29646) SQL Gateway should return a simpler error message

2022-10-19 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-29646: -- Affects Version/s: 1.17 (was: 1.17.0) > SQL Gateway should return a

[jira] [Updated] (FLINK-29646) SQL Gateway should return a simpler error message

2022-10-19 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-29646: -- Affects Version/s: 1.17.0 (was: 1.16.0) > SQL Gateway should return

[jira] [Updated] (FLINK-29690) listTables in HiveCatalog should only return table store tables

2022-10-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29690: --- Labels: pull-request-available (was: ) > listTables in HiveCatalog should only return table

[jira] [Updated] (FLINK-29558) Use select count(*) from xxx; and get SQL syntax

2022-10-19 Thread Hang HOU (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hang HOU updated FLINK-29558: - Attachment: screenshot-2.png > Use select count(*) from xxx; and get SQL syntax > --

[GitHub] [flink-table-store] SteNicholas opened a new pull request, #322: [FLINK-29690] listTables in HiveCatalog should only return table store tables

2022-10-19 Thread GitBox
SteNicholas opened a new pull request, #322: URL: https://github.com/apache/flink-table-store/pull/322 `listTables` in `HiveCatalog` should only return table store tables, which should filter the Hive tables with input and output format. **The brief change log** - `HiveCatalog#list

[GitHub] [flink] zhoulii commented on pull request #20168: [FLINK-28324][flink-sql-client][JUnit5 Migration] Module: flink-sql-client

2022-10-19 Thread GitBox
zhoulii commented on PR #20168: URL: https://github.com/apache/flink/pull/20168#issuecomment-1284809301 Hi @zhuzhurk, I have rebased the change to the latest master, the ci passed now. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Created] (FLINK-29696) [Doc] Operator helm install command points to wrong repo

2022-10-19 Thread Yufei Zhang (Jira)
Yufei Zhang created FLINK-29696: --- Summary: [Doc] Operator helm install command points to wrong repo Key: FLINK-29696 URL: https://issues.apache.org/jira/browse/FLINK-29696 Project: Flink Issue

[jira] [Commented] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

2022-10-19 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620674#comment-17620674 ] luoyuxia commented on FLINK-23074: -- Not very sure why this changes. [~yuchuanchen] Do y

[GitHub] [flink] czy006 commented on a diff in pull request #21012: [FLINK-29543] Jar Run Rest Handler Support Flink Configuration

2022-10-19 Thread GitBox
czy006 commented on code in PR #21012: URL: https://github.com/apache/flink/pull/21012#discussion_r165071 ## flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/handlers/JarHandlerParameterTest.java: ## @@ -211,6 +218,37 @@ void testProvideJobId() throws Exce

[jira] [Commented] (FLINK-29567) Revert sink output metric names from numRecordsSend back to numRecordsOut

2022-10-19 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620663#comment-17620663 ] Qingsheng Ren commented on FLINK-29567: --- master: d0e855090683920d57922acbddb64c9a9

[jira] [Closed] (FLINK-29567) Revert sink output metric names from numRecordsSend back to numRecordsOut

2022-10-19 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren closed FLINK-29567. - Resolution: Fixed > Revert sink output metric names from numRecordsSend back to numRecordsOut >

[GitHub] [flink] PatrickRen merged pull request #21112: [BP-1.16][FLINK-29567][connector/common] Change numRecordsSend / numBytesSend / numRecordsSendError back to numRecordsOut / numBytesOut / numRec

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

[GitHub] [flink] PatrickRen commented on pull request #21112: [BP-1.16][FLINK-29567][connector/common] Change numRecordsSend / numBytesSend / numRecordsSendError back to numRecordsOut / numBytesOut /

2022-10-19 Thread GitBox
PatrickRen commented on PR #21112: URL: https://github.com/apache/flink/pull/21112#issuecomment-1284759333 CI failed because of an unrelated case. Merging to release-1.16 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] PatrickRen merged pull request #21065: [FLINK-29567][connector/common] Change numRecordsSend / numBytesSend / numRecordsSendError back to numRecordsOut / numBytesOut / numRecordsOutEr

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

[GitHub] [flink] PatrickRen commented on pull request #21065: [FLINK-29567][connector/common] Change numRecordsSend / numBytesSend / numRecordsSendError back to numRecordsOut / numBytesOut / numRecord

2022-10-19 Thread GitBox
PatrickRen commented on PR #21065: URL: https://github.com/apache/flink/pull/21065#issuecomment-1284758289 CI passed on my own Azure pipeline: https://dev.azure.com/renqs/Apache%20Flink/_build/results?buildId=414&view=results -- This is an automated message from the Apache Git Service. To

[GitHub] [flink-kubernetes-operator] morhidi commented on pull request #406: [FLINK-29695] Create a utility to report the status of the last savep…

2022-10-19 Thread GitBox
morhidi commented on PR #406: URL: https://github.com/apache/flink-kubernetes-operator/pull/406#issuecomment-1284752677 @mbalassi @gyfora pls retrigger -- 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

[GitHub] [flink-kubernetes-operator] clarax commented on pull request #406: [FLINK-29695] Create a utility to report the status of the last savep…

2022-10-19 Thread GitBox
clarax commented on PR #406: URL: https://github.com/apache/flink-kubernetes-operator/pull/406#issuecomment-1284745291 Generated the > Triggered CI based on @morhidi's request. @clarax once you will have a PR merged this will proceed automatically. Got it. Thank you. -- Th

[GitHub] [flink] snuyanzin commented on pull request #21103: [hotfix] Remove unused private method LocalExecutorITCase#executeAndVerifySinkResult

2022-10-19 Thread GitBox
snuyanzin commented on PR #21103: URL: https://github.com/apache/flink/pull/21103#issuecomment-1284636642 @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 speci

[GitHub] [flink] ericxiao251 commented on pull request #21077: [FlINK-29248] Add Scala Async Retry Strategies and ResultPredicates Helper Classes

2022-10-19 Thread GitBox
ericxiao251 commented on PR #21077: URL: https://github.com/apache/flink/pull/21077#issuecomment-1284614435 @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

[GitHub] [flink] ericxiao251 commented on pull request #21077: [FlINK-29248] Add Scala Async Retry Strategies and ResultPredicates Helper Classes

2022-10-19 Thread GitBox
ericxiao251 commented on PR #21077: URL: https://github.com/apache/flink/pull/21077#issuecomment-1284605024 @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

[GitHub] [flink] snuyanzin commented on pull request #21103: [hotfix] Remove unused private method LocalExecutorITCase#executeAndVerifySinkResult

2022-10-19 Thread GitBox
snuyanzin commented on PR #21103: URL: https://github.com/apache/flink/pull/21103#issuecomment-1284589583 @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-connector-dynamodb] hlteoh37 commented on a diff in pull request #1: [FLINK-24229][Connectors][DynamoDB] - Add AWS DynamoDB connector

2022-10-19 Thread GitBox
hlteoh37 commented on code in PR #1: URL: https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r19824 ## flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkWriter.java: ## @@ -0,0 +1,181 @@ +/* + * Licensed

[GitHub] [flink] snuyanzin commented on pull request #21103: [hotfix] Remove unused private method LocalExecutorITCase#executeAndVerifySinkResult

2022-10-19 Thread GitBox
snuyanzin commented on PR #21103: URL: https://github.com/apache/flink/pull/21103#issuecomment-1284522060 @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] mbalassi commented on pull request #406: [FLINK-29695] Create a utility to report the status of the last savep…

2022-10-19 Thread GitBox
mbalassi commented on PR #406: URL: https://github.com/apache/flink-kubernetes-operator/pull/406#issuecomment-1284508201 Triggered CI based on @morhidi's request. @clarax once you will have a PR merged this will proceed automatically. -- This is an automated message from the Apache Git S

[GitHub] [flink-kubernetes-operator] morhidi commented on pull request #406: [FLINK-29695] Create a utility to report the status of the last savep…

2022-10-19 Thread GitBox
morhidi commented on PR #406: URL: https://github.com/apache/flink-kubernetes-operator/pull/406#issuecomment-1284498515 or @gyfora @mbalassi when you are online -- 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-kubernetes-operator] morhidi commented on pull request #406: [FLINK-29695] Create a utility to report the status of the last savep…

2022-10-19 Thread GitBox
morhidi commented on PR #406: URL: https://github.com/apache/flink-kubernetes-operator/pull/406#issuecomment-1284498140 Hi @tweise can you please kick the build workflow off on this? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to G

[GitHub] [flink] dannycranmer commented on a diff in pull request #20937: [FLINK-29478][flink-connector/hive] Flink connector hive upgrade to 3.1.3

2022-10-19 Thread GitBox
dannycranmer commented on code in PR #20937: URL: https://github.com/apache/flink/pull/20937#discussion_r999875007 ## flink-connectors/flink-sql-connector-hive-3.1.3/src/main/resources/META-INF/NOTICE: ## @@ -25,25 +26,22 @@ the Apache Software License 2.0 (http://www.apache.or

[jira] [Updated] (FLINK-29468) Update jackson-bom to 2.13.4

2022-10-19 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-29468: -- Fix Version/s: 1.15.3 1.16.1 > Update jackson-bom to 2.13.4 > -

[jira] [Commented] (FLINK-29468) Update jackson-bom to 2.13.4

2022-10-19 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620527#comment-17620527 ] Matthias Pohl commented on FLINK-29468: --- Backports as part of FLINK-29638: 1.16: 5

[jira] [Resolved] (FLINK-29638) Update jackson bom because of CVE-2022-42003

2022-10-19 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-29638. --- Fix Version/s: 1.17.0 1.15.3 1.16.1 Resolution:

[GitHub] [flink] XComp merged pull request #21106: [BP-1.16][FLINK-29638][connectors][filesystems][formats] Update Jackson-BOM to 2.13.4.2 because of CVE-2022-42003

2022-10-19 Thread GitBox
XComp merged PR #21106: URL: https://github.com/apache/flink/pull/21106 -- 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.

[GitHub] [flink] XComp merged pull request #21107: [BP-1.15][FLINK-29638][connectors][filesystems][formats] Update Jackson-BOM to 2.13.4.2 because of CVE-2022-42003

2022-10-19 Thread GitBox
XComp merged PR #21107: URL: https://github.com/apache/flink/pull/21107 -- 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.

[GitHub] [flink] XComp merged pull request #21064: [FLINK-29638][connectors][filesystems][formats] Update Jackson-BOM to 2.13.4.2 because of CVE-2022-42003

2022-10-19 Thread GitBox
XComp merged PR #21064: URL: https://github.com/apache/flink/pull/21064 -- 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.

[GitHub] [flink] kristoffSC commented on pull request #21113: [Flink 29627][streaming] Fix duplicate key exception during recovery more than 1 committable.

2022-10-19 Thread GitBox
kristoffSC commented on PR #21113: URL: https://github.com/apache/flink/pull/21113#issuecomment-1284459961 @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] kristoffSC commented on pull request #21101: [Flink 29627][streaming] Fix duplicate key exception during recovery more than 1 committable.

2022-10-19 Thread GitBox
kristoffSC commented on PR #21101: URL: https://github.com/apache/flink/pull/21101#issuecomment-1284459875 @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] snuyanzin commented on pull request #21106: [BP-1.16][FLINK-29638][connectors][filesystems][formats] Update Jackson-BOM to 2.13.4.2 because of CVE-2022-42003

2022-10-19 Thread GitBox
snuyanzin commented on PR #21106: URL: https://github.com/apache/flink/pull/21106#issuecomment-1284459519 it looks like one of the attempts failed during check out (seems like a network issue since check out was more than 1 hour) https://dev.azure.com/apache-flink/apache-flink/_build/res

[jira] [Updated] (FLINK-29695) Create a utility to report the status of the last savepoint

2022-10-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29695: --- Labels: pull-request-available (was: ) > Create a utility to report the status of the last

[GitHub] [flink-kubernetes-operator] clarax opened a new pull request, #406: [FLINK-29695] Create a utility to report the status of the last savep…

2022-10-19 Thread GitBox
clarax opened a new pull request, #406: URL: https://github.com/apache/flink-kubernetes-operator/pull/406 …oint ## What is the purpose of the change https://issues.apache.org/jira/browse/FLINK-29695 Users want to know the status of last savepoint, especially for manually

[GitHub] [flink] dannycranmer commented on a diff in pull request #20937: [FLINK-29478][flink-connector/hive] Flink connector hive upgrade to 3.1.3

2022-10-19 Thread GitBox
dannycranmer commented on code in PR #20937: URL: https://github.com/apache/flink/pull/20937#discussion_r999791121 ## flink-connectors/flink-sql-connector-hive-3.1.3/src/main/resources/META-INF/NOTICE: ## @@ -25,25 +26,22 @@ the Apache Software License 2.0 (http://www.apache.or

[GitHub] [flink] flinkbot commented on pull request #21120: [hotfix][backport-1.16] Fix joining.md docs typo

2022-10-19 Thread GitBox
flinkbot commented on PR #21120: URL: https://github.com/apache/flink/pull/21120#issuecomment-1284397124 ## CI report: * 174b013ae21bb0689a9f141e26ed305bd11b75b2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

  1   2   3   4   >