[GitHub] [flink] SunShine-1204 commented on pull request #23170: [FLINK-32812]Fix HBaseRowDataLookupFunction HTable instantiation of thread safety problems

SunShine-1204 commented on PR #23170: URL: https://github.com/apache/flink/pull/23170#issuecomment-1675591427 @lincoln-lil Could you help review this PR in your free time? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Updated] (FLINK-30630) Python: BatchModeDataStreamTests.test_keyed_map failed

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

[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: stale-major test-stability (was: test-stability) I am the [Flink Jira

[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: stale-critical test-stability (was: test-stability) I am the [Flink Jira

[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: stale-critical test-stability (was: test-stability) I am the [Flink Jira

[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: pull-request-available stale-major (was: pull-request-available) I am the [Flink

[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: pull-request-available stale-major (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-30540) DataSinkTaskTest failed with a 143 exit code

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

[jira] [Updated] (FLINK-30912) CreateTableAsITCase seem to have timed out on Azure

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

[jira] [Updated] (FLINK-31724) SqlClientITCase.testMatchRecognize fails with "bash -c rm -rf /opt/flink/checkpoint/*" returned non-zero exit code 1

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

[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 stale-major (was: Umbrella) I am the [Flink Jira

[jira] [Updated] (FLINK-27210) StateFun example link on datastream integration page is broken

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

[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: stale-critical test-stability (was: test-stability) I am the [Flink Jira

[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: stale-critical test-stability (was: test-stability) I am the [Flink Jira

[jira] [Updated] (FLINK-30514) HybridSource savepoint recovery sequence

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

[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 pull-request-available stale-minor (was:

[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: stale-major starter (was: starter) I am the [Flink Jira

[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: pull-request-available stale-major test-stability (was: pull-request-available

[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: stale-minor usability (was: usability) I am the [Flink Jira

[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: stale-critical test-stability (was: test-stability) I am the [Flink Jira

[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: stale-critical test-stability (was: test-stability) I am the [Flink Jira

[jira] [Updated] (FLINK-30768) flink-web version cleanup

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

[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: stale-critical test-stability (was: test-stability) I am the [Flink Jira

[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: pull-request-available stale-major (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-30644) ChangelogCompatibilityITCase.testRestore fails due to CheckpointCoordinator being shutdown

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

[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: stale-major test-stability (was: test-stability) I am the [Flink Jira

[jira] [Updated] (FLINK-31749) The Using Hadoop OutputFormats example is not avaliable for DataStream

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

[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: pull-request-available stale-major (was: pull-request-available) I am the [Flink

[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: stale-major test-stability (was: test-stability) I am the [Flink Jira

[jira] [Updated] (FLINK-27164) ResumeCheckpointManuallyITCase.testExternalizedFSCheckpointsWithLocalRecoveryZookeeper failed on azure

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

[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: pull-request-available stale-major (was: pull-request-available) I am the [Flink

[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: pull-request-available stale-major (was: pull-request-available) I am the [Flink

[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: stale-major starter (was: starter) I am the [Flink Jira

[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 stale-minor test-stability (was: auto-deprioritized-major

[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: stale-major test-stability (was: test-stability) I am the [Flink Jira

[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 pull-request-available stale-minor (was:

[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: pull-request-available stale-minor (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: pull-request-available stale-minor (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-31597) Cleanup usage of deprecated TableEnvironment#registerFunction

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

[jira] [Updated] (FLINK-27311) Rocksdb mapstate behaves unexpectedly

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

[jira] [Updated] (FLINK-31740) Allow setting boundedness for upsert-kafka SQL connector

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

[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 pull-request-available stale-minor (was:

[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: pull-request-available stale-minor (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-31600) Fix producer leaks in flink-connector-kafka tests

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

[jira] [Updated] (FLINK-31559) Update the flink version to 1.18-SNAPSHOT in flink-connector-kafka

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

[jira] [Updated] (FLINK-31606) Translate "sqlClient.md" page of "table" into Chinese

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

[jira] [Updated] (FLINK-31678) NonHAQueryableStateFsBackendITCase.testAggregatingState: Query did no succeed

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

[jira] [Updated] (FLINK-31648) Elasticsearch supports retrying writes when concurrency issues occur

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

[jira] [Updated] (FLINK-31689) Filesystem sink fails when parallelism of compactor operator changed

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

[jira] [Updated] (FLINK-31778) Casting array of rows produces incorrect result

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

[GitHub] [flink] Samrat002 commented on a diff in pull request #20990: [FLINK-29050][JUnit5 Migration] Module: flink-hadoop-compatibility

Samrat002 commented on code in PR #20990: URL: https://github.com/apache/flink/pull/20990#discussion_r1291657967 ## flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/JavaProgramTestBaseJUnit5.java: ## @@ -0,0 +1,210 @@ +/* + * Licensed to the

[GitHub] [flink] architgyl commented on a diff in pull request #23164: [FLINK- 32775]Add parent dir of files to classpath using yarn.provided.lib.dirs

architgyl commented on code in PR #23164: URL: https://github.com/apache/flink/pull/23164#discussion_r1291656637 ## flink-yarn/src/test/java/org/apache/flink/yarn/YarnApplicationFileUploaderTest.java: ## @@ -73,6 +74,38 @@ void testRegisterProvidedLocalResources(@TempDir File

[GitHub] [flink] architgyl commented on a diff in pull request #23164: [FLINK- 32775]Add parent dir of files to classpath using yarn.provided.lib.dirs

architgyl commented on code in PR #23164: URL: https://github.com/apache/flink/pull/23164#discussion_r1291655485 ## flink-yarn/src/main/java/org/apache/flink/yarn/YarnApplicationFileUploader.java: ## @@ -360,11 +362,27 @@ List registerProvidedLocalResources() {

[jira] [Updated] (FLINK-32176) [CVE-2022-1471] Mitigate CVE from snakeyaml coming from pulsar-client-all

[ https://issues.apache.org/jira/browse/FLINK-32176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Samrat Deb updated FLINK-32176: --- Labels: pull-request-available (was: pull-request-available stale-assigned) > [CVE-2022-1471]

[jira] [Closed] (FLINK-32176) [CVE-2022-1471] Mitigate CVE from snakeyaml coming from pulsar-client-all

[ https://issues.apache.org/jira/browse/FLINK-32176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Samrat Deb closed FLINK-32176. -- Release Note: This issue need to be addressed at pulsar end. Resolution: Won't Fix >

[GitHub] [flink] venkata91 commented on a diff in pull request #23164: [FLINK- 32775]Add parent dir of files to classpath using yarn.provided.lib.dirs

venkata91 commented on code in PR #23164: URL: https://github.com/apache/flink/pull/23164#discussion_r1291641821 ## flink-yarn/src/main/java/org/apache/flink/yarn/YarnApplicationFileUploader.java: ## @@ -360,11 +362,27 @@ List registerProvidedLocalResources() {

[GitHub] [flink-kubernetes-operator] mananmangal commented on a diff in pull request #648: [FLINK-32700] Support job drain for Savepoint upgrade mode

mananmangal commented on code in PR #648: URL: https://github.com/apache/flink-kubernetes-operator/pull/648#discussion_r1291624743 ## flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/reconciler/deployment/ApplicationReconcilerTest.java: ## @@

[jira] [Updated] (FLINK-31951) Mix schema record source creates corrupt record

[ https://issues.apache.org/jira/browse/FLINK-31951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Tseng updated FLINK-31951: Fix Version/s: 1.18.0 Labels: fix-provided pull-request-available (was:

[GitHub] [flink] flinkbot commented on pull request #23198: [FLINK-32856][JUnit5 Migration] Migrate the testutils, throughput and throwable packages of flink-runtime module to junit5

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

[jira] [Updated] (FLINK-32856) [JUnit5 Migration] The testtasks, testutils, throughput and throwable packages of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32856: --- Labels: pull-request-available (was: ) > [JUnit5 Migration] The testtasks, testutils,

[GitHub] [flink] YasuoStudyJava commented on pull request #18221: [FLINK-24803][table-planner] Fix cast BINARY/VARBINARY to STRING

YasuoStudyJava commented on PR #18221: URL: https://github.com/apache/flink/pull/18221#issuecomment-1674980230 @matriv Sorry, I can not understand why use an hex string representation when print byte[] like: [1, 2, -3]... come to https://issues.apache.org/jira/browse/FLINK-24803, I add

[jira] [Assigned] (FLINK-32856) [JUnit5 Migration] The testtasks, testutils, throughput and throwable packages of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-32856: --- Assignee: Rui Fan > [JUnit5 Migration] The testtasks, testutils, throughput and throwable >

[jira] [Assigned] (FLINK-32842) [JUnit5 Migration] The iterative, jobgraph and jobmanager packages of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-32842: --- Assignee: Rui Fan > [JUnit5 Migration] The iterative, jobgraph and jobmanager packages of >

[jira] [Assigned] (FLINK-32841) [JUnit5 Migration] The failure, filecache, hadoop, heartbeat, highavailability and instancepackages of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-32841: --- Assignee: Rui Fan > [JUnit5 Migration] The failure, filecache, hadoop, heartbeat, >

[GitHub] [flink] flinkbot commented on pull request #23197: [FLINK-32845][JUnit5 Migration] Migrate the memory and messages packages of flink-runtime module to junit5

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

[jira] [Updated] (FLINK-32845) [JUnit5 Migration] The leaderelection, leaderretrieval, mailbox, memory and messages packages of flink-runtime module

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

[GitHub] [flink] 1996fanrui opened a new pull request, #23197: [FLINK-32845][JUnit5 Migration] Migrate the memory and messages packages of flink-runtime module to junit5

1996fanrui opened a new pull request, #23197: URL: https://github.com/apache/flink/pull/23197 [FLINK-32845][JUnit5 Migration] Migrate the memory and messages packages of flink-runtime module to junit5 -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Assigned] (FLINK-32838) [JUnit5 Migration] The deployment and dispatcher packages of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-32838: --- Assignee: Rui Fan > [JUnit5 Migration] The deployment and dispatcher packages of flink-runtime >

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

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

[jira] [Updated] (FLINK-32857) [JUnit5 Migration] The webmonitor and zookeeper packages of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32857: --- Labels: pull-request-available (was: ) > [JUnit5 Migration] The webmonitor and zookeeper

[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 ] Matthias Pohl updated FLINK-30923: -- Description: Currently, we have multiple locations to install hugo. In the past this caused

[GitHub] [flink] XComp commented on a diff in pull request #23180: [FLINK-32751][runtime] Refactors close handling to CollectSinkOperatorCoordinator

XComp commented on code in PR #23180: URL: https://github.com/apache/flink/pull/23180#discussion_r1291318008 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectSinkOperatorCoordinator.java: ## @@ -101,75 +110,81 @@ public

[jira] [Assigned] (FLINK-32845) [JUnit5 Migration] The leaderelection, leaderretrieval, mailbox, memory and messages packages of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-32845: --- Assignee: Rui Fan > [JUnit5 Migration] The leaderelection, leaderretrieval, mailbox, memory and >

[GitHub] [flink] XComp commented on a diff in pull request #23180: [FLINK-32751][runtime] Refactors close handling to CollectSinkOperatorCoordinator

XComp commented on code in PR #23180: URL: https://github.com/apache/flink/pull/23180#discussion_r1291302669 ## flink-runtime/src/test/java/org/apache/flink/runtime/rest/RestClientTest.java: ## @@ -239,11 +230,12 @@ public void testCloseClientBeforeRequest() throws Exception {

[jira] [Comment Edited] (FLINK-32792) Release Testing: Verify FLINK-27237 - Partitioned table statement enhancement

[ https://issues.apache.org/jira/browse/FLINK-32792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17753212#comment-17753212 ] luoyuxia edited comment on FLINK-32792 at 8/11/23 12:17 PM: [~ruanhang1993]

[jira] [Closed] (FLINK-32792) Release Testing: Verify FLINK-27237 - Partitioned table statement enhancement

[ https://issues.apache.org/jira/browse/FLINK-32792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia closed FLINK-32792. Resolution: Fixed > Release Testing: Verify FLINK-27237 - Partitioned table statement enhancement >

[jira] [Commented] (FLINK-32792) Release Testing: Verify FLINK-27237 - Partitioned table statement enhancement

[ https://issues.apache.org/jira/browse/FLINK-32792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17753212#comment-17753212 ] luoyuxia commented on FLINK-32792: -- I'd like to say it seems an issue of HiveCatalog, instead of the

[GitHub] [flink] flinkbot commented on pull request #23195: [FLINK-32834] Ease local use of tools/ci/compile.sh

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

[jira] [Updated] (FLINK-32834) Allow compile.sh to be used manually

[ https://issues.apache.org/jira/browse/FLINK-32834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32834: --- Labels: pull-request-available (was: ) > Allow compile.sh to be used manually >

[GitHub] [flink] zentol opened a new pull request, #23195: [FLINK-32834] Ease local use of tools/ci/compile.sh

zentol opened a new pull request, #23195: URL: https://github.com/apache/flink/pull/23195 This PR allows devs to run this script locally, just like that. Lower-level scripts are also easier to use. The commits are quite granular and all have a commit message explaining the change.

[jira] [Commented] (FLINK-32563) Allow connectors CI to specify the main supported Flink version

[ https://issues.apache.org/jira/browse/FLINK-32563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17753211#comment-17753211 ] Etienne Chauchot commented on FLINK-32563: -- [~chesnay] [~martijnvisser] WDYT ? > Allow

[GitHub] [flink-connector-cassandra] echauchot merged pull request #19: [FLINK-32353] [hotfix] build against last flink 1.16 and 1.17 and enable archunit only on main flink release

echauchot merged PR #19: URL: https://github.com/apache/flink-connector-cassandra/pull/19 -- 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. To unsubscribe, e-mail:

[GitHub] [flink-connector-cassandra] echauchot commented on pull request #19: [FLINK-32353] [hotfix] build against last flink 1.16 and 1.17 and enable archunit only on main flink release

echauchot commented on PR #19: URL: https://github.com/apache/flink-connector-cassandra/pull/19#issuecomment-1674627393 It is an hotfix, so, self-merging -- 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

[jira] [Commented] (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:comment-tabpanel=17753207#comment-17753207 ] Weihua Hu commented on FLINK-32821: --- Fair enough, We cannot verify these examples unless these two

[jira] [Closed] (FLINK-32702) streaming examples could not run

[ https://issues.apache.org/jira/browse/FLINK-32702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu closed FLINK-32702. - Resolution: Duplicate > streaming examples could not run > > >

[GitHub] [flink] zentol commented on a diff in pull request #23180: [FLINK-32751][runtime] Refactors close handling to CollectSinkOperatorCoordinator

zentol commented on code in PR #23180: URL: https://github.com/apache/flink/pull/23180#discussion_r1291211941 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectSinkOperatorCoordinator.java: ## @@ -101,75 +110,81 @@ public

[jira] [Commented] (FLINK-25540) [JUnit5 Migration] Module: flink-runtime

[ https://issues.apache.org/jira/browse/FLINK-25540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17753203#comment-17753203 ] Ferenc Csaky commented on FLINK-25540: -- Thanks for the administration [~fanrui]! > [JUnit5

[jira] [Assigned] (FLINK-32858) [JUnit5 Migration] The util package of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-32858: --- Assignee: Zhanghao Chen > [JUnit5 Migration] The util package of flink-runtime module >

[jira] [Commented] (FLINK-32858) [JUnit5 Migration] The util package of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17753197#comment-17753197 ] Rui Fan commented on FLINK-32858: - Hi [~Zhanghao Chen], thanks for the warm, assigned to you. :) >

[jira] [Commented] (FLINK-32858) [JUnit5 Migration] The util package of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17753195#comment-17753195 ] Zhanghao Chen commented on FLINK-32858: --- Hi [~fanrui], I'd be willing to volunteer, could you

[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: stale-critical test-stability (was: test-stability) I am the [Flink Jira

[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: stale-critical test-stability (was: test-stability) I am the [Flink Jira

[jira] [Commented] (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:comment-tabpanel=17753194#comment-17753194 ] Zhanghao Chen commented on FLINK-32821: --- Hi [~huweihua], thanks for notifying me of that, I missed

[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: stale-critical test-stability (was: test-stability) I am the [Flink Jira

[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: stale-critical test-stability (was: test-stability) I am the [Flink Jira

[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: feature stale-major (was: feature) I am the [Flink Jira

[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: stale-critical test-stability (was: test-stability) I am the [Flink Jira

[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 pull-request-available stale-minor (was:

[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 external-resources stale-minor (was:

[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 stale-minor (was:

  1   2   3   >