[jira] [Closed] (FLINK-30000) Introduce FileSystemFactory to create FileSystem from custom configuration

2023-03-18 Thread Jingsong Lee (Jira)
[ 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 >

[jira] [Closed] (FLINK-30039) Insert overwrite show excetion that query and insert schema do not match

2023-03-18 Thread Jingsong Lee (Jira)
[ 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 >

[jira] [Closed] (FLINK-30031) flink table store run abnormally when shade flink

2023-03-18 Thread Jingsong Lee (Jira)
[ 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 >

[jira] [Closed] (FLINK-29630) Junit 5.8.1 run unit test with temporary directory will occur Failed to delete temp directory.

2023-03-18 Thread Jingsong Lee (Jira)
[ 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 >

[jira] [Closed] (FLINK-26937) Introduce Leveled compression for LSM

2023-03-18 Thread Jingsong Lee (Jira)
[ 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 > -

[jira] [Closed] (FLINK-29988) Improve upper case fields for hive metastore

2023-03-18 Thread Jingsong Lee (Jira)
[ 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 >

[jira] [Closed] (FLINK-27814) Add an abstraction layer for connectors to read and write row data instead of key-values

2023-03-18 Thread Jingsong Lee (Jira)
[ 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

[jira] [Closed] (FLINK-27548) Improve quick-start of table store

2023-03-18 Thread Jingsong Lee (Jira)
[ 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 > -- > >

[jira] [Closed] (FLINK-29636) Add micro benchmark module in flink table store

2023-03-18 Thread Jingsong Lee (Jira)
[ 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 >

[jira] [Closed] (FLINK-29290) Produce changelog during full compaction in Table Store

2023-03-18 Thread Jingsong Lee (Jira)
[ 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 >

[jira] [Closed] (FLINK-29746) Add workflow in github for micro benchmarks

2023-03-18 Thread Jingsong Lee (Jira)
[ 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 >

[jira] [Closed] (FLINK-28009) Optimize data split

2023-03-18 Thread Jingsong Lee (Jira)
[ 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:

[jira] [Closed] (FLINK-29331) pre-aggregated merge supports changelog inputs

2023-03-18 Thread Jingsong Lee (Jira)
[ 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 >

[jira] [Closed] (FLINK-28718) SinkSavepointITCase.testRecoverFromSavepoint is unstable

2023-03-18 Thread Jingsong Lee (Jira)
[ 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 >

[jira] [Closed] (FLINK-28690) UpdateSchema#fromCatalogTable lost column comment

2023-03-18 Thread Jingsong Lee (Jira)
[ 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 >

[jira] [Closed] (FLINK-29080) Migrate all tests from managed table to catalog-based tests

2023-03-18 Thread Jingsong Lee (Jira)
[ 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 >

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

2023-03-18 Thread Jingsong Lee (Jira)
[ 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

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

2023-03-18 Thread Jingsong Lee (Jira)
[ 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 >

[jira] [Commented] (FLINK-29820) Support to read data from table store with specify snapshot id

2023-03-18 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17702211#comment-17702211 ] Jingsong Lee commented on FLINK-29820: -- We have already supported this. > Support to read data

[jira] [Closed] (FLINK-29820) Support to read data from table store with specify snapshot id

2023-03-18 Thread Jingsong Lee (Jira)
[ 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 >

[jira] [Closed] (FLINK-29823) Support get schema for table snapshot

2023-03-18 Thread Jingsong Lee (Jira)
[ 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 > -

[jira] [Closed] (FLINK-29828) Support to read data from table with given snapshot id

2023-03-18 Thread Jingsong Lee (Jira)
[ 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 >

[jira] [Closed] (FLINK-29882) LargeDataITCase is not stable

2023-03-18 Thread Jingsong Lee (Jira)
[ 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 > - > >

[jira] [Closed] (FLINK-29832) Improve switch to default database in docs

2023-03-18 Thread Jingsong Lee (Jira)
[ 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 >

[jira] [Closed] (FLINK-30227) Add LeafEmptyFunction for predicate without fields

2023-03-18 Thread Jingsong Lee (Jira)
[ 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 >

[jira] [Closed] (FLINK-30080) Introduce public programming api and dependency jar for table store

2023-03-18 Thread Jingsong Lee (Jira)
[ 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 >

[jira] [Closed] (FLINK-30276) [umbrella] Flink free for table store core

2023-03-18 Thread Jingsong Lee (Jira)
[ 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 >

[jira] [Closed] (FLINK-31002) Provide data sampling query

2023-03-18 Thread Jingsong Lee (Jira)
[ 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 >

[jira] [Closed] (FLINK-30628) Kerberos in HiveCatalog is not work

2023-03-18 Thread Jingsong Lee (Jira)
[ 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 > --- > >

[jira] [Closed] (FLINK-31179) Make data structures serializable

2023-03-18 Thread Jingsong Lee (Jira)
[ 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 > - > >

[jira] [Closed] (FLINK-31322) Improve merge-into action

2023-03-18 Thread Jingsong Lee (Jira)
[ 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 > - > >

[jira] [Closed] (FLINK-31315) FlinkActionsE2eTest.testMergeInto is unstable

2023-03-18 Thread Jingsong Lee (Jira)
[ 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 >

[jira] [Closed] (FLINK-31338) support infer parallelism for flink table store

2023-03-18 Thread Jingsong Lee (Jira)
[ 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

[jira] [Closed] (FLINK-31417) Hadoop version unknown when TrinoPageSourceBase.getNextPage

2023-03-18 Thread Jingsong Lee (Jira)
[ 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 >

[jira] [Closed] (FLINK-31391) Introduce lookup changelog producer

2023-03-18 Thread Jingsong Lee (Jira)
[ 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 > --- > >

[jira] [Commented] (FLINK-31417) Hadoop version unknown when TrinoPageSourceBase.getNextPage

2023-03-18 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17702207#comment-17702207 ] Jingsong Lee commented on FLINK-31417: -- Thanks [~nonggia] , this has been fixed in 0.3, will cp to

[jira] [Closed] (FLINK-31461) Supports schema historical version expiring

2023-03-18 Thread Jingsong Lee (Jira)
[ 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 >

[jira] [Closed] (FLINK-31462) [Flink] Supports full calculation from specified snapshots in streaming mode

2023-03-18 Thread Jingsong Lee (Jira)
[ 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

[jira] [Commented] (FLINK-31429) Support CTAS(create table as) streaming job with schema changes in table store

2023-03-18 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17702206#comment-17702206 ] Jingsong Lee commented on FLINK-31429: -- Please use github pr/issues. > Support CTAS(create table

[jira] [Closed] (FLINK-31451) Flink Table Store Ecosystem: Introduce Presto Reader for table store

2023-03-18 Thread Jingsong Lee (Jira)
[ 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

[jira] [Closed] (FLINK-31479) Close blocking iterators in tests

2023-03-18 Thread Jingsong Lee (Jira)
[ 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 >

[jira] [Closed] (FLINK-31467) Support time travel for Spark 3.3

2023-03-18 Thread Jingsong Lee (Jira)
[ 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 >

[GitHub] [flink] xuzhiwen1255 commented on pull request #22208: [FLINK-31499] [table-planner] Move SqlCreateTable conversion logic to SqlCreateTableConverter

2023-03-18 Thread via GitHub
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

[GitHub] [flink] flinkbot commented on pull request #22210: [FLINK-31506][table] Move execution logic of AlterOperation out from TableEnvironmentImpl

2023-03-18 Thread via GitHub
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`

[jira] [Assigned] (FLINK-31506) Move execution logic of AlterOperation out from TableEnvironmentImpl

2023-03-18 Thread Sergey Nuyanzin (Jira)
[ 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

[GitHub] [flink] snuyanzin opened a new pull request, #22210: [FLINK-31506][table] Move execution logic of AlterOperation out from TableEnvironmentImpl

2023-03-18 Thread via GitHub
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

[jira] [Updated] (FLINK-31506) Move execution logic of AlterOperation out from TableEnvironmentImpl

2023-03-18 Thread ASF GitHub Bot (Jira)
[ 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

[GitHub] [flink] flinkbot commented on pull request #22209: [FLINK-31505][table] Move execution logic of DropOperation out from TableEnvironmentImpl

2023-03-18 Thread via GitHub
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`

[jira] [Updated] (FLINK-31505) Move execution logic of DropOperation out from TableEnvironmentImpl

2023-03-18 Thread ASF GitHub Bot (Jira)
[ 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

[GitHub] [flink] snuyanzin opened a new pull request, #22209: [FLINK-31505][table] Move execution logic of DropOperation out from TableEnvironmentImpl

2023-03-18 Thread via GitHub
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

[GitHub] [flink-web] JingGe opened a new pull request, #624: remove Jekyll toc

2023-03-18 Thread via GitHub
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.

[jira] [Assigned] (FLINK-31501) Move SqlCreateView conversion logic to SqlCreateViewConverter

2023-03-18 Thread Jark Wu (Jira)
[ 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 >

[GitHub] [flink] wuchong commented on a diff in pull request #22208: [FLINK-31499] [table-planner] Move SqlCreateTable conversion logic to SqlCreateTableConverter

2023-03-18 Thread via GitHub
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 @@ +/* + *

[jira] [Assigned] (FLINK-31511) Translate documentation sql_functions_zh.yml to the latest version

2023-03-18 Thread Jark Wu (Jira)
[ 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 >

[GitHub] [flink] lincoln-lil commented on a diff in pull request #22197: [FLINK-31487][table-planner] Add targetColumns to DynamicTableSink#Context

2023-03-18 Thread via GitHub
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

[GitHub] [flink-ml] lindong28 commented on a diff in pull request #219: [FLINK-31422] Add Servable for Logistic Regression Model

2023-03-18 Thread via GitHub
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

[jira] [Created] (FLINK-31511) Translate documentation sql_functions_zh.yml to the latest version

2023-03-18 Thread Hang Ruan (Jira)
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

[jira] [Commented] (FLINK-31511) Translate documentation sql_functions_zh.yml to the latest version

2023-03-18 Thread Hang Ruan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17702109#comment-17702109 ] Hang Ruan commented on FLINK-31511: --- Hi, all,  I would like to help update this document as some

[GitHub] [flink] chucheng92 commented on pull request #22179: [FLINK-31380][table] FLIP-297: Support enhanced show catalogs syntax

2023-03-18 Thread via GitHub
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

[jira] [Resolved] (FLINK-31319) Kafka new source partitionDiscoveryIntervalMs=0 cause bounded source can not quit

2023-03-18 Thread Leonard Xu (Jira)
[ 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 :

[GitHub] [flink] leonardBang merged pull request #22192: [FLINK-31319][BP-1.16][connectors/kafka] Fix kafka new source partitionDiscoveryIntervalMs=0 cause bounded source can not quit

2023-03-18 Thread via GitHub
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:

[GitHub] [flink-connector-kafka] boring-cyborg[bot] commented on pull request #8: [FLINK-31319][connectors/kafka] Fix kafka new source partitionDiscoveryIntervalMs=0 cause bounded source can not quit

2023-03-18 Thread via GitHub
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

[GitHub] [flink-connector-kafka] leonardBang merged pull request #8: [FLINK-31319][connectors/kafka] Fix kafka new source partitionDiscoveryIntervalMs=0 cause bounded source can not quit

2023-03-18 Thread via GitHub
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:

[jira] [Assigned] (FLINK-31505) Move execution logic of DropOperation out from TableEnvironmentImpl

2023-03-18 Thread Sergey Nuyanzin (Jira)
[ 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

[GitHub] [flink-ml] jiangxin369 commented on pull request #219: [FLINK-31422] Add Servable for Logistic Regression Model

2023-03-18 Thread via GitHub
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

[jira] [Commented] (FLINK-30229) SQL IT case for DynamoDB Sink

2023-03-18 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17702083#comment-17702083 ] Danny Cranmer commented on FLINK-30229: --- Merged commit

[jira] [Resolved] (FLINK-30229) SQL IT case for DynamoDB Sink

2023-03-18 Thread Danny Cranmer (Jira)
[ 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 > - > >

[GitHub] [flink-connector-aws] dannycranmer merged pull request #42: [FLINK-30229] Add SQL IT case for DynamoDB Sink

2023-03-18 Thread via GitHub
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: