[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #305: [FLINK-28447] GitHub Pull Request template

2022-07-08 Thread GitBox
gyfora commented on code in PR #305: URL: https://github.com/apache/flink-kubernetes-operator/pull/305#discussion_r917226385 ## .github/PULL_REQUEST_TEMPLATE.md: ## @@ -0,0 +1,68 @@ + + +## What is the purpose of the change + +*(For example: This pull request adds a new

[GitHub] [flink-docker] Myasuka commented on a diff in pull request #117: [FLINK-28057] Fix LD_PRELOAD on ARM images

2022-07-08 Thread GitBox
Myasuka commented on code in PR #117: URL: https://github.com/apache/flink-docker/pull/117#discussion_r917225904 ## 1.15/scala_2.12-java11-debian/docker-entrypoint.sh: ## @@ -91,7 +91,12 @@ prepare_configuration() { maybe_enable_jemalloc() { if [

[GitHub] [flink] zhuzhurk commented on a diff in pull request #20153: [FLINK-28144][runtime] Let JobMaster support blocklist.

2022-07-08 Thread GitBox
zhuzhurk commented on code in PR #20153: URL: https://github.com/apache/flink/pull/20153#discussion_r917217609 ## flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterTest.java: ## @@ -1384,8 +1374,9 @@ public void testRequestPartitionState() throws Exception

[jira] [Commented] (FLINK-28364) Python Job support for Kubernetes Operator

2022-07-08 Thread wu3396 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564511#comment-17564511 ] wu3396 commented on FLINK-28364:   My thought is that it is easy for users to use, and there are

[GitHub] [flink] zhuzhurk commented on a diff in pull request #20222: [FLINK-28137] Introduce SpeculativeScheduler

2022-07-08 Thread GitBox
zhuzhurk commented on code in PR #20222: URL: https://github.com/apache/flink/pull/20222#discussion_r917214684 ## flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/failover/flip1/ExecutionFailureHandlerTest.java: ## @@ -71,122 +74,125 @@ public void setUp() {

[GitHub] [flink] zhuzhurk commented on pull request #20221: [FLINK-28402] Create FailureHandlingResultSnapshot with the truly failed execution

2022-07-08 Thread GitBox
zhuzhurk commented on PR #20221: URL: https://github.com/apache/flink/pull/20221#issuecomment-1179457223 @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] mas-chen commented on pull request #19366: [FLINK-24660][Connectors / Kafka] allow setting KafkaSubscriber in KafkaSourceBuilder

2022-07-08 Thread GitBox
mas-chen commented on PR #19366: URL: https://github.com/apache/flink/pull/19366#issuecomment-1179434006 @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] flinkbot commented on pull request #20230: [FLINK-28449][tests][JUnit5 migration] flink-parquet

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

[jira] [Updated] (FLINK-28449) [JUnit5 Migration] Module: flink-parquet

2022-07-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28449: --- Labels: pull-request-available (was: ) > [JUnit5 Migration] Module: flink-parquet >

[GitHub] [flink] RyanSkraba opened a new pull request, #20230: [FLINK-28449][tests][JUnit5 migration] flink-parquet

2022-07-08 Thread GitBox
RyanSkraba opened a new pull request, #20230: URL: https://github.com/apache/flink/pull/20230 ## What is the purpose of the change Update the `flink-formats/flink-parquet` module to AssertJ and JUnit 5 following the [JUnit 5 Migration

[jira] [Updated] (FLINK-26366) Support "insert directory"

2022-07-08 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26366: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Updated] (FLINK-26202) Support Table API in Pulsar Source Connector

2022-07-08 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26202: --- Labels: Pulsar auto-deprioritized-major (was: Pulsar stale-major) Priority: Minor

[jira] [Updated] (FLINK-26238) PulsarSinkITCase.writeRecordsToPulsar failed on azure

2022-07-08 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26238: --- Labels: auto-deprioritized-major test-stability (was: stale-major test-stability)

[jira] [Updated] (FLINK-26237) PulsarSourceOrderedE2ECase failed on azure due to timeout

2022-07-08 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26237: --- Labels: auto-deprioritized-major test-stability (was: stale-major test-stability)

[jira] [Updated] (FLINK-26203) Support Table API in Pulsar Sink Connector

2022-07-08 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26203: --- Labels: Pulsar auto-deprioritized-major (was: Pulsar stale-major) Priority: Minor

[jira] [Updated] (FLINK-27529) HybridSourceSplitEnumerator sourceIndex using error Integer check

2022-07-08 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-27529: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Updated] (FLINK-27710) Improve logs to better display Execution

2022-07-08 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-27710: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Commented] (FLINK-25784) SerializedThrowable(De)Serializer out of sync

2022-07-08 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564456#comment-17564456 ] Weijie Guo commented on FLINK-25784: In `SerializedThrowableSerializer`, the other two fields have

[jira] [Commented] (FLINK-28399) Refactor CheckedThread to accept runnable via constructor

2022-07-08 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564448#comment-17564448 ] Weijie Guo commented on FLINK-28399: Hi [~chesnay] Thanks for open this ticket, I think this idea

[jira] [Comment Edited] (FLINK-28399) Refactor CheckedThread to accept runnable via constructor

2022-07-08 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564448#comment-17564448 ] Weijie Guo edited comment on FLINK-28399 at 7/8/22 8:07 PM: Hi [~chesnay]

[GitHub] [flink] flinkbot commented on pull request #20229: [FLINK-28399] Refactor CheckedThread to accept runnable via constructor

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

[GitHub] [flink] flinkbot commented on pull request #20228: [hotfix] [docs] Fix small typo in flink-conf.yaml file

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

[jira] [Updated] (FLINK-28399) Refactor CheckedThread to accept runnable via constructor

2022-07-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28399: --- Labels: pull-request-available (was: ) > Refactor CheckedThread to accept runnable via

[GitHub] [flink] reswqa opened a new pull request, #20229: [FLINK-28399] Refactor CheckedThread to accept runnable via constructor

2022-07-08 Thread GitBox
reswqa opened a new pull request, #20229: URL: https://github.com/apache/flink/pull/20229 ## What is the purpose of the change Let `CheckedThread` supports pass a `RunnableWithException` to constructor, this will make it behave more like a thread. After this pr, we can use

[GitHub] [flink] lkokhreidze opened a new pull request, #20228: [hotfix] [docs] Fix small typo in flink-conf.yaml file

2022-07-08 Thread GitBox
lkokhreidze opened a new pull request, #20228: URL: https://github.com/apache/flink/pull/20228 Fixes small typo in flink-conf.yaml. file. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above

[GitHub] [flink] sunshineJK commented on pull request #20127: [FLINK-26270] Flink SQL write data to kafka by CSV format , whether d…

2022-07-08 Thread GitBox
sunshineJK commented on PR #20127: URL: https://github.com/apache/flink/pull/20127#issuecomment-1179279118 hi @afedulov , Parameter name has been modified, thank you for your suggestion -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[jira] [Commented] (FLINK-27893) Add additionalPrinterColumns for Job Status and Reconciliation Status in CRDs

2022-07-08 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564401#comment-17564401 ] Gyula Fora commented on FLINK-27893: Thank you for the input [~maddisondavid] , I see the value but

[GitHub] [flink] flinkbot commented on pull request #20227: [FLINK-28471]Translate hive_read_write.md into Chinese

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

[jira] [Updated] (FLINK-28471) Translate hive_read_write.md into Chinese

2022-07-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28471: --- Labels: pull-request-available (was: ) > Translate hive_read_write.md into Chinese >

[GitHub] [flink] eyys opened a new pull request, #20227: [FLINK-28471]Translate hive_read_write.md into Chinese

2022-07-08 Thread GitBox
eyys opened a new pull request, #20227: URL: https://github.com/apache/flink/pull/20227 https://issues.apache.org/jira/browse/FLINK-28471 Hello, I have translated the hive_read_write.md into Chinese. It is my first attempt to translate it. I hope to get your correction for the

[GitHub] [flink] snuyanzin commented on pull request #20224: [FLINK-28466][Tests] Bump assertj to 3.23.1

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

[jira] [Created] (FLINK-28471) Translate hive_read_write.md into Chinese

2022-07-08 Thread eyys (Jira)
eyys created FLINK-28471: Summary: Translate hive_read_write.md into Chinese Key: FLINK-28471 URL: https://issues.apache.org/jira/browse/FLINK-28471 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-27893) Add additionalPrinterColumns for Job Status and Reconciliation Status in CRDs

2022-07-08 Thread David Maddison (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564362#comment-17564362 ] David Maddison commented on FLINK-27893: I do agree that the JobState reflects a point in time

[jira] [Commented] (FLINK-28250) exactly-once sink kafka cause out of memory

2022-07-08 Thread Chalres Tan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564358#comment-17564358 ] Chalres Tan commented on FLINK-28250: - Hi all, I've gone ahead and opened a PR with

[GitHub] [flink] HuangZhenQiu commented on pull request #20176: [FLINK-27660][table] add table api for registering function with resource

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

[jira] [Comment Edited] (FLINK-27357) In Flink HA Service on K8S, Web UI External Service should point to elected Job Manager leader's IP

2022-07-08 Thread Jesus H Christ (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564348#comment-17564348 ] Jesus H Christ edited comment on FLINK-27357 at 7/8/22 4:14 PM:

[jira] [Commented] (FLINK-27357) In Flink HA Service on K8S, Web UI External Service should point to elected Job Manager leader's IP

2022-07-08 Thread Jesus H Christ (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564348#comment-17564348 ] Jesus H Christ commented on FLINK-27357: Yes, that would be the correct solution. I will

[jira] [Created] (FLINK-28470) Show source watermarks on dashboard

2022-07-08 Thread James (Jira)
James created FLINK-28470: - Summary: Show source watermarks on dashboard Key: FLINK-28470 URL: https://issues.apache.org/jira/browse/FLINK-28470 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-28469) Setting a timer within broadcast applyToKeyedState()

2022-07-08 Thread James (Jira)
James created FLINK-28469: - Summary: Setting a timer within broadcast applyToKeyedState() Key: FLINK-28469 URL: https://issues.apache.org/jira/browse/FLINK-28469 Project: Flink Issue Type:

[jira] [Commented] (FLINK-28357) Watermark issue when recovering Finished sources

2022-07-08 Thread James (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564346#comment-17564346 ] James commented on FLINK-28357: --- Hello - sorry been busy and just got round to rechecking my test program. 

[jira] [Updated] (FLINK-28357) Watermark issue when recovering Finished sources

2022-07-08 Thread James (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James updated FLINK-28357: -- Attachment: image-2022-07-08-17-06-01-256.png > Watermark issue when recovering Finished sources >

[jira] [Commented] (FLINK-23528) stop-with-savepoint can fail with FlinkKinesisConsumer

2022-07-08 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564343#comment-17564343 ] Arvid Heise commented on FLINK-23528: - As far as I remember, I needed to fix this for the tests to

[jira] [Commented] (FLINK-24229) [FLIP-171] DynamoDB implementation of Async Sink

2022-07-08 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564342#comment-17564342 ] Danny Cranmer commented on FLINK-24229: --- [~Gusev] I think we certainly need to hide the

[jira] [Commented] (FLINK-27438) SQL validation failed when constructing a map array

2022-07-08 Thread Roman Boyko (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564339#comment-17564339 ] Roman Boyko commented on FLINK-27438: - Hi [~twalthr] ! Could you please check the changed fix -

[GitHub] [flink] rkhachatryan commented on a diff in pull request #19309: [FLINK-26964][state/heap] Notify CheckpointStrategy about checkpoint completion/abortion

2022-07-08 Thread GitBox
rkhachatryan commented on code in PR #19309: URL: https://github.com/apache/flink/pull/19309#discussion_r916946400 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java: ## @@ -333,13 +334,17 @@ public SavepointResources savepoint() {

[jira] [Commented] (FLINK-28325) DataOutputSerializer#writeBytes increase position twice

2022-07-08 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564338#comment-17564338 ] Weijie Guo commented on FLINK-28325: duplicate as FLINK-23598 > DataOutputSerializer#writeBytes

[GitHub] [flink] reswqa commented on pull request #20157: [FLINK-28326][runtime] fix unstable test ResultPartitionTest.testIdleAndBackPressuredTime.

2022-07-08 Thread GitBox
reswqa commented on PR #20157: URL: https://github.com/apache/flink/pull/20157#issuecomment-1179124729 Hi @zentol, I have update this pull request by your suggestion, PTAL~ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Closed] (FLINK-28172) Scatter dstl files into separate directories by job id

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

[jira] [Comment Edited] (FLINK-28364) Python Job support for Kubernetes Operator

2022-07-08 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564329#comment-17564329 ] Nicholas Jiang edited comment on FLINK-28364 at 7/8/22 3:35 PM:

[GitHub] [flink] rkhachatryan merged pull request #20093: [FLINK-28172][changelog] Scatter dstl files into separate directories…

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

[GitHub] [flink] mas-chen commented on pull request #19366: [FLINK-24660][Connectors / Kafka] allow setting KafkaSubscriber in KafkaSourceBuilder

2022-07-08 Thread GitBox
mas-chen commented on PR #19366: URL: https://github.com/apache/flink/pull/19366#issuecomment-1179122465 @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-28364) Python Job support for Kubernetes Operator

2022-07-08 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564329#comment-17564329 ] Nicholas Jiang commented on FLINK-28364: [~bgeng777], the users build a custom image which has

[GitHub] [flink] reswqa commented on a diff in pull request #20222: [FLINK-28137] Introduce SpeculativeScheduler

2022-07-08 Thread GitBox
reswqa commented on code in PR #20222: URL: https://github.com/apache/flink/pull/20222#discussion_r916889626 ## flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/failover/flip1/ExecutionFailureHandlerTest.java: ## @@ -71,122 +74,125 @@ public void setUp() {

[jira] [Commented] (FLINK-24229) [FLIP-171] DynamoDB implementation of Async Sink

2022-07-08 Thread Yuri Gusev (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564322#comment-17564322 ] Yuri Gusev commented on FLINK-24229: Ok thanks, we had few open questions in progress (like hiding

[jira] [Comment Edited] (FLINK-24229) [FLIP-171] DynamoDB implementation of Async Sink

2022-07-08 Thread Yuri Gusev (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564322#comment-17564322 ] Yuri Gusev edited comment on FLINK-24229 at 7/8/22 3:08 PM: Ok thanks, we

[GitHub] [flink] afedulov commented on a diff in pull request #20204: [hotfix][docs] Update code formatting instructions for newer IntelliJ versions.

2022-07-08 Thread GitBox
afedulov commented on code in PR #20204: URL: https://github.com/apache/flink/pull/20204#discussion_r916905260 ## docs/content/docs/flinkDev/ide_setup.md: ## @@ -149,6 +149,12 @@ It is recommended to automatically format your code by applying the following se 8. Under

[GitHub] [flink] 1996fanrui commented on pull request #20214: [FLINK-28454][kafka][docs] Fix the wrong timestamp unit of KafkaSource

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

[jira] [Assigned] (FLINK-27556) Performance regression in checkpointSingleInput.UNALIGNED on 29.04.2022

2022-07-08 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-27556: - Assignee: Roman Khachatryan > Performance regression in

[jira] [Closed] (FLINK-27556) Performance regression in checkpointSingleInput.UNALIGNED on 29.04.2022

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

[GitHub] [flink] rkhachatryan merged pull request #20173: [FLINK-27556][state] Inline state handle id generation

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

[jira] [Commented] (FLINK-26721) PulsarSourceITCase.testSavepoint failed on azure pipeline

2022-07-08 Thread Yufan Sheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564317#comment-17564317 ] Yufan Sheng commented on FLINK-26721: - [~martijnvisser] Pulsar 2.10.0 fixes the unstable tests on

[GitHub] [flink] rkhachatryan commented on pull request #20173: [FLINK-27556][state] Inline state handle id generation

2022-07-08 Thread GitBox
rkhachatryan commented on PR #20173: URL: https://github.com/apache/flink/pull/20173#issuecomment-1179085624 Thanks for the review @akalash, the failure is unrelated (FLINK-28391) and did not happen in my private

[jira] [Commented] (FLINK-27831) Provide example of Beam on the k8s operator

2022-07-08 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-27831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564309#comment-17564309 ] Márton Balassi commented on FLINK-27831: I am creating an example within the

[jira] [Assigned] (FLINK-28468) Creating benchmark channel in Apache Flink slack

2022-07-08 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov reassigned FLINK-28468: - Assignee: Anton Kalashnikov > Creating benchmark channel in Apache Flink slack

[jira] [Created] (FLINK-28468) Creating benchmark channel in Apache Flink slack

2022-07-08 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-28468: - Summary: Creating benchmark channel in Apache Flink slack Key: FLINK-28468 URL: https://issues.apache.org/jira/browse/FLINK-28468 Project: Flink

[jira] [Updated] (FLINK-28447) Create Kubernetes Operator PR template

2022-07-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28447: --- Labels: pull-request-available (was: ) > Create Kubernetes Operator PR template >

[GitHub] [flink-kubernetes-operator] mbalassi opened a new pull request, #305: [FLINK-28447] GitHub Pull Request template

2022-07-08 Thread GitBox
mbalassi opened a new pull request, #305: URL: https://github.com/apache/flink-kubernetes-operator/pull/305 I have started from the template in the main Flink repo and made some simplification given the smaller scope of the project. Let me know if you prefer to make the guide more

[GitHub] [flink] flinkbot commented on pull request #20226: Fix Chinese document format errors.

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

[GitHub] [flink] liuzhuang2017 opened a new pull request, #20226: Fix Chinese document format errors.

2022-07-08 Thread GitBox
liuzhuang2017 opened a new pull request, #20226: URL: https://github.com/apache/flink/pull/20226 ## What is the purpose of the change - **In english document:** ![image](https://user-images.githubusercontent.com/95120044/178011233-bff09671-ebe7-4fea-98cc-1fbcabc49ade.png)

[GitHub] [flink] zentol commented on a diff in pull request #20204: [hotfix][docs] Update code formatting instructions for newer IntelliJ versions.

2022-07-08 Thread GitBox
zentol commented on code in PR #20204: URL: https://github.com/apache/flink/pull/20204#discussion_r916868414 ## docs/content/docs/flinkDev/ide_setup.md: ## @@ -149,6 +149,12 @@ It is recommended to automatically format your code by applying the following se 8. Under

[GitHub] [flink] echauchot commented on pull request #19935: [FLINK-27884] Move OutputFormatBase to flink-core to offer flush mechanism to all output formats

2022-07-08 Thread GitBox
echauchot commented on PR #19935: URL: https://github.com/apache/flink/pull/19935#issuecomment-1179030111 @zentol All discussions are resolved and CI passes. Is this PR ready for merging ? -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] zentol commented on a diff in pull request #20204: [hotfix][docs] Update code formatting instructions for newer IntelliJ versions.

2022-07-08 Thread GitBox
zentol commented on code in PR #20204: URL: https://github.com/apache/flink/pull/20204#discussion_r916837239 ## docs/content/docs/flinkDev/ide_setup.md: ## @@ -149,6 +149,12 @@ It is recommended to automatically format your code by applying the following se 8. Under

[GitHub] [flink] reswqa commented on a diff in pull request #20223: [FLINK-28457][runtime] Introduce JobStatusHook

2022-07-08 Thread GitBox
reswqa commented on code in PR #20223: URL: https://github.com/apache/flink/pull/20223#discussion_r916800623 ## flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/TestingJobStatusHook.java: ## @@ -0,0 +1,54 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [flink] reswqa commented on a diff in pull request #20223: [FLINK-28457][runtime] Introduce JobStatusHook

2022-07-08 Thread GitBox
reswqa commented on code in PR #20223: URL: https://github.com/apache/flink/pull/20223#discussion_r916804257 ## flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/DefaultSchedulerTest.java: ## @@ -1618,6 +1622,99 @@ public void

[jira] [Commented] (FLINK-24229) [FLIP-171] DynamoDB implementation of Async Sink

2022-07-08 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564293#comment-17564293 ] Danny Cranmer commented on FLINK-24229: --- [~Gusev] we will need to move the PR since it will be a

[jira] [Commented] (FLINK-24229) [FLIP-171] DynamoDB implementation of Async Sink

2022-07-08 Thread Yuri Gusev (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564286#comment-17564286 ] Yuri Gusev commented on FLINK-24229: Hi [~dannycranmer], Sure happy to do this once new repo is

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

2022-07-08 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-28388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564285#comment-17564285 ] Márton Balassi commented on FLINK-28388: Thanks [~dianfu]! > Python doc build breaking nightly

[jira] [Commented] (FLINK-24229) [FLIP-171] DynamoDB implementation of Async Sink

2022-07-08 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564283#comment-17564283 ] Danny Cranmer commented on FLINK-24229: --- Hey [~Gusev], I have the FLIP ready and currently under

[jira] [Commented] (FLINK-24229) [FLIP-171] DynamoDB implementation of Async Sink

2022-07-08 Thread Yuri Gusev (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564281#comment-17564281 ] Yuri Gusev commented on FLINK-24229: Hi [~dannycranmer] & Team any updates on when this could be

[GitHub] [flink] reswqa commented on a diff in pull request #20223: [FLINK-28457][runtime] Introduce JobStatusHook

2022-07-08 Thread GitBox
reswqa commented on code in PR #20223: URL: https://github.com/apache/flink/pull/20223#discussion_r916792016 ## flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/JobStatusHook.java: ## @@ -0,0 +1,41 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

[GitHub] [flink] afedulov commented on a diff in pull request #20204: [hotfix][docs] Update code formatting instructions for newer IntelliJ versions.

2022-07-08 Thread GitBox
afedulov commented on code in PR #20204: URL: https://github.com/apache/flink/pull/20204#discussion_r916787296 ## docs/content/docs/flinkDev/ide_setup.md: ## @@ -149,6 +149,12 @@ It is recommended to automatically format your code by applying the following se 8. Under

[jira] [Commented] (FLINK-28364) Python Job support for Kubernetes Operator

2022-07-08 Thread Biao Geng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564277#comment-17564277 ] Biao Geng commented on FLINK-28364: --- Following the pattern we have adopted for sql job example, I have

[jira] [Closed] (FLINK-28297) Incorrect metric group order for namespaced operator metrics

2022-07-08 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-28297. -- Resolution: Fixed merged to main 1b3acc23868f9ad09ea73e7556a7b31176496783 > Incorrect metric group

[jira] [Closed] (FLINK-27914) Integrate JOSDK metrics with Flink Metrics reporter

2022-07-08 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-27914. -- Resolution: Fixed merged to main 308f8add74165febaa2f80c61a2a9d242d8b0629 > Integrate JOSDK metrics

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #302: [FLINK-28297][FLINK-27914] Improve operator metric groups + Add JOSDK metric integration

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

[GitHub] [flink] lsyldliu commented on a diff in pull request #20223: [FLINK-28457][runtime] Introduce JobStatusHook

2022-07-08 Thread GitBox
lsyldliu commented on code in PR #20223: URL: https://github.com/apache/flink/pull/20223#discussion_r916762924 ## flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/DefaultExecutionGraph.java: ## @@ -1544,6 +1552,30 @@ private void

[jira] [Updated] (FLINK-28467) Flink Table API Avro format fails during schema evolution

2022-07-08 Thread Jaya Ananthram (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jaya Ananthram updated FLINK-28467: --- Summary: Flink Table API Avro format fails during schema evolution (was: AVRO Table API

[jira] [Commented] (FLINK-26621) ChangelogPeriodicMaterializationITCase crashes JVM on CI in RocksDB cleanup

2022-07-08 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564270#comment-17564270 ] Chesnay Schepler commented on FLINK-26621: -- Currently looping the test on CI. One of the runs

[jira] [Comment Edited] (FLINK-26621) ChangelogPeriodicMaterializationITCase crashes JVM on CI in RocksDB cleanup

2022-07-08 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564270#comment-17564270 ] Chesnay Schepler edited comment on FLINK-26621 at 7/8/22 12:34 PM: ---

[jira] [Comment Edited] (FLINK-28467) AVRO Table API fails during schema evolution

2022-07-08 Thread Jaya Ananthram (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564268#comment-17564268 ] Jaya Ananthram edited comment on FLINK-28467 at 7/8/22 12:33 PM: - *Root

[jira] [Commented] (FLINK-28467) AVRO Table API fails during schema evolution

2022-07-08 Thread Jaya Ananthram (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564268#comment-17564268 ] Jaya Ananthram commented on FLINK-28467: *Root cause:* It looks like the byte buffer is not

[jira] [Assigned] (FLINK-28408) FAQ / best practices page for Kubernetes Operator

2022-07-08 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-28408: -- Assignee: Matyas Orhidi > FAQ / best practices page for Kubernetes Operator >

[jira] [Created] (FLINK-28467) AVRO Table API fails during schema evolution

2022-07-08 Thread Jaya Ananthram (Jira)
Jaya Ananthram created FLINK-28467: -- Summary: AVRO Table API fails during schema evolution Key: FLINK-28467 URL: https://issues.apache.org/jira/browse/FLINK-28467 Project: Flink Issue Type:

[GitHub] [flink] flinkbot commented on pull request #20225: Update japicmp configuration for 1.15.1

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

[jira] [Commented] (FLINK-28187) Duplicate job submission for FlinkSessionJob

2022-07-08 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564261#comment-17564261 ] Gyula Fora commented on FLINK-28187: [~aitozi] we have similar logic now in Flink for Applications:

[jira] [Closed] (FLINK-28445) Support operator configuration from multiple configmaps

2022-07-08 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-28445. -- Resolution: Fixed Merged to main 56381ecf4515ff12d72fe6b1a245160580aacb72 > Support operator

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #304: [FLINK-28445] Support operator configuration from multiple configmaps

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

[GitHub] [flink] zentol commented on a diff in pull request #20204: [hotfix][docs] Update code formatting instructions for newer IntelliJ versions.

2022-07-08 Thread GitBox
zentol commented on code in PR #20204: URL: https://github.com/apache/flink/pull/20204#discussion_r916758185 ## docs/content/docs/flinkDev/ide_setup.md: ## @@ -149,6 +149,12 @@ It is recommended to automatically format your code by applying the following se 8. Under

[GitHub] [flink] afedulov commented on a diff in pull request #20204: [hotfix][docs] Update code formatting instructions for newer IntelliJ versions.

2022-07-08 Thread GitBox
afedulov commented on code in PR #20204: URL: https://github.com/apache/flink/pull/20204#discussion_r916748524 ## docs/content/docs/flinkDev/ide_setup.md: ## @@ -149,6 +149,12 @@ It is recommended to automatically format your code by applying the following se 8. Under

[GitHub] [flink-docker] nferrario commented on a diff in pull request #117: [FLINK-28057] Fix LD_PRELOAD on ARM images

2022-07-08 Thread GitBox
nferrario commented on code in PR #117: URL: https://github.com/apache/flink-docker/pull/117#discussion_r916746986 ## 1.15/scala_2.12-java11-debian/docker-entrypoint.sh: ## @@ -91,7 +91,12 @@ prepare_configuration() { maybe_enable_jemalloc() { if [

  1   2   3   >