[jira] [Updated] (FLINK-29755) PulsarSourceUnorderedE2ECase.testSavepoint failed because of missing TaskManagers

[ https://issues.apache.org/jira/browse/FLINK-29755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-29755: -- Parent: FLINK-28352 Issue Type: Sub-task (was: Bug) > PulsarSourceUnorderedE2ECase.te

[jira] [Commented] (FLINK-29755) PulsarSourceUnorderedE2ECase.testSavepoint failed because of missing TaskManagers

[ https://issues.apache.org/jira/browse/FLINK-29755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641095#comment-17641095 ] Matthias Pohl commented on FLINK-29755: --- I moved this under the Umbrella ticket fo

[jira] [Commented] (FLINK-29830) PulsarSinkITCase$DeliveryGuaranteeTest.writeRecordsToPulsar failed

[ https://issues.apache.org/jira/browse/FLINK-29830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641094#comment-17641094 ] Matthias Pohl commented on FLINK-29830: --- I moved this under the Umbrella Pulsar st

[jira] [Commented] (FLINK-30202) RateLimitedSourceReader may emit one more record than permitted

[ https://issues.apache.org/jira/browse/FLINK-30202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641096#comment-17641096 ] Matthias Pohl commented on FLINK-30202: --- https://dev.azure.com/apache-flink/apache

[jira] [Commented] (FLINK-29461) ProcessDataStreamStreamingTests.test_process_function unstable

[ https://issues.apache.org/jira/browse/FLINK-29461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641099#comment-17641099 ] Matthias Pohl commented on FLINK-29461: --- No worries. Thanks for picking it up. :)

[jira] [Commented] (FLINK-28440) EventTimeWindowCheckpointingITCase.testSlidingTimeWindow failed with restore

[ https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641100#comment-17641100 ] Matthias Pohl commented on FLINK-28440: --- https://dev.azure.com/apache-flink/apache

[GitHub] [flink-table-store] tsreaper merged pull request #406: [FLINK-30206] Allow FileStoreScan to read incremental changes from OVERWRITE snapshot in Table Store

tsreaper merged PR #406: URL: https://github.com/apache/flink-table-store/pull/406 -- 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: issues-unsubscr...@fl

[jira] [Updated] (FLINK-28440) EventTimeWindowCheckpointingITCase.testSlidingTimeWindow failed with restore

[ https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-28440: -- Affects Version/s: 1.17.0 > EventTimeWindowCheckpointingITCase.testSlidingTimeWindow failed wi

[jira] [Commented] (FLINK-28177) Elasticsearch6DynamicSinkITCase.testWritingDocumentsNoPrimaryKey failed with 503 Service Unavailable

[ https://issues.apache.org/jira/browse/FLINK-28177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641103#comment-17641103 ] Matthias Pohl commented on FLINK-28177: --- https://dev.azure.com/apache-flink/apache

[jira] [Updated] (FLINK-30244) When task using udf/udtf with jni, on k8s session the old TM will shut down and create new TM or the task will fail

[ https://issues.apache.org/jira/browse/FLINK-30244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] AlexHu updated FLINK-30244: --- Attachment: image-2022-11-30-15-05-29-120.png image-2022-11-30-15-04-45-696.png

[jira] [Closed] (FLINK-30206) Allow FileStoreScan to read incremental changes from OVERWRITE snapshot in Table Store

[ https://issues.apache.org/jira/browse/FLINK-30206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-30206. --- Resolution: Fixed master: c7bc1fb9d1d656dd93fafe66dbef185b560a33c2 > Allow FileStoreScan to read in

[jira] [Updated] (FLINK-30244) When task using udf/udtf with jni, on k8s session the old TM will shut down and create new TM or the task will fail

[ https://issues.apache.org/jira/browse/FLINK-30244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] AlexHu updated FLINK-30244: --- Component/s: Kubernetes Operator Runtime / Task > When task using udf/udtf with jni, on k8s

[jira] [Commented] (FLINK-30138) BlobServerCleanupTest utilizes failsWithin with a quite low timeout which might result in test instabilities

[ https://issues.apache.org/jira/browse/FLINK-30138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641105#comment-17641105 ] Matthias Pohl commented on FLINK-30138: --- https://dev.azure.com/apache-flink/apache

[GitHub] [flink-ml] jiangxin369 opened a new pull request, #187: [FLINK-29601] Add Estimator and Transformer for UnivariateFeatureSelector

jiangxin369 opened a new pull request, #187: URL: https://github.com/apache/flink-ml/pull/187 ## What is the purpose of the change Add Estimator and Transformer for UnivariateFeatureSelector ## Brief change log - Adds Transformer and Estimator implementation of

[jira] [Updated] (FLINK-29601) Add Estimator and Transformer for UnivariateFeatureSelector

[ https://issues.apache.org/jira/browse/FLINK-29601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29601: --- Labels: pull-request-available (was: ) > Add Estimator and Transformer for UnivariateFeatur

[jira] [Commented] (FLINK-30242) Push localHashAggregate pass the union node

[ https://issues.apache.org/jira/browse/FLINK-30242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641107#comment-17641107 ] Runkang He commented on FLINK-30242: We have already done this work, and have a pres

[GitHub] [flink-table-store] SteNicholas commented on a diff in pull request #394: [FLINK-29614] Introduce Spark writer for table store

SteNicholas commented on code in PR #394: URL: https://github.com/apache/flink-table-store/pull/394#discussion_r1035598799 ## flink-table-store-spark/src/main/java/org/apache/flink/table/store/spark/SparkRowData.java: ## @@ -0,0 +1,371 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink-table-store] SteNicholas commented on a diff in pull request #394: [FLINK-29614] Introduce Spark writer for table store

SteNicholas commented on code in PR #394: URL: https://github.com/apache/flink-table-store/pull/394#discussion_r1035600618 ## flink-table-store-spark/src/main/java/org/apache/flink/table/store/spark/SparkRowData.java: ## @@ -0,0 +1,371 @@ +/* + * Licensed to the Apache Software

[jira] [Created] (FLINK-30245) NPE thrown when filtering decimal(18, 4) values after calling DecimalDataUtils.subtract method

Wei Zhong created FLINK-30245: - Summary: NPE thrown when filtering decimal(18, 4) values after calling DecimalDataUtils.subtract method Key: FLINK-30245 URL: https://issues.apache.org/jira/browse/FLINK-30245

[GitHub] [flink-table-store] SteNicholas commented on a diff in pull request #394: [FLINK-29614] Introduce Spark writer for table store

SteNicholas commented on code in PR #394: URL: https://github.com/apache/flink-table-store/pull/394#discussion_r1035602663 ## flink-table-store-spark/src/main/java/org/apache/flink/table/store/spark/SparkTable.java: ## @@ -76,4 +93,30 @@ public Transform[] partitioning() {

[GitHub] [flink] fredia commented on pull request #21405: [FLINK-23035][state/changelog] Add explicit append() to StateChangelogWriter to write metadata

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

[jira] [Commented] (FLINK-30242) Push localHashAggregate pass the union node

[ https://issues.apache.org/jira/browse/FLINK-30242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1764#comment-1764 ] Aitozi commented on FLINK-30242: Hi [~Runking], Sorry I have not noticed that. If you ha

[jira] [Created] (FLINK-30246) Registering the same metric object with different name and group will conflict in metric reporter

Qingsheng Ren created FLINK-30246: - Summary: Registering the same metric object with different name and group will conflict in metric reporter Key: FLINK-30246 URL: https://issues.apache.org/jira/browse/FLINK-3024

[jira] [Closed] (FLINK-30243) Remove duplicate commas

[ https://issues.apache.org/jira/browse/FLINK-30243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-30243. -- Resolution: Invalid Per https://flink.apache.org/contributing/code-style-and-quality-pull-req

[GitHub] [flink] slfan1989 commented on pull request #21424: [FLINK-30243] Remove duplicate commas.

slfan1989 commented on PR #21424: URL: https://github.com/apache/flink/pull/21424#issuecomment-1331767186 > Thanks for this but I do question the value of this PR vs the resources it costs to build the PR: this can be fixed if someone touches on this code, but there's no value in creating a

[GitHub] [flink] slfan1989 closed pull request #21424: [FLINK-30243] Remove duplicate commas.

slfan1989 closed pull request #21424: [FLINK-30243] Remove duplicate commas. URL: https://github.com/apache/flink/pull/21424 -- 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

<    1   2   3   4