[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

[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

[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=17754403#comment-17754403 ] Kezhu Wang commented on FLINK-32480: Flink never provide such a guarantee. The "Expected behavior"

[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=17754401#comment-17754401 ] Hangxiang Yu commented on FLINK-26585: -- [~Matthias Schwalbe]  Hi, Thanks for reporting this. Let

[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

[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

[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

[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

[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

[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 >

[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:

[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

[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

[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=17754379#comment-17754379 ] Qiwei Wu commented on FLINK-32776: -- hi~[~martijnvisser] can you please assign this ticket to me? I've

[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=17754378#comment-17754378 ] xiangyu feng commented on FLINK-32863: -- +1, this is very useful for short-lived queries > Improve

[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=17754377#comment-17754377 ] Feng Jin edited comment on FLINK-32789 at 8/15/23 3:03 AM: --- Verified the RTAS

[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

[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=17754377#comment-17754377 ] Feng Jin commented on FLINK-32789: -- Verified the CTAS with paimon catalog; !截屏2023-08-15

[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=17754376#comment-17754376 ] Hang Ruan commented on FLINK-29039: --- This bug is the same as

[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

[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

[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

[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

[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:

[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

[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

[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

[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

[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

[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

[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:

[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

[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:

[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

[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

[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

[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

[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

[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

[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:

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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=17754208#comment-17754208 ] Feng Jin commented on FLINK-32791: -- A test process that can be used as a reference. Test time travel

[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=17754199#comment-17754199 ] Galen Warren commented on FLINK-31619: -- Created pull request: [[FLINK-31619] Upgrade Stateful

[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

[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=17754170#comment-17754170 ] Gyula Fora commented on FLINK-32867: If you change the restartNonce a full job restart / upgrade

[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=17754157#comment-17754157 ] xiangyu feng commented on FLINK-25015: -- Hi [~zouyunhe] , we think this issue is very important in

[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

[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:

[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=17754155#comment-17754155 ] xiangyu feng commented on FLINK-32488: -- Hi [~liangtl] , we also found this improvement very useful,

[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=17754138#comment-17754138 ] Rui Fan commented on FLINK-26341: - https://github.com/apache/flink/pull/23196 is updating the

[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=17754128#comment-17754128 ] Roman Khachatryan commented on FLINK-31139: --- [~Feifan Wang] thanks for the reminder, I have

[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

[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

[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=17754119#comment-17754119 ] Weijie Guo commented on FLINK-31360: Sure, I will take some time to take a look. We have not

[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=17754117#comment-17754117 ] haiqingchen commented on FLINK-32829: - Hi [~ivan.stoiev], you can use   |h5.

[jira] [Commented] (FLINK-32835) [JUnit5 Migration] The accumulators, blob and blocklist packages of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17754110#comment-17754110 ] Ferenc Csaky commented on FLINK-32835: -- FYI: Jira contains the "blocklist" package, as I just

[GitHub] [flink] 1996fanrui commented on pull request #23203: [FLINK-32859][scheduler] Introduce the StateWithoutExecutionGraph

1996fanrui commented on PR #23203: URL: https://github.com/apache/flink/pull/23203#issuecomment-1677339869 > > Add the test later. > > What does this mean? Hi @XComp , some tests can be moved from `Created`, `CreatingExecutionGraph` and `WaitingForResources` to

[jira] [Assigned] (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:all-tabpanel ] Rui Fan reassigned FLINK-26341: --- Assignee: Rui Fan > ZooKeeperTestEnvironment does not allow for repeated test execution >

[jira] [Closed] (FLINK-30302) WatermarkAssignerChangelogNormalizeTransposeRuleTest failed

[ https://issues.apache.org/jira/browse/FLINK-30302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl closed FLINK-30302. - Resolution: Cannot Reproduce Thanks for the clarification, [~Sergey Nuyanzin]. I'm gonna go

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

[ https://issues.apache.org/jira/browse/FLINK-30163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17754100#comment-17754100 ] Sergey Nuyanzin commented on FLINK-30163: - I had a look through the jira and was not able to

[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=17754101#comment-17754101 ] Matthias Pohl commented on FLINK-26341: --- That sounds reasonable. That way we can remove

[jira] [Commented] (FLINK-30302) WatermarkAssignerChangelogNormalizeTransposeRuleTest failed

[ https://issues.apache.org/jira/browse/FLINK-30302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17754099#comment-17754099 ] Sergey Nuyanzin commented on FLINK-30302: - I think so, I've also haven't faced this for a long

  1   2   3   >