[GitHub] [flink] flinkbot commented on pull request #16171: [FLINK-22886][State Backends] fix Thread leak in RocksDBStateUploader

flinkbot commented on pull request #16171: URL: https://github.com/apache/flink/pull/16171#issuecomment-862067374 ## CI report: * da7bdeeb228b36feb85493ecf24e21a36c551373 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] Airblader commented on a change in pull request #16166: [FLINK-23000] Add log bundler to collect and compress logs

Airblader commented on a change in pull request #16166: URL: https://github.com/apache/flink/pull/16166#discussion_r652361282 ## File path: flink-runtime-web/web-dashboard/src/app/app.component.html ## @@ -49,6 +49,9 @@ Apache Flink Dashboard Submit New Job

[GitHub] [flink] flinkbot edited a comment on pull request #16170: [hotfix][docs]Document format issues

flinkbot edited a comment on pull request #16170: URL: https://github.com/apache/flink/pull/16170#issuecomment-862025760 ## CI report: * f7124bc3e87aa654f83e759135e48a4230936403 Azure:

[GitHub] [flink] rmetzger edited a comment on pull request #16166: [FLINK-23000] Add log bundler to collect and compress logs

rmetzger edited a comment on pull request #16166: URL: https://github.com/apache/flink/pull/16166#issuecomment-861546021 Open TODOs: - [x] Test on minikube with large log files (to make sure there are no locks, or any other issues with remote file transfers / large files) - [x] Add a

[jira] [Commented] (FLINK-22886) Thread leak in RocksDBStateUploader

[ https://issues.apache.org/jira/browse/FLINK-22886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364075#comment-17364075 ] Yue Ma commented on FLINK-22886: [~yunta] Sorry for the late creation of pr.

[GitHub] [flink] rmetzger edited a comment on pull request #16166: [FLINK-23000] Add log bundler to collect and compress logs

rmetzger edited a comment on pull request #16166: URL: https://github.com/apache/flink/pull/16166#issuecomment-861546021 Open TODOs: - [x] Test on minikube with large log files (to make sure there are no locks, or any other issues with remote file transfers / large files) - [ ] Add a

[GitHub] [flink] flinkbot edited a comment on pull request #15200: [FLINK-21355] Send changes to the state changelog

flinkbot edited a comment on pull request #15200: URL: https://github.com/apache/flink/pull/15200#issuecomment-798902665 ## CI report: * 5e1342d9916f5c4356c622a40bc27bcbdacde9d7 UNKNOWN * bad38399fc85b1bd5e4dc122fe983801262c92ad Azure:

[GitHub] [flink] flinkbot commented on pull request #16171: [FLINK-22886][State Backends] fix Thread leak in RocksDBStateUploader

flinkbot commented on pull request #16171: URL: https://github.com/apache/flink/pull/16171#issuecomment-862052036 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] [Updated] (FLINK-22886) Thread leak in RocksDBStateUploader

[ https://issues.apache.org/jira/browse/FLINK-22886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22886: --- Labels: critical pull-request-available (was: critical) > Thread leak in

[GitHub] [flink] mayuehappy opened a new pull request #16171: [FLINK-22886][State Backends] fix Thread leak in RocksDBStateUploader

mayuehappy opened a new pull request #16171: URL: https://github.com/apache/flink/pull/16171 ## What is the purpose of the change fix the thread leak in RocksDBStateUploader ## Brief change log - name the thread group in RocksDBStateDataTransfer's ExecutorService

[GitHub] [flink] flinkbot edited a comment on pull request #16163: [FLINK-22994][Table SQL / Planner] improve the performace of invoking…

flinkbot edited a comment on pull request #16163: URL: https://github.com/apache/flink/pull/16163#issuecomment-861284972 ## CI report: * 00f7cd34fc503db8cc116dd201bcc7f54a4b6f20 UNKNOWN * 2601616d90b1e5e76290ef8d4b020a31226c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16096: [FLINK-22901][table] Introduce getChangeLogUpsertKeys in FlinkRelMetadataQuery

flinkbot edited a comment on pull request #16096: URL: https://github.com/apache/flink/pull/16096#issuecomment-855890303 ## CI report: * cacdca40ef74dc0f7f67e866325ecffe2dc7a586 UNKNOWN * a77d04839cd4e3c32623e545c73aff1ea624a3eb Azure:

[jira] [Updated] (FLINK-16641) Announce sender's backlog to solve the deadlock issue without exclusive buffers

[ https://issues.apache.org/jira/browse/FLINK-16641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-16641: Labels: pull-request-available (was: pull-request-available stale-assigned) > Announce sender's

[GitHub] [flink] xintongsong commented on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

xintongsong commented on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-862042096 Thanks for the info, @galenwarren. I guess I'll wait for the remaining being done. Concerning the testability, ideally yes. It would be nice to have test cases

[GitHub] [flink] RocMarshal removed a comment on pull request #16168: [FLINK-23003][runtime] Fix resource leak in RocksIncrementalSnapshotStrategy

RocMarshal removed a comment on pull request #16168: URL: https://github.com/apache/flink/pull/16168#issuecomment-862040908 @fredia Thank you for your contribution. LGTM +1, wait the CI passed. -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] RocMarshal commented on pull request #16168: [FLINK-23003][runtime] Fix resource leak in RocksIncrementalSnapshotStrategy

RocMarshal commented on pull request #16168: URL: https://github.com/apache/flink/pull/16168#issuecomment-862040908 @fredia Thank you for your contribution. LGTM +1, wait the CI passed. -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] flinkbot edited a comment on pull request #15317: [FLINK-20562][SQL-Client][Table-Api] Improvements,Support ExplainDetail…

flinkbot edited a comment on pull request #15317: URL: https://github.com/apache/flink/pull/15317#issuecomment-803958506 ## CI report: * 6b34ea34bb7720d8ef2ee8c98f6be11662a79ad1 UNKNOWN * 5066d4eee35d6bb379860c0cd6e08f02c6f6d277 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16170: [hotfix][docs]Document format issues

flinkbot edited a comment on pull request #16170: URL: https://github.com/apache/flink/pull/16170#issuecomment-862025760 ## CI report: * f7124bc3e87aa654f83e759135e48a4230936403 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16169: [FLINK-23004] Fix misleading log

flinkbot edited a comment on pull request #16169: URL: https://github.com/apache/flink/pull/16169#issuecomment-862025702 ## CI report: * 57da320969988670c6294be12f652ec7cd50e929 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16163: [FLINK-22994][Table SQL / Planner] improve the performace of invoking…

flinkbot edited a comment on pull request #16163: URL: https://github.com/apache/flink/pull/16163#issuecomment-861284972 ## CI report: * 00f7cd34fc503db8cc116dd201bcc7f54a4b6f20 UNKNOWN * 2601616d90b1e5e76290ef8d4b020a31226c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16096: [FLINK-22901][table] Introduce getChangeLogUpsertKeys in FlinkRelMetadataQuery

flinkbot edited a comment on pull request #16096: URL: https://github.com/apache/flink/pull/16096#issuecomment-855890303 ## CI report: * cacdca40ef74dc0f7f67e866325ecffe2dc7a586 UNKNOWN * a77d04839cd4e3c32623e545c73aff1ea624a3eb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15317: [FLINK-20562][SQL-Client][Table-Api] Improvements,Support ExplainDetail…

flinkbot edited a comment on pull request #15317: URL: https://github.com/apache/flink/pull/15317#issuecomment-803958506 ## CI report: * 6b34ea34bb7720d8ef2ee8c98f6be11662a79ad1 UNKNOWN * 5066d4eee35d6bb379860c0cd6e08f02c6f6d277 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN *

[GitHub] [flink] curcur commented on pull request #15200: [FLINK-21355] Send changes to the state changelog

curcur commented on pull request #15200: URL: https://github.com/apache/flink/pull/15200#issuecomment-862029755 Thanks @rkhachatryan ! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [flink] curcur commented on pull request #15200: [FLINK-21355] Send changes to the state changelog

curcur commented on pull request #15200: URL: https://github.com/apache/flink/pull/15200#issuecomment-862029547 I am fine as long as all the comments are addressed. Take a glance. approved. -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] flinkbot commented on pull request #16170: [hotfix][docs]Document format issues

flinkbot commented on pull request #16170: URL: https://github.com/apache/flink/pull/16170#issuecomment-862025760 ## CI report: * f7124bc3e87aa654f83e759135e48a4230936403 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #16169: [FLINK-23004] Fix misleading log

flinkbot commented on pull request #16169: URL: https://github.com/apache/flink/pull/16169#issuecomment-862025702 ## CI report: * 57da320969988670c6294be12f652ec7cd50e929 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15823: [FLINK-22462][jdbc] Fix connection leak and stabilize JdbcExactlyOnceSinkE2eTest

flinkbot edited a comment on pull request #15823: URL: https://github.com/apache/flink/pull/15823#issuecomment-831107274 ## CI report: * 9f7cdc6ffb1134c615c93175e12baae06af3e170 Azure:

[jira] [Commented] (FLINK-22735) HiveTableSourceITCase.testStreamPartitionReadByCreateTime failed because of times out

[ https://issues.apache.org/jira/browse/FLINK-22735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364047#comment-17364047 ] Rui Li commented on FLINK-22735: Just realized the recent failure is on 1.12 branch which doesn't have

[GitHub] [flink] laughingman7743 commented on a change in pull request #14376: [FLINK-18202][PB format] New Format of protobuf

laughingman7743 commented on a change in pull request #14376: URL: https://github.com/apache/flink/pull/14376#discussion_r652332960 ## File path: flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/serialize/RowToProtoConverter.java ## @@ -0,0 +1,111

[GitHub] [flink] laughingman7743 commented on a change in pull request #14376: [FLINK-18202][PB format] New Format of protobuf

laughingman7743 commented on a change in pull request #14376: URL: https://github.com/apache/flink/pull/14376#discussion_r652332960 ## File path: flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/serialize/RowToProtoConverter.java ## @@ -0,0 +1,111

[jira] [Updated] (FLINK-22994) Improve the performance of invoking nesting udf

[ https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-22994: --- Component/s: (was: Table SQL / Planner) Table SQL / Runtime > Improve the

[jira] [Updated] (FLINK-23005) Optimize the deployment of tasks

[ https://issues.apache.org/jira/browse/FLINK-23005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-23005: - Description: h3. Introduction The optimizations introduced in FLINK-21110 so far have improved

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a721a9d5f663117a203628547a19b33b23927ac2 UNKNOWN * 8f1051527a46aeba13aadc2db3c5f34d8aff78d2 UNKNOWN *

[jira] [Created] (FLINK-23005) Optimize the deployment of tasks

Zhilong Hong created FLINK-23005: Summary: Optimize the deployment of tasks Key: FLINK-23005 URL: https://issues.apache.org/jira/browse/FLINK-23005 Project: Flink Issue Type: Sub-task

[GitHub] [flink] zuston commented on pull request #16169: [FLINK-23004] Fix misleading log

zuston commented on pull request #16169: URL: https://github.com/apache/flink/pull/16169#issuecomment-862015661 @lirui-apache Please review it. Thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

[GitHub] [flink] flinkbot commented on pull request #16170: [hotfix][docs]Document format issues

flinkbot commented on pull request #16170: URL: https://github.com/apache/flink/pull/16170#issuecomment-862014515 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] simenliuxing opened a new pull request #16170: [hotfix][docs]Document format issues

simenliuxing opened a new pull request #16170: URL: https://github.com/apache/flink/pull/16170 ## What is the purpose of the change this page https://ci.apache.org/projects/flink/flink-docs-master/zh/docs/try-flink/datastream/ content "{% panel 说明:

[GitHub] [flink] maosuhan commented on a change in pull request #14376: [FLINK-18202][PB format] New Format of protobuf

maosuhan commented on a change in pull request #14376: URL: https://github.com/apache/flink/pull/14376#discussion_r652326974 ## File path: flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/serialize/RowToProtoConverter.java ## @@ -0,0 +1,111 @@ +/*

[GitHub] [flink] JingsongLi commented on pull request #16129: [FLINK-22956][table-runtime] Stream Over TTL should use enableTimeToLive of state instead of timer

JingsongLi commented on pull request #16129: URL: https://github.com/apache/flink/pull/16129#issuecomment-862013709 There is a problem with the implementation, and it is being modified. -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] flinkbot edited a comment on pull request #16168: [FLINK-23003][runtime] Fix resource leak in RocksIncrementalSnapshotStrategy

flinkbot edited a comment on pull request #16168: URL: https://github.com/apache/flink/pull/16168#issuecomment-862006295 ## CI report: * 0c51b09689868f19dbeb6113830ace734bd915be Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16163: [FLINK-22994][Table SQL / Planner] improve the performace of invoking…

flinkbot edited a comment on pull request #16163: URL: https://github.com/apache/flink/pull/16163#issuecomment-861284972 ## CI report: * 00f7cd34fc503db8cc116dd201bcc7f54a4b6f20 UNKNOWN * 2601616d90b1e5e76290ef8d4b020a31226c Azure:

[GitHub] [flink] flinkbot commented on pull request #16169: [FLINK-23004] Fix misleading log

flinkbot commented on pull request #16169: URL: https://github.com/apache/flink/pull/16169#issuecomment-862011285 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] maosuhan commented on a change in pull request #14376: [FLINK-18202][PB format] New Format of protobuf

maosuhan commented on a change in pull request #14376: URL: https://github.com/apache/flink/pull/14376#discussion_r652323821 ## File path: flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/PbFormatUtils.java ## @@ -0,0 +1,146 @@ +/* + * Licensed to

[jira] [Updated] (FLINK-23004) Fix misleading log

[ https://issues.apache.org/jira/browse/FLINK-23004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23004: --- Labels: pull-request-available (was: ) > Fix misleading log > -- > >

[GitHub] [flink] zuston opened a new pull request #16169: [FLINK-23004] Fix misleading log

zuston opened a new pull request #16169: URL: https://github.com/apache/flink/pull/16169 -- 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. For queries about this service,

[jira] [Created] (FLINK-23004) Fix misleading log

Junfan Zhang created FLINK-23004: Summary: Fix misleading log Key: FLINK-23004 URL: https://issues.apache.org/jira/browse/FLINK-23004 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-22980) FileExecutionGraphInfoStoreTest hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364034#comment-17364034 ] Xintong Song commented on FLINK-22980: -- An observation that might be related: For all the reported

[GitHub] [flink] flinkbot edited a comment on pull request #16163: [FLINK-22994][Table SQL / Planner] improve the performace of invoking…

flinkbot edited a comment on pull request #16163: URL: https://github.com/apache/flink/pull/16163#issuecomment-861284972 ## CI report: * 00f7cd34fc503db8cc116dd201bcc7f54a4b6f20 UNKNOWN * 2601616d90b1e5e76290ef8d4b020a31226c Azure:

[GitHub] [flink] flinkbot commented on pull request #16168: [FLINK-23003][runtime] Fix resource leak in RocksIncrementalSnapshotStrategy

flinkbot commented on pull request #16168: URL: https://github.com/apache/flink/pull/16168#issuecomment-862006295 ## CI report: * 0c51b09689868f19dbeb6113830ace734bd915be UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-22980) FileExecutionGraphInfoStoreTest hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364033#comment-17364033 ] Xintong Song commented on FLINK-22980: --

[jira] [Commented] (FLINK-22387) UpsertKafkaTableITCase hangs when setting up kafka

[ https://issues.apache.org/jira/browse/FLINK-22387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364032#comment-17364032 ] Xintong Song commented on FLINK-22387: --

[jira] [Commented] (FLINK-22480) KafkaChangelogTableITCase hangs on Azure

[ https://issues.apache.org/jira/browse/FLINK-22480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364031#comment-17364031 ] Xintong Song commented on FLINK-22480: --

[jira] [Comment Edited] (FLINK-23003) Resource leak in RocksIncrementalSnapshotStrategy

[ https://issues.apache.org/jira/browse/FLINK-23003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364027#comment-17364027 ] Yuan Mei edited comment on FLINK-23003 at 6/16/21, 2:53 AM: cc [~yunta]

[jira] [Commented] (FLINK-23003) Resource leak in RocksIncrementalSnapshotStrategy

[ https://issues.apache.org/jira/browse/FLINK-23003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364027#comment-17364027 ] Yuan Mei commented on FLINK-23003: -- cc [~yunta] [~roman_khachatryan]hatryan > Resource leak in

[jira] [Comment Edited] (FLINK-23003) Resource leak in RocksIncrementalSnapshotStrategy

[ https://issues.apache.org/jira/browse/FLINK-23003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364027#comment-17364027 ] Yuan Mei edited comment on FLINK-23003 at 6/16/21, 2:51 AM: cc [~yunta]

[GitHub] [flink] flinkbot commented on pull request #16168: [FLINK-23003][runtime] Fix resource leak in RocksIncrementalSnapshotStrategy

flinkbot commented on pull request #16168: URL: https://github.com/apache/flink/pull/16168#issuecomment-861993294 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] [Comment Edited] (FLINK-22999) Using the column 'user' in Table API is not possible

[ https://issues.apache.org/jira/browse/FLINK-22999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364019#comment-17364019 ] Jark Wu edited comment on FLINK-22999 at 6/16/21, 2:41 AM: --- Hi

[jira] [Closed] (FLINK-22999) Using the column 'user' in Table API is not possible

[ https://issues.apache.org/jira/browse/FLINK-22999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-22999. --- Resolution: Not A Problem Hi [~MartijnVisser], {{user}} is a reserved keyword in SQL, please use backticks

[jira] [Commented] (FLINK-23003) Resource leak in RocksIncrementalSnapshotStrategy

[ https://issues.apache.org/jira/browse/FLINK-23003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364018#comment-17364018 ] Jiayi Liao commented on FLINK-23003: [~Yanfei Lei] This looks like a duplicate of

[jira] [Updated] (FLINK-23003) Resource leak in RocksIncrementalSnapshotStrategy

[ https://issues.apache.org/jira/browse/FLINK-23003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23003: --- Labels: pull-request-available (was: ) > Resource leak in RocksIncrementalSnapshotStrategy

[GitHub] [flink] fredia opened a new pull request #16168: [FLINK-23003][runtime] Fix resource leak in RocksIncrementalSnapshotStrategy

fredia opened a new pull request #16168: URL: https://github.com/apache/flink/pull/16168 ## What is the purpose of the change This pull request fix resource leak in `RocksIncrementalSnapshotStrategy` caused by `RocksDBStateUploader` not being closed. ## Brief

[jira] [Commented] (FLINK-22937) rocksdb cause jvm to crash

[ https://issues.apache.org/jira/browse/FLINK-22937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364017#comment-17364017 ] Yun Tang commented on FLINK-22937: -- [~PiersSoCool], actually what I want is core dump file which could

[jira] [Updated] (FLINK-22994) Improve the performance of invoking nesting udf

[ https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lynn1.zhang updated FLINK-22994: Description: h1. BackGround Flink maintain the udf result as BinaryData, like BinaryStringData.

[jira] [Commented] (FLINK-22980) FileExecutionGraphInfoStoreTest hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364014#comment-17364014 ] Xintong Song commented on FLINK-22980: --

[jira] [Updated] (FLINK-23003) Resource leak in RocksIncrementalSnapshotStrategy

[ https://issues.apache.org/jira/browse/FLINK-23003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei updated FLINK-23003: --- Summary: Resource leak in RocksIncrementalSnapshotStrategy (was: resource leak in

[jira] [Created] (FLINK-23003) resource leak in RocksIncrementalSnapshotStrategy

Yanfei Lei created FLINK-23003: -- Summary: resource leak in RocksIncrementalSnapshotStrategy Key: FLINK-23003 URL: https://issues.apache.org/jira/browse/FLINK-23003 Project: Flink Issue Type:

[GitHub] [flink] meetjunsu commented on pull request #16122: [FLINK-21195][Connectors/FileSystem]LimitableBulkFormat is invalid wh…

meetjunsu commented on pull request #16122: URL: https://github.com/apache/flink/pull/16122#issuecomment-861983361 @JingsongLi There is already LimitedBulkFormatTest for TextLineFormat, maybe I can add cases in OrcFileSystemITCase and ParquetFileSystemITCase -- This is an automated

[jira] [Assigned] (FLINK-22085) KafkaSourceLegacyITCase hangs/fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-22085: Assignee: Yun Gao > KafkaSourceLegacyITCase hangs/fails on azure >

[jira] [Commented] (FLINK-22085) KafkaSourceLegacyITCase hangs/fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364012#comment-17364012 ] Xintong Song commented on FLINK-22085: -- Thanks a log, [~gaoyunhaii]. I've assigned you to the

[GitHub] [flink] chaozwn commented on a change in pull request #15317: [FLINK-20562][SQL-Client][Table-Api] Improvements,Support ExplainDetail…

chaozwn commented on a change in pull request #15317: URL: https://github.com/apache/flink/pull/15317#discussion_r652295126 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/operations/SqlToOperationConverter.java ## @@ -942,16

[jira] [Commented] (FLINK-22085) KafkaSourceLegacyITCase hangs/fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364011#comment-17364011 ] Xintong Song commented on FLINK-22085: --

[jira] [Commented] (FLINK-22459) FlinkKafkaProducerITCase testScaleUpAfterScalingDown failed because of Timeout expired after 60000milliseconds while awaiting EndTxn(COMMIT)

[ https://issues.apache.org/jira/browse/FLINK-22459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17364010#comment-17364010 ] Xintong Song commented on FLINK-22459: --

[jira] [Updated] (FLINK-6131) Add side inputs for DataStream API

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

[jira] [Updated] (FLINK-22805) Dynamic configuration of Flink checkpoint interval

[ https://issues.apache.org/jira/browse/FLINK-22805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22805: --- Labels: auto-deprioritized-critical (was: stale-critical) Priority: Major (was:

[jira] [Updated] (FLINK-19722) Pushdown Watermark to SourceProvider (new Source)

[ https://issues.apache.org/jira/browse/FLINK-19722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19722: --- Labels: stale-critical (was: ) I am the [Flink Jira

[jira] [Updated] (FLINK-22949) java.io.InvalidClassException With Flink Kafka Beam

[ https://issues.apache.org/jira/browse/FLINK-22949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22949: --- I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community

[jira] [Updated] (FLINK-21928) DuplicateJobSubmissionException after JobManager failover

[ https://issues.apache.org/jira/browse/FLINK-21928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21928: --- Labels: stale-critical (was: ) I am the [Flink Jira

[jira] [Updated] (FLINK-5865) Throw original exception in states

[ https://issues.apache.org/jira/browse/FLINK-5865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5865: -- Labels: auto-unassigned pull-request-available stale-major (was: auto-unassigned

[jira] [Updated] (FLINK-22821) FlinkKafkaProducerMigrationTest fails with "Address already in use"

[ https://issues.apache.org/jira/browse/FLINK-22821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22821: --- Labels: pull-request-available stale-critical test-stability (was: pull-request-available

[jira] [Updated] (FLINK-21979) Job can be restarted from the beginning after it reached a terminal state

[ https://issues.apache.org/jira/browse/FLINK-21979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21979: --- Labels: stale-critical (was: ) I am the [Flink Jira

[jira] [Updated] (FLINK-5901) DAG can not show properly in IE

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

[jira] [Updated] (FLINK-5740) Make WrappingFunction an interface and move to flink-core

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

[jira] [Updated] (FLINK-5944) Flink should support reading Snappy Files

[ https://issues.apache.org/jira/browse/FLINK-5944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5944: -- Labels: auto-unassigned features stale-major (was: auto-unassigned features) I am the [Flink

[jira] [Updated] (FLINK-6116) Watermarks don't work when unioning with same DataStream

[ https://issues.apache.org/jira/browse/FLINK-6116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6116: -- Labels: auto-deprioritized-critical pull-request-available stale-major (was:

[jira] [Updated] (FLINK-6081) Offset/Fetch support for SQL Streaming

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

[jira] [Updated] (FLINK-6027) Ignore the exception thrown by the subsuming of old completed checkpoints

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

[jira] [Updated] (FLINK-6363) Document precedence rules of Kryo serializer registrations

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

[jira] [Updated] (FLINK-6343) Migrate from discouraged Java serialization for all sources / sinks

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

[jira] [Updated] (FLINK-6209) StreamPlanEnvironment always has a parallelism of 1

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

[jira] [Updated] (FLINK-6109) Add "consumer lag" report metric to FlinkKafkaConsumer

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

[jira] [Updated] (FLINK-12596) Unify all kinds of cluster via ClusterClient in FlinkShell

[ https://issues.apache.org/jira/browse/FLINK-12596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12596: --- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major)

[jira] [Updated] (FLINK-6224) RemoteStreamEnvironment not resolve ip of JobManager to hostname

[ https://issues.apache.org/jira/browse/FLINK-6224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6224: -- Labels: auto-unassigned patch stale-major (was: auto-unassigned patch) I am the [Flink Jira

[jira] [Updated] (FLINK-12590) Replace http links in documentation

[ https://issues.apache.org/jira/browse/FLINK-12590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12590: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available (was:

[jira] [Updated] (FLINK-6166) Broken quickstart for snapshots

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

[jira] [Updated] (FLINK-5914) remove aggregateResultType from streaming.api.datastream.aggregate

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

[jira] [Updated] (FLINK-12639) FLIP-42: Rework Documentation

[ https://issues.apache.org/jira/browse/FLINK-12639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12639: --- Labels: auto-deprioritized-major pull-request-available usability (was:

[jira] [Updated] (FLINK-22491) JdbcBatchingOutputFormat checks size of buffer in TableBufferReducedStatementExecutor

[ https://issues.apache.org/jira/browse/FLINK-22491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22491: --- Labels: auto-deprioritized-major performance (was: performance stale-major)

[jira] [Updated] (FLINK-15736) Support Java 17 (LTS)

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

[jira] [Updated] (FLINK-18578) Add rejecting checkpoint logic in source

[ https://issues.apache.org/jira/browse/FLINK-18578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18578: --- Labels: auto-deprioritized-major auto-unassigned (was: auto-unassigned stale-major)

  1   2   3   4   >