[GitHub] [flink] luoyuxia commented on pull request #21149: [FLINK-29527][formats/parquet] Make unknownFieldsIndices work for single ParquetReader

luoyuxia commented on PR #21149: URL: https://github.com/apache/flink/pull/21149#issuecomment-1336860164 @saLeox Thanks for contribution. I had a quick look about the changes. These changes looks reasonable to me. @Tartarus0zm Could you please have a look again to check these changes s

[GitHub] [flink-table-store] tsreaper commented on a diff in pull request #410: [FLINK-30247] Introduce time travel reading for table store

tsreaper commented on code in PR #410: URL: https://github.com/apache/flink-table-store/pull/410#discussion_r1039215031 ## docs/layouts/shortcodes/generated/core_configuration.html: ## @@ -8,6 +8,18 @@ + +as-of-snapshot +(non

[jira] [Created] (FLINK-30294) Change table property key 'log.scan' to 'startup.mode' and add a default startup mode in Table Store

Caizhi Weng created FLINK-30294: --- Summary: Change table property key 'log.scan' to 'startup.mode' and add a default startup mode in Table Store Key: FLINK-30294 URL: https://issues.apache.org/jira/browse/FLINK-30294

[jira] (FLINK-28513) Flink Table API CSV streaming sink throws SerializedThrowable exception

[ https://issues.apache.org/jira/browse/FLINK-28513 ] Samrat Deb deleted comment on FLINK-28513: was (Author: samrat007):   org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy at org.apache.fli

[jira] [Commented] (FLINK-28513) Flink Table API CSV streaming sink throws SerializedThrowable exception

[ https://issues.apache.org/jira/browse/FLINK-28513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17643135#comment-17643135 ] Samrat Deb commented on FLINK-28513:   org.apache.flink.runtime.JobException: Recove

[jira] [Updated] (FLINK-30293) Create an enumerator for static (batch)

[ https://issues.apache.org/jira/browse/FLINK-30293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30293: --- Labels: pull-request-available (was: ) > Create an enumerator for static (batch) >

[GitHub] [flink-table-store] zjureel opened a new pull request, #421: [FLINK-30293] Add static snapshot enumerator

zjureel opened a new pull request, #421: URL: https://github.com/apache/flink-table-store/pull/421 Add a `StaticSnapshotEnumerator` to generate snapshots for `StaticFileStoreSource` in scan -- This is an automated message from the Apache Git Service. To respond to the message, please log

[jira] [Commented] (FLINK-30254) Sync Pulsar updates to external Pulsar connector repository

[ https://issues.apache.org/jira/browse/FLINK-30254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17643129#comment-17643129 ] Martijn Visser commented on FLINK-30254: [~syhily] This will probably be done to

[jira] [Commented] (FLINK-30254) Sync Pulsar updates to external Pulsar connector repository

[ https://issues.apache.org/jira/browse/FLINK-30254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17643128#comment-17643128 ] Yufan Sheng commented on FLINK-30254: - [~martijnvisser] I want to migrate all the pe

[GitHub] [flink-ml] jiangxin369 commented on a diff in pull request #183: [FLINK-29603] Add Transformer for StopWordsRemover

jiangxin369 commented on code in PR #183: URL: https://github.com/apache/flink-ml/pull/183#discussion_r1039164531 ## docs/content/docs/operators/feature/stopwordsremover.md: ## @@ -0,0 +1,165 @@ +--- +title: "StopWordsRemover" +weight: 1 +type: docs +aliases: +- /operators/featu

[GitHub] [flink-ml] jiangxin369 commented on a diff in pull request #183: [FLINK-29603] Add Transformer for StopWordsRemover

jiangxin369 commented on code in PR #183: URL: https://github.com/apache/flink-ml/pull/183#discussion_r1039164531 ## docs/content/docs/operators/feature/stopwordsremover.md: ## @@ -0,0 +1,165 @@ +--- +title: "StopWordsRemover" +weight: 1 +type: docs +aliases: +- /operators/featu

[GitHub] [flink] fsk119 commented on pull request #21133: [FLINK-29732][sql-gateway] support configuring session with SQL statement.

fsk119 commented on PR #21133: URL: https://github.com/apache/flink/pull/21133#issuecomment-1336779615 I have added a commit to improve the codes. Could you take a time to look, @yuzelin ? -- This is an automated message from the Apache Git Service. To respond to the message, please log o

[jira] (FLINK-27176) FLIP-220: Binary Sorted State

[ https://issues.apache.org/jira/browse/FLINK-27176 ] Echo Lee deleted comment on FLINK-27176: -- was (Author: echo lee): Hi [~danderson]  Is there any progress on this feature? We want to optimize temporal join operator. I think this idea is very

[GitHub] [flink] flinkbot commented on pull request #21453: [hotfix][table-planner] fix tests for FLINK-28988 merged(no code conflict with latest master but a related test case failed)

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

[GitHub] [flink] lincoln-lil opened a new pull request, #21453: [hotfix][table-planner] fix tests for FLINK-28988 merged(no code conflict with latest master but a related test case failed)

lincoln-lil opened a new pull request, #21453: URL: https://github.com/apache/flink/pull/21453 FLINK-28988 fixed the incorrectly filter pushdown issue, but when merged into master it affects a related test case (added by FLINK-29781 recently), this pr will fix this fail case. -- This is

[GitHub] [flink-table-store] zjureel commented on pull request #410: [FLINK-30247] Introduce time travel reading for table store

zjureel commented on PR #410: URL: https://github.com/apache/flink-table-store/pull/410#issuecomment-1336743159 > Pretty good! I will fix https://issues.apache.org/jira/browse/FLINK-30293 first, please assign it to me, THX -- This is an automated message from the Apache Git Servi

[GitHub] [flink] flinkbot commented on pull request #21452: [FLINK-30282] Fix Logical type ROW lost inner field's nullability after converting to RelDataType

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

[GitHub] [flink] LadyForest opened a new pull request, #21452: [FLINK-30282] Fix Logical type ROW lost inner field's nullability after converting to RelDataType

LadyForest opened a new pull request, #21452: URL: https://github.com/apache/flink/pull/21452 ## What is the purpose of the change This pull request fixes the issue that Flink SQL's logical type `Row` lost the inner field's nullability after converting to `RelDataType`. E.g. `a Row` i

[jira] [Updated] (FLINK-30282) Logical type ROW lost inner field's nullability after convert to RelDataType

[ https://issues.apache.org/jira/browse/FLINK-30282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30282: --- Labels: pull-request-available (was: ) > Logical type ROW lost inner field's nullability af

[GitHub] [flink] maosuhan commented on a diff in pull request #21436: [FLINK-30093] [formats] Protobuf Timestamp Compile Error

maosuhan commented on code in PR #21436: URL: https://github.com/apache/flink/pull/21436#discussion_r1039121017 ## flink-formats/flink-protobuf/src/test/java/org/apache/flink/formats/protobuf/Pb3ToRowTest.java: ## @@ -85,6 +88,8 @@ public void testDeserialization() throws Except

[GitHub] [flink] flinkbot commented on pull request #21451: [hotfix][docs] Update the link for `concepts'

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

[GitHub] [flink] ChenZhongPu opened a new pull request, #21451: [hotfix][docs] Update the link for `concepts'

ChenZhongPu opened a new pull request, #21451: URL: https://github.com/apache/flink/pull/21451 - The `concepts` link in try-flink/local_installation#Summary is broken, and it leads an empty page. (ref "docs/concepts" -> ref "docs/concepts/overview") - For consistency, the first letter sho

[jira] (FLINK-29527) Make unknownFieldsIndices work for single ParquetReader

[ https://issues.apache.org/jira/browse/FLINK-29527 ] Sun Shun deleted comment on FLINK-29527: -- was (Author: JIRAUSER283602): [~lirui] could you please help take a look at this PR when you are free, thanks > Make unknownFieldsIndices work for sing

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #183: [FLINK-29603] Add Transformer for StopWordsRemover

yunfengzhou-hub commented on code in PR #183: URL: https://github.com/apache/flink-ml/pull/183#discussion_r1039104387 ## docs/content/docs/operators/feature/stopwordsremover.md: ## @@ -0,0 +1,165 @@ +--- +title: "StopWordsRemover" +weight: 1 +type: docs +aliases: +- /operators/f

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #183: [FLINK-29603] Add Transformer for StopWordsRemover

yunfengzhou-hub commented on code in PR #183: URL: https://github.com/apache/flink-ml/pull/183#discussion_r1039103892 ## flink-ml-lib/src/main/resources/org/apache/flink/ml/feature/stopwords/README: ## @@ -0,0 +1,12 @@ +Stopwords Corpus Review Comment: When the amount of wor

[GitHub] [flink] dupen01 closed pull request #16947: update hive_function.md

dupen01 closed pull request #16947: update hive_function.md URL: https://github.com/apache/flink/pull/16947 -- 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-ma

[GitHub] [flink] godfreyhe merged pull request #20745: [FLINK-28988] Don't push filters down into the right table for temporal join

godfreyhe merged PR #20745: URL: https://github.com/apache/flink/pull/20745 -- 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.apa

[GitHub] [flink-ml] yunfengzhou-hub commented on pull request #171: [FLINK-29911] Improve performance of AgglomerativeClustering

yunfengzhou-hub commented on PR #171: URL: https://github.com/apache/flink-ml/pull/171#issuecomment-1336653558 Thanks for the update! It LGTM. -- 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

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #414: [FLINK-30263] Introduce schemas table in table store

JingsongLi commented on code in PR #414: URL: https://github.com/apache/flink-table-store/pull/414#discussion_r1039094224 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/table/metadata/SchemasTable.java: ## @@ -0,0 +1,258 @@ +/* + * Licensed to the Apache So

[jira] [Closed] (FLINK-30207) Move split initialization and discovery logic fully into SnapshotEnumerator in Table Store

[ https://issues.apache.org/jira/browse/FLINK-30207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30207. Resolution: Fixed master: 23dad789879735249651992ab9fe23b986ef1564 > Move split initialization an

[GitHub] [flink-table-store] JingsongLi merged pull request #411: [FLINK-30207] Move split initialization and discovery logic fully into SnapshotEnumerator in Table Store

JingsongLi merged PR #411: URL: https://github.com/apache/flink-table-store/pull/411 -- 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-table-store] JingsongLi commented on a diff in pull request #410: [FLINK-30247] Introduce time travel reading for table store

JingsongLi commented on code in PR #410: URL: https://github.com/apache/flink-table-store/pull/410#discussion_r1039089223 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/AbstractFileStoreScan.java: ## @@ -184,10 +203,14 @@ public Plan plan() {

[jira] [Created] (FLINK-30293) Create an enumerator for static (batch)

Jingsong Lee created FLINK-30293: Summary: Create an enumerator for static (batch) Key: FLINK-30293 URL: https://issues.apache.org/jira/browse/FLINK-30293 Project: Flink Issue Type: Improveme

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #416: [FLINK-30271] Introduce Table.copy from dynamic options

JingsongLi commented on code in PR #416: URL: https://github.com/apache/flink-table-store/pull/416#discussion_r1039087564 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/table/AbstractFileStoreTable.java: ## @@ -40,6 +47,43 @@ public AbstractFileStoreTable(P

[GitHub] [flink] Myracle commented on pull request #21347: [FLINK-29640][Client/Job Submission]Enhance the function configured by execution.shutdown-on-attached-exi…

Myracle commented on PR #21347: URL: https://github.com/apache/flink/pull/21347#issuecomment-1336607971 @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.

[jira] [Created] (FLINK-30292) Better support for conversion between DataType and TypeInformation

Yunfeng Zhou created FLINK-30292: Summary: Better support for conversion between DataType and TypeInformation Key: FLINK-30292 URL: https://issues.apache.org/jira/browse/FLINK-30292 Project: Flink

[GitHub] [flink] flinkbot commented on pull request #21450: [FLINK-30291][Connector/DynamoDB] Update docs to render DynamoDB conn…

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

[GitHub] [flink] dannycranmer opened a new pull request, #21450: [FLINK-30291][Connector/DynamoDB] Update docs to render DynamoDB conn…

dannycranmer opened a new pull request, #21450: URL: https://github.com/apache/flink/pull/21450 ## What is the purpose of the change Integrate flink-connector-aws into Flink docs Related https://github.com/apache/flink/pull/21449 ## Brief change log - Add a new sho

[GitHub] [flink] flinkbot commented on pull request #21449: [FLINK-30291][Connector/DynamoDB] Update docs to render DynamoDB conn…

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

[jira] [Updated] (FLINK-30291) Integrate flink-connector-aws into Flink docs

[ https://issues.apache.org/jira/browse/FLINK-30291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30291: --- Labels: pull-request-available (was: ) > Integrate flink-connector-aws into Flink docs > --

[GitHub] [flink] dannycranmer opened a new pull request, #21449: [FLINK-30291][Connector/DynamoDB] Update docs to render DynamoDB conn…

dannycranmer opened a new pull request, #21449: URL: https://github.com/apache/flink/pull/21449 ## What is the purpose of the change Integrate flink-connector-aws into Flink docs ## Brief change log - Add a new short_code (`sql_connector_download_table`) to render SQL

[jira] [Assigned] (FLINK-30291) Integrate flink-connector-aws into Flink docs

[ https://issues.apache.org/jira/browse/FLINK-30291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-30291: - Assignee: Danny Cranmer > Integrate flink-connector-aws into Flink docs > -

[jira] [Created] (FLINK-30291) Integrate flink-connector-aws into Flink docs

Danny Cranmer created FLINK-30291: - Summary: Integrate flink-connector-aws into Flink docs Key: FLINK-30291 URL: https://issues.apache.org/jira/browse/FLINK-30291 Project: Flink Issue Type: T

[GitHub] [flink-connector-aws] dannycranmer opened a new pull request, #35: [FLINK-29907] Externalize Kinesis/Firehose documentation

dannycranmer opened a new pull request, #35: URL: https://github.com/apache/flink-connector-aws/pull/35 Copy over documentation for Kinesis and Firehose from the Flink repo -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and u

[jira] [Resolved] (FLINK-29109) Checkpoint path conflict with stateless upgrade mode

[ https://issues.apache.org/jira/browse/FLINK-29109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-29109. -- Resolution: Fixed > Checkpoint path conflict with stateless upgrade mode > ---

[jira] [Updated] (FLINK-29109) Checkpoint path conflict with stateless upgrade mode

[ https://issues.apache.org/jira/browse/FLINK-29109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-29109: - Fix Version/s: kubernetes-operator-1.3.0 > Checkpoint path conflict with stateless upgrade mode

[jira] [Updated] (FLINK-30287) Configmaps get cleaned up when upgrading standalone Flink cluster

[ https://issues.apache.org/jira/browse/FLINK-30287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-30287: - Affects Version/s: (was: 1.2) > Configmaps get cleaned up when upgrading standalone

[jira] [Created] (FLINK-30290) IteratorSourceReaderBase should report END_OF_INPUT sooner

Chesnay Schepler created FLINK-30290: Summary: IteratorSourceReaderBase should report END_OF_INPUT sooner Key: FLINK-30290 URL: https://issues.apache.org/jira/browse/FLINK-30290 Project: Flink

[jira] [Created] (FLINK-30289) RateLimitedSourceReader uses wrong signal for checkpoint rate-limiting

Chesnay Schepler created FLINK-30289: Summary: RateLimitedSourceReader uses wrong signal for checkpoint rate-limiting Key: FLINK-30289 URL: https://issues.apache.org/jira/browse/FLINK-30289 Projec

[jira] [Closed] (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:all-tabpanel ] Chesnay Schepler closed FLINK-30202. Fix Version/s: 1.17.0 Resolution: Fixed master: 81ed6c649e1a219c457628c54a7165d75b8

[GitHub] [flink] zentol merged pull request #21416: [FLINK-30202][tests] Do not assert on checkpointId

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

[jira] [Updated] (FLINK-27184) Optimize IntervalJoinOperator by using binary sorted state

[ https://issues.apache.org/jira/browse/FLINK-27184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27184: --- Summary: Optimize IntervalJoinOperator by using binary sorted state (was: Optimize Interval

[jira] [Updated] (FLINK-27184) Optimize IntervalJoinOperator by using binary sorted state

[ https://issues.apache.org/jira/browse/FLINK-27184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27184: --- Description: The performance of interval joins on RocksDB can be optimized by using binary s

[jira] [Updated] (FLINK-27182) Optimize RowTimeSortOperator by using binary sorted state

[ https://issues.apache.org/jira/browse/FLINK-27182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27182: --- Summary: Optimize RowTimeSortOperator by using binary sorted state (was: Optimize RowTimeSo

[jira] [Updated] (FLINK-27183) Optimize CepOperator by using temporal state

[ https://issues.apache.org/jira/browse/FLINK-27183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27183: --- Description: The performance of CEP on RocksDB can be significantly improved by having it us

[jira] [Updated] (FLINK-27183) Optimize CepOperator by using binary sorted state

[ https://issues.apache.org/jira/browse/FLINK-27183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27183: --- Summary: Optimize CepOperator by using binary sorted state (was: Optimize CepOperator by us

[jira] [Updated] (FLINK-27182) Optimize RowTimeSortOperator by using binary sorted state

[ https://issues.apache.org/jira/browse/FLINK-27182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27182: --- Description: The performance of the RowTimeSortOperator can be significantly improved by usi

[jira] [Updated] (FLINK-27181) Optimize TemporalRowTimeJoinOperator by using temporal state

[ https://issues.apache.org/jira/browse/FLINK-27181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27181: --- Description: The throughput of the TemporalRowTimeJoinOperator can be significantly improved

[jira] [Updated] (FLINK-27181) Optimize TemporalRowTimeJoinOperator by using binary sorted state

[ https://issues.apache.org/jira/browse/FLINK-27181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27181: --- Summary: Optimize TemporalRowTimeJoinOperator by using binary sorted state (was: Optimize T

[jira] [Closed] (FLINK-27179) Update training example to use temporal state

[ https://issues.apache.org/jira/browse/FLINK-27179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson closed FLINK-27179. -- Resolution: Won't Do > Update training example to use temporal state > ---

[jira] [Updated] (FLINK-27180) Docs for binary sorted state

[ https://issues.apache.org/jira/browse/FLINK-27180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27180: --- Description: Update [https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastre

[jira] [Updated] (FLINK-27180) Docs for binary sorted state

[ https://issues.apache.org/jira/browse/FLINK-27180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27180: --- Summary: Docs for binary sorted state (was: Docs for temporal state) > Docs for binary sort

[jira] [Updated] (FLINK-27178) create examples that use binary sorted state

[ https://issues.apache.org/jira/browse/FLINK-27178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27178: --- Summary: create examples that use binary sorted state (was: create examples that use tempor

[jira] [Updated] (FLINK-27178) create examples that use binary sorted state

[ https://issues.apache.org/jira/browse/FLINK-27178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27178: --- Description: Add examples showing how to use binary sorted state. E.g., for custom windowing

[jira] [Updated] (FLINK-27177) Implement Binary Sorted State

[ https://issues.apache.org/jira/browse/FLINK-27177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27177: --- Summary: Implement Binary Sorted State (was: Implement Temporal State) > Implement Binary S

[jira] [Updated] (FLINK-27177) Implement Binary Sorted State

[ https://issues.apache.org/jira/browse/FLINK-27177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27177: --- Description: Following the plan in [FLIP-220|[https://cwiki.apache.org/confluence/x/Xo_FD]|h

[jira] [Updated] (FLINK-27176) FLIP-220: Binary Sorted State

[ https://issues.apache.org/jira/browse/FLINK-27176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27176: --- Description: Task for implementing FLIP-220: Binary Sorted State: [https://cwiki.apache.org/

[jira] [Updated] (FLINK-27176) FLIP-220: Binary Sorted State

[ https://issues.apache.org/jira/browse/FLINK-27176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27176: --- Release Note: Added BinarySortedState to optimize state accesses and updates used for sortin

[jira] [Updated] (FLINK-27176) FLIP-220: Binary Sorted State

[ https://issues.apache.org/jira/browse/FLINK-27176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-27176: --- Summary: FLIP-220: Binary Sorted State (was: FLIP-220: Temporal State) > FLIP-220: Binary S

[jira] [Assigned] (FLINK-27176) FLIP-220: Binary Sorted State

[ https://issues.apache.org/jira/browse/FLINK-27176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson reassigned FLINK-27176: -- Assignee: David Anderson > FLIP-220: Binary Sorted State > --

[GitHub] [flink] hdulay commented on a diff in pull request #21436: [FLINK-30093] [formats] Protobuf Timestamp Compile Error

hdulay commented on code in PR #21436: URL: https://github.com/apache/flink/pull/21436#discussion_r1039021869 ## flink-formats/flink-protobuf/src/test/java/org/apache/flink/formats/protobuf/Pb3ToRowTest.java: ## @@ -85,6 +88,8 @@ public void testDeserialization() throws Exceptio

[GitHub] [flink] MartijnVisser commented on a diff in pull request #21436: [FLINK-30093] [formats] Protobuf Timestamp Compile Error

MartijnVisser commented on code in PR #21436: URL: https://github.com/apache/flink/pull/21436#discussion_r1039012360 ## flink-formats/flink-protobuf/src/test/java/org/apache/flink/formats/protobuf/Pb3ToRowTest.java: ## @@ -85,6 +88,8 @@ public void testDeserialization() throws E

[jira] [Closed] (FLINK-30186) Bump Flink version to 1.15.3

[ https://issues.apache.org/jira/browse/FLINK-30186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-30186. -- Resolution: Fixed Merged to main 3c5ec6cd86de61752c708eba385646a7c1164880 > Bump Flink version to 1.1

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #451: [FLINK-30186] Bump Flink version to 1.15.3

gyfora merged PR #451: URL: https://github.com/apache/flink-kubernetes-operator/pull/451 -- 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] hdulay commented on a diff in pull request #21436: [FLINK-30093] [formats] Protobuf Timestamp Compile Error

hdulay commented on code in PR #21436: URL: https://github.com/apache/flink/pull/21436#discussion_r1039003583 ## flink-formats/flink-protobuf/src/test/java/org/apache/flink/formats/protobuf/Pb3ToRowTest.java: ## @@ -85,6 +88,8 @@ public void testDeserialization() throws Exceptio

[GitHub] [flink-table-store] zjureel commented on a diff in pull request #416: [FLINK-30271] Introduce Table.copy from dynamic options

zjureel commented on code in PR #416: URL: https://github.com/apache/flink-table-store/pull/416#discussion_r1038981579 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/table/AbstractFileStoreTable.java: ## @@ -40,6 +47,43 @@ public AbstractFileStoreTable(Path

[GitHub] [flink] maosuhan commented on a diff in pull request #21436: [FLINK-30093] [formats] Protobuf Timestamp Compile Error

maosuhan commented on code in PR #21436: URL: https://github.com/apache/flink/pull/21436#discussion_r1038980183 ## flink-formats/flink-protobuf/src/test/java/org/apache/flink/formats/protobuf/Pb3ToRowTest.java: ## @@ -85,6 +88,8 @@ public void testDeserialization() throws Except

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #457: [docs] Add controller flow docs

gyfora commented on PR #457: URL: https://github.com/apache/flink-kubernetes-operator/pull/457#issuecomment-1336426415 I will remove them once back from holiday , this is not urgent. Thank you! -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink-table-store] zjureel commented on a diff in pull request #418: [FLINK-30273] Introduce RecordReaderUtils.transform to transform RecordReader

zjureel commented on code in PR #418: URL: https://github.com/apache/flink-table-store/pull/418#discussion_r1038979729 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/utils/RecordReaderUtils.java: ## @@ -44,4 +45,49 @@ public static void forEachRemaini

[GitHub] [flink-table-store] zjureel commented on a diff in pull request #418: [FLINK-30273] Introduce RecordReaderUtils.transform to transform RecordReader

zjureel commented on code in PR #418: URL: https://github.com/apache/flink-table-store/pull/418#discussion_r1038979666 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/utils/RecordReaderUtils.java: ## @@ -44,4 +45,49 @@ public static void forEachRemaini

[jira] [Closed] (FLINK-28766) UnalignedCheckpointStressITCase.runStressTest failed with NoSuchFileException

[ https://issues.apache.org/jira/browse/FLINK-28766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-28766. -- Resolution: Fixed Merged to master as 1ddaa2a460d and 9e1cefe2509 > UnalignedCheckpointStress

[GitHub] [flink] pnowojski merged pull request #21440: [FLINK-28766][tests] Safe iterate over checkpoint files in order to avoid exception during parallel savepoint deletion

pnowojski merged PR #21440: URL: https://github.com/apache/flink/pull/21440 -- 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.apa

[GitHub] [flink-kubernetes-operator] morhidi commented on pull request #457: [docs] Add controller flow docs

morhidi commented on PR #457: URL: https://github.com/apache/flink-kubernetes-operator/pull/457#issuecomment-1336415811 > > +1 I was unable to render the pictures on this PR. > > Sorry @morhidi , I should have posted some screenshots. Unfortunately I don’t have the laptop on me hm

[GitHub] [flink-kubernetes-operator] morhidi merged pull request #420: FLINK-29536 - Add WATCH_NAMESPACE env var to operator

morhidi merged PR #420: URL: https://github.com/apache/flink-kubernetes-operator/pull/420 -- 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-unsubsc

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #457: [docs] Add controller flow docs

gyfora commented on PR #457: URL: https://github.com/apache/flink-kubernetes-operator/pull/457#issuecomment-1336413490 > +1 I was unable to render the pictures on this PR. Sorry @morhidi , I should have posted some screenshots. Unfortunately I don’t have the laptop on me -- This

[GitHub] [flink-kubernetes-operator] morhidi merged pull request #469: [FLINK-29109] Generate random jobId for stateless upgrade mode irrespective of Flink version

morhidi merged PR #469: URL: https://github.com/apache/flink-kubernetes-operator/pull/469 -- 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-unsubsc

[GitHub] [flink-kubernetes-operator] tagarr commented on a diff in pull request #420: FLINK-29536 - Add WATCH_NAMESPACE env var to operator

tagarr commented on code in PR #420: URL: https://github.com/apache/flink-kubernetes-operator/pull/420#discussion_r1038965294 ## helm/flink-kubernetes-operator/templates/flink-operator.yaml: ## @@ -79,7 +79,9 @@ spec: {{- end }} env: - name: O

[jira] [Created] (FLINK-30288) Use visitor to convert predicate for orc

Shammon created FLINK-30288: --- Summary: Use visitor to convert predicate for orc Key: FLINK-30288 URL: https://issues.apache.org/jira/browse/FLINK-30288 Project: Flink Issue Type: Improvement

[GitHub] [flink-ml] jiangxin369 commented on a diff in pull request #183: [FLINK-29603] Add Transformer for StopWordsRemover

jiangxin369 commented on code in PR #183: URL: https://github.com/apache/flink-ml/pull/183#discussion_r1038916503 ## flink-ml-python/pyflink/ml/lib/feature/stopwordsremover.py: ## @@ -0,0 +1,135 @@ +