[
https://issues.apache.org/jira/browse/FLINK-31503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-31503.
---
Fix Version/s: 1.16.2
1.18.0
1.17.1
Resolution: Fixed
Fixed in:
[
https://issues.apache.org/jira/browse/FLINK-31503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-31503:
Affects Version/s: 1.15.0
> "org.apache.beam.sdk.options.PipelineOptionsRegistrar: Provider
> org.apache.
dianfu closed pull request #22206: [FLINK-31503][python] Makes sure it loads
Beam classes using the same class loader as the PyFlink classes
URL: https://github.com/apache/flink/pull/22206
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/FLINK-3?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-3.
Resolution: Fixed
> Introduce FileSystemFactory to create FileSystem from custom configuration
> -
[
https://issues.apache.org/jira/browse/FLINK-30039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-30039.
Resolution: Fixed
> Insert overwrite show excetion that query and insert schema do not match
> ---
[
https://issues.apache.org/jira/browse/FLINK-30031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-30031.
Resolution: Fixed
> flink table store run abnormally when shade flink
> --
[
https://issues.apache.org/jira/browse/FLINK-29630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-29630.
Resolution: Fixed
> Junit 5.8.1 run unit test with temporary directory will occur Failed to
> del
[
https://issues.apache.org/jira/browse/FLINK-26937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-26937.
Resolution: Fixed
> Introduce Leveled compression for LSM
> -
[
https://issues.apache.org/jira/browse/FLINK-29988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-29988.
Resolution: Fixed
> Improve upper case fields for hive metastore
> ---
[
https://issues.apache.org/jira/browse/FLINK-27814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-27814.
Resolution: Fixed
> Add an abstraction layer for connectors to read and write row data instead of
[
https://issues.apache.org/jira/browse/FLINK-27548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-27548.
Resolution: Fixed
> Improve quick-start of table store
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-29636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-29636.
Resolution: Fixed
> Add micro benchmark module in flink table store
>
[
https://issues.apache.org/jira/browse/FLINK-29290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-29290.
Resolution: Fixed
> Produce changelog during full compaction in Table Store
>
[
https://issues.apache.org/jira/browse/FLINK-29746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-29746.
Resolution: Fixed
> Add workflow in github for micro benchmarks
>
[
https://issues.apache.org/jira/browse/FLINK-28009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-28009.
Resolution: Fixed
> Optimize data split
> ---
>
> Key: FLINK-28009
[
https://issues.apache.org/jira/browse/FLINK-29331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-29331.
Resolution: Fixed
> pre-aggregated merge supports changelog inputs
> -
[
https://issues.apache.org/jira/browse/FLINK-28718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-28718.
Resolution: Fixed
> SinkSavepointITCase.testRecoverFromSavepoint is unstable
> ---
[
https://issues.apache.org/jira/browse/FLINK-28690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-28690.
Resolution: Fixed
> UpdateSchema#fromCatalogTable lost column comment
> --
[
https://issues.apache.org/jira/browse/FLINK-29080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-29080.
Resolution: Fixed
> Migrate all tests from managed table to catalog-based tests
>
[
https://issues.apache.org/jira/browse/FLINK-29243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-29243.
Resolution: Fixed
changelog producer = full-compaction is the cow mode.
> Introduce a COW mode fo
[
https://issues.apache.org/jira/browse/FLINK-29272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-29272.
Resolution: Fixed
> Document DataStream API (DataStream to Table) for table store
> --
[
https://issues.apache.org/jira/browse/FLINK-29820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17702211#comment-17702211
]
Jingsong Lee commented on FLINK-29820:
--
We have already supported this.
> Support
[
https://issues.apache.org/jira/browse/FLINK-29820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-29820.
Resolution: Fixed
> Support to read data from table store with specify snapshot id
> -
[
https://issues.apache.org/jira/browse/FLINK-29823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-29823.
Resolution: Fixed
> Support get schema for table snapshot
> -
[
https://issues.apache.org/jira/browse/FLINK-29828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-29828.
Resolution: Fixed
> Support to read data from table with given snapshot id
> -
[
https://issues.apache.org/jira/browse/FLINK-29882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-29882.
Resolution: Fixed
> LargeDataITCase is not stable
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-29832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-29832.
Resolution: Fixed
> Improve switch to default database in docs
> -
[
https://issues.apache.org/jira/browse/FLINK-30227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-30227.
Resolution: Fixed
> Add LeafEmptyFunction for predicate without fields
> -
[
https://issues.apache.org/jira/browse/FLINK-30080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-30080.
Resolution: Fixed
> Introduce public programming api and dependency jar for table store
>
[
https://issues.apache.org/jira/browse/FLINK-30276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-30276.
Resolution: Fixed
> [umbrella] Flink free for table store core
> -
[
https://issues.apache.org/jira/browse/FLINK-31002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31002.
Resolution: Fixed
this should be implemented by flink sql
> Provide data sampling query
> ---
[
https://issues.apache.org/jira/browse/FLINK-30628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-30628.
Resolution: Fixed
> Kerberos in HiveCatalog is not work
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-31179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31179.
Resolution: Fixed
> Make data structures serializable
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-31322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31322.
Resolution: Fixed
> Improve merge-into action
> -
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-31315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31315.
Resolution: Fixed
> FlinkActionsE2eTest.testMergeInto is unstable
> --
[
https://issues.apache.org/jira/browse/FLINK-31338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31338.
Resolution: Fixed
Just use github pr/issues.
> support infer parallelism for flink table store
>
[
https://issues.apache.org/jira/browse/FLINK-31417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31417.
Resolution: Fixed
> Hadoop version unknown when TrinoPageSourceBase.getNextPage
>
[
https://issues.apache.org/jira/browse/FLINK-31391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31391.
Resolution: Fixed
> Introduce lookup changelog producer
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-31417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17702207#comment-17702207
]
Jingsong Lee commented on FLINK-31417:
--
Thanks [~nonggia] , this has been fixed in
[
https://issues.apache.org/jira/browse/FLINK-31461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31461.
Resolution: Fixed
Use github pr/issues.
> Supports schema historical version expiring
> -
[
https://issues.apache.org/jira/browse/FLINK-31462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31462.
Resolution: Fixed
Use github pr/issues.
> [Flink] Supports full calculation from specified snapsh
[
https://issues.apache.org/jira/browse/FLINK-31429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17702206#comment-17702206
]
Jingsong Lee commented on FLINK-31429:
--
Please use github pr/issues.
> Support CTA
[
https://issues.apache.org/jira/browse/FLINK-31451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31451.
Resolution: Fixed
Use github pr/issues.
> Flink Table Store Ecosystem: Introduce Presto Reader fo
[
https://issues.apache.org/jira/browse/FLINK-31479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31479.
Resolution: Fixed
Use github issues.
> Close blocking iterators in tests
> --
[
https://issues.apache.org/jira/browse/FLINK-31467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-31467.
Resolution: Fixed
Use github issues.
> Support time travel for Spark 3.3
> --
xuzhiwen1255 commented on PR #22208:
URL: https://github.com/apache/flink/pull/22208#issuecomment-1475073169
Thanks for @wuchong, according to the comments, I reworked the code, PTAL.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
flinkbot commented on PR #22210:
URL: https://github.com/apache/flink/pull/22210#issuecomment-1475038905
## CI report:
* cdbe35311a6437a0161640ba41f4d97be0495566 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin reassigned FLINK-31506:
---
Assignee: Sergey Nuyanzin
> Move execution logic of AlterOperation out from TableEn
snuyanzin opened a new pull request, #22210:
URL: https://github.com/apache/flink/pull/22210
The PR continues the work started at
https://github.com/apache/flink/pull/22175
This PR does this for `AlterOperation`.
## What is the purpose of the change
Migrate `AlterOperati
[
https://issues.apache.org/jira/browse/FLINK-31506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31506:
---
Labels: pull-request-available (was: )
> Move execution logic of AlterOperation out from Ta
flinkbot commented on PR #22209:
URL: https://github.com/apache/flink/pull/22209#issuecomment-1475016874
## CI report:
* f5e1772b1a1385099a0f761d89bff4ff47451440 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31505:
---
Labels: pull-request-available (was: )
> Move execution logic of DropOperation out from Tab
snuyanzin opened a new pull request, #22209:
URL: https://github.com/apache/flink/pull/22209
The PR continues the work started at
https://github.com/apache/flink/pull/22175
This PR does this for `DropOperation`.
It also removes methods became unused after merging of
https://githu
JingGe opened a new pull request, #624:
URL: https://github.com/apache/flink-web/pull/624
Remove all unused Jekyll {% toc %}
--
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.
[
https://issues.apache.org/jira/browse/FLINK-31501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-31501:
---
Assignee: Jark Wu
> Move SqlCreateView conversion logic to SqlCreateViewConverter
> ---
wuchong commented on code in PR #22208:
URL: https://github.com/apache/flink/pull/22208#discussion_r1141037935
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/SqlCreateTableLikeConverter.java:
##
@@ -0,0 +1,33 @@
+/*
+ * Lice
[
https://issues.apache.org/jira/browse/FLINK-31511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-31511:
---
Assignee: Hang Ruan
> Translate documentation sql_functions_zh.yml to the latest version
> ---
lincoln-lil commented on code in PR #22197:
URL: https://github.com/apache/flink/pull/22197#discussion_r1141026773
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/common/PartialInsertTest.scala:
##
@@ -163,6 +192,21 @@ class PartialInsertTes
lindong28 commented on code in PR #219:
URL: https://github.com/apache/flink-ml/pull/219#discussion_r1141014031
##
flink-ml-lib/src/test/java/org/apache/flink/ml/classification/LogisticRegressionTest.java:
##
@@ -282,6 +287,50 @@ public void testSetModelData() throws Exception {
Hang Ruan created FLINK-31511:
-
Summary: Translate documentation sql_functions_zh.yml to the
latest version
Key: FLINK-31511
URL: https://issues.apache.org/jira/browse/FLINK-31511
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-31511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17702109#comment-17702109
]
Hang Ruan commented on FLINK-31511:
---
Hi, all,
I would like to help update this docum
chucheng92 commented on PR #22179:
URL: https://github.com/apache/flink/pull/22179#issuecomment-1474829928
@Aitozi hi, Considering using a SupportLike parent class may make confused,
i have changed and rebased the code. thanks for reviewing.
--
This is an automated message from the Apach
[
https://issues.apache.org/jira/browse/FLINK-31319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-31319.
Fix Version/s: 1.16.2
Resolution: Fixed
Fixed by:
* flink-connector-kafka main : 58f35374
leonardBang merged PR #22192:
URL: https://github.com/apache/flink/pull/22192
--
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.a
boring-cyborg[bot] commented on PR #8:
URL:
https://github.com/apache/flink-connector-kafka/pull/8#issuecomment-1474791944
Awesome work, congrats on your first merged pull request!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
leonardBang merged PR #8:
URL: https://github.com/apache/flink-connector-kafka/pull/8
--
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...
[
https://issues.apache.org/jira/browse/FLINK-31505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin reassigned FLINK-31505:
---
Assignee: Sergey Nuyanzin
> Move execution logic of DropOperation out from TableEnv
jiangxin369 commented on PR #219:
URL: https://github.com/apache/flink-ml/pull/219#issuecomment-1474774669
@lindong28 Thanks for the review, could you help review again?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
[
https://issues.apache.org/jira/browse/FLINK-30229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17702083#comment-17702083
]
Danny Cranmer commented on FLINK-30229:
---
Merged commit
[{{930d196}}|https://githu
[
https://issues.apache.org/jira/browse/FLINK-30229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-30229.
---
Resolution: Fixed
> SQL IT case for DynamoDB Sink
> -
>
>
dannycranmer merged PR #42:
URL: https://github.com/apache/flink-connector-aws/pull/42
--
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..
71 matches
Mail list logo