[GitHub] [flink] rkhachatryan commented on pull request #20091: [FLINK-27570][runtime] Fix checkFailureCounter in CheckpointFailureManager for finalize failure

2022-08-12 Thread GitBox
rkhachatryan commented on PR #20091: URL: https://github.com/apache/flink/pull/20091#issuecomment-1212794453 I'm going to assume there's no further feedback and given that the previous feedback was addressed will merge the PR. We can address any further issues separately. -- This is an

[jira] [Commented] (FLINK-28609) Flink-Pulsar connector fails on larger schemas

2022-08-12 Thread Aleksandra Sarna (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17578838#comment-17578838 ] Aleksandra Sarna commented on FLINK-28609: -- Thanks for the information [~syhily

[GitHub] [flink] swuferhong commented on a diff in pull request #20513: [FLINK-28858][docs] Add document to describe join hints for batch sql

2022-08-12 Thread GitBox
swuferhong commented on code in PR #20513: URL: https://github.com/apache/flink/pull/20513#discussion_r944173151 ## docs/content/docs/dev/table/sql/queries/hints.md: ## @@ -84,4 +84,222 @@ insert into kafka_table1 /*+ OPTIONS('sink.partitioner'='round-robin') */ select ```

[jira] [Created] (FLINK-28945) Several task IO metrics not displayed on web ui

2022-08-12 Thread lincoln lee (Jira)
lincoln lee created FLINK-28945: --- Summary: Several task IO metrics not displayed on web ui Key: FLINK-28945 URL: https://issues.apache.org/jira/browse/FLINK-28945 Project: Flink Issue Type: Bug

[GitHub] [flink] twalthr commented on a diff in pull request #20555: [FLINK-28861][table] Make UID generation behavior configurable and plan-only by default

2022-08-12 Thread GitBox
twalthr commented on code in PR #20555: URL: https://github.com/apache/flink/pull/20555#discussion_r944176982 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/codegen/LongAdaptiveHashJoinGeneratorTest.java: ## @@ -88,7 +87,7 @@ public JoinCondition

[jira] [Updated] (FLINK-28945) Several task IO metrics not displayed on web ui

2022-08-12 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-28945: Description: There is feedback from the community user that neither the receive nor the sent metr

[GitHub] [flink] rkhachatryan closed pull request #20091: [FLINK-27570][runtime] Fix checkFailureCounter in CheckpointFailureManager for finalize failure

2022-08-12 Thread GitBox
rkhachatryan closed pull request #20091: [FLINK-27570][runtime] Fix checkFailureCounter in CheckpointFailureManager for finalize failure URL: https://github.com/apache/flink/pull/20091 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] rkhachatryan commented on pull request #20091: [FLINK-27570][runtime] Fix checkFailureCounter in CheckpointFailureManager for finalize failure

2022-08-12 Thread GitBox
rkhachatryan commented on PR #20091: URL: https://github.com/apache/flink/pull/20091#issuecomment-1212809791 Merged as 88b309b7dcad269ad084eab5e2944724daf6dee4. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL a

[jira] [Updated] (FLINK-27570) Checkpoint path error does not cause the job to stop

2022-08-12 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-27570: -- Fix Version/s: 1.16.0 1.15.2 > Checkpoint path error does not cause

[jira] [Closed] (FLINK-27570) Checkpoint path error does not cause the job to stop

2022-08-12 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-27570. - Resolution: Fixed Merged into master as 88b309b7dcad269ad084eab5e2944724daf6dee4, into 1

[GitHub] [flink] JesseAtSZ commented on pull request #20091: [FLINK-27570][runtime] Fix checkFailureCounter in CheckpointFailureManager for finalize failure

2022-08-12 Thread GitBox
JesseAtSZ commented on PR #20091: URL: https://github.com/apache/flink/pull/20091#issuecomment-1212826620 @rkhachatryan How can I find my name in the contributor list? This is my first contribution. -- This is an automated message from the Apache Git Service. To respond to the message, pl

[GitHub] [flink-benchmarks] fredia commented on pull request #58: [FLINK-28931] Fix BlockingPartitionBenchmark compile error

2022-08-12 Thread GitBox
fredia commented on PR #58: URL: https://github.com/apache/flink-benchmarks/pull/58#issuecomment-1212837366 @reswqa would you like 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 above to go to

[jira] [Updated] (FLINK-28931) BlockingPartitionBenchmark doesn't compile

2022-08-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28931: --- Labels: pull-request-available (was: ) > BlockingPartitionBenchmark doesn't compile > -

[GitHub] [flink-benchmarks] rkhachatryan merged pull request #58: [FLINK-28931] Fix BlockingPartitionBenchmark compile error

2022-08-12 Thread GitBox
rkhachatryan merged PR #58: URL: https://github.com/apache/flink-benchmarks/pull/58 -- 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...@f

[GitHub] [flink-benchmarks] rkhachatryan commented on pull request #58: [FLINK-28931] Fix BlockingPartitionBenchmark compile error

2022-08-12 Thread GitBox
rkhachatryan commented on PR #58: URL: https://github.com/apache/flink-benchmarks/pull/58#issuecomment-1212839373 Sorry, just noticed the last message after merging. If there are any comments I'd be happy to address them in a separate PR then. -- This is an automated message from the A

[GitHub] [flink] Myasuka merged pull request #20420: [FLINK-28626][tests]Fix unstable RescaleCheckpointManuallyITCase

2022-08-12 Thread GitBox
Myasuka merged PR #20420: URL: https://github.com/apache/flink/pull/20420 -- 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.apach

[jira] [Resolved] (FLINK-28626) RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState failed with FileNotFoundException

2022-08-12 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-28626. -- Resolution: Fixed merged in master: 7cf71585a603866822ed0aee3978eea8d8587eee > RescaleCheckpointManua

[GitHub] [flink] lindong28 commented on a diff in pull request #20454: [FLINK-28639][Runtime/Checkpointing] Preserve consistency of events from subtask to OC

2022-08-12 Thread GitBox
lindong28 commented on code in PR #20454: URL: https://github.com/apache/flink/pull/20454#discussion_r944072971 ## flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinatorHolder.java: ## @@ -312,26 +446,81 @@ private void checkpointCoordina

[GitHub] [flink] Grypse commented on pull request #20558: [BP-1.15]FLINK-27856][k8s] Fix the NPE when no spec is configured in pod template

2022-08-12 Thread GitBox
Grypse commented on PR #20558: URL: https://github.com/apache/flink/pull/20558#issuecomment-1212845410 @wangyang0918 Please help review this PR. -- 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 th

[jira] [Closed] (FLINK-28931) BlockingPartitionBenchmark doesn't compile

2022-08-12 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-28931. - Fix Version/s: 1.16.0 Resolution: Fixed Merged as 4726194e7e73a39a78b102a4ce2b4ec

[jira] [Commented] (FLINK-28719) Mapping a data source before window aggregation causes Flink to stop handle late events correctly.

2022-08-12 Thread Mykyta Mykhailenko (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17578858#comment-17578858 ] Mykyta Mykhailenko commented on FLINK-28719: Actually, I think I hurried a l

[jira] [Reopened] (FLINK-28719) Mapping a data source before window aggregation causes Flink to stop handle late events correctly.

2022-08-12 Thread Mykyta Mykhailenko (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mykyta Mykhailenko reopened FLINK-28719: > Mapping a data source before window aggregation causes Flink to stop handle > late

[jira] [Comment Edited] (FLINK-28719) Mapping a data source before window aggregation causes Flink to stop handle late events correctly.

2022-08-12 Thread Mykyta Mykhailenko (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17578858#comment-17578858 ] Mykyta Mykhailenko edited comment on FLINK-28719 at 8/12/22 8:15 AM: -

[GitHub] [flink-connector-dynamodb] nirtsruya opened a new pull request, #1: [FLINK-24229][Connectors][DynamoDB] - Add AWS DynamoDB connector

2022-08-12 Thread GitBox
nirtsruya opened a new pull request, #1: URL: https://github.com/apache/flink-connector-dynamodb/pull/1 Move flink-connector-aws-connector from the flink respository -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] Myasuka commented on a diff in pull request #20405: [FLINK-28010][state] Use deleteRange to optimize the clear method of RocksDBMapState.

2022-08-12 Thread GitBox
Myasuka commented on code in PR #20405: URL: https://github.com/apache/flink/pull/20405#discussion_r944230268 ## flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/EmbeddedRocksDBStateBackendTest.java: ## @@ -637,11 +642,75 @@

[GitHub] [flink] wangyang0918 merged pull request #20558: [BP-1.15]FLINK-27856][k8s] Fix the NPE when no spec is configured in pod template

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

[jira] [Commented] (FLINK-27856) Adding pod template without spec crashes job manager

2022-08-12 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17578863#comment-17578863 ] Yang Wang commented on FLINK-27856: --- Fixed via: master: 5e554c17742e1809188aa702daca3

[jira] [Closed] (FLINK-27856) Adding pod template without spec crashes job manager

2022-08-12 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-27856. - Resolution: Fixed > Adding pod template without spec crashes job manager > -

[GitHub] [flink] zhongqishang commented on pull request #20530: [FLINK-28817] NullPointerException in HybridSource when restoring from checkpoint

2022-08-12 Thread GitBox
zhongqishang commented on PR #20530: URL: https://github.com/apache/flink/pull/20530#issuecomment-1212873257 @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 comme

[GitHub] [flink-benchmarks] rkhachatryan commented on pull request #58: [FLINK-28931] Fix BlockingPartitionBenchmark compile error

2022-08-12 Thread GitBox
rkhachatryan commented on PR #58: URL: https://github.com/apache/flink-benchmarks/pull/58#issuecomment-1212877266 Thanks @reswqa and @fredia for the prompt review -- 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] HuangXingBo opened a new pull request, #20561: [FLINK-28944][python][docs] Optimize the Python Execution Mode Documentation

2022-08-12 Thread GitBox
HuangXingBo opened a new pull request, #20561: URL: https://github.com/apache/flink/pull/20561 ## What is the purpose of the change *This pull request will optimize the Python Execution Mode Documentation* ## Brief change log - *Optimize the Python Execution Mode Do

[jira] [Updated] (FLINK-28944) Optimize the Python Execution Mode Documentation

2022-08-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28944: --- Labels: pull-request-available (was: ) > Optimize the Python Execution Mode Documentation >

[GitHub] [flink] flinkbot commented on pull request #20561: [FLINK-28944][python][docs] Optimize the Python Execution Mode Documentation

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

[jira] [Updated] (FLINK-28946) Remove RexSimplify together with calcite upgrade

2022-08-12 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-28946: Description: As mentioned in {{org.apache.calcite.rex.RexSimplify}} comment {noformat} * C

[jira] [Created] (FLINK-28946) Remove RexSimplify together with calcite upgrade

2022-08-12 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-28946: --- Summary: Remove RexSimplify together with calcite upgrade Key: FLINK-28946 URL: https://issues.apache.org/jira/browse/FLINK-28946 Project: Flink Issue

[jira] [Commented] (FLINK-24318) Casting a number to boolean has different results between 'select' fields and 'where' condition

2022-08-12 Thread Yuan Kui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17578884#comment-17578884 ] Yuan Kui commented on FLINK-24318: -- In 1.13.4, correct commit is: ea53e4a6cd1d39592cf3a

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

2022-08-12 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17578887#comment-17578887 ] Zhu Zhu commented on FLINK-28766: - https://dev.azure.com/apache-flink/apache-flink/_buil

[GitHub] [flink] zhuzhurk commented on pull request #20559: [FLINK-28878][tests] Increase slot request timeout of PipelinedRegionSchedulingITCase

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

[jira] [Commented] (FLINK-28719) Mapping a data source before window aggregation causes Flink to stop handle late events correctly.

2022-08-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17578890#comment-17578890 ] Chesnay Schepler commented on FLINK-28719: -- > As far as I understand, op1 and o

[jira] [Comment Edited] (FLINK-28719) Mapping a data source before window aggregation causes Flink to stop handle late events correctly.

2022-08-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17578890#comment-17578890 ] Chesnay Schepler edited comment on FLINK-28719 at 8/12/22 9:42 AM: ---

[jira] [Created] (FLINK-28947) Curator framework fails with NullPointerException

2022-08-12 Thread Juha (Jira)
Juha created FLINK-28947: Summary: Curator framework fails with NullPointerException Key: FLINK-28947 URL: https://issues.apache.org/jira/browse/FLINK-28947 Project: Flink Issue Type: Bug Affects

[jira] [Comment Edited] (FLINK-28719) Mapping a data source before window aggregation causes Flink to stop handle late events correctly.

2022-08-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17578890#comment-17578890 ] Chesnay Schepler edited comment on FLINK-28719 at 8/12/22 9:43 AM: ---

[GitHub] [flink] wsry merged pull request #20560: [FLINK-28942][network] Fix the deadlock bug when recycling readers for SortMergeResultPartition

2022-08-12 Thread GitBox
wsry merged PR #20560: URL: https://github.com/apache/flink/pull/20560 -- 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.o

[jira] [Comment Edited] (FLINK-28719) Mapping a data source before window aggregation causes Flink to stop handle late events correctly.

2022-08-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17578890#comment-17578890 ] Chesnay Schepler edited comment on FLINK-28719 at 8/12/22 9:42 AM: ---

[jira] [Updated] (FLINK-28942) Deadlock may occurs when releasing readers for SortMergeResultPartition

2022-08-12 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-28942: Fix Version/s: 1.16.0 > Deadlock may occurs when releasing readers for SortMergeResultPartition >

[jira] [Assigned] (FLINK-28942) Deadlock may occurs when releasing readers for SortMergeResultPartition

2022-08-12 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao reassigned FLINK-28942: --- Assignee: Yuxin Tan > Deadlock may occurs when releasing readers for SortMergeResultPartiti

[jira] [Resolved] (FLINK-28942) Deadlock may occurs when releasing readers for SortMergeResultPartition

2022-08-12 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao resolved FLINK-28942. - Resolution: Fixed Merged into master via f2fb6b20ec493a3af3f19a6f69f25e26ed226dda > Deadlock ma

[GitHub] [flink] wsry commented on pull request #20560: [FLINK-28942][network] Fix the deadlock bug when recycling readers for SortMergeResultPartition

2022-08-12 Thread GitBox
wsry commented on PR #20560: URL: https://github.com/apache/flink/pull/20560#issuecomment-1212934966 @TanYuxin-tyx Thanks for the fix. LGTM. Merged. -- 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 t

[jira] [Commented] (FLINK-28817) NullPointerException in HybridSource when restoring from checkpoint

2022-08-12 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17578893#comment-17578893 ] Nicholas Jiang commented on FLINK-28817: [~thw], IMO, this pull request could al

[GitHub] [flink] SteNicholas commented on pull request #20530: [FLINK-28817] NullPointerException in HybridSource when restoring from checkpoint

2022-08-12 Thread GitBox
SteNicholas commented on PR #20530: URL: https://github.com/apache/flink/pull/20530#issuecomment-1212938121 @zhongqishang, could you please add test which refers to [HybridSourceTest](https://issues.apache.org/jira/secure/attachment/13041815/HybridSourceTest.java) to verify whether to fix t

[jira] [Updated] (FLINK-28890) Incorrect semantic of latestLoadTime in CachingLookupFunction and CachingAsyncLookupFunction

2022-08-12 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-28890: -- Priority: Critical (was: Major) > Incorrect semantic of latestLoadTime in CachingLookupFuncti

[GitHub] [flink] twalthr commented on pull request #20555: [FLINK-28861][table] Make UID generation behavior configurable and plan-only by default

2022-08-12 Thread GitBox
twalthr commented on PR #20555: URL: https://github.com/apache/flink/pull/20555#issuecomment-1212955760 Thanks for the review @zentol. Next to the necessity to pass around the `isCompile` flag, I found another issue due to the fact that transformations can be caches in a transient variable.

[GitHub] [flink] zhongqishang commented on pull request #20530: [FLINK-28817] NullPointerException in HybridSource when restoring from checkpoint

2022-08-12 Thread GitBox
zhongqishang commented on PR #20530: URL: https://github.com/apache/flink/pull/20530#issuecomment-1212955847 @SteNicholas, In fact I encountered the situation described in FLINK-26938, I will try to add a test case as soon as possible. -- This is an automated message from the Apache Git

[jira] [Created] (FLINK-28948) Add more test coverage for lookup table full caching

2022-08-12 Thread Qingsheng Ren (Jira)
Qingsheng Ren created FLINK-28948: - Summary: Add more test coverage for lookup table full caching Key: FLINK-28948 URL: https://issues.apache.org/jira/browse/FLINK-28948 Project: Flink Issue

[GitHub] [flink] SteNicholas commented on pull request #20530: [FLINK-28817] NullPointerException in HybridSource when restoring from checkpoint

2022-08-12 Thread GitBox
SteNicholas commented on PR #20530: URL: https://github.com/apache/flink/pull/20530#issuecomment-1212960450 @zhongqishang, it's better to add the test case for the situation described in [FLINK-26938](https://issues.apache.org/jira/browse/FLINK-26938). cc @tweise -- This is an automated

[GitHub] [flink] xuyangzhong commented on a diff in pull request #20513: [FLINK-28858][docs] Add document to describe join hints for batch sql

2022-08-12 Thread GitBox
xuyangzhong commented on code in PR #20513: URL: https://github.com/apache/flink/pull/20513#discussion_r944079451 ## docs/content/docs/dev/table/sql/queries/hints.md: ## @@ -84,4 +84,222 @@ insert into kafka_table1 /*+ OPTIONS('sink.partitioner'='round-robin') */ select ```

[GitHub] [flink] xuyangzhong commented on pull request #20513: [FLINK-28858][docs] Add document to describe join hints for batch sql

2022-08-12 Thread GitBox
xuyangzhong commented on PR #20513: URL: https://github.com/apache/flink/pull/20513#issuecomment-1212963681 Hi, thank for you contribution. I left some comments here. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] SteNicholas commented on a diff in pull request #20530: [FLINK-28817] NullPointerException in HybridSource when restoring from checkpoint

2022-08-12 Thread GitBox
SteNicholas commented on code in PR #20530: URL: https://github.com/apache/flink/pull/20530#discussion_r944331765 ## flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/SwitchedSources.java: ## @@ -45,4 +47,8 @@ public SimpleVersione

[GitHub] [flink] SteNicholas commented on a diff in pull request #20530: [FLINK-28817] NullPointerException in HybridSource when restoring from checkpoint

2022-08-12 Thread GitBox
SteNicholas commented on code in PR #20530: URL: https://github.com/apache/flink/pull/20530#discussion_r944332749 ## flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplitEnumerator.java: ## @@ -218,7 +218,8 @@ public

[GitHub] [flink] zentol commented on a diff in pull request #20555: [FLINK-28861][table] Make UID generation behavior configurable and plan-only by default

2022-08-12 Thread GitBox
zentol commented on code in PR #20555: URL: https://github.com/apache/flink/pull/20555#discussion_r944337888 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/ExecNodeBase.java: ## @@ -49,6 +49,13 @@ @JsonIgnoreProperties(ignoreUnkn

[jira] [Commented] (FLINK-27171) Add periodic kerberos delegation token obtain possibility to DelegationTokenManager

2022-08-12 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17578920#comment-17578920 ] Gabor Somogyi commented on FLINK-27171: --- I see your point. OK, we can plan this fe

[GitHub] [flink] fsk119 commented on pull request #20514: [FLINK-28855][hive] Fix 'Table.INDEX_TABLE' not found in the Hive3

2022-08-12 Thread GitBox
fsk119 commented on PR #20514: URL: https://github.com/apache/flink/pull/20514#issuecomment-1212984028 @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. T

[GitHub] [flink] syhily commented on pull request #19972: [FLINK-27399][Connector/Pulsar] Change initial consuming position setting logic for better handle the checkpoint.

2022-08-12 Thread GitBox
syhily commented on PR #19972: URL: https://github.com/apache/flink/pull/19972#issuecomment-1213014404 @tisonkun Finally, the ci turns green. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the s

[GitHub] [flink-web] SteNicholas commented on pull request #564: [FLINK-28930] Add roadmap of Flink Table Store to Apache Flink Roadmap

2022-08-12 Thread GitBox
SteNicholas commented on PR #564: URL: https://github.com/apache/flink-web/pull/564#issuecomment-1213017632 @JingsongLi, PTAL. -- 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] yunfengzhou-hub commented on a diff in pull request #20454: [FLINK-28639][Runtime/Checkpointing] Preserve consistency of events from subtask to OC

2022-08-12 Thread GitBox
yunfengzhou-hub commented on code in PR #20454: URL: https://github.com/apache/flink/pull/20454#discussion_r944382861 ## flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinatorHolder.java: ## @@ -299,9 +364,78 @@ public void resetToCheckpo

[GitHub] [flink] yunfengzhou-hub commented on pull request #20454: [FLINK-28639][Runtime/Checkpointing] Preserve consistency of events from subtask to OC

2022-08-12 Thread GitBox
yunfengzhou-hub commented on PR #20454: URL: https://github.com/apache/flink/pull/20454#issuecomment-1213052159 @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 co

[GitHub] [flink] yunfengzhou-hub commented on a diff in pull request #20454: [FLINK-28639][Runtime/Checkpointing] Preserve consistency of events from subtask to OC

2022-08-12 Thread GitBox
yunfengzhou-hub commented on code in PR #20454: URL: https://github.com/apache/flink/pull/20454#discussion_r944406293 ## flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/SubtaskGatewayImpl.java: ## @@ -220,12 +228,11 @@ void openGatewayAndUnmarkCheckpo

[jira] [Updated] (FLINK-28931) BlockingPartitionBenchmark doesn't compile

2022-08-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28931: - Issue Type: Technical Debt (was: Bug) > BlockingPartitionBenchmark doesn't compile > --

[jira] [Updated] (FLINK-28856) YARNHighAvailabilityITCase tests failed with NoSuchMethodError

2022-08-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28856: - Fix Version/s: (was: 1.16.0) > YARNHighAvailabilityITCase tests failed with NoSuchMe

[jira] [Updated] (FLINK-28856) YARNHighAvailabilityITCase tests failed with NoSuchMethodError

2022-08-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28856: - Issue Type: Technical Debt (was: Bug) > YARNHighAvailabilityITCase tests failed with No

[jira] [Updated] (FLINK-28844) YARNHighAvailabilityITCase fails with NoSuchMethod of org.apache.curator

2022-08-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28844: - Issue Type: Technical Debt (was: Bug) > YARNHighAvailabilityITCase fails with NoSuchMet

[jira] [Updated] (FLINK-28781) Hybrid Shuffle should support compression

2022-08-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28781: - Issue Type: Improvement (was: Bug) > Hybrid Shuffle should support compression > --

[jira] [Updated] (FLINK-28388) Python doc build breaking nightly docs

2022-08-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28388: - Issue Type: Technical Debt (was: Bug) > Python doc build breaking nightly docs > --

[jira] [Updated] (FLINK-28263) TPC-DS Bash e2e tests don't clean-up after completing

2022-08-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28263: - Issue Type: Technical Debt (was: Bug) > TPC-DS Bash e2e tests don't clean-up after comp

[jira] [Updated] (FLINK-28198) CassandraConnectorITCase fails with timeout

2022-08-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28198: - Issue Type: Technical Debt (was: Bug) > CassandraConnectorITCase fails with timeout > -

[jira] [Updated] (FLINK-27751) Dependency resolution from repository.jboss.org fails on CI

2022-08-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-27751: - Issue Type: Improvement (was: Bug) > Dependency resolution from repository.jboss.org fa

[jira] [Updated] (FLINK-27751) Dependency resolution from repository.jboss.org fails on CI

2022-08-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-27751: - Issue Type: Technical Debt (was: Improvement) > Dependency resolution from repository.j

[jira] [Updated] (FLINK-27485) Documentation build pipeline is broken

2022-08-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-27485: - Issue Type: Technical Debt (was: Bug) > Documentation build pipeline is broken > -

[jira] [Updated] (FLINK-27163) Fix typo issue in Flink Metrics documentation

2022-08-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-27163: - Issue Type: Technical Debt (was: Bug) > Fix typo issue in Flink Metrics documentation >

[jira] [Updated] (FLINK-26710) TestLoggerResource hides log lines

2022-08-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-26710: - Issue Type: Technical Debt (was: Bug) > TestLoggerResource hides log lines > --

[jira] [Updated] (FLINK-26553) Enable scalafmt for scala codebase

2022-08-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-26553: - Issue Type: Technical Debt (was: Bug) > Enable scalafmt for scala codebase > --

[jira] [Updated] (FLINK-14998) Remove FileUtils#deletePathIfEmpty

2022-08-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-14998: - Issue Type: Technical Debt (was: Bug) > Remove FileUtils#deletePathIfEmpty > --

[jira] [Updated] (FLINK-19358) HA should not always use jobid 0000000000

2022-08-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-19358: - Summary: HA should not always use jobid 00 (was: when submit job on application

[jira] [Updated] (FLINK-19358) when submit job on application mode with HA,the jobid will be 0000000000

2022-08-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-19358: - Issue Type: Improvement (was: Bug) > when submit job on application mode with HA,the jo

[jira] [Updated] (FLINK-28722) Hybrid Source should use .equals() for Integer comparison

2022-08-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28722: - Issue Type: Bug (was: Improvement) > Hybrid Source should use .equals() for Integer com

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

2022-08-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-25806: - Issue Type: Technical Debt (was: Improvement) > Remove legacy high availability service

[jira] [Updated] (FLINK-26958) Add Github Actions build pipeline for flink-connector-elasticsearch

2022-08-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-26958: - Issue Type: Technical Debt (was: Improvement) > Add Github Actions build pipeline for f

[GitHub] [flink] tisonkun merged pull request #19972: [FLINK-27399][Connector/Pulsar] Change initial consuming position setting logic for better handle the checkpoint.

2022-08-12 Thread GitBox
tisonkun merged PR #19972: URL: https://github.com/apache/flink/pull/19972 -- 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.apac

[jira] [Commented] (FLINK-28931) BlockingPartitionBenchmark doesn't compile

2022-08-12 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17578953#comment-17578953 ] Roman Khachatryan commented on FLINK-28931: --- I don't think this was a technica

[jira] [Commented] (FLINK-28931) BlockingPartitionBenchmark doesn't compile

2022-08-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17578956#comment-17578956 ] Chesnay Schepler commented on FLINK-28931: -- To me a bug has to directly impact

[GitHub] [flink] zentol merged pull request #20556: [FLINK-28932][Table/SQL] Use Builder#withConfiguration instead of deprecated EnvironmentSettings#fromConfiguration

2022-08-12 Thread GitBox
zentol merged PR #20556: URL: https://github.com/apache/flink/pull/20556 -- 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] [Closed] (FLINK-28932) Use Builder#withConfiguration instead of deprecated EnvironmentSettings#fromConfiguration

2022-08-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-28932. Fix Version/s: 1.16.0 Assignee: Sergey Nuyanzin Resolution: Fixed master:

[jira] [Created] (FLINK-28949) Secondary job manager fails to retrieve savepoint

2022-08-12 Thread Tiago Rodrigues (Jira)
Tiago Rodrigues created FLINK-28949: --- Summary: Secondary job manager fails to retrieve savepoint Key: FLINK-28949 URL: https://issues.apache.org/jira/browse/FLINK-28949 Project: Flink Issue

[jira] [Updated] (FLINK-28949) Secondary job manager fails to retrieve savepoint

2022-08-12 Thread Tiago Rodrigues (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tiago Rodrigues updated FLINK-28949: Description: After creating a savepoint, its information cannot be retrieved unless the AP

[jira] [Closed] (FLINK-28949) Secondary job manager fails to retrieve savepoint

2022-08-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-28949. Resolution: Duplicate This is fixed in 1.15. > Secondary job manager fails to retrieve sa

[GitHub] [flink] ganlute commented on pull request #20542: [FLINK-28910][connectors/hbase]CDC From Mysql To Hbase Bugs

2022-08-12 Thread GitBox
ganlute commented on PR #20542: URL: https://github.com/apache/flink/pull/20542#issuecomment-1213132485 @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] [Created] (FLINK-28950) Disable HBase2 version check in hbase-default.xml

2022-08-12 Thread xi chaomin (Jira)
xi chaomin created FLINK-28950: -- Summary: Disable HBase2 version check in hbase-default.xml Key: FLINK-28950 URL: https://issues.apache.org/jira/browse/FLINK-28950 Project: Flink Issue Type: Imp

[GitHub] [flink] xicm opened a new pull request, #20562: [FLINK-28950] Disable HBase2 version check in hbase-default.xml

2022-08-12 Thread GitBox
xicm opened a new pull request, #20562: URL: https://github.com/apache/flink/pull/20562 ## 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 on ea

[jira] [Updated] (FLINK-28950) Disable HBase2 version check in hbase-default.xml

2022-08-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28950: --- Labels: pull-request-available (was: ) > Disable HBase2 version check in hbase-default.xml

[GitHub] [flink] flinkbot commented on pull request #20562: [FLINK-28950] Disable HBase2 version check in hbase-default.xml

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

  1   2   >