[GitHub] [flink-table-store] zjureel commented on pull request #324: [FLINK-29701] Refactor flink-table-store-benchmark module to cluster benchmark

2022-10-20 Thread GitBox
zjureel commented on PR #324: URL: https://github.com/apache/flink-table-store/pull/324#issuecomment-1285203136 Hi @JingsongLi I refactor `flink-table-store-benchmark` to `flink-table-store-cluster-benchmark` in this PR -- This is an automated message from the Apache Git Service. To resp

[GitHub] [flink] flinkbot commented on pull request #21125: [FLINK-28102] Flink AkkaRpcSystemLoader fails when temporary directory is a symlink

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

[jira] [Comment Edited] (FLINK-29589) Data Loss in Sink GlobalCommitter during Task Manager recovery

2022-10-20 Thread Krzysztof Chmielewski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17616307#comment-17616307 ] Krzysztof Chmielewski edited comment on FLINK-29589 at 10/20/22 9:10 AM: -

[jira] [Updated] (FLINK-28102) Flink AkkaRpcSystemLoader fails when temporary directory is a symlink

2022-10-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28102: --- Labels: pull-request-available (was: ) > Flink AkkaRpcSystemLoader fails when temporary dir

[GitHub] [flink] reswqa opened a new pull request, #21125: [FLINK-28102] Flink AkkaRpcSystemLoader fails when temporary directory is a symlink

2022-10-20 Thread GitBox
reswqa opened a new pull request, #21125: URL: https://github.com/apache/flink/pull/21125 ## What is the purpose of the change *Flink AkkaRpcSystemLoader fails when temporary directory is a symlink. This is caused by FLINK-23500, as createDirectories will throw `FileAlreadyExistsExce

[jira] [Commented] (FLINK-29627) Sink - Duplicate key exception during recover more than 1 committable.

2022-10-20 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620921#comment-17620921 ] Fabian Paul commented on FLINK-29627: - Merged into: master: ac044f894dc930dcad0def4

[jira] [Updated] (FLINK-29627) Sink - Duplicate key exception during recover more than 1 committable.

2022-10-20 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-29627: Fix Version/s: 1.17.0 1.15.3 1.16.1 > Sink - Duplicate key e

[jira] [Updated] (FLINK-29627) Sink - Duplicate key exception during recover more than 1 committable.

2022-10-20 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-29627: Component/s: Connectors / Common > Sink - Duplicate key exception during recover more than 1 commi

[jira] [Resolved] (FLINK-29627) Sink - Duplicate key exception during recover more than 1 committable.

2022-10-20 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul resolved FLINK-29627. - Resolution: Fixed > Sink - Duplicate key exception during recover more than 1 committable. > ---

[jira] [Closed] (FLINK-29402) Add USE_DIRECT_READ configuration parameter for RocksDB

2022-10-20 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei closed FLINK-29402. Resolution: Not A Problem > Add USE_DIRECT_READ configuration parameter for RocksDB >

[jira] [Updated] (FLINK-29627) Sink - Duplicate key exception during recover more than 1 committable.

2022-10-20 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-29627: Affects Version/s: (was: 1.16.1) > Sink - Duplicate key exception during recover more than 1 c

[jira] [Commented] (FLINK-29402) Add USE_DIRECT_READ configuration parameter for RocksDB

2022-10-20 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620916#comment-17620916 ] Yuan Mei commented on FLINK-29402: -- # benchmarking for a pure k-v store ruling out othe

[jira] [Comment Edited] (FLINK-29402) Add USE_DIRECT_READ configuration parameter for RocksDB

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

[GitHub] [flink] fapaul merged pull request #21115: [Flink 29627][streaming] Fix duplicate key exception during recovery more than 1 committable.

2022-10-20 Thread GitBox
fapaul merged PR #21115: URL: https://github.com/apache/flink/pull/21115 -- 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] fapaul merged pull request #21113: [Flink 29627][streaming] Fix duplicate key exception during recovery more than 1 committable.

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

2022-10-20 Thread GitBox
fapaul merged PR #21101: URL: https://github.com/apache/flink/pull/21101 -- 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] liyubin117 commented on pull request #21116: [FLINK-29679][table] DESCRIBE statement shows column comment

2022-10-20 Thread GitBox
liyubin117 commented on PR #21116: URL: https://github.com/apache/flink/pull/21116#issuecomment-1285177702 @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] yangjunhan commented on pull request #21121: [FLINK-29684] chore: bump runtime web Angular to v14

2022-10-20 Thread GitBox
yangjunhan commented on PR #21121: URL: https://github.com/apache/flink/pull/21121#issuecomment-1285169199 @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] [Resolved] (FLINK-29307) Fix timeInQueue in CheckpointRequestDecider

2022-10-20 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei resolved FLINK-29307. -- Resolution: Fixed merged commit  [{{2851078}}|https://github.com/apache/flink/commit/2851078d61ef3c043

[GitHub] [flink-table-store] zjureel closed pull request #320: [FLINK-29636] Add micro benchmarks module

2022-10-20 Thread GitBox
zjureel closed pull request #320: [FLINK-29636] Add micro benchmarks module URL: https://github.com/apache/flink-table-store/pull/320 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comm

[GitHub] [flink] curcur commented on pull request #20921: [FLINK-29307][runtime/checkpoint] Fix timeInQueue in CheckpointRequestDecider

2022-10-20 Thread GitBox
curcur commented on PR #20921: URL: https://github.com/apache/flink/pull/20921#issuecomment-1285156220 @chenzihao5 Thanks for fixing this issue! -- 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-table-store] zjureel opened a new pull request, #324: [FLINK-29701] Refactor flink-table-store-benchmark module to cluster benchmark

2022-10-20 Thread GitBox
zjureel opened a new pull request, #324: URL: https://github.com/apache/flink-table-store/pull/324 Refactor `flink-table-store-benchmark` module as `flink-table-store-cluster-benchmark` in it -- This is an automated message from the Apache Git Service. To respond to the message, please lo

[GitHub] [flink] curcur merged pull request #20921: [FLINK-29307][runtime/checkpoint] Fix timeInQueue in CheckpointRequestDecider

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

[jira] [Updated] (FLINK-29701) Refactor flink-table-store-benchmark and create micro benchmarks module

2022-10-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29701: --- Labels: pull-request-available (was: ) > Refactor flink-table-store-benchmark and create mi

[jira] [Commented] (FLINK-29402) Add USE_DIRECT_READ configuration parameter for RocksDB

2022-10-20 Thread Donatien (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620901#comment-17620901 ] Donatien commented on FLINK-29402: -- Hey Yuan! This concern of enabling DirectIO for ben

[jira] [Updated] (FLINK-29701) Refactor flink-table-store-benchmark and create micro benchmarks module

2022-10-20 Thread Shammon (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shammon updated FLINK-29701: Description: Refactor the `flink-table-store-benchmark` to `flink-table-store-cluster-benchmark` (was: Re

[jira] [Created] (FLINK-29702) Add merge tree reader and writer micro benchmarks

2022-10-20 Thread Shammon (Jira)
Shammon created FLINK-29702: --- Summary: Add merge tree reader and writer micro benchmarks Key: FLINK-29702 URL: https://issues.apache.org/jira/browse/FLINK-29702 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-29701) Refactor flink-table-store-benchmark and create micro benchmarks module

2022-10-20 Thread Shammon (Jira)
Shammon created FLINK-29701: --- Summary: Refactor flink-table-store-benchmark and create micro benchmarks module Key: FLINK-29701 URL: https://issues.apache.org/jira/browse/FLINK-29701 Project: Flink

[GitHub] [flink] echauchot commented on pull request #21073: [FLINK-26822] Add Source for Cassandra connector

2022-10-20 Thread GitBox
echauchot commented on PR #21073: URL: https://github.com/apache/flink/pull/21073#issuecomment-1285129346 > It would be great if @mzuehlke could indeed help out on this due to limited bandwidth at this moment you mean help reviewing ? I don't know Flink specifics on reviews but can a

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

2022-10-20 Thread GitBox
zjureel commented on PR #320: URL: https://github.com/apache/flink-table-store/pull/320#issuecomment-1285125775 > Can you create a separate PR for module refactor? Then this pr is just to introduce micro benchmark. Look good to me 👍 -- This is an automated message from the Apache

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

2022-10-20 Thread Cai Liuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620889#comment-17620889 ] Cai Liuyang edited comment on FLINK-29577 at 10/20/22 8:11 AM: ---

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

2022-10-20 Thread Cai Liuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620889#comment-17620889 ] Cai Liuyang commented on FLINK-29577: - [~ym]  This is my test case: 1. disable roc

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

2022-10-20 Thread Cai Liuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Cai Liuyang updated FLINK-29577: Attachment: image-2022-10-20-16-08-15-746.png > Disable rocksdb wal when restore from full snapsho

[jira] [Created] (FLINK-29700) Serializer to BinaryInMemorySortBuffer is wrong

2022-10-20 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-29700: Summary: Serializer to BinaryInMemorySortBuffer is wrong Key: FLINK-29700 URL: https://issues.apache.org/jira/browse/FLINK-29700 Project: Flink Issue Type: B

[jira] [Commented] (FLINK-29134) fetch metrics may cause oom(ThreadPool task pile up)

2022-10-20 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620884#comment-17620884 ] Xintong Song commented on FLINK-29134: -- I think this can be fixed by checking wheth

[jira] [Commented] (FLINK-29699) Debezium format parsing supports converting strings at the end with Z and numbers to timestamp

2022-10-20 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620885#comment-17620885 ] Martijn Visser commented on FLINK-29699: [~waywtdcc] New features can't be added

[jira] [Updated] (FLINK-29699) Debezium format parsing supports converting strings at the end with Z and numbers to timestamp

2022-10-20 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-29699: --- Fix Version/s: 1.17.0 (was: 1.16.1) > Debezium format parsing support

[jira] [Comment Edited] (FLINK-29402) Add USE_DIRECT_READ configuration parameter for RocksDB

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

[jira] [Comment Edited] (FLINK-29402) Add USE_DIRECT_READ configuration parameter for RocksDB

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

[jira] [Assigned] (FLINK-29134) fetch metrics may cause oom(ThreadPool task pile up)

2022-10-20 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-29134: Assignee: Yuxin Tan > fetch metrics may cause oom(ThreadPool task pile up) >

[jira] [Commented] (FLINK-29234) Dead lock in DefaultLeaderElectionService

2022-10-20 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620883#comment-17620883 ] Xintong Song commented on FLINK-29234: -- Looks like a valid bug to me. [~Weijie Guo]

[jira] [Assigned] (FLINK-29234) Dead lock in DefaultLeaderElectionService

2022-10-20 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-29234: Assignee: Weijie Guo > Dead lock in DefaultLeaderElectionService > --

[jira] [Commented] (FLINK-29699) Debezium format parsing supports converting strings at the end with Z and numbers to timestamp

2022-10-20 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620881#comment-17620881 ] Martijn Visser commented on FLINK-29699: I still don't understand what is missin

[GitHub] [flink] snuyanzin commented on a diff in pull request #20991: [FLINK-25538][flink-connector-kafka] JUnit5 Migration

2022-10-20 Thread GitBox
snuyanzin commented on code in PR #20991: URL: https://github.com/apache/flink/pull/20991#discussion_r1000270961 ## flink-connectors/flink-connector-kafka/archunit-violations/97dda445-f6bc-43e2-8106-5876ca0cd052: ## @@ -26,12 +26,6 @@ org.apache.flink.connector.kafka.source.Kafk

[jira] [Assigned] (FLINK-28102) Flink AkkaRpcSystemLoader fails when temporary directory is a symlink

2022-10-20 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-28102: Assignee: Weijie Guo > Flink AkkaRpcSystemLoader fails when temporary directory is a syml

[jira] [Closed] (FLINK-29296) OperatorCoordinatorHolder.create throws NPE

2022-10-20 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao closed FLINK-29296. --- Resolution: Fixed > OperatorCoordinatorHolder.create throws NPE > --

[jira] [Commented] (FLINK-29296) OperatorCoordinatorHolder.create throws NPE

2022-10-20 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620874#comment-17620874 ] Yingjie Cao commented on FLINK-29296: - I think it is already fixed by https://issue

[jira] [Commented] (FLINK-28102) Flink AkkaRpcSystemLoader fails when temporary directory is a symlink

2022-10-20 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620871#comment-17620871 ] Weijie Guo commented on FLINK-28102: _[~xtsong]_ I will fix this, could you help ass

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

2022-10-20 Thread Samrat Deb (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620862#comment-17620862 ] Samrat Deb edited comment on FLINK-29697 at 10/20/22 7:48 AM:

[jira] [Commented] (FLINK-29362) Allow loading dynamic config for kerberos authentication in CliFrontend

2022-10-20 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620868#comment-17620868 ] Lijie Wang commented on FLINK-29362: I will close this issue because it's duplicated

[jira] [Resolved] (FLINK-29195) Expose the metrics of LastCompletedCheckpointId

2022-10-20 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei resolved FLINK-29195. -- Resolution: Fixed merged commit  [{{667732e}}|https://github.com/apache/flink/commit/667732e0af117db11

[jira] [Closed] (FLINK-29362) Allow loading dynamic config for kerberos authentication in CliFrontend

2022-10-20 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang closed FLINK-29362. -- Resolution: Duplicate > Allow loading dynamic config for kerberos authentication in CliFrontend >

[GitHub] [flink] curcur merged pull request #20782: [FLINK-29195] Expose lastCompletedCheckpointId metric

2022-10-20 Thread GitBox
curcur merged PR #20782: URL: https://github.com/apache/flink/pull/20782 -- 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] curcur commented on pull request #20782: [FLINK-29195] Expose lastCompletedCheckpointId metric

2022-10-20 Thread GitBox
curcur commented on PR #20782: URL: https://github.com/apache/flink/pull/20782#issuecomment-1285088823 Thanks for fixing up this @chenyuzhi459 -- 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] RyanSkraba commented on pull request #19897: [FLINK-27885][tests][JUnit5 migration] flink-csv

2022-10-20 Thread GitBox
RyanSkraba commented on PR #19897: URL: https://github.com/apache/flink/pull/19897#issuecomment-1285088453 Rebased with no additional code changes. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] XComp commented on a diff in pull request #20805: [FLINK-29198][test] Fail after maximum RetryOnException

2022-10-20 Thread GitBox
XComp commented on code in PR #20805: URL: https://github.com/apache/flink/pull/20805#discussion_r1000260540 ## flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/junit/extensions/retry/strategy/RetryStrategy.java: ## @@ -27,11 +27,17 @@ publ

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

2022-10-20 Thread Hang HOU (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620865#comment-17620865 ] Hang HOU commented on FLINK-29558: -- [~jiabao.sun] Hi,if column like 'id',and 'id' is th

[GitHub] [flink] RyanSkraba commented on a diff in pull request #20805: [FLINK-29198][test] Fail after maximum RetryOnException

2022-10-20 Thread GitBox
RyanSkraba commented on code in PR #20805: URL: https://github.com/apache/flink/pull/20805#discussion_r1000259397 ## flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/junit/extensions/retry/strategy/RetryStrategy.java: ## @@ -27,11 +27,17 @@

[jira] [Updated] (FLINK-29699) Debezium format parsing supports converting strings at the end with Z and numbers to timestamp

2022-10-20 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] waywtdcc updated FLINK-29699: - Description: Debezium format parsing supports converting strings at the end with Z and numbers  to time

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

2022-10-20 Thread Samrat Deb (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620862#comment-17620862 ] Samrat Deb edited comment on FLINK-29697 at 10/20/22 7:42 AM:

[jira] [Updated] (FLINK-28985) support create table like view

2022-10-20 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] waywtdcc updated FLINK-28985: - Issue Type: New Feature (was: Improvement) > support create table like view > -

[GitHub] [flink] RyanSkraba commented on pull request #20805: [FLINK-29198][test] Fail after maximum RetryOnException

2022-10-20 Thread GitBox
RyanSkraba commented on PR #20805: URL: https://github.com/apache/flink/pull/20805#issuecomment-1285085672 Rebased again and edited the commit messages! -- 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

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

2022-10-20 Thread Samrat Deb (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Samrat Deb updated FLINK-29697: --- Description: {code:java} org.apache.flink.streaming.connectors.kafka.shuffle.KafkaShuffleExactlyOnce

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

2022-10-20 Thread Samrat Deb (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620862#comment-17620862 ] Samrat Deb commented on FLINK-29697: Oh ! appologies [~martijnvisser] !  I have atta

[jira] [Updated] (FLINK-29699) Debezium format parsing supports converting strings at the end with Z and numbers to timestamp

2022-10-20 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] waywtdcc updated FLINK-29699: - Summary: Debezium format parsing supports converting strings at the end with Z and numbers to timestamp

[jira] [Updated] (FLINK-29699) Debezium format parsing supports converting strings with Z and numbers at the end to timestamp

2022-10-20 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] waywtdcc updated FLINK-29699: - Summary: Debezium format parsing supports converting strings with Z and numbers at the end to timestamp

[jira] [Updated] (FLINK-29699) Debezium format parsing supports converting strings at the end with Z and numbers to timestamp

2022-10-20 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] waywtdcc updated FLINK-29699: - Description: Debezium format parsing supports converting strings at the end with Z and numbers  to time

[jira] [Commented] (FLINK-29402) Add USE_DIRECT_READ configuration parameter for RocksDB

2022-10-20 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620861#comment-17620861 ] Yuan Mei commented on FLINK-29402: -- [~donaschmi]  * I understand enabling/disabling Di

[jira] [Updated] (FLINK-29699) Debezium format parsing supports converting strings and numbers with Z at the end to timestamp

2022-10-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29699: --- Labels: pull-request-available (was: ) > Debezium format parsing supports converting string

[jira] [Commented] (FLINK-29699) Debezium format parsing supports converting strings and numbers with Z at the end to timestamp

2022-10-20 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620860#comment-17620860 ] waywtdcc commented on FLINK-29699: -- [~martijnvisser] Thanks you .update now > Debezium

[GitHub] [flink] flinkbot commented on pull request #21124: [FLINK-29699]Debezium format parsing supports converting strings with Z and numbers at the end to timestamp

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

[jira] [Updated] (FLINK-29699) Debezium format parsing supports converting strings and numbers with Z at the end to timestamp

2022-10-20 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] waywtdcc updated FLINK-29699: - Fix Version/s: 1.16.1 > Debezium format parsing supports converting strings and numbers with Z at the >

[jira] [Comment Edited] (FLINK-29183) flink job ended before window time up while using bounded stream source

2022-10-20 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620855#comment-17620855 ] Yun Gao edited comment on FLINK-29183 at 10/20/22 7:39 AM: --- Hi

[jira] [Assigned] (FLINK-29347) Failed to restore from list state with empty protobuf object

2022-10-20 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-29347: -- Assignee: shen > Failed to restore from list state with empty protobuf object > -

[jira] [Commented] (FLINK-29650) Printing the contents of error lines when parsing yaml file may leak sensitive configuration values

2022-10-20 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620857#comment-17620857 ] Zhu Zhu commented on FLINK-29650: - [~lyssg] would you share more information about what

[jira] [Commented] (FLINK-29183) flink job ended before window time up while using bounded stream source

2022-10-20 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620855#comment-17620855 ] Yun Gao commented on FLINK-29183: - Hi [~landlord] , this is indeed a known issue that cu

[jira] [Updated] (FLINK-29699) Debezium format parsing supports converting strings and numbers with Z at the end to timestamp

2022-10-20 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] waywtdcc updated FLINK-29699: - Description: Debezium format parsing supports converting strings  with Z and numbers at the end to time

[jira] [Commented] (FLINK-29647) report stackoverflow when using kryo

2022-10-20 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620854#comment-17620854 ] Zhu Zhu commented on FLINK-29647: - [~jackin853] I think you are right that is is a known

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

2022-10-20 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-29697. -- Resolution: Invalid [~samrat007] Thanks for filing the ticket, but the Azure run that you've l

[jira] [Commented] (FLINK-29298) LocalBufferPool request buffer from NetworkBufferPool hanging

2022-10-20 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620848#comment-17620848 ] Yingjie Cao commented on FLINK-29298: - [~Weijie Guo] Thanks for reporting this. > L

[jira] [Updated] (FLINK-29699) Debezium format parsing supports converting strings and numbers with Z at the end to timestamp

2022-10-20 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] waywtdcc updated FLINK-29699: - Description: Debezium format parsing supports converting strings  with Z and numbers at the end to times

[GitHub] [flink] snuyanzin commented on a diff in pull request #20850: [FLINK-20873][Table SQl/API] Update to calcite 1.27

2022-10-20 Thread GitBox
snuyanzin commented on code in PR #20850: URL: https://github.com/apache/flink/pull/20850#discussion_r999569994 ## flink-table/flink-table-planner/pom.xml: ## @@ -347,6 +367,7 @@ under the License. com.google.guava:failure

[jira] [Commented] (FLINK-29699) Debezium format parsing supports converting strings and numbers with Z at the end to timestamp

2022-10-20 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620847#comment-17620847 ] Martijn Visser commented on FLINK-29699: [~waywtdcc] Thanks for the ticket, but

[GitHub] [flink] waywtdcc opened a new pull request, #21124: Debezium format parsing supports converting strings with Z and numbers at the end to timestamp

2022-10-20 Thread GitBox
waywtdcc opened a new pull request, #21124: URL: https://github.com/apache/flink/pull/21124 ## What is the purpose of the change *Debezium format parsing supports converting strings with Z and numbers at the end to timestamp* ## Brief change log - *deb

[jira] [Updated] (FLINK-29699) Debezium format parsing supports converting strings and numbers with Z at the end to timestamp

2022-10-20 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-29699: --- Fix Version/s: (was: 1.16.1) > Debezium format parsing supports converting strings and n

[jira] [Assigned] (FLINK-29306) fail to check multiple flink-dist*.jar for config.sh

2022-10-20 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao reassigned FLINK-29306: --- Assignee: LiuZeshan > fail to check multiple flink-dist*.jar for config.sh > --

[GitHub] [flink] liyubin117 commented on pull request #21116: [FLINK-29679][table] DESCRIBE statement shows column comment

2022-10-20 Thread GitBox
liyubin117 commented on PR #21116: URL: https://github.com/apache/flink/pull/21116#issuecomment-1285073426 @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] [Updated] (FLINK-29347) Failed to restore from list state with empty protobuf object

2022-10-20 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang updated FLINK-29347: --- Component/s: Runtime / State Backends > Failed to restore from list state with empty protobuf object

[jira] [Updated] (FLINK-29328) 【Flink is having problems using the status expiration setting】

2022-10-20 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29328: - Component/s: Runtime / State Backends (was: API / DataStream) > 【Flink is h

[jira] [Created] (FLINK-29699) Debezium format parsing supports converting strings and numbers with Z at the end to timestamp

2022-10-20 Thread waywtdcc (Jira)
waywtdcc created FLINK-29699: Summary: Debezium format parsing supports converting strings and numbers with Z at the end to timestamp Key: FLINK-29699 URL: https://issues.apache.org/jira/browse/FLINK-29699

[jira] [Commented] (FLINK-29610) Infinite timeout is used in SavepointHandlers calls to RestfulGateway

2022-10-20 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620844#comment-17620844 ] Yun Gao commented on FLINK-29610: - Thanks [~Jiale] for creating the issue. Since it seem

[jira] [Commented] (FLINK-29339) JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager blocks main thread

2022-10-20 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620842#comment-17620842 ] Xintong Song commented on FLINK-29339: -- Any updates on this? [~xuannan][~gaoyunhaii

[jira] [Updated] (FLINK-28102) Flink AkkaRpcSystemLoader fails when temporary directory is a symlink

2022-10-20 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-28102: Affects Version/s: 1.16.0 1.17.0 > Flink AkkaRpcSystemLoader fails when tem

[jira] [Reopened] (FLINK-28102) Flink AkkaRpcSystemLoader fails when temporary directory is a symlink

2022-10-20 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng reopened FLINK-28102: - Mistakenly closed. > Flink AkkaRpcSystemLoader fails when temporary directory is a symlink > --

[jira] [Commented] (FLINK-29686) There are bugs in Flink-SQL using Hive dialect

2022-10-20 Thread Vincent Long (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620837#comment-17620837 ] Vincent Long commented on FLINK-29686: -- Ok, thank you very much for your opinion, I

[jira] [Commented] (FLINK-29565) In Flink per job mode, the logs printed by taskManager on the web UI will not be highlighted, because the log contents are annotated due to special symbols, which will

2022-10-20 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620835#comment-17620835 ] Yingjie Cao commented on FLINK-29565: - [~1336399775] Thanks for reporting this. Do y

[jira] [Commented] (FLINK-29660) Show all attempts of subtasks in WebUI

2022-10-20 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17620833#comment-17620833 ] Zhu Zhu commented on FLINK-29660: - To check the failed attempt, I think it's better to c

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

2022-10-20 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-29698. Resolution: Duplicate Closing this for duplication. I also upgraded FLINK-28102 to Critical. > Jo

[jira] [Closed] (FLINK-28102) Flink AkkaRpcSystemLoader fails when temporary directory is a symlink

2022-10-20 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-28102. --- Resolution: Duplicate > Flink AkkaRpcSystemLoader fails when temporary directory is a symlink >

[jira] [Updated] (FLINK-28102) Flink AkkaRpcSystemLoader fails when temporary directory is a symlink

2022-10-20 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28102: - Priority: Critical (was: Minor) > Flink AkkaRpcSystemLoader fails when temporary directory is a

<    1   2   3   4   >