[jira] [Updated] (FLINK-27958) Compare batch maxKey to reduce comparisons in SortMergeReader

[ https://issues.apache.org/jira/browse/FLINK-27958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-27958: - Fix Version/s: table-store-0.4.0 (was: table-store-0.3.0) > Compare

[jira] [Updated] (FLINK-29272) Document DataStream API (DataStream to Table) for table store

[ https://issues.apache.org/jira/browse/FLINK-29272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-29272: - Fix Version/s: table-store-0.4.0 (was: table-store-0.3.0) > Document

[jira] [Updated] (FLINK-29490) Timestamp LTZ is unsupported in table store

[ https://issues.apache.org/jira/browse/FLINK-29490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-29490: - Fix Version/s: table-store-0.4.0 (was: table-store-0.3.0) > Timestamp

[jira] [Updated] (FLINK-29243) Introduce a COW mode for table store

[ https://issues.apache.org/jira/browse/FLINK-29243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-29243: - Fix Version/s: table-store-0.4.0 (was: table-store-0.3.0) > Introduce a

[jira] [Updated] (FLINK-28661) Introduce generic mode for table store catalog

[ https://issues.apache.org/jira/browse/FLINK-28661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-28661: - Fix Version/s: table-store-0.4.0 (was: table-store-0.3.0) > Introduce

[GitHub] [flink] fsk119 commented on a diff in pull request #21597: [FLINK-30554][sql-client] Remove useless sessionId in the Executor

fsk119 commented on code in PR #21597: URL: https://github.com/apache/flink/pull/21597#discussion_r1064257149 ## flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/Executor.java: ## @@ -42,54 +42,50 @@ public interface Executor { * Open a new

[GitHub] [flink] fsk119 commented on a diff in pull request #21597: [FLINK-30554][sql-client] Remove useless sessionId in the Executor

fsk119 commented on code in PR #21597: URL: https://github.com/apache/flink/pull/21597#discussion_r1064257149 ## flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/Executor.java: ## @@ -42,54 +42,50 @@ public interface Executor { * Open a new

[GitHub] [flink] godfreyhe commented on a diff in pull request #21556: [FLINK-30491][hive] Hive table partition supports deserializing later during runtime

godfreyhe commented on code in PR #21556: URL: https://github.com/apache/flink/pull/21556#discussion_r1064257049 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveSourceFileEnumerator.java: ## @@ -222,19 +225,24 @@ private static int

[jira] [Closed] (FLINK-28809) Concurrent write support for table store

[ https://issues.apache.org/jira/browse/FLINK-28809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-28809. Assignee: Jingsong Lee Resolution: Fixed > Concurrent write support for table store >

[jira] [Commented] (FLINK-30419) Allow tuning of transaction timeout

[ https://issues.apache.org/jira/browse/FLINK-30419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17655883#comment-17655883 ] Jingsong Lee commented on FLINK-30419: -- I have an idea that we can not use kafka's transaction

[jira] [Commented] (FLINK-30419) Allow tuning of transaction timeout

[ https://issues.apache.org/jira/browse/FLINK-30419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17655881#comment-17655881 ] Jingsong Lee commented on FLINK-30419: -- Thanks [~vicky_papavas] and [~Ge]. I don't know whether

[jira] [Commented] (FLINK-30414) Add unit test time out when run ci.

[ https://issues.apache.org/jira/browse/FLINK-30414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17655880#comment-17655880 ] Jingsong Lee commented on FLINK-30414: -- [~nicholasjiang] I think this is not a true issue, the root

[jira] [Closed] (FLINK-30592) The unsupported hive version is not deleted on the hive overview document

[ https://issues.apache.org/jira/browse/FLINK-30592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-30592. --- Fix Version/s: 1.17.0 Assignee: chrismartin Resolution: Fixed Fixed in master:

[GitHub] [flink] wuchong merged pull request #21611: [FLINK-30592][doc] remove unsupported hive version in hive overview document

wuchong merged PR #21611: URL: https://github.com/apache/flink/pull/21611 -- 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] godfreyhe commented on pull request #21489: [FLINK-30365][table-planner] New dynamic partition pruning strategy to support more dpp patterns

godfreyhe commented on PR #21489: URL: https://github.com/apache/flink/pull/21489#issuecomment-1375039582 It's better we can add this optimization in flink-tpcds-test module, we can do it in another pr. -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] godfreyhe commented on a diff in pull request #21489: [FLINK-30365][table-planner] New dynamic partition pruning strategy to support more dpp patterns

godfreyhe commented on code in PR #21489: URL: https://github.com/apache/flink/pull/21489#discussion_r1064250203 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/DynamicPartitionPruningUtils.java: ## @@ -60,318 +69,470 @@ public class

[jira] [Closed] (FLINK-30595) support create table like

[ https://issues.apache.org/jira/browse/FLINK-30595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30595. Fix Version/s: table-store-0.3.0 (was: table-store-0.4.0)

[GitHub] [flink-table-store] JingsongLi merged pull request #467: [FLINK-30595] support create table like

JingsongLi merged PR #467: URL: https://github.com/apache/flink-table-store/pull/467 -- 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-table-store] JingsongLi merged pull request #468: [hotfix] fix typo

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

[jira] [Commented] (FLINK-25447) batch query cannot generate plan when a sorted view into multi sinks

[ https://issues.apache.org/jira/browse/FLINK-25447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17655874#comment-17655874 ] lincoln lee commented on FLINK-25447: - [~fsk119] Good question! From my understanding, the

[jira] [Updated] (FLINK-30600) Merge flink-table-store-kafka to flink-table-store-connector

[ https://issues.apache.org/jira/browse/FLINK-30600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30600: --- Labels: pull-request-available (was: ) > Merge flink-table-store-kafka to

[GitHub] [flink-table-store] JingsongLi opened a new pull request, #469: [FLINK-30600] Merge flink-table-store-kafka to flink-table-store-connector

JingsongLi opened a new pull request, #469: URL: https://github.com/apache/flink-table-store/pull/469 At present, Kafka heavily relies on the implementation of Flink, which is difficult to extract, so it can be directly incorporated into the Flink connector. -- This is an automated

[GitHub] [flink] maosuhan commented on pull request #21613: [FLINK-30093][formats] Fix compile errors for google.protobuf.Timestamp type

maosuhan commented on PR #21613: URL: https://github.com/apache/flink/pull/21613#issuecomment-1375027529 @laughingman7743 The code LGTM. Would you also add documentation in protobuf page describing how to use timestamp type or other internal provided type? Some users may not know the

[jira] [Created] (FLINK-30600) Merge flink-table-store-kafka to flink-table-store-connector

Jingsong Lee created FLINK-30600: Summary: Merge flink-table-store-kafka to flink-table-store-connector Key: FLINK-30600 URL: https://issues.apache.org/jira/browse/FLINK-30600 Project: Flink

[jira] [Closed] (FLINK-30587) Validate primary key in an append-only table in ddl

[ https://issues.apache.org/jira/browse/FLINK-30587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30587. Fix Version/s: table-store-0.3.0 Assignee: Shammon Resolution: Fixed master:

[jira] [Closed] (FLINK-30589) Snapshot expiration should be skipped in Table Store dedicated writer jobs

[ https://issues.apache.org/jira/browse/FLINK-30589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30589. Resolution: Fixed master: 8365182ae1b715508b3a24ed3911f2dfa244b17b release-0.3:

[GitHub] [flink-table-store] JingsongLi merged pull request #462: [FLINK-30587] Validate primary key in append-only table in ddl

JingsongLi merged PR #462: URL: https://github.com/apache/flink-table-store/pull/462 -- 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-table-store] JingsongLi merged pull request #464: [FLINK-30589] Snapshot expiration should be skipped in Table Store dedicated writer jobs

JingsongLi merged PR #464: URL: https://github.com/apache/flink-table-store/pull/464 -- 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-table-store] JingsongLi commented on pull request #463: [FLINK-30581] Remove FileStoreTableITCase and use CatalogITCaseBase

JingsongLi commented on PR #463: URL: https://github.com/apache/flink-table-store/pull/463#issuecomment-1375020166 Hi @zjureel , can you create a new JIRA for this? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Closed] (FLINK-30581) Deprecate FileStoreTableITCase and use CatalogITCaseBase

[ https://issues.apache.org/jira/browse/FLINK-30581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30581. Resolution: Fixed master: 8a20d9337ef6135730bdb63a8af902ead6855a7c > Deprecate

[GitHub] [flink-table-store] JingsongLi merged pull request #465: [FLINK-30581] Deprecate FileStoreTableITCase and use CatalogITCaseBase

JingsongLi merged PR #465: URL: https://github.com/apache/flink-table-store/pull/465 -- 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] luoyuxia commented on pull request #21611: [FLINK-30592][doc] remove unsupported hive version in hive overview document

luoyuxia commented on PR #21611: URL: https://github.com/apache/flink/pull/21611#issuecomment-1374999280 @wuchong Could you please help merge. Thanks. -- 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

[GitHub] [flink] luoyuxia commented on a diff in pull request #21556: [FLINK-30491][hive] Hive table partition supports deserializing later during runtime

luoyuxia commented on code in PR #21556: URL: https://github.com/apache/flink/pull/21556#discussion_r1063970639 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveSourceFileEnumerator.java: ## @@ -222,19 +225,24 @@ private static int

[jira] [Commented] (FLINK-30556) Improve the logic for enumerating splits for Hive source to avoid potential OOM

[ https://issues.apache.org/jira/browse/FLINK-30556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17655863#comment-17655863 ] luoyuxia commented on FLINK-30556: -- [~Wencong Liu] Great, look forward to it. > Improve the logic for

[GitHub] [flink] swuferhong commented on a diff in pull request #21489: [FLINK-30365][table-planner] New dynamic partition pruning strategy to support more dpp patterns

swuferhong commented on code in PR #21489: URL: https://github.com/apache/flink/pull/21489#discussion_r1064235043 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/DynamicPartitionPruningUtils.java: ## @@ -45,153 +52,177 @@ import

[GitHub] [flink] swuferhong commented on a diff in pull request #21489: [FLINK-30365][table-planner] New dynamic partition pruning strategy to support more dpp patterns

swuferhong commented on code in PR #21489: URL: https://github.com/apache/flink/pull/21489#discussion_r1064234998 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/DynamicPartitionPruningUtils.java: ## @@ -45,153 +52,177 @@ import

[GitHub] [flink] dongjoon-hyun commented on pull request #21606: [FLINK-30578][build] Publish SBOM artifacts

dongjoon-hyun commented on PR #21606: URL: https://github.com/apache/flink/pull/21606#issuecomment-1374987087 Thank you, @mbalassi . Yes, right. Here are the examples. - Apache ORC:

[GitHub] [flink-connector-hive] chenqin opened a new pull request, #2: Move Flink Hive Connector

chenqin opened a new pull request, #2: URL: https://github.com/apache/flink-connector-hive/pull/2 Flink Hive Connector has complex dependencies. In an effort to externalize connectors and maintain the independence of Apache Flink project releases from connector releases, this PR initiates

[jira] [Commented] (FLINK-25421) Port JDBC Sink to new Unified Sink API (FLIP-143)

[ https://issues.apache.org/jira/browse/FLINK-25421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17655845#comment-17655845 ] Martijn Visser commented on FLINK-25421: [~wanglijie] It would be good to bring that up for a

[jira] [Commented] (FLINK-25565) Write and Read Parquet INT64 Timestamp

[ https://issues.apache.org/jira/browse/FLINK-25565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17655844#comment-17655844 ] Martijn Visser commented on FLINK-25565: [~sergiimk] The PR is not merged because the CI fails

[jira] [Assigned] (FLINK-25565) Write and Read Parquet INT64 Timestamp

[ https://issues.apache.org/jira/browse/FLINK-25565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-25565: -- Assignee: Bo Cui > Write and Read Parquet INT64 Timestamp >

[GitHub] [flink] MartijnVisser commented on pull request #18304: [FLINK-25565][Formats][Parquet] write and read parquet int64 timestamp

MartijnVisser commented on PR #18304: URL: https://github.com/apache/flink/pull/18304#issuecomment-1374936219 @cuibo01 Also don't forget to run `mvn spotless:apply` since the CI still fails for your PR due to spotless errors -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] MartijnVisser commented on pull request #18304: [FLINK-25565][Formats][Parquet] write and read parquet int64 timestamp

MartijnVisser commented on PR #18304: URL: https://github.com/apache/flink/pull/18304#issuecomment-1374936109 @cuibo01 Can you please rebase and squash your commits? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Created] (FLINK-30599) Publish SBOM for k8s operator

Márton Balassi created FLINK-30599: -- Summary: Publish SBOM for k8s operator Key: FLINK-30599 URL: https://issues.apache.org/jira/browse/FLINK-30599 Project: Flink Issue Type: Sub-task

[jira] [Assigned] (FLINK-30578) Publish SBOM artifacts

[ https://issues.apache.org/jira/browse/FLINK-30578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-30578: -- Assignee: Dongjoon Hyun > Publish SBOM artifacts > -- > >

[jira] [Commented] (FLINK-25447) batch query cannot generate plan when a sorted view into multi sinks

[ https://issues.apache.org/jira/browse/FLINK-25447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17655801#comment-17655801 ] Shengkai Fang commented on FLINK-25447: --- After investigations,  the main problem is that

[GitHub] [flink] laughingman7743 commented on pull request #21613: [FLINK-30093][formats] Fix compile errors for google.protobuf.Timestamp type

laughingman7743 commented on PR #21613: URL: https://github.com/apache/flink/pull/21613#issuecomment-1374858341 @maosuhan I have added a test cases to convert from flink internal primitive data to proto timestamp data. I will add any other test cases that are needed.

[jira] [Updated] (FLINK-30598) Wrong code generated for WatermarkGenerator because of inconsistent source type info when deserialized from exec plan

[ https://issues.apache.org/jira/browse/FLINK-30598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-30598: Fix Version/s: (was: 1.16.1) > Wrong code generated for WatermarkGenerator because of

[jira] [Created] (FLINK-30598) Wrong code generated for WatermarkGenerator because of inconsistent source type info when deserialized from exec plan

lincoln lee created FLINK-30598: --- Summary: Wrong code generated for WatermarkGenerator because of inconsistent source type info when deserialized from exec plan Key: FLINK-30598 URL:

[GitHub] [flink] maosuhan commented on pull request #21613: [FLINK-30093][formats] Fix compile errors for google.protobuf.Timestamp type

maosuhan commented on PR #21613: URL: https://github.com/apache/flink/pull/21613#issuecomment-1374837459 @laughingman7743 Thanks for your quick quick fix. We are almost there. Would you add another unit test like TimestampMultiRowToProto.java to make sure flink row can be correctly

[jira] [Commented] (FLINK-30556) Improve the logic for enumerating splits for Hive source to avoid potential OOM

[ https://issues.apache.org/jira/browse/FLINK-30556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17655791#comment-17655791 ] Wencong Liu commented on FLINK-30556: - Thanks [~luoyuxia]. As the ContinuousHiveSplitEnumerator can

[GitHub] [flink-table-store] zjureel closed pull request #463: [FLINK-30581] Remove FileStoreTableITCase and use CatalogITCaseBase

zjureel closed pull request #463: [FLINK-30581] Remove FileStoreTableITCase and use CatalogITCaseBase URL: https://github.com/apache/flink-table-store/pull/463 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Closed] (FLINK-30576) JdbcOutputFormat refactor

[ https://issues.apache.org/jira/browse/FLINK-30576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] João Boto closed FLINK-30576. - Resolution: Duplicate > JdbcOutputFormat refactor > - > > Key:

[GitHub] [flink-connector-jdbc] eskabetxe closed pull request #15: [FLINK-30576] Refactor JdbcOutputFormat to use ExecutionConfig

eskabetxe closed pull request #15: [FLINK-30576] Refactor JdbcOutputFormat to use ExecutionConfig URL: https://github.com/apache/flink-connector-jdbc/pull/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 above

[GitHub] [flink-connector-jdbc] eskabetxe commented on pull request #15: [FLINK-30576] Refactor JdbcOutputFormat to use ExecutionConfig

eskabetxe commented on PR #15: URL: https://github.com/apache/flink-connector-jdbc/pull/15#issuecomment-1374821876 closing this PR.. only 1 PR will be submitted with all changes -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Commented] (FLINK-30590) Remove set default value manually for table options

[ https://issues.apache.org/jira/browse/FLINK-30590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17655787#comment-17655787 ] Shammon commented on FLINK-30590: - [~nicholasjiang] Currently `CoreOptions.startupMode` will check the

[GitHub] [flink-table-store] zjureel commented on pull request #462: [FLINK-30587] Validate primary key in append-only table in ddl

zjureel commented on PR #462: URL: https://github.com/apache/flink-table-store/pull/462#issuecomment-1374816020 Hi @JingsongLi Can you help to review this PR? Thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] flinkbot commented on pull request #21617: Bump json5 from 1.0.1 to 1.0.2 in /flink-runtime-web/web-dashboard

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

[GitHub] [flink] dependabot[bot] opened a new pull request, #21617: Bump json5 from 1.0.1 to 1.0.2 in /flink-runtime-web/web-dashboard

dependabot[bot] opened a new pull request, #21617: URL: https://github.com/apache/flink/pull/21617 Bumps [json5](https://github.com/json5/json5) from 1.0.1 to 1.0.2. Release notes Sourced from https://github.com/json5/json5/releases;>json5's releases. v1.0.2 Fix:

[GitHub] [flink] laughingman7743 commented on a diff in pull request #21613: [FLINK-30093][formats] Fix compile errors for google.protobuf.Timestamp type

laughingman7743 commented on code in PR #21613: URL: https://github.com/apache/flink/pull/21613#discussion_r1064120073 ## flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/util/PbFormatUtils.java: ## @@ -28,26 +28,25 @@ /** Protobuf function util.

[GitHub] [flink] laughingman7743 commented on a diff in pull request #21613: [FLINK-30093][formats] Fix compile errors for google.protobuf.Timestamp type

laughingman7743 commented on code in PR #21613: URL: https://github.com/apache/flink/pull/21613#discussion_r1064120073 ## flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/util/PbFormatUtils.java: ## @@ -28,26 +28,25 @@ /** Protobuf function util.

[GitHub] [flink] laughingman7743 commented on pull request #21613: [FLINK-30093][formats] Fix compile errors for google.protobuf.Timestamp type

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

[GitHub] [flink] laughingman7743 commented on pull request #21613: [FLINK-30093][formats] Fix compile errors for google.protobuf.Timestamp type

laughingman7743 commented on PR #21613: URL: https://github.com/apache/flink/pull/21613#issuecomment-1374797735 @maosuhan I have addressed the comments, PTAL when you have time  -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] laughingman7743 commented on a diff in pull request #21613: [FLINK-30093][formats] Fix compile errors for google.protobuf.Timestamp type

laughingman7743 commented on code in PR #21613: URL: https://github.com/apache/flink/pull/21613#discussion_r1064120073 ## flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/util/PbFormatUtils.java: ## @@ -28,26 +28,25 @@ /** Protobuf function util.

[GitHub] [flink] laughingman7743 commented on a diff in pull request #21613: [FLINK-30093][formats] Fix compile errors for google.protobuf.Timestamp type

laughingman7743 commented on code in PR #21613: URL: https://github.com/apache/flink/pull/21613#discussion_r1064118738 ## flink-formats/flink-protobuf/src/test/proto/test_simple_noouter_nomulti.proto: ## @@ -21,18 +21,17 @@ package org.apache.flink.formats.protobuf.proto;

[GitHub] [flink] laughingman7743 commented on a diff in pull request #21613: [FLINK-30093][formats] Fix compile errors for google.protobuf.Timestamp type

laughingman7743 commented on code in PR #21613: URL: https://github.com/apache/flink/pull/21613#discussion_r1064118335 ## flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/util/PbFormatUtils.java: ## @@ -72,14 +71,33 @@ public static String

[GitHub] [flink] laughingman7743 commented on a diff in pull request #21613: [FLINK-30093][formats] Fix compile errors for google.protobuf.Timestamp type

laughingman7743 commented on code in PR #21613: URL: https://github.com/apache/flink/pull/21613#discussion_r1064118261 ## flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/deserialize/ProtoToRowConverter.java: ## @@ -58,16 +58,15 @@ public class

[GitHub] [flink] laughingman7743 commented on a diff in pull request #21613: [FLINK-30093][formats] Fix compile errors for google.protobuf.Timestamp type

laughingman7743 commented on code in PR #21613: URL: https://github.com/apache/flink/pull/21613#discussion_r1064118762 ## flink-formats/flink-protobuf/src/test/proto/test_timestamp.proto: ## @@ -0,0 +1,27 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + *

[GitHub] [flink] laughingman7743 commented on a diff in pull request #21613: [FLINK-30093][formats] Fix compile errors for google.protobuf.Timestamp type

laughingman7743 commented on code in PR #21613: URL: https://github.com/apache/flink/pull/21613#discussion_r1064118738 ## flink-formats/flink-protobuf/src/test/proto/test_simple_noouter_nomulti.proto: ## @@ -21,18 +21,17 @@ package org.apache.flink.formats.protobuf.proto;

[GitHub] [flink] laughingman7743 commented on a diff in pull request #21613: [FLINK-30093][formats] Fix compile errors for google.protobuf.Timestamp type

laughingman7743 commented on code in PR #21613: URL: https://github.com/apache/flink/pull/21613#discussion_r1064118335 ## flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/util/PbFormatUtils.java: ## @@ -72,14 +71,33 @@ public static String

[GitHub] [flink] laughingman7743 commented on a diff in pull request #21613: [FLINK-30093][formats] Fix compile errors for google.protobuf.Timestamp type

laughingman7743 commented on code in PR #21613: URL: https://github.com/apache/flink/pull/21613#discussion_r1064118261 ## flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/deserialize/ProtoToRowConverter.java: ## @@ -58,16 +58,15 @@ public class

[GitHub] [flink] flinkbot commented on pull request #21616: [FLINK-30597] Refactor FlinkProjectJoinTransposeRule and FlinkPruneEm…

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

[jira] [Updated] (FLINK-30597) Refactor FlinkProjectJoinTransposeRule and FlinkPruneEmptyRules

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

[GitHub] [flink] cuibo01 opened a new pull request, #21616: [FLINK-30597] Refactor FlinkProjectJoinTransposeRule and FlinkPruneEm…

cuibo01 opened a new pull request, #21616: URL: https://github.com/apache/flink/pull/21616 …ptyRules ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid

[jira] [Created] (FLINK-30597) Refactor FlinkProjectJoinTransposeRule and FlinkPruneEmptyRules

Bo Cui created FLINK-30597: -- Summary: Refactor FlinkProjectJoinTransposeRule and FlinkPruneEmptyRules Key: FLINK-30597 URL: https://issues.apache.org/jira/browse/FLINK-30597 Project: Flink Issue

[jira] [Closed] (FLINK-25686) Support Pulsar Schema evolution in Pulsar Source Connector

[ https://issues.apache.org/jira/browse/FLINK-25686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-25686. - Fix Version/s: pulsar-4.0.0 Resolution: Fixed master via

[GitHub] [flink-connector-pulsar] tisonkun merged pull request #12: [FLINK-25686][Connector/Pulsar] Support schema evolution for Pulsar source and sink.

tisonkun merged PR #12: URL: https://github.com/apache/flink-connector-pulsar/pull/12 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink-connector-pulsar] tisonkun commented on pull request #12: [FLINK-25686][Connector/Pulsar] Support schema evolution for Pulsar source and sink.

tisonkun commented on PR #12: URL: https://github.com/apache/flink-connector-pulsar/pull/12#issuecomment-1374762398 Merging... -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

<    1   2