[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

[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

[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

[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

[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

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

[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

[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

[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=17571719#comment-17571719 ] Hangxiang Yu commented on FLINK-28653: -- Hi, Maybe you could try to set

[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=17571720#comment-17571720 ] Yun Tang commented on FLINK-28577: -- [~Yu Chen] Thanks for figuring out this problem, and it seems we

[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

[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=17571718#comment-17571718 ] Yun Tang commented on FLINK-28697: -- [~jmahonin] Did you use different flink versions between the client

[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

[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=17571715#comment-17571715 ] Xintong Song commented on FLINK-28698: -- Thanks [~wanglijie95], that makes sense to me. [~junhany],

[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

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

[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

[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

[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=17571713#comment-17571713 ] Yu Chen commented on FLINK-28577: - Well, I think I've found the root cause of this issue: it is mainly

[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

[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

[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

[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

[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

[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=17571694#comment-17571694 ] Lijie Wang commented on FLINK-28698: cc [~xtsong]  > The display order of aggregated metrics should

[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

[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

[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

[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=17571693#comment-17571693 ] Jingsong Lee commented on FLINK-26902: -- Hi [~ConradJam] You can see from your point of view, how

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

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

[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

[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

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

[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

[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

[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

[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

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

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

[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

[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

[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

[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=17571628#comment-17571628 ] David Anderson commented on FLINK-28060: [~martijnvisser] [~renqs] [~mason6345] Are we any

[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

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

[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

[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=17571487#comment-17571487 ] Hongbo edited comment on FLINK-28693 at 7/26/22 5:49 PM: - Swaping

[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

[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

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

[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

[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

[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

[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

[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

[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=17571487#comment-17571487 ] Hongbo commented on FLINK-28693: Swapping replacing flink-table-planner-loader with flink-table-planer

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

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

[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=17571471#comment-17571471 ] Robert Metzger commented on FLINK-28680: Sorry, I wasn't sure whether 1.14 is still maintained.

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

[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=17571460#comment-17571460 ] ConradJam commented on FLINK-26902: --- Hi [~lzljs3620320] I want to tick this ticket to my first commit

[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=17571456#comment-17571456 ] Josh Mahonin commented on FLINK-19589: -- PR is open. Note that this only address dynamic

[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

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

[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

[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

[jira] [Commented] (FLINK-27536) Rename method parameter in AsyncSinkWriter

[ https://issues.apache.org/jira/browse/FLINK-27536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17571447#comment-17571447 ] DavidLiu commented on FLINK-27536: -- [~dannycranmer]  Please help review this Pull Request again，which

[jira] (FLINK-27536) Rename method parameter in AsyncSinkWriter

[ https://issues.apache.org/jira/browse/FLINK-27536 ] DavidLiu deleted comment on FLINK-27536: -- was (Author: JIRAUSER289843): [~dannycranmer]  Please help review this Pull Request again，which has been updated. 

[jira] [Created] (FLINK-28695) Fail to send partition request to restarted taskmanager

Simonas created FLINK-28695: --- Summary: Fail to send partition request to restarted taskmanager Key: FLINK-28695 URL: https://issues.apache.org/jira/browse/FLINK-28695 Project: Flink Issue Type:

[jira] [Updated] (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:all-tabpanel ] Hongbo updated FLINK-28693: --- Description: The following code will throw an exception:   {code:java} Table program cannot be compiled.

[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

[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=17571444#comment-17571444 ] Hongbo commented on FLINK-28693: Is it caused by change in the codegen logic or a classloader problem

[jira] [Updated] (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:all-tabpanel ] Hongbo updated FLINK-28693: --- Description: The following code will throw an exception:   {code:java} Table program cannot be compiled.

[jira] [Comment Edited] (FLINK-27536) Rename method parameter in AsyncSinkWriter

[ https://issues.apache.org/jira/browse/FLINK-27536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17571196#comment-17571196 ] DavidLiu edited comment on FLINK-27536 at 7/26/22 1:54 PM: --- [~dannycranmer] 

[jira] [Updated] (FLINK-28694) Set pipeline.name to resource name by default for application deployments

[ https://issues.apache.org/jira/browse/FLINK-28694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-28694: --- Summary: Set pipeline.name to resource name by default for application deployments (was: Set

[jira] [Commented] (FLINK-28694) Set pipeline.name to resource name by default for application deployments

[ https://issues.apache.org/jira/browse/FLINK-28694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17571443#comment-17571443 ] Gyula Fora commented on FLINK-28694: [~wangyang0918] do you see any downsides? > Set pipeline.name

[jira] [Updated] (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:all-tabpanel ] Hongbo updated FLINK-28693: --- Description: The following code will throw an exception:   {code:java} Table program cannot be compiled.

  1   2   3   >