[GitHub] [flink] flinkbot commented on pull request #20373: [FLINK-28577][runtime-web] Fix the null error of reading checkpointed_size in Checkpoint Tab

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

[jira] [Updated] (FLINK-28577) 1.15.1 web ui console report error about checkpoint size

[ https://issues.apache.org/jira/browse/FLINK-28577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28577: --- Labels: pull-request-available (was: ) > 1.15.1 web ui console report error about checkpoin

[GitHub] [flink] yuchenECNU opened a new pull request, #20373: [FLINK-28577][runtime-web] Fix the null error of reading checkpointed_size in Checkpoint Tab

yuchenECNU opened a new pull request, #20373: URL: https://github.com/apache/flink/pull/20373 ## What is the purpose of the change This pull request fixes the problem that the checkpoint details page of the Flink Dashboard shows blank after the job triggers savepoint. #

[GitHub] [flink] flinkbot commented on pull request #20372: [FLINK-28698][runtime-web] fix order of aggregate durations to follow task state transitions

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

[GitHub] [flink] yangjunhan commented on pull request #20372: [FLINK-28698][runtime-web] fix order of aggregate durations to follow task state transitions

yangjunhan commented on PR #20372: URL: https://github.com/apache/flink/pull/20372#issuecomment-1196307859 Hi, @xintongsong . This fix is relatively trivial. Could you help me review and merge this? -- This is an automated message from the Apache Git Service. To respond to the message, pl

[jira] [Updated] (FLINK-28698) The display order of aggregated metrics should follow the order of task state transitions

[ https://issues.apache.org/jira/browse/FLINK-28698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28698: --- Labels: pull-request-available (was: ) > The display order of aggregated metrics should fol

[GitHub] [flink] yangjunhan opened a new pull request, #20372: [FLINK-28698][runtime-web] fix order of aggregate durations to follow task state transitions

yangjunhan opened a new pull request, #20372: URL: https://github.com/apache/flink/pull/20372 ## What is the purpose of the change This PR closes FLINK-28698, which it fix the order of aggregated metrics status durations in order to follow the natural task state transitions:

[GitHub] [flink] swuferhong commented on a diff in pull request #20084: [FLINK-27988][table-planner] Let HiveTableSource extend from SupportStatisticsReport

swuferhong commented on code in PR #20084: URL: https://github.com/apache/flink/pull/20084#discussion_r930653031 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSource.java: ## @@ -261,6 +273,99 @@ public DynamicTableSource copy()

[jira] [Created] (FLINK-28701) Minimize the explosion range during failover for hybrid shuffle

Weijie Guo created FLINK-28701: -- Summary: Minimize the explosion range during failover for hybrid shuffle Key: FLINK-28701 URL: https://issues.apache.org/jira/browse/FLINK-28701 Project: Flink

[GitHub] [flink-table-store] tsreaper opened a new pull request, #244: [FLINK-28700] Table store sink fails to commit for Flink 1.14 batch job

tsreaper opened a new pull request, #244: URL: https://github.com/apache/flink-table-store/pull/244 We can't get configurations from `DummyStreamExecutionEnvironment` in Flink 1.14 (this is fixed by FLINK-26709 in Flink 1.15) so we have to use Java reflection to check if this execution envi

[jira] [Updated] (FLINK-28700) Table store sink fails to commit for Flink 1.14 batch job

[ https://issues.apache.org/jira/browse/FLINK-28700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28700: --- Labels: pull-request-available (was: ) > Table store sink fails to commit for Flink 1.14 ba

[jira] [Created] (FLINK-28700) Table store sink fails to commit for Flink 1.14 batch job

Caizhi Weng created FLINK-28700: --- Summary: Table store sink fails to commit for Flink 1.14 batch job Key: FLINK-28700 URL: https://issues.apache.org/jira/browse/FLINK-28700 Project: Flink Issue

[GitHub] [flink] fsk119 commented on a diff in pull request #20298: [FLINK-28152][sql-gateway][hive] Allow executing statement for the HiveServer2Endpoint

fsk119 commented on code in PR #20298: URL: https://github.com/apache/flink/pull/20298#discussion_r930644202 ## flink-connectors/flink-connector-hive/src/test/resources/endpoint/hive_catalog.q: ## @@ -0,0 +1,121 @@ +# catalog_database.q - CREATE/DROP/SHOW/USE CATALOG/DATABASE +#

[GitHub] [flink] xinbinhuang commented on pull request #20289: [FLINK-23633][FLIP-150][connector/common] HybridSource: Support dynamic stop position in FileSource

xinbinhuang commented on PR #20289: URL: https://github.com/apache/flink/pull/20289#issuecomment-1196291153 @tweise Thank you so much for reviewing the PR! I just realized that I might have misread jira issue as `HybridSource: Support dynamic stop position in HybridSource` instead of `H

[jira] [Closed] (FLINK-28696) Notify all newlyAdded/Merged blocked nodes to BlocklistListener

[ https://issues.apache.org/jira/browse/FLINK-28696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28696. --- Resolution: Fixed Fixed via bbaeb628f48a4bc4c324bfc4afd06ddf34f546f0 > Notify all newlyAdded/Merged blocked

[GitHub] [flink] zhuzhurk closed pull request #20368: [FLINK-28696][runtime] Fix the bug that the blocklist listeners will not be notified when there are no newly added nodes (only merge nodes)

zhuzhurk closed pull request #20368: [FLINK-28696][runtime] Fix the bug that the blocklist listeners will not be notified when there are no newly added nodes (only merge nodes) URL: https://github.com/apache/flink/pull/20368 -- This is an automated message from the Apache Git Service. To res

[GitHub] [flink] lindong28 commented on a diff in pull request #20275: [FLINK-28606][Runtime/Checkpointing] Preserve consistency of OperatorEvent from OperatorCoordinator to subtasks

lindong28 commented on code in PR #20275: URL: https://github.com/apache/flink/pull/20275#discussion_r930593185 ## flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinatorHolder.java: ## @@ -308,6 +337,24 @@ private void checkpointCoordinat

[GitHub] [flink-ml] taosiyuan163 commented on pull request #132: [FLINK-28571] Add AlgoOperator for Chi-squared test

taosiyuan163 commented on PR #132: URL: https://github.com/apache/flink-ml/pull/132#issuecomment-1196269416 Hi,@zhipeng93 , I updated the following according to your comments: 1. Optimize the implementation for several operators. 2. Reformat the document. 3. Fix the test cases.

[jira] [Resolved] (FLINK-24434) PyFlink YARN per-job on Docker test fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-24434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo resolved FLINK-24434. -- Resolution: Fixed Since https://issues.apache.org/jira/browse/FLINK-28680 has been resolved, I

[jira] [Assigned] (FLINK-28696) Notify all newlyAdded/Merged blocked nodes to BlocklistListener

[ https://issues.apache.org/jira/browse/FLINK-28696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-28696: --- Assignee: Lijie Wang > Notify all newlyAdded/Merged blocked nodes to BlocklistListener > --

[jira] [Assigned] (FLINK-28698) The display order of aggregated metrics should follow the order of task state transitions

[ https://issues.apache.org/jira/browse/FLINK-28698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-28698: Assignee: Junhan Yang > The display order of aggregated metrics should follow the order o

[jira] [Created] (FLINK-28699) Native rocksdb full snapshot in non-incremental checkpointing

Lihe Ma created FLINK-28699: --- Summary: Native rocksdb full snapshot in non-incremental checkpointing Key: FLINK-28699 URL: https://issues.apache.org/jira/browse/FLINK-28699 Project: Flink Issue Ty

[jira] [Commented] (FLINK-28653) State Schema Evolution does not work - Flink defaults to Kryo serialization even for POJOs and Avro SpecificRecords

[ https://issues.apache.org/jira/browse/FLINK-28653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571719#comment-17571719 ] Hangxiang Yu commented on FLINK-28653: -- Hi, Maybe you could try to set {{env.getCo

[jira] [Assigned] (FLINK-28577) 1.15.1 web ui console report error about checkpoint size

[ https://issues.apache.org/jira/browse/FLINK-28577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-28577: Assignee: Yu Chen > 1.15.1 web ui console report error about checkpoint size > --

[jira] [Commented] (FLINK-28577) 1.15.1 web ui console report error about checkpoint size

[ https://issues.apache.org/jira/browse/FLINK-28577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571720#comment-17571720 ] Yun Tang commented on FLINK-28577: -- [~Yu Chen] Thanks for figuring out this problem, an

[GitHub] [flink] zoltar9264 commented on a diff in pull request #20152: [FLINK-27155][changelog] Reduce multiple reads to the same Changelog …

zoltar9264 commented on code in PR #20152: URL: https://github.com/apache/flink/pull/20152#discussion_r930584225 ## flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogStateBackend.java: ## @@ -87,9 +87,14 @@ protected Check

[jira] [Commented] (FLINK-28697) MapDataSerializer doesn't declare a serialVersionUID

[ https://issues.apache.org/jira/browse/FLINK-28697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571718#comment-17571718 ] Yun Tang commented on FLINK-28697: -- [~jmahonin] Did you use different flink versions be

[jira] [Updated] (FLINK-28697) MapDataSerializer doesn't declare a serialVersionUID

[ https://issues.apache.org/jira/browse/FLINK-28697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-28697: - Fix Version/s: (was: 1.15.1) > MapDataSerializer doesn't declare a serialVersionUID > --

[GitHub] [flink] Tartarus0zm commented on pull request #20252: [FLINK-28463][flink-sql-parser] Flink dialect supports CREATE TABLE AS SELECT(CTAS) syntax

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

[jira] [Updated] (FLINK-28698) The display order of aggregated metrics should follow the order of task state transitions

[ https://issues.apache.org/jira/browse/FLINK-28698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28698: - Priority: Minor (was: Major) > The display order of aggregated metrics should follow the order

[jira] [Commented] (FLINK-28698) The display order of aggregated metrics should follow the order of task state transitions

[ https://issues.apache.org/jira/browse/FLINK-28698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571715#comment-17571715 ] Xintong Song commented on FLINK-28698: -- Thanks [~wanglijie95], that makes sense to

[jira] [Updated] (FLINK-28698) The display order of aggregated metrics should follow the order of task state transitions

[ https://issues.apache.org/jira/browse/FLINK-28698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28698: - Affects Version/s: 1.16.0 > The display order of aggregated metrics should follow the order of t

[GitHub] [flink] PatrickRen merged pull request #20177: [FLINK-28416][table] Add (Async)LookupFunction and providers in replace of (Async)TableFunction as the API for lookup table

PatrickRen merged PR #20177: URL: https://github.com/apache/flink/pull/20177 -- 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...@flink.ap

[GitHub] [flink] LinMingQiang commented on pull request #19995: [FLINK-28060][BP 1.15][Connector/Kafka] Updated Kafka Clients to 3.1.1

LinMingQiang commented on PR #19995: URL: https://github.com/apache/flink/pull/19995#issuecomment-1196218666 I still have problems applying this patch on 1.15. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL ab

[GitHub] [flink] fredia commented on a diff in pull request #20152: [FLINK-27155][changelog] Reduce multiple reads to the same Changelog …

fredia commented on code in PR #20152: URL: https://github.com/apache/flink/pull/20152#discussion_r930579497 ## flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogStateBackend.java: ## @@ -87,9 +87,14 @@ protected Checkpoin

[jira] [Commented] (FLINK-28577) 1.15.1 web ui console report error about checkpoint size

[ https://issues.apache.org/jira/browse/FLINK-28577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571713#comment-17571713 ] Yu Chen commented on FLINK-28577: - Well, I think I've found the root cause of this issue

[GitHub] [flink] DavidLiu001 commented on pull request #20338: [FLINK-27536][Connectors / Common] Rename method parameter in AsyncSi…

DavidLiu001 commented on PR #20338: URL: https://github.com/apache/flink/pull/20338#issuecomment-1196217453 Nice, I will follow your suggestion for the later PR -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] DavidLiu001 commented on pull request #20338: [FLINK-27536][Connectors / Common] Rename method parameter in AsyncSi…

DavidLiu001 commented on PR #20338: URL: https://github.com/apache/flink/pull/20338#issuecomment-1196217231 Nice, I will follow your suggestion for the later PR -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] flinkbot commented on pull request #20371: [FLINK-27908][network] Introduce HsResultPartition and HsSubpartitionView

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

[GitHub] [flink] masteryhx commented on a diff in pull request #20306: [FLINK-28602][state/changelog] Close stream of StateChangeFsUploader normally while enabling compression

masteryhx commented on code in PR #20306: URL: https://github.com/apache/flink/pull/20306#discussion_r930578280 ## flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/StateChangeFsUploader.java: ## @@ -168,7 +168,7 @@ private UploadTasksResult upload(Path path,

[GitHub] [flink] DavidLiu001 commented on pull request #20360: [FLINK-27536][Connectors / Common] Rename method parameter in AsyncSi…

DavidLiu001 commented on PR #20360: URL: https://github.com/apache/flink/pull/20360#issuecomment-1196214414 BUILD FAILURE: Failed to execute goal on project flink-connector-elasticsearch-base: Could not resolve dependencies for project org.apache.flink:flink-connector-elasticsearch-base:ja

[jira] [Updated] (FLINK-27908) Introduce HsResultPartition and HsSubpartitionView

[ https://issues.apache.org/jira/browse/FLINK-27908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27908: --- Labels: pull-request-available (was: ) > Introduce HsResultPartition and HsSubpartitionView

[GitHub] [flink] reswqa opened a new pull request, #20371: [FLINK-27908][network] Introduce HsResultPartition and HsSubpartitionView

reswqa opened a new pull request, #20371: URL: https://github.com/apache/flink/pull/20371 ## What is the purpose of the change *Introduce HsResultPartition and HsSubpartitionView, this is the last part of hybrid shuffle mode in the shuffle layer.* ## Brief change log

[GitHub] [flink] Tartarus0zm commented on pull request #20252: [FLINK-28463][flink-sql-parser] Flink dialect supports CREATE TABLE AS SELECT(CTAS) syntax

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

[GitHub] [flink] zoltar9264 commented on a diff in pull request #20152: [FLINK-27155][changelog] Reduce multiple reads to the same Changelog …

zoltar9264 commented on code in PR #20152: URL: https://github.com/apache/flink/pull/20152#discussion_r930567765 ## flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/StateChangeIteratorWithCache.java: ## @@ -0,0 +1,367 @@ +/* + * Licensed to the Apache Softwa

[jira] [Commented] (FLINK-28698) The display order of aggregated metrics should follow the order of task state transitions

[ https://issues.apache.org/jira/browse/FLINK-28698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571694#comment-17571694 ] Lijie Wang commented on FLINK-28698: cc [~xtsong]  > The display order of aggregate

[jira] [Updated] (FLINK-28698) The display order of aggregated metrics should follow the order of task state transitions

[ https://issues.apache.org/jira/browse/FLINK-28698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang updated FLINK-28698: --- Description: !image-2022-07-27-10-00-49-345.png|width=921,height=382!  Currently, the display order

[jira] [Updated] (FLINK-28698) The display order of aggregated metrics should follow the order of task state transitions

[ https://issues.apache.org/jira/browse/FLINK-28698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang updated FLINK-28698: --- Description: !image-2022-07-27-10-00-49-345.png|width=921,height=382!  Currently, the display order

[jira] [Updated] (FLINK-28698) The display order of aggregated metrics should follow the order of task state transitions

[ https://issues.apache.org/jira/browse/FLINK-28698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang updated FLINK-28698: --- Attachment: image-2022-07-27-10-00-49-345.png > The display order of aggregated metrics should follo

[jira] [Created] (FLINK-28698) The display order of aggregated metrics should follow the order of task state transitions

Lijie Wang created FLINK-28698: -- Summary: The display order of aggregated metrics should follow the order of task state transitions Key: FLINK-28698 URL: https://issues.apache.org/jira/browse/FLINK-28698

[jira] [Commented] (FLINK-26902) Introduce performence tune and benchmark document for table store

[ https://issues.apache.org/jira/browse/FLINK-26902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571693#comment-17571693 ] Jingsong Lee commented on FLINK-26902: -- Hi [~ConradJam] You can see from your point

[GitHub] [flink] Vancior commented on a diff in pull request #20263: [FLINK-28510][python][connector] Support using new KafkaSink API

Vancior commented on code in PR #20263: URL: https://github.com/apache/flink/pull/20263#discussion_r930546050 ## flink-python/pyflink/datastream/connectors/base.py: ## @@ -52,6 +53,24 @@ def __init__(self, sink: Union[str, JavaObject]): super(Sink, self).__init__(sink)

[jira] [Closed] (FLINK-28692) Check warehouse path in CatalogFactory

[ https://issues.apache.org/jira/browse/FLINK-28692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-28692. Resolution: Fixed master: d30e7998b136dec0f9aded8376a516a76b467f2e release-0.2: f149a4f349fa2ced98

[GitHub] [flink-table-store] JingsongLi merged pull request #243: [FLINK-28692] Check warehouse path in CatalogFactory

JingsongLi merged PR #243: URL: https://github.com/apache/flink-table-store/pull/243 -- 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...@

[GitHub] [flink] tweise commented on pull request #20289: [FLINK-23633][FLIP-150][connector/common] HybridSource: Support dynamic stop position in FileSource

tweise commented on PR #20289: URL: https://github.com/apache/flink/pull/20289#issuecomment-1196163399 @xinbinhuang looking at all the modifications to HybridSource itself I think it is necessary to take a step back here and discuss the design aspects first. The underlying sources are

[GitHub] [flink-kubernetes-operator] czy006 commented on pull request #308: [FLINK-28223] Add artifact-fetcher to the pod-template.yaml example

czy006 commented on PR #308: URL: https://github.com/apache/flink-kubernetes-operator/pull/308#issuecomment-1196161652 @morhidi PLAT -- 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] lsyldliu commented on a diff in pull request #20361: [FLINK-27790][Table SQL / API] Port ADD JAR /SHOW JARS syntax implementation from SqlClient to TableEnvironment side

lsyldliu commented on code in PR #20361: URL: https://github.com/apache/flink/pull/20361#discussion_r929988353 ## flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/context/AddRemoteJarITCase.java: ## @@ -0,0 +1,110 @@ +package org.apache.flink.tabl

[jira] [Updated] (FLINK-28681) The number of windows allocated by sliding windows is inaccurate, when the window length is irregular

[ https://issues.apache.org/jira/browse/FLINK-28681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nyingping updated FLINK-28681: -- Description: In assignWindows, the initial length of the list of Windows is determined by '(int) (siz

[GitHub] [flink] lsyldliu commented on a diff in pull request #20361: [FLINK-27790][Table SQL / API] Port ADD JAR /SHOW JARS syntax implementation from SqlClient to TableEnvironment side

lsyldliu commented on code in PR #20361: URL: https://github.com/apache/flink/pull/20361#discussion_r92650 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java: ## @@ -461,6 +463,23 @@ public boolean dropTemporaryFun

[GitHub] [flink] flinkbot commented on pull request #20370: [FLINK-28185][Connector/Kafka] Make TimestampOffsetsInitializer apply offset reset str…

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

[jira] [Updated] (FLINK-28185) "Invalid negative offset" when using OffsetsInitializer.timestamp(.)

[ https://issues.apache.org/jira/browse/FLINK-28185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28185: --- Labels: pull-request-available (was: ) > "Invalid negative offset" when using OffsetsInitia

[GitHub] [flink] mas-chen opened a new pull request, #20370: [FLINK-28185] Make TimestampOffsetsInitializer apply offset reset str…

mas-chen opened a new pull request, #20370: URL: https://github.com/apache/flink/pull/20370 …ategy and handle timestamps that do not map to an offset ## What is the purpose of the change This change improves the TimestampOffsetsInitializer to be initialized with a configured of

[GitHub] [flink] rkhachatryan commented on a diff in pull request #20152: [FLINK-27155][changelog] Reduce multiple reads to the same Changelog …

rkhachatryan commented on code in PR #20152: URL: https://github.com/apache/flink/pull/20152#discussion_r930493192 ## flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/StateChangeIteratorWithCache.java: ## @@ -0,0 +1,367 @@ +/* + * Licensed to the Apache Soft

[jira] [Updated] (FLINK-27701) HashMapStateBackendWindowITCase. testAggregateWindowStateReader failed with Not all required tasks are currently running

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

[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 test-stability (was: stale-major test-stability) Pri

[jira] [Updated] (FLINK-22741) Hide Flink complexity from Stateful Functions

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

[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: features stale-major (was: features) I am the [Flink Jira Bot|https://github.com/ap

[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 ] Flink Jira Bot updated FLINK-28440: --- Labels: stale-critical test-stability (was: test-stability) I am the [Flink Jira Bot|https:

[jira] [Commented] (FLINK-28060) Kafka Commit on checkpointing fails repeatedly after a broker restart

[ https://issues.apache.org/jira/browse/FLINK-28060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571628#comment-17571628 ] David Anderson commented on FLINK-28060: [~martijnvisser] [~renqs] [~mason6345]

[jira] [Closed] (FLINK-27692) Support local recovery for materialized part(write, restore, discard)

[ https://issues.apache.org/jira/browse/FLINK-27692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-27692. - Assignee: Yanfei Lei Resolution: Fixed Merged into master as aef75be34d99c737f5c5

[GitHub] [flink] rkhachatryan merged pull request #19907: [FLINK-27692][state] Support local recovery for materialized part of changelog

rkhachatryan merged PR #19907: URL: https://github.com/apache/flink/pull/19907 -- 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...@flink.

[GitHub] [flink] dannycranmer commented on pull request #20360: [FLINK-27536][Connectors / Common] Rename method parameter in AsyncSi…

dannycranmer commented on PR #20360: URL: https://github.com/apache/flink/pull/20360#issuecomment-1195928597 @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 comme

[jira] [Comment Edited] (FLINK-28693) Codegen failed if the watermark is defined on a columnByExpression

[ https://issues.apache.org/jira/browse/FLINK-28693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571487#comment-17571487 ] Hongbo edited comment on FLINK-28693 at 7/26/22 5:49 PM: - Swapin

[GitHub] [flink] rkhachatryan commented on a diff in pull request #20306: [FLINK-28602][state/changelog] Close stream of StateChangeFsUploader normally while enabling compression

rkhachatryan commented on code in PR #20306: URL: https://github.com/apache/flink/pull/20306#discussion_r930161714 ## flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/StateChangeFsUploader.java: ## @@ -168,7 +168,7 @@ private UploadTasksResult upload(Path pa

[jira] [Closed] (FLINK-26853) HeapStateBackend ignores metadata updates in certain cases

[ https://issues.apache.org/jira/browse/FLINK-26853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-26853. - Fix Version/s: 1.16.0 Resolution: Fixed Merged into master as 8df50536ef913b63620

[GitHub] [flink] rkhachatryan merged pull request #20268: [FLINK-26853][state] Update state serializer in StateMap when metaInfo changed

rkhachatryan merged PR #20268: URL: https://github.com/apache/flink/pull/20268 -- 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...@flink.

[GitHub] [flink] rkhachatryan commented on a diff in pull request #19907: [FLINK-27692][state] Support local recovery for materialized part of changelog

rkhachatryan commented on code in PR #19907: URL: https://github.com/apache/flink/pull/19907#discussion_r930115553 ## flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java: ## @@ -407,8 +408,15 @@ public

[GitHub] [flink] zentol commented on pull request #20355: [FLINK-28634][json] Add simple JsonSerDeSchema

zentol commented on PR #20355: URL: https://github.com/apache/flink/pull/20355#issuecomment-1195637892 > It's very common for deserializers to include an implementation of getProducedType. We extend the `AbstractDeserializationSchema` which takes care of that based on the class/typei

[GitHub] [flink] flinkbot commented on pull request #20369: [FLINK-28697][table] MapDataSerializer doesn't declare a serialVersionUID

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

[jira] [Updated] (FLINK-28697) MapDataSerializer doesn't declare a serialVersionUID

[ https://issues.apache.org/jira/browse/FLINK-28697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28697: --- Labels: pull-request-available (was: ) > MapDataSerializer doesn't declare a serialVersionU

[GitHub] [flink] jmahonin opened a new pull request, #20369: [FLINK-28697][table] MapDataSerializer doesn't declare a serialVersionUID

jmahonin opened a new pull request, #20369: URL: https://github.com/apache/flink/pull/20369 ## What is the purpose of the change *MapDataSerializer doesn't declare a serialVersionUID, which can manifest as a InvalidClassException when attempting to serialize with different JREs for c

[GitHub] [flink] alpinegizmo commented on a diff in pull request #20355: [FLINK-28634][json] Add simple JsonSerDeSchema

alpinegizmo commented on code in PR #20355: URL: https://github.com/apache/flink/pull/20355#discussion_r930088762 ## docs/content.zh/docs/connectors/datastream/formats/json.md: ## @@ -0,0 +1,77 @@ +--- +title: "JSON" +weight: 4 +type: docs +--- + + +# Json format + +To use the

[GitHub] [flink] flinkbot commented on pull request #20368: [FLINK-28696][runtime] Fix the bug that the blocklist listeners will not be notified when there are no newly added nodes (only merge nodes)

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

[jira] [Created] (FLINK-28697) MapDataSerializer doesn't declare a serialVersionUID

Josh Mahonin created FLINK-28697: Summary: MapDataSerializer doesn't declare a serialVersionUID Key: FLINK-28697 URL: https://issues.apache.org/jira/browse/FLINK-28697 Project: Flink Issue Ty

[jira] [Updated] (FLINK-28696) Notify all newlyAdded/Merged blocked nodes to BlocklistListener

[ https://issues.apache.org/jira/browse/FLINK-28696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28696: --- Labels: pull-request-available (was: ) > Notify all newlyAdded/Merged blocked nodes to Bloc

[jira] [Commented] (FLINK-28693) Codegen failed if the watermark is defined on a columnByExpression

[ https://issues.apache.org/jira/browse/FLINK-28693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571487#comment-17571487 ] Hongbo commented on FLINK-28693: Swapping replacing flink-table-planner-loader with flin

[GitHub] [flink] wanglijie95 opened a new pull request, #20368: [FLINK-28696][runtime] Fix the bug that the blocklist listeners will not be notified when there are no newly added nodes (only merge nod

wanglijie95 opened a new pull request, #20368: URL: https://github.com/apache/flink/pull/20368 ## What is the purpose of the change [FLINK-28696][runtime] Fix the bug that the blocklist listeners will not be notified when there are no newly added nodes (only merge nodes) ## Ver

[GitHub] [flink-kubernetes-operator] morhidi commented on a diff in pull request #308: [FLINK-28223] Add artifact-fetcher to the pod-template.yaml example

morhidi commented on code in PR #308: URL: https://github.com/apache/flink-kubernetes-operator/pull/308#discussion_r930060228 ## examples/pod-template-artifact-fetcher.yaml: ## @@ -0,0 +1,84 @@ + R

[jira] [Updated] (FLINK-28592) Custom resource counter metrics improvements

[ https://issues.apache.org/jira/browse/FLINK-28592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28592: --- Labels: pull-request-available (was: ) > Custom resource counter metrics improvements > ---

[GitHub] [flink-kubernetes-operator] morhidi opened a new pull request, #331: [FLINK-28592] Custom resource counter metrics improvements

morhidi opened a new pull request, #331: URL: https://github.com/apache/flink-kubernetes-operator/pull/331 ## What is the purpose of the change - add option to turn on/off the base custom resource metrics - some additional refactor around the `MetricManager` ## Brief change log -

[jira] [Commented] (FLINK-28680) No space left on device on Azure e2e_2_ci tests

[ https://issues.apache.org/jira/browse/FLINK-28680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571471#comment-17571471 ] Robert Metzger commented on FLINK-28680: Sorry, I wasn't sure whether 1.14 is st

[GitHub] [flink] maosuhan commented on a diff in pull request #14376: [FLINK-18202][PB format] New Format of protobuf

maosuhan commented on code in PR #14376: URL: https://github.com/apache/flink/pull/14376#discussion_r930035338 ## flink-formats/flink-sql-protobuf/src/main/resources/META-INF/NOTICE: ## @@ -0,0 +1,9 @@ +flink-sql-protobuf +Copyright 2014-2021 The Apache Software Foundation + +Th

[GitHub] [flink] flinkbot commented on pull request #20367: [FLINK-19589][Filesystem][S3] Support per-connector FileSystem configuration

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

[jira] [Commented] (FLINK-26902) Introduce performence tune and benchmark document for table store

[ https://issues.apache.org/jira/browse/FLINK-26902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571460#comment-17571460 ] ConradJam commented on FLINK-26902: --- Hi [~lzljs3620320] I want to tick this ticket to

[jira] [Commented] (FLINK-19589) Support per-connector FileSystem configuration

[ https://issues.apache.org/jira/browse/FLINK-19589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17571456#comment-17571456 ] Josh Mahonin commented on FLINK-19589: -- PR is open. Note that this only address dyn

[jira] [Updated] (FLINK-19589) Support per-connector FileSystem configuration

[ https://issues.apache.org/jira/browse/FLINK-19589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19589: --- Labels: pull-request-available (was: ) > Support per-connector FileSystem configuration > -

[GitHub] [flink] jmahonin opened a new pull request, #20367: [FLINK-19589][Filesystem][S3] Support per-connector FileSystem configuration

jmahonin opened a new pull request, #20367: URL: https://github.com/apache/flink/pull/20367 ## What is the purpose of the change Introduces dynamic filesystem configuration for S3 ## Brief change log - *Add URI query parameter parsing and apply `fs.s3a.` entries to Hado

[GitHub] [flink-ml] taosiyuan163 commented on a diff in pull request #132: [FLINK-28571] Add AlgoOperator for Chi-squared test

taosiyuan163 commented on code in PR #132: URL: https://github.com/apache/flink-ml/pull/132#discussion_r930018268 ## flink-ml-lib/src/main/java/org/apache/flink/ml/stats/chisqtest/ChiSqTest.java: ## @@ -0,0 +1,492 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under

[jira] [Updated] (FLINK-28696) Notify all newlyAdded/Merged blocked nodes to BlocklistListener

[ https://issues.apache.org/jira/browse/FLINK-28696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang updated FLINK-28696: --- Description: This bug was introduced by FLINK-28660. Our newly added logic results in that blocklis

[jira] [Created] (FLINK-28696) Notify all newlyAdded/Merged blocked nodes to BlocklistListener

Lijie Wang created FLINK-28696: -- Summary: Notify all newlyAdded/Merged blocked nodes to BlocklistListener Key: FLINK-28696 URL: https://issues.apache.org/jira/browse/FLINK-28696 Project: Flink

  1   2   3   >