[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 ] Jiayi Liao updated FLINK-22886: --- Labels: critical (was: ) > Thread leak in RocksDBStateUploader > --

[jira] [Created] (FLINK-22887) Backlog based optimizations for RebalancePartitioner and RescalePartitioner

Jiayi Liao created FLINK-22887: -- Summary: Backlog based optimizations for RebalancePartitioner and RescalePartitioner Key: FLINK-22887 URL: https://issues.apache.org/jira/browse/FLINK-22887 Project: Flin

[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 ] Jiayi Liao updated FLINK-22886: --- Description: {{ExecutorService}} in {{RocksDBStateUploader}} is not shut down, which may leak threa

[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 ] Jiayi Liao updated FLINK-22886: --- Description: {{ExecutorService}} in {{RocksDBStateUploader}} is not shut down, which may leak threa

[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 ] Jiayi Liao updated FLINK-22886: --- Attachment: image-2021-06-06-13-46-34-604.png > Thread leak in RocksDBStateUploader > --

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

Jiayi Liao created FLINK-22886: -- Summary: Thread leak in RocksDBStateUploader Key: FLINK-22886 URL: https://issues.apache.org/jira/browse/FLINK-22886 Project: Flink Issue Type: Bug Com

[jira] [Created] (FLINK-22885) Support 'SHOW COLUMNS'.

Roc Marshal created FLINK-22885: --- Summary: Support 'SHOW COLUMNS'. Key: FLINK-22885 URL: https://issues.apache.org/jira/browse/FLINK-22885 Project: Flink Issue Type: Improvement Compo

[jira] [Updated] (FLINK-22885) Support 'SHOW COLUMNS'.

[ https://issues.apache.org/jira/browse/FLINK-22885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal updated FLINK-22885: Description: h1. Support 'SHOW COLUMNS'. SHOW COLUMNS ( FROM | IN ) [LIKE ] was: h1. Support

[GitHub] [flink] gaoyunhaii commented on pull request #15982: [FLINK-22284] Log the remote address when channel is closed in NettyPartitionRequestClient

gaoyunhaii commented on pull request #15982: URL: https://github.com/apache/flink/pull/15982#issuecomment-855322107 Yes, the PR looks good to me now. Very sorry for the late response~ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Updated] (FLINK-19863) SQLClientHBaseITCase.testHBase failed with "java.io.IOException: Process failed due to timeout"

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

[jira] [Updated] (FLINK-14625) Eliminate cross join in multi join to reduce cost

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

[jira] [Updated] (FLINK-14510) Remove the lazy vertex attaching mechanism from ExecutionGraph

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

[jira] [Updated] (FLINK-14410) Retrieve CharacterFilter once after registration

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

[jira] [Updated] (FLINK-14867) Move TextInputFormat & TextOutputFormat to flink-core

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

[jira] [Updated] (FLINK-14748) Migrate duration and memory size related ConfigOptions to typed options

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

[jira] [Updated] (FLINK-14569) use flink to deal with batch task,when parallelism granter than 1, always 1 or 2 records loss

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

[jira] [Updated] (FLINK-14879) Support 'DESCRIBE DATABSE databaseName' in TableEnvironment and SQL Client

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

[jira] [Updated] (FLINK-14763) flink sql cep parallelism error

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

[jira] [Updated] (FLINK-14875) Blink planner should pass the right ExecutionConfig to the creation of serializer

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

[jira] [Updated] (FLINK-14479) Strange exceptions found in log file after executing `test_udf.py`

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

[jira] [Updated] (FLINK-22572) JsonFsStreamSinkITCase.testPart fails running in a timeout

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

[jira] [Updated] (FLINK-14690) Support 'DESCRIBE CATALOG catalogName' statement in TableEnvironment and SQL Client

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

[jira] [Updated] (FLINK-22427) Support DEFAULT value syntax to simplify data clean process

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

[jira] [Updated] (FLINK-22547) OperatorCoordinatorHolderTest. verifyCheckpointEventOrderWhenCheckpointFutureCompletesLate fail

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

[jira] [Updated] (FLINK-22582) Scrollbar "jumps" when clicking on tabs for Scala and Python

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

[jira] [Updated] (FLINK-22561) Restore checkpoint from another cluster

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

[jira] [Updated] (FLINK-21228) [Kinesis][Producer] Deadlock in KinesisProducer

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

[jira] [Updated] (FLINK-21501) Sync Chinese documentation with FLINK-21343

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

[jira] [Updated] (FLINK-21450) Add local recovery support to adaptive scheduler

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

[jira] [Updated] (FLINK-21427) Recovering from savepoint key does not exist in S3

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

[jira] [Updated] (FLINK-21440) Translate Real Time Reporting with the Table API doc and correct a spelling mistake

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

[jira] [Updated] (FLINK-21367) Support objectReuse in JDBC sink

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

[jira] [Updated] (FLINK-21121) TaggedOperatorSubtaskState is missing when creating a new savepoint using state processor api

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

[jira] [Updated] (FLINK-22380) Pub/Sub Lite Connector for Flink

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

[jira] [Updated] (FLINK-21830) [kinesis][auth] Add support for Session Token

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

[jira] [Updated] (FLINK-21858) TaskMetricGroup taskName is too long, especially in sql tasks.

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

[jira] [Updated] (FLINK-21712) Extract interfaces for the Execution* (classes used by the DefaultExecutonGraph)

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

[jira] [Updated] (FLINK-21161) Investigate Datadog OOM on timeout

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

[jira] [Updated] (FLINK-22513) Failed to upload compile artifacts

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

[jira] [Updated] (FLINK-22500) flink stop 命令找不到00000000000000000000000000000000

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

[jira] [Updated] (FLINK-22496) ClusterEntrypointTest.testCloseAsyncShouldBeExecutedInShutdownHook failed

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

[jira] [Updated] (FLINK-13083) Various improvements PubSub Connector

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

[GitHub] [flink] flinkbot edited a comment on pull request #16023: [FLINK-22698][connectors/rabbitmq] Add deliveryTimeout parameter to RabbitMQ source

flinkbot edited a comment on pull request #16023: URL: https://github.com/apache/flink/pull/16023#issuecomment-850460112 ## CI report: * a229e25d5835019d0be5909f8fba9bb1b62a9f92 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16023: [FLINK-22698][connectors/rabbitmq] Add deliveryTimeout parameter to RabbitMQ source

flinkbot edited a comment on pull request #16023: URL: https://github.com/apache/flink/pull/16023#issuecomment-850460112 ## CI report: * a384aa989f54a9b6f3a3d3e50b65f49e6eab4b0e Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] pnowojski commented on pull request #15982: [FLINK-22284] Log the remote address when channel is closed in NettyPartitionRequestClient

pnowojski commented on pull request #15982: URL: https://github.com/apache/flink/pull/15982#issuecomment-855282637 @gaoyunhaii does this one look good to you? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL ab

[GitHub] [flink] flinkbot edited a comment on pull request #16023: [FLINK-22698][connectors/rabbitmq] Add deliveryTimeout parameter to RabbitMQ source

flinkbot edited a comment on pull request #16023: URL: https://github.com/apache/flink/pull/16023#issuecomment-850460112 ## CI report: * a384aa989f54a9b6f3a3d3e50b65f49e6eab4b0e Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16023: [FLINK-22698][connectors/rabbitmq] Add deliveryTimeout parameter to RabbitMQ source

flinkbot edited a comment on pull request #16023: URL: https://github.com/apache/flink/pull/16023#issuecomment-850460112 ## CI report: * a384aa989f54a9b6f3a3d3e50b65f49e6eab4b0e Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16023: [FLINK-22698][connectors/rabbitmq] Add deliveryTimeout parameter to RabbitMQ source

flinkbot edited a comment on pull request #16023: URL: https://github.com/apache/flink/pull/16023#issuecomment-850460112 ## CI report: * a384aa989f54a9b6f3a3d3e50b65f49e6eab4b0e Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] cmick commented on pull request #16023: [FLINK-22698][connectors/rabbitmq] Add deliveryTimeout parameter to RabbitMQ source

cmick commented on pull request #16023: URL: https://github.com/apache/flink/pull/16023#issuecomment-855270004 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific co

[GitHub] [flink] cmick commented on a change in pull request #16023: [FLINK-22698][connectors/rabbitmq] Add deliveryTimeout parameter to RabbitMQ source

cmick commented on a change in pull request #16023: URL: https://github.com/apache/flink/pull/16023#discussion_r646014934 ## File path: flink-connectors/flink-connector-rabbitmq/src/test/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSourceTest.java ## @@ -419,6 +421,4

[GitHub] [flink] tisonkun commented on pull request #16082: [hotfix][docs] Corrected markup backtick

tisonkun commented on pull request #16082: URL: https://github.com/apache/flink/pull/16082#issuecomment-855243069 Thanks for your 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 above to go to th

[GitHub] [flink] tisonkun merged pull request #16082: [hotfix][docs] Corrected markup backtick

tisonkun merged pull request #16082: URL: https://github.com/apache/flink/pull/16082 -- 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, pleas

[GitHub] [flink] flinkbot edited a comment on pull request #16076: [FLINK-22038][table-planner-blink] Update TopN to be without rowNumber if rowNumber field is never used by the successor Calc

flinkbot edited a comment on pull request #16076: URL: https://github.com/apache/flink/pull/16076#issuecomment-854646866 ## CI report: * 37c65699113155acb03ef5b4da91d02b16fadf17 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-16754) Consider refactoring of ProcessMemoryUtilsTestBase to avoid inheritance

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

[jira] [Updated] (FLINK-20465) Fail globally when not resuming from the latest checkpoint in regional failover

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

[jira] [Updated] (FLINK-15004) Choose two-phase Aggregate if the statistics is unknown

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

[jira] [Updated] (FLINK-14902) JDBCTableSource support AsyncLookupFunction

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

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

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

[jira] [Updated] (FLINK-14986) Support to get detailed Kubernetes cluster description

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

[jira] [Updated] (FLINK-15959) Add min number of slots configuration to limit total number of slots

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

[jira] [Updated] (FLINK-15000) WebUI Metrics is very slow in large parallelism

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

[jira] [Updated] (FLINK-14996) Missing java doc in org.apache.flink.runtime.operators.TempBarrier

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

[jira] [Updated] (FLINK-15012) Checkpoint directory not cleaned up

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

[jira] [Updated] (FLINK-15856) Various Kubernetes command client improvements

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

[jira] [Updated] (FLINK-16562) Handle JobManager termination future in place

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

[jira] [Updated] (FLINK-18295) Remove the hack logics of result consumers

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

[jira] [Updated] (FLINK-20748) Remap excess slots to outstanding requirements

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

[jira] [Updated] (FLINK-20681) Support specifying the hdfs path when ship archives or files

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

[jira] [Updated] (FLINK-20714) Hive delegation token is not obtained when using `kinit` to submit Yarn per-job

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

[jira] [Updated] (FLINK-11103) Set a default uncaught exception handler

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

[jira] [Updated] (FLINK-10333) Rethink ZooKeeper based stores (SubmittedJobGraph, MesosWorker, CompletedCheckpoints)

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

[jira] [Updated] (FLINK-12381) W/o HA, upon a full restart, checkpointing crashes

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

[jira] [Updated] (FLINK-9586) Make collection sources parallelisable

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

[jira] [Updated] (FLINK-10804) Transfer suppressed exceptions with SerializedThrowable

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

[jira] [Updated] (FLINK-13448) Support ARM architecture

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

[jira] [Updated] (FLINK-13031) Support dynamic offset in tumbling windows

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

[jira] [Updated] (FLINK-13247) Implement external shuffle service for YARN

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

[jira] [Updated] (FLINK-13015) Create validators, strategies and transformations required for porting logical expressions

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

[jira] [Updated] (FLINK-13836) Improve support of java.util.UUID for JDBCTypeUtil

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

[jira] [Updated] (FLINK-13570) Pluggable Intermediate Result Storage

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

[jira] [Updated] (FLINK-13735) Support session window with blink planner in batch mode

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

[jira] [Updated] (FLINK-14011) Make some fields final and initialize them during construction in AsyncWaitOperator

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

[jira] [Updated] (FLINK-14414) Support string serializable for SymbolType

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

[jira] [Updated] (FLINK-14146) Introduce Pulsar connector

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

[GitHub] [flink] rmetzger commented on pull request #16081: [FLINK-22856][Azure] Upgrade to ubuntu-20.04

rmetzger commented on pull request #16081: URL: https://github.com/apache/flink/pull/16081#issuecomment-855218204 e2e failed on my personal CI, I'll investigate https://dev.azure.com/rmetzger/Flink/_build/results?buildId=9119&view=results&j=9401bf33-03c4-5a24-83fe-e51d75db73ef&t=72901ab2-7c

[GitHub] [flink-training] alpinegizmo closed pull request #20: [ververica] Update to Flink 1.13.1

alpinegizmo closed pull request #20: URL: https://github.com/apache/flink-training/pull/20 -- 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,

[GitHub] [flink-training] alpinegizmo opened a new pull request #20: [ververica] Update to Flink 1.13.1

alpinegizmo opened a new pull request #20: URL: https://github.com/apache/flink-training/pull/20 Similar to the update from apache/flink-training, but also fixed the deprecation for the MemoryStateBackend affecting the state processor API exercise/example. -- This is an automated messag

[GitHub] [flink] mans2singh commented on pull request #16082: [hotfix][docs] Corrected markup backtick

mans2singh commented on pull request #16082: URL: https://github.com/apache/flink/pull/16082#issuecomment-855210521 Hello @tisonkun, @wuchong, @leonardBang - Can you please review this PR ? Thanks -- This is an automated message from the Apache Git Service. To respond to the message, pl

[GitHub] [flink] flinkbot edited a comment on pull request #16076: [FLINK-22038][table-planner-blink] Update TopN to be without rowNumber if rowNumber field is never used by the successor Calc

flinkbot edited a comment on pull request #16076: URL: https://github.com/apache/flink/pull/16076#issuecomment-854646866 ## CI report: * 37c65699113155acb03ef5b4da91d02b16fadf17 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-22871) Support to execute PyFlink jobs in YARN application mode

[ https://issues.apache.org/jira/browse/FLINK-22871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17357779#comment-17357779 ] Dian Fu commented on FLINK-22871: - [~wukong] Thanks a lot! Have assigned it to you and l

[jira] [Comment Edited] (FLINK-22875) Cannot work by Pickler and Unpickler

[ https://issues.apache.org/jira/browse/FLINK-22875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17357778#comment-17357778 ] Dian Fu edited comment on FLINK-22875 at 6/5/21, 7:46 AM: -- [~JY

[jira] [Assigned] (FLINK-22871) Support to execute PyFlink jobs in YARN application mode

[ https://issues.apache.org/jira/browse/FLINK-22871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-22871: --- Assignee: konwu > Support to execute PyFlink jobs in YARN application mode > --

[jira] [Closed] (FLINK-22875) Cannot work by Pickler and Unpickler

[ https://issues.apache.org/jira/browse/FLINK-22875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-22875. --- Resolution: Not A Problem > Cannot work by Pickler and Unpickler > > >

[jira] [Commented] (FLINK-22875) Cannot work by Pickler and Unpickler

[ https://issues.apache.org/jira/browse/FLINK-22875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17357778#comment-17357778 ] Dian Fu commented on FLINK-22875: - [~JYXL_1] Thanks. I'd like to close this ticket for n

[jira] [Updated] (FLINK-22884) Select view columns fail when store metadata with hive

[ https://issues.apache.org/jira/browse/FLINK-22884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ELLEX_SHEN updated FLINK-22884: --- Attachment: (was: image-2021-06-05-14-55-14-937.png) > Select view columns fail when store metad

[GitHub] [flink] flinkbot edited a comment on pull request #16076: [FLINK-22038][table-planner-blink] Update TopN to be without rowNumber if rowNumber field is never used by the successor Calc

flinkbot edited a comment on pull request #16076: URL: https://github.com/apache/flink/pull/16076#issuecomment-854646866 ## CI report: * 37c65699113155acb03ef5b4da91d02b16fadf17 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] RocMarshal commented on pull request #16060: [FLINK-22860][table sql-client] Supplement 'HELP' command prompt message for SQL-Cli.

RocMarshal commented on pull request #16060: URL: https://github.com/apache/flink/pull/16060#issuecomment-855197825 @leonardBang This PR is ready. Please take a look. Thank you. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHu

[jira] [Closed] (FLINK-22680) An `IndexOutOfBoundsException` is thrown out when apply `WatermarkAssignerChangelogNormalizeTransposeRule`

[ https://issues.apache.org/jira/browse/FLINK-22680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-22680. -- Resolution: Fixed Fixed in 1.14.0: 73d97fb4c3ffd60b9657de734d0293eb5b14e4f7 > An `IndexOutOfBoundsExc

[GitHub] [flink] godfreyhe commented on pull request #16076: [FLINK-22038][table-planner-blink] Update TopN to be without rowNumber if rowNumber field is never used by the successor Calc

godfreyhe commented on pull request #16076: URL: https://github.com/apache/flink/pull/16076#issuecomment-855197393 @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 specifi

[GitHub] [flink] godfreyhe closed pull request #16077: [FLINK-22680][table-planner-blink] Fix IndexOutOfBoundsException when apply WatermarkAssignerChangelogNormalizeTransposeRule

godfreyhe closed pull request #16077: URL: https://github.com/apache/flink/pull/16077 -- 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, plea

  1   2   >