[GitHub] [flink] Jiabao-Sun commented on pull request #23200: [FLINK-32850][flink-runtime][JUnit5 Migration] Module: The io package of flink-runtime

Jiabao-Sun commented on PR #23200: URL: https://github.com/apache/flink/pull/23200#issuecomment-1685200389 Thanks @X-czh for the detailed review. Most of the comments are resolved. Please help review it again when you have time. -- This is an automated message from the Apache Git Ser

[GitHub] [flink] Jiabao-Sun commented on a diff in pull request #23200: [FLINK-32850][flink-runtime][JUnit5 Migration] Module: The io package of flink-runtime

Jiabao-Sun commented on code in PR #23200: URL: https://github.com/apache/flink/pull/23200#discussion_r1299313599 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/ProducerFailedExceptionTest.java: ## @@ -21,26 +21,26 @@ import org.apache.flink.runtim

[GitHub] [flink] Jiabao-Sun commented on a diff in pull request #23200: [FLINK-32850][flink-runtime][JUnit5 Migration] Module: The io package of flink-runtime

Jiabao-Sun commented on code in PR #23200: URL: https://github.com/apache/flink/pull/23200#discussion_r1299313576 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPoolTest.java: ## @@ -65,15 +65,15 @@ class LocalBufferPoolTest { private B

[GitHub] [flink] Jiabao-Sun commented on a diff in pull request #23200: [FLINK-32850][flink-runtime][JUnit5 Migration] Module: The io package of flink-runtime

Jiabao-Sun commented on code in PR #23200: URL: https://github.com/apache/flink/pull/23200#discussion_r1299313498 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartitionTest.java: ## @@ -340,7 +340,7 @@ void testReleaseWhileWriting()

[GitHub] [flink] Jiabao-Sun commented on a diff in pull request #23200: [FLINK-32850][flink-runtime][JUnit5 Migration] Module: The io package of flink-runtime

Jiabao-Sun commented on code in PR #23200: URL: https://github.com/apache/flink/pull/23200#discussion_r1299313467 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPoolTest.java: ## @@ -220,52 +219,52 @@ public void testMultipleThreadRequestAn

[GitHub] [flink] Jiabao-Sun commented on a diff in pull request #23200: [FLINK-32850][flink-runtime][JUnit5 Migration] Module: The io package of flink-runtime

Jiabao-Sun commented on code in PR #23200: URL: https://github.com/apache/flink/pull/23200#discussion_r1299304252 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/disk/iomanager/IOManagerTest.java: ## @@ -61,12 +54,16 @@ public void channelEnumerator() throws Exception

[GitHub] [flink] Jiabao-Sun commented on pull request #23233: [FLINK-32847][flink-runtime][JUnit5 Migration] Module: The operators package of flink-runtime

Jiabao-Sun commented on PR #23233: URL: https://github.com/apache/flink/pull/23233#issuecomment-1685176322 Hi @1996fanrui. Could you help review it when you have time? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] X-czh commented on a diff in pull request #23200: [FLINK-32850][flink-runtime][JUnit5 Migration] Module: The io package of flink-runtime

X-czh commented on code in PR #23200: URL: https://github.com/apache/flink/pull/23200#discussion_r1299296506 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPoolDestroyTest.java: ## @@ -20,30 +20,24 @@ import org.apache.flink.runtime.execu

[jira] [Commented] (FLINK-32896) Incorrect `Map.computeIfAbsent(..., ...::new)` usage which misinterprets key as initial capacity

[ https://issues.apache.org/jira/browse/FLINK-32896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17756420#comment-17756420 ] Flavio Pompermaier commented on FLINK-32896: Good catch > Incorrect `Map.co

[jira] [Updated] (FLINK-30883) Missing JobID caused the k8s e2e test to fail

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

[jira] [Updated] (FLINK-30551) Add open method to PartitionCommitPolicy

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

[jira] [Updated] (FLINK-29944) Support accumulator in source reader

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

[jira] [Updated] (FLINK-30539) YARNSessionCapacitySchedulerITCase.testDetachedPerJobYarnCluster and testDetachedPerJobYarnClusterWithStreamingJob timing out

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

[jira] [Updated] (FLINK-30907) HiveSinkCompactionITCase.testSingleParallelism fails with test timeout

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

[jira] [Updated] (FLINK-30703) PulsarOrderedPartitionSplitReaderTest>PulsarPartitionSplitReaderTestBase.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition fails

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

[jira] [Updated] (FLINK-30793) PyFlink YARN per-job on Docker test fails on Azure due to permission issues

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

[jira] [Updated] (FLINK-30267) PyFlink YARN per-job on Docker test failed because it could not build hadoop image

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

[jira] [Updated] (FLINK-30732) "Running HA (hashmap, sync) end-to-end test" failed with exit code 1

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

[jira] [Updated] (FLINK-30106) Build python wheels on macs failed due to install for crcmod error

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

[jira] [Updated] (FLINK-30835) Add smoke tests for flink connector

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

[jira] [Updated] (FLINK-32312) SSLConnectionSocketFactory produced no output for 900 seconds

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

[jira] [Updated] (FLINK-30784) HiveTableSourceITCase.testPartitionFilter failed with assertion error

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

[jira] [Updated] (FLINK-30597) Refactor FlinkProjectJoinTransposeRule and FlinkPruneEmptyRules

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

[jira] [Updated] (FLINK-30570) RexNodeExtractor#isSupportedPartitionPredicate generates unexpected partition predicates

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

[jira] [Updated] (FLINK-30913) Various PyFlink tests fail

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

[jira] [Updated] (FLINK-30909) Running HA (hashmap, sync) end-to-end test

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

[jira] [Updated] (FLINK-30697) Fix scalafmt documentation

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

[jira] [Updated] (FLINK-30537) Add support for OpenSearch 2.3

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

[jira] [Updated] (FLINK-32395) EmbeddedFileSourceCsvReaderFormatTests.test_csv_add_columns_from fails on AZP

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

[jira] [Updated] (FLINK-31033) UsingRemoteJarITCase.testUdfInRemoteJar failed with assertion

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

[jira] [Updated] (FLINK-30568) Add benchmark for PolyNomialExpansion, Normalizer, Binarizer, Interaction, MaxAbsScaler, VectorSlicer, ElementWiseProduct and Featurehasher

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

[jira] [Updated] (FLINK-30642) CsvFileCompactionITCase>CompactionITCaseBase.testPartition timed out

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

[jira] [Updated] (FLINK-30721) The confluent schema registry is not compatible with Apicurio schema registry

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

[jira] [Updated] (FLINK-30831) Improving e2e test output in case errors/exceptions are found

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

[jira] [Updated] (FLINK-30843) Add Notifier For Autoscaler

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

[jira] [Updated] (FLINK-27406) After canceling the job, it is falsely reported as a job failure.

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

[jira] [Updated] (FLINK-32508) Flink-Metrics Prometheus - Native Histograms / Native Counters

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

[jira] [Updated] (FLINK-27741) Fix NPE when use dense_rank() and rank() in over aggregation

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

[jira] [Updated] (FLINK-27725) Create tests for TypeInformation and TypeSerializer classes in table

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

[jira] [Updated] (FLINK-27437) Syntax error when running tpcds test

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

[jira] [Updated] (FLINK-27695) KafkaTransactionLogITCase failed on azure due to Could not find a valid Docker environment

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

[jira] [Updated] (FLINK-32418) ClassNotFoundException when using flink-protobuf with sql-client

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

[jira] [Updated] (FLINK-27726) shade thrift and fb303 in hive connector

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

[jira] [Updated] (FLINK-31105) SqlClient: Make HELP, EXIT and QUIT also work without a semicolon

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

[jira] [Updated] (FLINK-27239) rewrite PreValidateReWriter from scala to java

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

[jira] [Updated] (FLINK-27489) Allow users to run dedicated tests in the CI

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

[jira] [Updated] (FLINK-27440) adds ignore-parse-errors configuration in avro format

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

[jira] [Updated] (FLINK-27764) SetOperatorsITCase tests failed

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

[jira] [Created] (FLINK-32896) Incorrect `Map.computeIfAbsent(..., ...::new)` usage which misinterprets key as initial capacity

Marcono1234 created FLINK-32896: --- Summary: Incorrect `Map.computeIfAbsent(..., ...::new)` usage which misinterprets key as initial capacity Key: FLINK-32896 URL: https://issues.apache.org/jira/browse/FLINK-32896

[jira] [Closed] (FLINK-31992) FlinkKafkaConsumer API is suggested to use as part of documentation, when that API is deprecated for flink version 1.14

[ https://issues.apache.org/jira/browse/FLINK-31992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sandesh Mendan closed FLINK-31992. -- Since this issue has been corrected in higher flink version, I am proceeding to this ticket > Fl

[jira] [Commented] (FLINK-31992) FlinkKafkaConsumer API is suggested to use as part of documentation, when that API is deprecated for flink version 1.14

[ https://issues.apache.org/jira/browse/FLINK-31992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17756351#comment-17756351 ] Sandesh Mendan commented on FLINK-31992: Thanks for your update [~martijnvisser]

[jira] [Resolved] (FLINK-31992) FlinkKafkaConsumer API is suggested to use as part of documentation, when that API is deprecated for flink version 1.14

[ https://issues.apache.org/jira/browse/FLINK-31992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sandesh Mendan resolved FLINK-31992. Resolution: Information Provided > FlinkKafkaConsumer API is suggested to use as part of d

[GitHub] [flink] flinkbot commented on pull request #23242: [FLINK-32851][runtime][JUnit5 Migration] The rest package of flink-runtime module

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

[jira] [Updated] (FLINK-32851) [JUnit5 Migration] The rest package of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32851: --- Labels: pull-request-available (was: ) > [JUnit5 Migration] The rest package of flink-runti

[GitHub] [flink] wangzzu opened a new pull request, #23242: [FLINK-32851][runtime][JUnit5 Migration] The rest package of flink-runtime module

wangzzu opened a new pull request, #23242: URL: https://github.com/apache/flink/pull/23242 ## What is the purpose of the change Migrate rest package related tests under flink-runtime module to junit5 ## Brief change log Migrate rest package related tests under fli

[GitHub] [flink] xuzifu666 commented on pull request #23220: [FLINK-32871][SQL] Support BuiltInMethod TO_TIMESTAMP with timezone options

xuzifu666 commented on PR #23220: URL: https://github.com/apache/flink/pull/23220#issuecomment-1684985918 @FangYongs could you have a review plz? -- 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 t

[GitHub] [flink] qinf commented on a diff in pull request #23219: [FLINK-20681][yarn] Support specifying the hdfs path when ship archives or files

qinf commented on code in PR #23219: URL: https://github.com/apache/flink/pull/23219#discussion_r1299172981 ## flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java: ## @@ -911,31 +929,21 @@ private ApplicationReport startAppMaster( final List system

[GitHub] [flink] 1996fanrui commented on a diff in pull request #22985: [FLINK-21883][scheduler] Implement cooldown period for adaptive scheduler

1996fanrui commented on code in PR #22985: URL: https://github.com/apache/flink/pull/22985#discussion_r1299169121 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Executing.java: ## @@ -144,6 +188,17 @@ private void maybeRescale() { } }

[jira] [Updated] (FLINK-31228) flink-playgrounds is using a buggy zookeeper

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

[jira] [Updated] (FLINK-31134) Out of memory error in KafkaSourceE2ECase>SourceTestSuiteBase.testScaleDown

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

[jira] [Updated] (FLINK-27775) FlinkKafkaProducer VS KafkaSink

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

[jira] [Updated] (FLINK-27934) Python API- Inefficient deserialization/serialization of state variables within a batch

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

[jira] [Updated] (FLINK-31278) exit code 137 (i.e. OutOfMemoryError) in core module

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

[jira] [Updated] (FLINK-31339) PlannerScalaFreeITCase.testImperativeUdaf

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

[jira] [Updated] (FLINK-30975) Migrate aws sdk from v1 to v2

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

[jira] [Updated] (FLINK-31341) OutOfMemoryError in Kafka e2e tests

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

[jira] [Updated] (FLINK-13703) AvroTypeInfo requires objects to be strict POJOs (mutable, with setters)

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

[jira] [Updated] (FLINK-31010) Add Transformer and Estimator for GBTClassifier and GBTRegressor

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

[jira] [Updated] (FLINK-31034) Deploy Maven Snapshot failed

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

[jira] [Updated] (FLINK-31244) OffHeapUnsafeMemorySegmentTest.testCallCleanerOnceOnConcurrentFree prints IllegalStateException

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

[jira] [Updated] (FLINK-31490) ZooKeeperLeaderElectionTest.testLeaderShouldBeCorrectedWhenOverwritten times out

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

[jira] [Updated] (FLINK-27807) The improvement of addBatch is empty when jdbc batch submit

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

[jira] [Updated] (FLINK-31488) Dependency convergence failed due to dependency not being available

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

[jira] [Updated] (FLINK-27779) Connectors should not depend on `flink-table-planner`

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

[jira] [Updated] (FLINK-31241) Hive dependency cannot be resolved

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

[jira] [Updated] (FLINK-31342) SQLClientSchemaRegistryITCase timed out when starting the test container

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

[jira] [Updated] (FLINK-31355) CommonDataStreamTests.test_execute_and_collect failed

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

[jira] [Updated] (FLINK-31282) Create and Close the zookeeper connection frequently

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

[jira] [Updated] (FLINK-31296) Add JoinConditionEqualityTransferRule to stream optimizer

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

[jira] [Updated] (FLINK-31352) OverAggregateITCase.testWindowAggregationSumWithoutOrderBy times out on CI

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

[jira] [Updated] (FLINK-12450) [Bitwise Functions] Add BIT_LSHIFT, BIT_RSHIFT functions supported in Table API and SQL

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

[jira] [Updated] (FLINK-30974) Add commons-io to flink-sql-connector-hbase

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

[jira] [Updated] (FLINK-31525) JdbcExactlyOnceSinkE2eTest.testInsert times out

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

[jira] [Updated] (FLINK-30923) Provide single script for installing Hugo

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

[jira] [Updated] (FLINK-30941) Error when downloading the flink binaries into the Docker container

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

[jira] [Updated] (FLINK-30893) Replace not specifying a driver in Minikube by something else

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

[jira] [Updated] (FLINK-31016) "Run kubernetes pyflink application test" fails due to Rust package manager not being listed in the PATH

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

[jira] [Updated] (FLINK-31373) PerRoundWrapperOperator should carry epoch information in watermark

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

[jira] [Updated] (FLINK-27963) FlinkRuntimeException in KafkaSink causes a Flink job to hang

[ https://issues.apache.org/jira/browse/FLINK-27963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-27963: --- Labels: FlinkRuntimeException KafkaSink auto-deprioritized-major auto-deprioritized-minor

[jira] [Updated] (FLINK-27876) Error side is chosen in BatchPhysicalHashJoinRule when the join is Semi or Anti

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

[jira] [Updated] (FLINK-27801) Disable flushing stream when call Jackson's writeValue() method for CsvBulkWriter

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

[jira] [Updated] (FLINK-27986) Refactor the name of finish method for JdbcOutputFormatBuilder

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

[jira] [Updated] (FLINK-27886) Error way for skipping shade plugin in sub-modules

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

[jira] [Updated] (FLINK-12451) [Bitwise Functions] Add BIT_XOR function supported in Table API and SQL

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

[jira] [Updated] (FLINK-10356) Add sanity checks to SpillingAdaptiveSpanningRecordDeserializer

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

[jira] [Updated] (FLINK-27928) External Resource Framework: 'external-resources' name delimitation not working as expected

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

[jira] [Updated] (FLINK-31332) Limit the use of ExecutionConfig on JdbcOutputFormat

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

[jira] [Updated] (FLINK-16073) Translate "State & Fault Tolerance" pages into Chinese

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

[jira] [Updated] (FLINK-13871) Consolidate isRunning, canceled, isFinished fields in StreamTask and SourceStreamTask

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

[jira] [Updated] (FLINK-17224) Precision of TIME type does not work correctly

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

  1   2   >