[jira] [Updated] (FLINK-26349) AvroParquetReaders does not work with ReflectData

2022-02-25 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-26349: Fix Version/s: 1.15.0 > AvroParquetReaders does not work with ReflectData >

[jira] [Updated] (FLINK-26349) AvroParquetReaders does not work with ReflectData

2022-02-25 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-26349: Fix Version/s: (was: 1.15.0) > AvroParquetReaders does not work with ReflectData >

[jira] [Updated] (FLINK-26349) AvroParquetReaders does not work with ReflectData

2022-02-25 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-26349: Affects Version/s: (was: 1.15.0) > AvroParquetReaders does not work with ReflectData >

[GitHub] [flink] beyond1920 closed pull request #17793: [FLINK-21565][Table SQL/API] Support more integer types in TIMESTAMPADD

2022-02-25 Thread GitBox
beyond1920 closed pull request #17793: URL: https://github.com/apache/flink/pull/17793 -- 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] [Updated] (FLINK-26372) Allow to configure Changelog Storage per program

2022-02-25 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-26372: -- Description: It's currently possible to override state.backend.changelog.enabled per

[GitHub] [flink] flinkbot edited a comment on pull request #18869: [FLINK-26284] Introduces mark-for-deletion state in ZooKeeperStateHandleStore

2022-02-25 Thread GitBox
flinkbot edited a comment on pull request #18869: URL: https://github.com/apache/flink/pull/18869#issuecomment-1047490231 ## CI report: * da8a99fac89bc0c5c30c941cd4387208e87078bd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18865: [FLINK-25819][runtime] Reordered requesting and recycling buffers in order to avoid race condition in testIsAvailableOrNotAfterReques

2022-02-25 Thread GitBox
flinkbot edited a comment on pull request #18865: URL: https://github.com/apache/flink/pull/18865#issuecomment-1047019322 ## CI report: * 4c8d8ff1664dec8f6e497e7cb844ce5efe9694cd Azure:

[jira] [Commented] (FLINK-26349) AvroParquetReaders does not work with ReflectData

2022-02-25 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498100#comment-17498100 ] Jing Ge commented on FLINK-26349: - Thanks for the input, I will do further research on it. >

[jira] [Updated] (FLINK-25736) Chinese Translation - Update documentation for Kinesis Table Api

2022-02-25 Thread Zichen Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zichen Liu updated FLINK-25736: --- Fix Version/s: (was: 1.15.0) > Chinese Translation - Update documentation for Kinesis Table Api

[jira] [Updated] (FLINK-25737) Chinese Translation - Add documentation for Firehose Async Sink

2022-02-25 Thread Zichen Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zichen Liu updated FLINK-25737: --- Fix Version/s: (was: 1.15.0) > Chinese Translation - Add documentation for Firehose Async Sink

[jira] [Updated] (FLINK-25735) Chinese Translation - Add documentation for KDS Async Sink

2022-02-25 Thread Zichen Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zichen Liu updated FLINK-25735: --- Fix Version/s: (was: 1.15.0) > Chinese Translation - Add documentation for KDS Async Sink >

[jira] [Updated] (FLINK-26372) Allow to configure Changelog Storage per program

2022-02-25 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-26372: -- Summary: Allow to configure Changelog Storage per program (was: Allow Changelog

[jira] [Updated] (FLINK-26256) AWS SDK Async Event Loop Group Classloader Issue

2022-02-25 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-26256: -- Priority: Major (was: Critical) > AWS SDK Async Event Loop Group Classloader Issue >

[GitHub] [flink] dmvk commented on a change in pull request #18901: [FLINK-26286][kuberentes] Introduce idempotent KubernetesStateHandleS…

2022-02-25 Thread GitBox
dmvk commented on a change in pull request #18901: URL: https://github.com/apache/flink/pull/18901#discussion_r814721306 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/highavailability/KubernetesStateHandleStore.java ## @@ -379,39 +456,51 @@ public

[jira] [Created] (FLINK-26372) Allow Changelog Storage configuration per program

2022-02-25 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-26372: - Summary: Allow Changelog Storage configuration per program Key: FLINK-26372 URL: https://issues.apache.org/jira/browse/FLINK-26372 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #17830: [FLINK-24893][Table SQL/Client][FLIP-189] SQL Client prompts customization

2022-02-25 Thread GitBox
flinkbot edited a comment on pull request #17830: URL: https://github.com/apache/flink/pull/17830#issuecomment-973131002 ## CI report: * 63ddba017e24c798b2f75f773b645ecaa22b5bc3 Azure:

[jira] [Updated] (FLINK-24278) [FLIP-171] Async Sink Base Sink Developer Guide for Documentation

2022-02-25 Thread Zichen Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zichen Liu updated FLINK-24278: --- Fix Version/s: (was: 1.15.0) > [FLIP-171] Async Sink Base Sink Developer Guide for

[GitHub] [flink] flinkbot edited a comment on pull request #17725: [FLINK-24750][table][docs] Code blocks to prevent sql quotes convertion

2022-02-25 Thread GitBox
flinkbot edited a comment on pull request #17725: URL: https://github.com/apache/flink/pull/17725#issuecomment-963191520 ## CI report: * 472be86049919833eceb17604ecc04c0ec69fa16 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17505: [docs][typos] Misprint in types.md

2022-02-25 Thread GitBox
flinkbot edited a comment on pull request #17505: URL: https://github.com/apache/flink/pull/17505#issuecomment-945205008 ## CI report: * 296fb9bebf16af5b459692e423a547b829573745 Azure:

[GitHub] [flink] JingGe commented on pull request #18911: [FLINK-26357][format] add FLINK API annotations

2022-02-25 Thread GitBox
JingGe commented on pull request #18911: URL: https://github.com/apache/flink/pull/18911#issuecomment-1050793640 @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] [Updated] (FLINK-25144) Test Changelog State Backend manually

2022-02-25 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-25144: -- Labels: release-testing (was: ) > Test Changelog State Backend manually >

[jira] [Updated] (FLINK-25144) Test Changelog State Backend manually

2022-02-25 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-25144: -- Affects Version/s: 1.15.0 > Test Changelog State Backend manually >

[GitHub] [flink] JingGe commented on pull request #18911: [FLINK-26357][format] add FLINK API annotations

2022-02-25 Thread GitBox
JingGe commented on pull request #18911: URL: https://github.com/apache/flink/pull/18911#issuecomment-1050788912 > Thanks for the PR, @JingGe, I added some comments. In general, it looks fine to me, with the exception of two points: > > * What is the rationale behind marking the

[jira] [Updated] (FLINK-25144) Test Changelog State Backend manually

2022-02-25 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-25144: -- Description: This is a testing task for FLINK-21352 / FLIP-158. Test plan:

[jira] [Commented] (FLINK-25144) Test Changelog State Backend manually

2022-02-25 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498089#comment-17498089 ] Roman Khachatryan commented on FLINK-25144: --- Extracted from FLINK-21352 into an independent

[GitHub] [flink] snuyanzin commented on pull request #17505: [docs][typos] Misprint in types.md

2022-02-25 Thread GitBox
snuyanzin commented on pull request #17505: URL: https://github.com/apache/flink/pull/17505#issuecomment-1050787765 > please change the commit message to [hotfix][docs] ... and maybe rebase with the latest master sure, done -- This is an automated message from the Apache Git

[jira] [Commented] (FLINK-21352) FLIP-158: Generalized incremental checkpoints

2022-02-25 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498088#comment-17498088 ] Roman Khachatryan commented on FLINK-21352: --- Extracted FLINK-25144 into an independent Blocker

[GitHub] [flink] flinkbot edited a comment on pull request #18912: [FLINK-26353] flink stop --help does not list --type option

2022-02-25 Thread GitBox
flinkbot edited a comment on pull request #18912: URL: https://github.com/apache/flink/pull/18912#issuecomment-1050078111 ## CI report: * 34b7d3090acdce8d53f2537c7a34f060ab00e7ce Azure:

[jira] [Updated] (FLINK-26371) Support read hive variables using the syntax like select ${hiveconf:select_time}

2022-02-25 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26371: - Description: In hive, it's allow to read hive variables using "${xxx}" in sql like: {code:sql} select

[jira] [Updated] (FLINK-25144) Test Changelog State Backend manually

2022-02-25 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-25144: -- Parent: (was: FLINK-21352) Issue Type: Technical Debt (was: Sub-task) >

[jira] [Created] (FLINK-26371) Support read hive variables using the syntax like select ${hiveconf:select_time}

2022-02-25 Thread luoyuxia (Jira)
luoyuxia created FLINK-26371: Summary: Support read hive variables using the syntax like select ${hiveconf:select_time} Key: FLINK-26371 URL: https://issues.apache.org/jira/browse/FLINK-26371 Project:

[jira] [Updated] (FLINK-25144) Test Changelog State Backend manually

2022-02-25 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-25144: -- Summary: Test Changelog State Backend manually (was: Manual test) > Test Changelog

[jira] [Updated] (FLINK-25144) Manual test

2022-02-25 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-25144: -- Priority: Blocker (was: Major) > Manual test > --- > > Key:

[GitHub] [flink] flinkbot commented on pull request #18922: [BP-1.13][FLINK-26285] Fixes an inconsistency

2022-02-25 Thread GitBox
flinkbot commented on pull request #18922: URL: https://github.com/apache/flink/pull/18922#issuecomment-1050783887 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot commented on pull request #18921: [BP-1.14][FLINK-26285] Fixes an inconsistency

2022-02-25 Thread GitBox
flinkbot commented on pull request #18921: URL: https://github.com/apache/flink/pull/18921#issuecomment-1050783908 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Commented] (FLINK-26349) AvroParquetReaders does not work with ReflectData

2022-02-25 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498082#comment-17498082 ] Dawid Wysakowicz commented on FLINK-26349: -- That is not true. The problem I pointed above is

[GitHub] [flink] fapaul merged pull request #17636: [hotfix][typos] Typos in PULL_REQUEST_TEMPLATE.md

2022-02-25 Thread GitBox
fapaul merged pull request #17636: URL: https://github.com/apache/flink/pull/17636 -- 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] XComp opened a new pull request #18922: [BP-1.13][FLINK-26285] Fixes an inconsistency

2022-02-25 Thread GitBox
XComp opened a new pull request #18922: URL: https://github.com/apache/flink/pull/18922 This serves as a 1.13 backport for PR #18919 The cherry-pick only caused some minor import conflict due to the upgrade from `curator4` to `curator5` and `guava18` to `guava30` See the parent

[jira] [Commented] (FLINK-26349) AvroParquetReaders does not work with ReflectData

2022-02-25 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498080#comment-17498080 ] Jing Ge commented on FLINK-26349: - hmm, I think it is a question of how the standard AvroParquet works

[GitHub] [flink] flinkbot edited a comment on pull request #18869: [FLINK-26284] Introduces mark-for-deletion state in ZooKeeperStateHandleStore

2022-02-25 Thread GitBox
flinkbot edited a comment on pull request #18869: URL: https://github.com/apache/flink/pull/18869#issuecomment-1047490231 ## CI report: * 3c6641a82f49307803fab39e6fd9a69760c17ab4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18865: [FLINK-25819][runtime] Reordered requesting and recycling buffers in order to avoid race condition in testIsAvailableOrNotAfterReques

2022-02-25 Thread GitBox
flinkbot edited a comment on pull request #18865: URL: https://github.com/apache/flink/pull/18865#issuecomment-1047019322 ## CI report: * 4c8d8ff1664dec8f6e497e7cb844ce5efe9694cd Azure:

[GitHub] [flink] XComp opened a new pull request #18921: [BP-1.14][FLINK-26285] Fixes an inconsistency

2022-02-25 Thread GitBox
XComp opened a new pull request #18921: URL: https://github.com/apache/flink/pull/18921 This serves as a 1.14 backport for PR #18919 The cherry-pick only caused some minor import conflict due to the upgrade from curator4 to curator5 Description copied: ## What is the

[GitHub] [flink] beyond1920 commented on pull request #17793: [FLINK-21565][Table SQL/API] Support more integer types in TIMESTAMPADD

2022-02-25 Thread GitBox
beyond1920 commented on pull request #17793: URL: https://github.com/apache/flink/pull/17793#issuecomment-1050778958 @shenzhu LGTM. Thanks for contribution. -- 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] flinkbot commented on pull request #18920: [FLINK-26361][hive] add variables when create LogicFilter to fix "une…

2022-02-25 Thread GitBox
flinkbot commented on pull request #18920: URL: https://github.com/apache/flink/pull/18920#issuecomment-1050778751 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot edited a comment on pull request #18656: [FLINK-25249][connector/kafka] Reimplement KafkaTestEnvironment with KafkaContainer

2022-02-25 Thread GitBox
flinkbot edited a comment on pull request #18656: URL: https://github.com/apache/flink/pull/18656#issuecomment-1032337760 ## CI report: * 3d605d379cd71a6edfa470ec669bf08daaadce33 Azure:

[jira] [Updated] (FLINK-26361) "Unexpected correlate variable $cor0" when using hive dialect to write a subquery

2022-02-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26361: --- Labels: pull-request-available (was: ) > "Unexpected correlate variable $cor0" when using

[GitHub] [flink] flinkbot edited a comment on pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

2022-02-25 Thread GitBox
flinkbot edited a comment on pull request #18651: URL: https://github.com/apache/flink/pull/18651#issuecomment-1031863806 ## CI report: * 339c6100fb2530e9f72aa9da84b27e1748693d4b Azure:

[GitHub] [flink] luoyuxia opened a new pull request #18920: [FLINK-26361][hive] add variables when create LogicFilter to fix "une…

2022-02-25 Thread GitBox
luoyuxia opened a new pull request #18920: URL: https://github.com/apache/flink/pull/18920 …xpected correlate variable $cor0" exception. ## What is the purpose of the change To fix "unexpected correlate variable $cor0" exception using hive dialect. ## Brief change

[GitHub] [flink] flinkbot edited a comment on pull request #17725: [FLINK-24750][table][docs] Code blocks to prevent sql quotes convertion

2022-02-25 Thread GitBox
flinkbot edited a comment on pull request #17725: URL: https://github.com/apache/flink/pull/17725#issuecomment-963191520 ## CI report: * 472be86049919833eceb17604ecc04c0ec69fa16 Azure:

[GitHub] [flink-table-store] JingsongLi commented on pull request #23: [FLINK-26276] Introduce ITCase for table store source and sink

2022-02-25 Thread GitBox
JingsongLi commented on pull request #23: URL: https://github.com/apache/flink-table-store/pull/23#issuecomment-1050769940 @LadyForest @tsreaper I think I have resolved your comments, please take a look again. -- This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] XComp commented on pull request #18919: [FLINK-26285] Fixes an inconsistency

2022-02-25 Thread GitBox
XComp commented on pull request #18919: URL: https://github.com/apache/flink/pull/18919#issuecomment-1050769440 Thanks for your approval and confirmation. I ran into it when going through all the cases for the mark-for-deletion change to have the removal being done atomically

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #23: [FLINK-26276] Introduce ITCase for table store source and sink

2022-02-25 Thread GitBox
JingsongLi commented on a change in pull request #23: URL: https://github.com/apache/flink-table-store/pull/23#discussion_r814587417 ## File path: flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/global/GlobalCommitterOperator.java ## @@

[jira] [Assigned] (FLINK-26370) Make Flink cluster communication asynchronous

2022-02-25 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-26370: -- Assignee: Gyula Fora > Make Flink cluster communication asynchronous >

[jira] [Updated] (FLINK-26370) Make Flink cluster communication asynchronous

2022-02-25 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-26370: --- Description: In the current architecture calls to the flink clusters (through the rest client) are

[GitHub] [flink] XComp commented on pull request #18869: [FLINK-26284] Introduces mark-for-deletion state in ZooKeeperStateHandleStore

2022-02-25 Thread GitBox
XComp commented on pull request #18869: URL: https://github.com/apache/flink/pull/18869#issuecomment-1050766013 I did another minor refactoring in order to be consistent with the changes of #18901 (see [comment](https://github.com/apache/flink/pull/18901/files#r814672839)): `addAndLock`

[jira] [Created] (FLINK-26370) Make Flink cluster communication asynchronous

2022-02-25 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-26370: -- Summary: Make Flink cluster communication asynchronous Key: FLINK-26370 URL: https://issues.apache.org/jira/browse/FLINK-26370 Project: Flink Issue Type:

[GitHub] [flink] dawidwys commented on a change in pull request #18865: [FLINK-25819][runtime] Reordered requesting and recycling buffers in order to avoid race condition in testIsAvailableOrNotAfterR

2022-02-25 Thread GitBox
dawidwys commented on a change in pull request #18865: URL: https://github.com/apache/flink/pull/18865#discussion_r814683798 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPoolTest.java ## @@ -757,7 +746,7 @@ public void

[GitHub] [flink] flinkbot edited a comment on pull request #18910: [FLINK-26296] Add missing documentation for JobResultStore and repeatable resource cleanup strategy

2022-02-25 Thread GitBox
flinkbot edited a comment on pull request #18910: URL: https://github.com/apache/flink/pull/18910#issuecomment-1049985255 ## CI report: * 93de9d36f85fe69085d8ea1231d2054a382f9b8f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

2022-02-25 Thread GitBox
flinkbot edited a comment on pull request #18651: URL: https://github.com/apache/flink/pull/18651#issuecomment-1031863806 ## CI report: * 339c6100fb2530e9f72aa9da84b27e1748693d4b Azure:

[GitHub] [flink] akalash commented on a change in pull request #18865: [FLINK-25819][runtime] Reordered requesting and recycling buffers in order to avoid race condition in testIsAvailableOrNotAfterRe

2022-02-25 Thread GitBox
akalash commented on a change in pull request #18865: URL: https://github.com/apache/flink/pull/18865#discussion_r814683059 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPoolTest.java ## @@ -757,7 +746,7 @@ public void

[GitHub] [flink] snuyanzin commented on pull request #17636: [hotfix][typos] Typos in PULL_REQUEST_TEMPLATE.md

2022-02-25 Thread GitBox
snuyanzin commented on pull request #17636: URL: https://github.com/apache/flink/pull/17636#issuecomment-1050759049 @fapaul sorry for the poke, but this is already approved by @MartijnVisser and I noticed you've merged some of my similar PRs. -- This is an automated message from the

[GitHub] [flink] snuyanzin commented on pull request #17505: [docs][typos] Misprint in types.md

2022-02-25 Thread GitBox
snuyanzin commented on pull request #17505: URL: https://github.com/apache/flink/pull/17505#issuecomment-1050757880 @fapaul sorry for the poke, I noticed you've merged some of my similar PRs. -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] flinkbot edited a comment on pull request #18869: [FLINK-26284] Introduces mark-for-deletion state in ZooKeeperStateHandleStore

2022-02-25 Thread GitBox
flinkbot edited a comment on pull request #18869: URL: https://github.com/apache/flink/pull/18869#issuecomment-1047490231 ## CI report: * 3c6641a82f49307803fab39e6fd9a69760c17ab4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

2022-02-25 Thread GitBox
flinkbot edited a comment on pull request #18651: URL: https://github.com/apache/flink/pull/18651#issuecomment-1031863806 ## CI report: * 339c6100fb2530e9f72aa9da84b27e1748693d4b Azure:

[GitHub] [flink] wangyang0918 commented on pull request #13864: [FLINK-19543][k8s] Implement RunningJobsRegistry, JobGraphStore based on Kubernetes API

2022-02-25 Thread GitBox
wangyang0918 commented on pull request #13864: URL: https://github.com/apache/flink/pull/13864#issuecomment-1050753194 If you search for the nearest commit to 3dda515d2707b6ccaf3c0369bb2eaf39372b4b63 which contains `This closes #xxx`, then we will find this PR and get to the ticket.

[GitHub] [flink] XComp commented on a change in pull request #18901: [FLINK-26286][kuberentes] Introduce idempotent KubernetesStateHandleS…

2022-02-25 Thread GitBox
XComp commented on a change in pull request #18901: URL: https://github.com/apache/flink/pull/18901#discussion_r814672839 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/highavailability/KubernetesStateHandleStore.java ## @@ -132,31 +197,27 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #18919: [FLINK-26285] Fixes an inconsistency

2022-02-25 Thread GitBox
flinkbot edited a comment on pull request #18919: URL: https://github.com/apache/flink/pull/18919#issuecomment-1050740854 ## CI report: * 742ab75f87281f0ff37641276ce5bbac82516b75 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18913: [FLINK-26331] Make cleanup retry strategy configurable similar to how the task restart is configurable

2022-02-25 Thread GitBox
flinkbot edited a comment on pull request #18913: URL: https://github.com/apache/flink/pull/18913#issuecomment-1050153597 ## CI report: * c40adf10f7104f099655be65037b26ffba7be52b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18912: [FLINK-26353] flink stop --help does not list --type option

2022-02-25 Thread GitBox
flinkbot edited a comment on pull request #18912: URL: https://github.com/apache/flink/pull/18912#issuecomment-1050078111 ## CI report: * 34b7d3090acdce8d53f2537c7a34f060ab00e7ce Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18869: [FLINK-26284] Introduces mark-for-deletion state in ZooKeeperStateHandleStore

2022-02-25 Thread GitBox
flinkbot edited a comment on pull request #18869: URL: https://github.com/apache/flink/pull/18869#issuecomment-1047490231 ## CI report: * 59399b4d133e898af4b00965cd0de07989fe6815 Azure:

[jira] [Closed] (FLINK-26342) Add missing CSV format page

2022-02-25 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul closed FLINK-26342. --- > Add missing CSV format page > --- > > Key: FLINK-26342 >

[jira] [Updated] (FLINK-26342) Add missing CSV format page

2022-02-25 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-26342: Fix Version/s: 1.15.0 > Add missing CSV format page > --- > >

[jira] [Commented] (FLINK-26342) Add missing CSV format page

2022-02-25 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498058#comment-17498058 ] Fabian Paul commented on FLINK-26342: - Merged in master: aeb3822ece887734dcaed5b2554f5583488d2dc0 >

[jira] [Resolved] (FLINK-26342) Add missing CSV format page

2022-02-25 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul resolved FLINK-26342. - Resolution: Fixed > Add missing CSV format page > --- > >

[GitHub] [flink] fapaul merged pull request #18903: [FLINK-26342][docs][formats] Add DataStream documentation for the CSV format

2022-02-25 Thread GitBox
fapaul merged pull request #18903: URL: https://github.com/apache/flink/pull/18903 -- 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] fapaul commented on pull request #18903: [FLINK-26342][docs][formats] Add DataStream documentation for the CSV format

2022-02-25 Thread GitBox
fapaul commented on pull request #18903: URL: https://github.com/apache/flink/pull/18903#issuecomment-1050747253 Docs CI has passed I am merging -- 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] [Commented] (FLINK-26301) Test AvroParquet format

2022-02-25 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498056#comment-17498056 ] Dawid Wysakowicz commented on FLINK-26301: -- A very basic job works fine. I created parquet

[jira] [Closed] (FLINK-26301) Test AvroParquet format

2022-02-25 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-26301. Resolution: Done > Test AvroParquet format > --- > >

[jira] [Updated] (FLINK-24376) Operator name in OperatorCoordinator should not use chained name

2022-02-25 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-24376: - Fix Version/s: (was: 1.14.4) > Operator name in OperatorCoordinator should not use

[jira] [Updated] (FLINK-24735) SQL client crashes with `Cannot add expression of different type to set`

2022-02-25 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-24735: - Fix Version/s: (was: 1.14.4) > SQL client crashes with `Cannot add expression of

[jira] [Updated] (FLINK-25227) Comparing the equality of the same (boxed) numeric values returns false

2022-02-25 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-25227: - Fix Version/s: (was: 1.14.4) > Comparing the equality of the same (boxed) numeric

[jira] [Updated] (FLINK-23955) submit flink sql job error when flink HA on yarn is configured

2022-02-25 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-23955: - Fix Version/s: (was: 1.14.4) > submit flink sql job error when flink HA on yarn is

[jira] [Updated] (FLINK-25444) ClosureCleaner rejects ExecutionConfig as not be Serializable due to TextElement

2022-02-25 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-25444: - Fix Version/s: (was: 1.14.4) > ClosureCleaner rejects ExecutionConfig as not be

[jira] [Updated] (FLINK-25771) CassandraConnectorITCase.testRetrialAndDropTables timeouts on AZP

2022-02-25 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-25771: - Fix Version/s: (was: 1.14.4) > CassandraConnectorITCase.testRetrialAndDropTables

[jira] [Updated] (FLINK-26018) Unnecessary late events when using the new KafkaSource

2022-02-25 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-26018: - Fix Version/s: (was: 1.14.4) > Unnecessary late events when using the new

[jira] [Updated] (FLINK-21302) Fix NPE when use row_number() in over agg

2022-02-25 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-21302: - Fix Version/s: (was: 1.14.4) > Fix NPE when use row_number() in over agg >

[jira] [Updated] (FLINK-24491) ExecutionGraphInfo may not be archived when the dispatcher terminates

2022-02-25 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-24491: - Fix Version/s: (was: 1.14.4) > ExecutionGraphInfo may not be archived when the

[jira] [Updated] (FLINK-24483) Document what is Public API and what compatibility guarantees Flink is providing

2022-02-25 Thread Konstantin Knauf (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-24483: - Fix Version/s: (was: 1.14.4) > Document what is Public API and what compatibility

[GitHub] [flink] XComp commented on a change in pull request #18869: [FLINK-26284] Introduces mark-for-deletion state in ZooKeeperStateHandleStore

2022-02-25 Thread GitBox
XComp commented on a change in pull request #18869: URL: https://github.com/apache/flink/pull/18869#discussion_r814667385 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java ## @@ -375,7 +415,7 @@ public

[jira] [Updated] (FLINK-26285) ZooKeeperStateHandleStore does not handle not existing nodes properly in getAllAndLock

2022-02-25 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-26285: -- Priority: Minor (was: Major) > ZooKeeperStateHandleStore does not handle not existing nodes

[jira] [Assigned] (FLINK-26285) ZooKeeperStateHandleStore does not handle not existing nodes properly in getAllAndLock

2022-02-25 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-26285: - Assignee: Matthias Pohl > ZooKeeperStateHandleStore does not handle not existing nodes

[GitHub] [flink] flinkbot edited a comment on pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

2022-02-25 Thread GitBox
flinkbot edited a comment on pull request #18651: URL: https://github.com/apache/flink/pull/18651#issuecomment-1031863806 ## CI report: * 339c6100fb2530e9f72aa9da84b27e1748693d4b Azure:

[GitHub] [flink] XComp commented on pull request #18869: [FLINK-26284] Introduces mark-for-deletion state in ZooKeeperStateHandleStore

2022-02-25 Thread GitBox
XComp commented on pull request #18869: URL: https://github.com/apache/flink/pull/18869#issuecomment-1050742102 I reorganized the commits once more moving the FLINK-26285 fix into its own PR #18919 and rebased this branch onto the FLINK-26285 PR (that's why there's an additional commit

[GitHub] [flink] matriv commented on a change in pull request #18908: [FLINK-26075][table-api][table-planner] Persist and use node configuration

2022-02-25 Thread GitBox
matriv commented on a change in pull request #18908: URL: https://github.com/apache/flink/pull/18908#discussion_r814664404 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/ConfigurationJsonSerializerFilter.java

[GitHub] [flink] flinkbot commented on pull request #18919: [FLINK-26285] Fixes an inconsistency

2022-02-25 Thread GitBox
flinkbot commented on pull request #18919: URL: https://github.com/apache/flink/pull/18919#issuecomment-1050740854 ## CI report: * 742ab75f87281f0ff37641276ce5bbac82516b75 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] matriv commented on a change in pull request #18908: [FLINK-26075][table-api][table-planner] Persist and use node configuration

2022-02-25 Thread GitBox
matriv commented on a change in pull request #18908: URL: https://github.com/apache/flink/pull/18908#discussion_r814662369 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/ExecNodeConfig.java ## @@ -51,20 +51,20 @@

[GitHub] [flink] flinkbot commented on pull request #18919: [FLINK-26285] Fixes an inconsistency

2022-02-25 Thread GitBox
flinkbot commented on pull request #18919: URL: https://github.com/apache/flink/pull/18919#issuecomment-1050739719 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot edited a comment on pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

2022-02-25 Thread GitBox
flinkbot edited a comment on pull request #18651: URL: https://github.com/apache/flink/pull/18651#issuecomment-1031863806 ## CI report: * 339c6100fb2530e9f72aa9da84b27e1748693d4b Azure:

[jira] [Updated] (FLINK-21936) Rescale pointwise connections for unaligned checkpoints

2022-02-25 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21936: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-22265) Abnormal document display

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

<    1   2   3   4   5   >