[GitHub] [flink] hackergin commented on a diff in pull request #23130: [Flink-32356] Add doc for procedure

hackergin commented on code in PR #23130: URL: https://github.com/apache/flink/pull/23130#discussion_r1294251979 ## docs/content.zh/docs/dev/table/procedures.md: ## @@ -0,0 +1,541 @@ +--- +title: "存储过程" +is_beta: true +weight: 50 +type: docs +aliases: + - /zh/dev/table/procedur

[GitHub] [flink-ml] Fanoid commented on a diff in pull request #250: [FLINK-32810] Improve memory allocation in ListStateWithCache

Fanoid commented on code in PR #250: URL: https://github.com/apache/flink-ml/pull/250#discussion_r1294247032 ## flink-ml-core/src/test/java/org/apache/flink/iteration/datacache/nonkeyed/ListStateWithCacheTest.java: ## @@ -0,0 +1,169 @@ +/* + * Licensed to the Apache Software Fou

[GitHub] [flink] flinkbot commented on pull request #23215: [FLINK-32844][table-planner] Does not apply runtime filter and DPP on same key

flinkbot commented on PR #23215: URL: https://github.com/apache/flink/pull/23215#issuecomment-1678474176 ## CI report: * efa0c7ea64988f31e8233edd4d1659d72e776566 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-32844) Runtime Filter should not be applied if the field is already filtered by DPP

[ https://issues.apache.org/jira/browse/FLINK-32844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32844: --- Labels: pull-request-available (was: ) > Runtime Filter should not be applied if the field

[GitHub] [flink] wanglijie95 opened a new pull request, #23215: [FLINK-32844][table-planner] Does not apply runtime filter and DPP on same key

wanglijie95 opened a new pull request, #23215: URL: https://github.com/apache/flink/pull/23215 ## What is the purpose of the change Fix FLINK-32844, does not apply runtime filter and DPP on same key ## Verifying this change Add test `testDoesNotApplyRuntimeFilterA

[GitHub] [flink-kubernetes-operator] X-czh commented on a diff in pull request #651: [FLINK-32868][docs] Document the need to backport FLINK-30213 for using autoscaler with older version Flinks

X-czh commented on code in PR #651: URL: https://github.com/apache/flink-kubernetes-operator/pull/651#discussion_r1294229251 ## docs/content/docs/custom-resource/autoscaler.md: ## @@ -37,7 +37,10 @@ Key benefits to the user: Job requirements: - The autoscaler currently onl

[jira] [Assigned] (FLINK-32868) Document the need to backport FLINK-30213 for using autoscaler with older version Flinks

[ https://issues.apache.org/jira/browse/FLINK-32868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-32868: --- Assignee: Zhanghao Chen > Document the need to backport FLINK-30213 for using autoscaler with older

[jira] [Updated] (FLINK-32868) Document the need to backport FLINK-30213 for using autoscaler with older version Flinks

[ https://issues.apache.org/jira/browse/FLINK-32868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32868: --- Labels: pull-request-available (was: ) > Document the need to backport FLINK-30213 for usin

[GitHub] [flink-kubernetes-operator] X-czh opened a new pull request, #651: [FLINK-32868][docs] Document the need to backport FLINK-30213 for using autoscaler with older version Flinks

X-czh opened a new pull request, #651: URL: https://github.com/apache/flink-kubernetes-operator/pull/651 ## What is the purpose of the change The current Autoscaler doc states on job requirements as the following: > Job requirements: > > The autoscaler currently o

[GitHub] [flink] hackergin commented on a diff in pull request #23130: [Flink-32356] Add doc for procedure

hackergin commented on code in PR #23130: URL: https://github.com/apache/flink/pull/23130#discussion_r1294194387 ## docs/content.zh/docs/dev/table/sql/call.md: ## @@ -0,0 +1,118 @@ +--- +title: "CALL 语句" +weight: 19 +type: docs +aliases: +- /zh/dev/table/sql/call.html +--- + + +

[jira] [Created] (FLINK-32868) Document the need to backport FLINK-30213 for using autoscaler with older version Flinks

Zhanghao Chen created FLINK-32868: - Summary: Document the need to backport FLINK-30213 for using autoscaler with older version Flinks Key: FLINK-32868 URL: https://issues.apache.org/jira/browse/FLINK-32868

[jira] [Updated] (FLINK-32821) Streaming examples failed to execute due to error in packaging

[ https://issues.apache.org/jira/browse/FLINK-32821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-32821: -- Description: 7 out of the 8 streaming examples failed to run: * Iteration & SessionWindowing

[jira] [Commented] (FLINK-32480) Keyed State always returns new value instance

[ https://issues.apache.org/jira/browse/FLINK-32480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17754403#comment-17754403 ] Kezhu Wang commented on FLINK-32480: Flink never provide such a guarantee. The "Expe

[jira] [Commented] (FLINK-26585) State Processor API: Loading a state set buffers the whole state set in memory before starting to process

[ https://issues.apache.org/jira/browse/FLINK-26585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17754401#comment-17754401 ] Hangxiang Yu commented on FLINK-26585: -- [~Matthias Schwalbe]  Hi, Thanks for report

[GitHub] [flink] JunRuiLee commented on pull request #23167: [FLINK-32788][runtime] Support the handling of allocation errors when SpeculativeScheduler schedule speculative tasks by trigger fatal erro

JunRuiLee commented on PR #23167: URL: https://github.com/apache/flink/pull/23167#issuecomment-1678404180 @zhuzhurk I'd updated this pr, PTAL. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[jira] [Updated] (FLINK-32758) PyFlink bounds are overly restrictive and outdated

[ https://issues.apache.org/jira/browse/FLINK-32758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32758: --- Labels: pull-request-available (was: ) > PyFlink bounds are overly restrictive and outdated

[GitHub] [flink] HuangXingBo commented on a diff in pull request #23141: [FLINK-32758][python] Remove PyFlink dependencies' upper bounds

HuangXingBo commented on code in PR #23141: URL: https://github.com/apache/flink/pull/23141#discussion_r1294158183 ## flink-python/dev/dev-requirements.txt: ## @@ -15,20 +15,20 @@ pip>=20.3 setuptools>=18.0 wheel -apache-beam==2.43.0 -cython==0.29.24 +apache-beam>=2.43.0,<2.4

[GitHub] [flink] HuangXingBo commented on pull request #23141: [FLINK-32758][python] Remove PyFlink dependencies' upper bounds

HuangXingBo commented on PR #23141: URL: https://github.com/apache/flink/pull/23141#issuecomment-1678397196 @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 commen

[jira] [Assigned] (FLINK-32790) Release Testing: Verify FLIP-311: Support Call Stored Procedure

[ https://issues.apache.org/jira/browse/FLINK-32790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia reassigned FLINK-32790: Assignee: Feng Jin (was: Jin Feng) > Release Testing: Verify FLIP-311: Support Call Stored Proce

[jira] [Assigned] (FLINK-32790) Release Testing: Verify FLIP-311: Support Call Stored Procedure

[ https://issues.apache.org/jira/browse/FLINK-32790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia reassigned FLINK-32790: Assignee: Jin Feng (was: luoyuxia) > Release Testing: Verify FLIP-311: Support Call Stored Proce

[jira] [Assigned] (FLINK-32791) Release Testing: Verify FLIP-308: Support Time Travel

[ https://issues.apache.org/jira/browse/FLINK-32791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia reassigned FLINK-32791: Assignee: tartarus (was: Feng Jin) > Release Testing: Verify FLIP-308: Support Time Travel > ---

[jira] [Assigned] (FLINK-32787) Release Testing: Verify FLIP-305: Support atomic for CREATE TABLE AS SELECT(CTAS) statement

[ https://issues.apache.org/jira/browse/FLINK-32787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia reassigned FLINK-32787: Assignee: Feng Jin > Release Testing: Verify FLIP-305: Support atomic for CREATE TABLE AS > SELE

[jira] [Resolved] (FLINK-32789) Release Testing: Verify FLIP-303: Support REPLACE TABLE AS SELECT statement

[ https://issues.apache.org/jira/browse/FLINK-32789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-32789. -- Resolution: Fixed [~hackergin] Thanks for help. Closing... > Release Testing: Verify FLIP-303: Suppor

[jira] [Assigned] (FLINK-32787) Release Testing: Verify FLIP-305: Support atomic for CREATE TABLE AS SELECT(CTAS) statement

[ https://issues.apache.org/jira/browse/FLINK-32787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia reassigned FLINK-32787: Assignee: (was: luoyuxia) > Release Testing: Verify FLIP-305: Support atomic for CREATE TABLE

[jira] [Assigned] (FLINK-25015) job name should not always be `collect` submitted by sql client

[ https://issues.apache.org/jira/browse/FLINK-25015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-25015: - Assignee: xiangyu feng (was: KevinyhZou) > job name should not always be `collect` submitted b

[jira] [Commented] (FLINK-32776) Adding HTTP basic authentication support to PrometheusPushGatewayReporter

[ https://issues.apache.org/jira/browse/FLINK-32776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17754379#comment-17754379 ] Qiwei Wu commented on FLINK-32776: -- hi~[~martijnvisser] can you please assign this tick

[jira] [Commented] (FLINK-32863) Improve Flink UI's time precision from second level to millisecond level

[ https://issues.apache.org/jira/browse/FLINK-32863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17754378#comment-17754378 ] xiangyu feng commented on FLINK-32863: -- +1, this is very useful for short-lived que

[jira] [Comment Edited] (FLINK-32789) Release Testing: Verify FLIP-303: Support REPLACE TABLE AS SELECT statement

[ https://issues.apache.org/jira/browse/FLINK-32789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17754377#comment-17754377 ] Feng Jin edited comment on FLINK-32789 at 8/15/23 3:03 AM: --- Ve

[jira] (FLINK-32776) Adding HTTP basic authentication support to PrometheusPushGatewayReporter

[ https://issues.apache.org/jira/browse/FLINK-32776 ] Qiwei Wu deleted comment on FLINK-32776: -- was (Author: JIRAUSER301673): [~Weijie Guo]  can you please assign this ticket to [~stonewu] ? > Adding HTTP basic authentication support to Prometheus

[jira] [Commented] (FLINK-32789) Release Testing: Verify FLIP-303: Support REPLACE TABLE AS SELECT statement

[ https://issues.apache.org/jira/browse/FLINK-32789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17754377#comment-17754377 ] Feng Jin commented on FLINK-32789: -- Verified the CTAS with paimon catalog; !截屏2023-0

[jira] [Commented] (FLINK-29039) RowData produced by LineBytesInputFormat is reused, but DeserializationSchemaAdapter#Reader only shallow copies produced data, thus result will always be the last row

[ https://issues.apache.org/jira/browse/FLINK-29039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17754376#comment-17754376 ] Hang Ruan commented on FLINK-29039: --- This bug is the same as https://issues.apache.org

[jira] [Updated] (FLINK-32789) Release Testing: Verify FLIP-303: Support REPLACE TABLE AS SELECT statement

[ https://issues.apache.org/jira/browse/FLINK-32789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feng Jin updated FLINK-32789: - Attachment: 截屏2023-08-15 10.59.35.png > Release Testing: Verify FLIP-303: Support REPLACE TABLE AS SELEC

[jira] [Assigned] (FLINK-32862) Support INIT operation type to be compatible with DTS on Alibaba Cloud

[ https://issues.apache.org/jira/browse/FLINK-32862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-32862: -- Assignee: Hang Ruan > Support INIT operation type to be compatible with DTS on Alibaba Cloud

[GitHub] [flink] masteryhx commented on pull request #21835: [FLINK-30854][state] Support periodic compaction for RocksdbCompactFilterCleanupStrategy

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

[GitHub] [flink-ml] zhipeng93 closed pull request #237: [Flink-27826] Support training very high dimensional logistic regression

zhipeng93 closed pull request #237: [Flink-27826] Support training very high dimensional logistic regression URL: https://github.com/apache/flink-ml/pull/237 -- 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 t

[GitHub] [flink-ml] zhipeng93 opened a new pull request, #251: [Draft][FLINK-27286] Add communication infra to support training high dimens…

zhipeng93 opened a new pull request, #251: URL: https://github.com/apache/flink-ml/pull/251 …ion models ## What is the purpose of the change *(For example: This pull request adds the implementation of Naive Bayes algorithm.)* ## Brief change log *(for exam

[GitHub] [flink] flinkbot commented on pull request #23214: [FLINK-32860][flink-table-api] Add missing visibility annotation for Table APIs

flinkbot commented on PR #23214: URL: https://github.com/apache/flink/pull/23214#issuecomment-1678303210 ## CI report: * 1d99ae10c25ac27a84aaa6ccdef201670afce05b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-32860) Add missing visibility annotation for Table APIs

[ https://issues.apache.org/jira/browse/FLINK-32860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32860: --- Labels: pull-request-available (was: ) > Add missing visibility annotation for Table APIs >

[GitHub] [flink] LadyForest opened a new pull request, #23214: [FLINK-32860][flink-table-api] Add missing visibility annotation for Table APIs

LadyForest opened a new pull request, #23214: URL: https://github.com/apache/flink/pull/23214 ## What is the purpose of the change This pull request adds missing visibility annotations for classes under `flink-table-api-java`, `flink-table-api-java-bridge`, and `flink-table-common`.

[jira] [Updated] (FLINK-24640) CEIL, FLOOR built-in functions for Timestamp should respect DST

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

[jira] [Updated] (FLINK-24681) org.apache.kafka.clients.consumer.NoOffsetForPartitionException: Undefined offset with no reset policy for partitions

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

[jira] [Updated] (FLINK-25450) JobMasterTest.testJobFailureWhenTaskExecutorHeartbeatTimeout is unstable on azure

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

[jira] [Updated] (FLINK-20576) Flink Temporal Join Hive Dim Error

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

[jira] [Updated] (FLINK-22194) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers fail due to commit timeout

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

[jira] [Updated] (FLINK-20928) KafkaSourceReaderTest.testOffsetCommitOnCheckpointComplete:189->pollUntil:270 » Timeout

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

[jira] [Updated] (FLINK-20908) ShardConsumerFanOutTest.testStartFromLatestIsTranslatedToTimestamp test failed with AssertionError

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

[jira] [Updated] (FLINK-29961) Make referencing custom image clearer for Docker

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

[jira] [Updated] (FLINK-22366) HiveSinkCompactionITCase fails on azure

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

[jira] [Updated] (FLINK-25449) KafkaSourceITCase.testRedundantParallelism failed on azure

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

[jira] [Updated] (FLINK-24581) compatible uname command with multiple OS on ARM platform

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

[jira] [Updated] (FLINK-24528) Flink HBase Asyc Lookup throw NPE if rowkey is null

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

[jira] [Updated] (FLINK-24031) I am trying to deploy Flink in kubernetes but when I launch the taskManager in other container I get a Exception

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

[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 stale-major (was: auto-deprioritized-critical) I am th

[jira] [Updated] (FLINK-23632) [DOCS]The link to setup-Pyflink-virtual-env.sh is broken for page dev/python/faq

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

[jira] [Updated] (FLINK-21871) Support watermark for Hive and Filesystem streaming source

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

[jira] [Updated] (FLINK-22068) FlinkKinesisConsumerTest.testPeriodicWatermark fails on azure

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

[jira] [Updated] (FLINK-24111) UnsignedTypeConversionITCase fails locally

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

[jira] [Updated] (FLINK-25451) KafkaEnumeratorTest.testDiscoverPartitionsPeriodically failed on azure

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

[jira] [Updated] (FLINK-24941) Cannot report backpressure with DatadogReporter

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

[jira] [Updated] (FLINK-25100) RMQSourceITCase failed on azure due to java.io.EOFException

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

[jira] [Updated] (FLINK-24701) "late events" link in "Timely Stream Processing" document is not working

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

[jira] [Updated] (FLINK-23238) EventTimeWindowCheckpointingITCase.testTumblingTimeWindowWithKVStateMaxMaxParallelism fails on azure

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

[jira] [Updated] (FLINK-23982) Compiling error in WindowOperatorTest

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

[jira] [Updated] (FLINK-23810) Print sql when parse failed , which is convenient to find error sql from multiple executed sql

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

[jira] [Updated] (FLINK-29984) Flink Histogram not emitting min and max when using Prometheus Reporter

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

[jira] [Updated] (FLINK-31820) Support data source sub-database and sub-table

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

[jira] [Updated] (FLINK-30119) Breaking change: Flink Kubernetes Operator should store last savepoint in the SavepointInfo.lastSavepoint field whether it is completed or pending

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

[jira] [Updated] (FLINK-30097) CachedDataStream java example in the document is not correct

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

[jira] [Updated] (FLINK-30088) Excessive state updates for TtlMapState and TtlListState

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

[jira] [Updated] (FLINK-24095) Elasticsearch7DynamicSinkITCase.testWritingDocuments fails due to socket timeout

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

[jira] [Updated] (FLINK-29991) KinesisFirehoseSinkTest#firehoseSinkFailsWhenUnableToConnectToRemoteService failed

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

[jira] [Updated] (FLINK-30169) Adds version switcher in PyFlink API doc

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

[jira] [Updated] (FLINK-25306) Flink CLI end-to-end test timeout on azure

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

[jira] [Updated] (FLINK-30199) Add a script to run Kubernetes Operator e2e tests manually

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

[jira] [Updated] (FLINK-30166) Refactor tests that use the deprecated StreamingFileSink instead of FileSink

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

[jira] [Updated] (FLINK-29971) Hbase sink will lose data at extreme case

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

[jira] [Updated] (FLINK-30219) Fetch results api in sql gateway return error result.

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

[GitHub] [flink] zoltar9264 commented on pull request #23146: [FLINK-32761][state/backends] Use UUID based on PhysicalStateHandleID…

zoltar9264 commented on PR #23146: URL: https://github.com/apache/flink/pull/23146#issuecomment-1677831666 Thanks for reply @rkhachatryan , and can you help merge this pr ? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and u

[jira] [Commented] (FLINK-32791) Release Testing: Verify FLIP-308: Support Time Travel

[ https://issues.apache.org/jira/browse/FLINK-32791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17754208#comment-17754208 ] Feng Jin commented on FLINK-32791: -- A test process that can be used as a reference. Tes

[jira] [Commented] (FLINK-31619) Upgrade Stateful Functions to Flink 1.16.1

[ https://issues.apache.org/jira/browse/FLINK-31619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17754199#comment-17754199 ] Galen Warren commented on FLINK-31619: -- Created pull request: [[FLINK-31619] Upgrad

[jira] [Updated] (FLINK-31619) Upgrade Stateful Functions to Flink 1.16.1

[ https://issues.apache.org/jira/browse/FLINK-31619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31619: --- Labels: pull-request-available (was: ) > Upgrade Stateful Functions to Flink 1.16.1 > -

[jira] [Updated] (FLINK-32866) Clean up the `@ExtendWith(TestLoggerExtension.class)` for modules that added the `TestLoggerExtension` to the `org.junit.jupiter.api.extension.Extension resource` file

[ https://issues.apache.org/jira/browse/FLINK-32866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32866: Description: Some modules added the {{TestLoggerExtension}} to the {{org.junit.jupiter.api.extension.Exte

[GitHub] [flink] 1996fanrui commented on a diff in pull request #23196: [FLINK-32857][JUnit5 Migration] Migrate the webmonitor and zookeeper packages of flink-runtime module to junit5

1996fanrui commented on code in PR #23196: URL: https://github.com/apache/flink/pull/23196#discussion_r1293639624 ## flink-runtime/src/test/java/org/apache/flink/runtime/webmonitor/WebMonitorEndpointTest.java: ## @@ -39,10 +40,11 @@ import java.util.concurrent.TimeUnit; /**

[GitHub] [flink] flinkbot commented on pull request #23213: [BP-1.17][FLINK-32564][table]bytes-to-number & number-to-bytes

flinkbot commented on PR #23213: URL: https://github.com/apache/flink/pull/23213#issuecomment-1677619935 ## CI report: * fab460c6defdc51466614edd5b0a798ca1f3130b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-32867) Suspending job and triggering savepoint when only updating restartNonce

[ https://issues.apache.org/jira/browse/FLINK-32867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17754170#comment-17754170 ] Gyula Fora commented on FLINK-32867: If you change the restartNonce a full job resta

[GitHub] [flink] hanyuzheng7 opened a new pull request, #23213: [BP-1.17][FLINK-32564][table]bytes-to-number & number-to-bytes

hanyuzheng7 opened a new pull request, #23213: URL: https://github.com/apache/flink/pull/23213 ### What is the purpose of the change Implement` CAST` from `BINARY`/`VARBINART`/`BYTES `to `NUMBER` Implement` CAST` from `NUMBER` to `BINARY`/`VARBINART`/`BYTES ` ### Brief change log

[jira] [Closed] (FLINK-32814) Support disabling failed JM shutdown in the operator

[ https://issues.apache.org/jira/browse/FLINK-32814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yaroslav Tkachenko closed FLINK-32814. -- Resolution: Won't Fix > Support disabling failed JM shutdown in the operator > ---

[GitHub] [flink-kubernetes-operator] sap1ens closed pull request #646: [FLINK-32814] Make terminal JM shutdown configurable

sap1ens closed pull request #646: [FLINK-32814] Make terminal JM shutdown configurable URL: https://github.com/apache/flink-kubernetes-operator/pull/646 -- 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

[jira] [Commented] (FLINK-25015) job name should not always be `collect` submitted by sql client

[ https://issues.apache.org/jira/browse/FLINK-25015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17754157#comment-17754157 ] xiangyu feng commented on FLINK-25015: -- Hi [~zouyunhe] , we think this issue is ver

[jira] [Updated] (FLINK-32867) Suspending job and triggering savepoint when only updating restartNonce

[ https://issues.apache.org/jira/browse/FLINK-32867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] haiqingchen updated FLINK-32867: Affects Version/s: kubernetes-operator-1.6.0 > Suspending job and triggering savepoint when only u

[jira] [Updated] (FLINK-32867) Suspending job and triggering savepoint when only updating restartNonce

[ https://issues.apache.org/jira/browse/FLINK-32867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] haiqingchen updated FLINK-32867: Affects Version/s: kubernetes-operator-1.4.0 (was: kubernetes-operator-1

[jira] [Commented] (FLINK-32488) Introduce configuration to control ExecutionGraph cache in REST API

[ https://issues.apache.org/jira/browse/FLINK-32488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17754155#comment-17754155 ] xiangyu feng commented on FLINK-32488: -- Hi [~liangtl] , we also found this improvem

[jira] [Created] (FLINK-32867) Suspending job and triggering savepoint when only updating restartNonce

haiqingchen created FLINK-32867: --- Summary: Suspending job and triggering savepoint when only updating restartNonce Key: FLINK-32867 URL: https://issues.apache.org/jira/browse/FLINK-32867 Project: Flink

[jira] [Created] (FLINK-32866) Clean up the `@ExtendWith(TestLoggerExtension.class)` for modules that added the `TestLoggerExtension` to the `org.junit.jupiter.api.extension.Extension resource` file

Rui Fan created FLINK-32866: --- Summary: Clean up the `@ExtendWith(TestLoggerExtension.class)` for modules that added the `TestLoggerExtension` to the `org.junit.jupiter.api.extension.Extension resource` file Key: FLINK-32866

[jira] [Commented] (FLINK-26341) ZooKeeperTestEnvironment does not allow for repeated test execution

[ https://issues.apache.org/jira/browse/FLINK-26341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17754138#comment-17754138 ] Rui Fan commented on FLINK-26341: - https://github.com/apache/flink/pull/23196 is updatin

[jira] [Commented] (FLINK-31139) not upload empty state changelog file

[ https://issues.apache.org/jira/browse/FLINK-31139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17754128#comment-17754128 ] Roman Khachatryan commented on FLINK-31139: --- [~Feifan Wang] thanks for the rem

[jira] [Closed] (FLINK-30163) StreamPandasUDFITTests.test_basic_functionality failed

[ https://issues.apache.org/jira/browse/FLINK-30163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl closed FLINK-30163. - Resolution: Cannot Reproduce Ok, thanks. Let's close it then since it hasn't reappeared for awhi

[GitHub] [flink] XComp commented on a diff in pull request #23196: [FLINK-32857][JUnit5 Migration] Migrate the webmonitor and zookeeper packages of flink-runtime module to junit5

XComp commented on code in PR #23196: URL: https://github.com/apache/flink/pull/23196#discussion_r1293482931 ## flink-runtime/src/test/java/org/apache/flink/runtime/webmonitor/retriever/LeaderGatewayRetrieverTest.java: ## @@ -60,19 +61,15 @@ public void testGatewayRetrievalFailu

[jira] [Commented] (FLINK-31360) Running HsResultPartitionTest repeatedly causes error with 137 exit code indicating a memory leak

[ https://issues.apache.org/jira/browse/FLINK-31360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17754119#comment-17754119 ] Weijie Guo commented on FLINK-31360: Sure, I will take some time to take a look. We

[jira] [Commented] (FLINK-32829) Allow setting different values for CPU requests and limits

[ https://issues.apache.org/jira/browse/FLINK-32829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17754117#comment-17754117 ] haiqingchen commented on FLINK-32829: - Hi [~ivan.stoiev], you can use   |h5. kuberne

  1   2   3   >