[jira] [Created] (FLINK-12890) Add partition lifecycle related Shuffle API

Andrey Zagrebin created FLINK-12890: --- Summary: Add partition lifecycle related Shuffle API Key: FLINK-12890 URL: https://issues.apache.org/jira/browse/FLINK-12890 Project: Flink Issue

[GitHub] [flink] Flyangz commented on a change in pull request #8750: [FLINK-11606] Translate the "Distributed Runtime Environment" page in to Chinese

Flyangz commented on a change in pull request #8750: [FLINK-11606] Translate the "Distributed Runtime Environment" page in to Chinese URL: https://github.com/apache/flink/pull/8750#discussion_r294860859 ## File path: docs/concepts/runtime.zh.md ## @@ -26,102 +26,74 @@

[GitHub] [flink] Flyangz commented on a change in pull request #8750: [FLINK-11606] Translate the "Distributed Runtime Environment" page in to Chinese

Flyangz commented on a change in pull request #8750: [FLINK-11606] Translate the "Distributed Runtime Environment" page in to Chinese URL: https://github.com/apache/flink/pull/8750#discussion_r294860859 ## File path: docs/concepts/runtime.zh.md ## @@ -26,102 +26,74 @@

[GitHub] [flink] asfgit closed pull request #8661: [FLINK-12711][table] Separate function implementation and definition

asfgit closed pull request #8661: [FLINK-12711][table] Separate function implementation and definition URL: https://github.com/apache/flink/pull/8661 This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] azagrebin commented on a change in pull request #8778: [FLINK-12615][coordination] Track partitions on JM

azagrebin commented on a change in pull request #8778: [FLINK-12615][coordination] Track partitions on JM URL: https://github.com/apache/flink/pull/8778#discussion_r294857180 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java

[jira] [Closed] (FLINK-12711) Separate function implementation and definition

[ https://issues.apache.org/jira/browse/FLINK-12711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-12711. Resolution: Fixed Fix Version/s: 1.9.0 Fixed in 1.9.0:

[GitHub] [flink] azagrebin commented on a change in pull request #8778: [FLINK-12615][coordination] Track partitions on JM

azagrebin commented on a change in pull request #8778: [FLINK-12615][coordination] Track partitions on JM URL: https://github.com/apache/flink/pull/8778#discussion_r294859917 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java ##

[GitHub] [flink] Flyangz commented on a change in pull request #8750: [FLINK-11606] Translate the "Distributed Runtime Environment" page in to Chinese

Flyangz commented on a change in pull request #8750: [FLINK-11606] Translate the "Distributed Runtime Environment" page in to Chinese URL: https://github.com/apache/flink/pull/8750#discussion_r294855711 ## File path: docs/concepts/runtime.zh.md ## @@ -26,102 +26,74 @@

[GitHub] [flink] tillrohrmann opened a new pull request #8783: [FLINK-12863][FLINK-12865] Remove concurrency from HeartbeatManager(Sender)Impl

tillrohrmann opened a new pull request #8783: [FLINK-12863][FLINK-12865] Remove concurrency from HeartbeatManager(Sender)Impl URL: https://github.com/apache/flink/pull/8783 ## What is the purpose of the change This commit makes the HeartbeatManager implementations to use the

[jira] [Updated] (FLINK-12863) Race condition between slot offerings and AllocatedSlotReport

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

[GitHub] [flink] Aitozi commented on issue #8455: [FLINK-12284, FLINK-12637][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode

Aitozi commented on issue #8455: [FLINK-12284,FLINK-12637][Network,Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode URL: https://github.com/apache/flink/pull/8455#issuecomment-503180836 ping @pnowojski @zhijiangW

[jira] [Updated] (FLINK-12890) Add partition lifecycle related Shuffle API

[ https://issues.apache.org/jira/browse/FLINK-12890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-12890: Description: At the moment we have ShuffleEnvironment.releasePartitions which is used to

[GitHub] [flink] flinkbot commented on issue #8783: [FLINK-12863][FLINK-12865] Remove concurrency from HeartbeatManager(Sender)Impl

flinkbot commented on issue #8783: [FLINK-12863][FLINK-12865] Remove concurrency from HeartbeatManager(Sender)Impl URL: https://github.com/apache/flink/pull/8783#issuecomment-503163830 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] azagrebin commented on a change in pull request #8778: [FLINK-12615][coordination] Track partitions on JM

azagrebin commented on a change in pull request #8778: [FLINK-12615][coordination] Track partitions on JM URL: https://github.com/apache/flink/pull/8778#discussion_r294857180 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java

[GitHub] [flink] Flyangz commented on a change in pull request #8750: [FLINK-11606] Translate the "Distributed Runtime Environment" page in to Chinese

Flyangz commented on a change in pull request #8750: [FLINK-11606] Translate the "Distributed Runtime Environment" page in to Chinese URL: https://github.com/apache/flink/pull/8750#discussion_r294862879 ## File path: docs/concepts/runtime.zh.md ## @@ -26,102 +26,74 @@

[GitHub] [flink] ex00 commented on a change in pull request #8632: [FLINK-12744][ml] add shared params in ml package

ex00 commented on a change in pull request #8632: [FLINK-12744][ml] add shared params in ml package URL: https://github.com/apache/flink/pull/8632#discussion_r294887854 ## File path: flink-ml-parent/flink-ml-api/src/main/java/org/apache/flink/ml/api/misc/param/Params.java

[GitHub] [flink] ex00 commented on a change in pull request #8632: [FLINK-12744][ml] add shared params in ml package

ex00 commented on a change in pull request #8632: [FLINK-12744][ml] add shared params in ml package URL: https://github.com/apache/flink/pull/8632#discussion_r294888177 ## File path: flink-ml-parent/flink-ml-api/src/main/java/org/apache/flink/ml/api/misc/param/Params.java

[GitHub] [flink] bowenli86 commented on issue #8720: [FLINK-12771][hive] Support ConnectorCatalogTable in HiveCatalog

bowenli86 commented on issue #8720: [FLINK-12771][hive] Support ConnectorCatalogTable in HiveCatalog URL: https://github.com/apache/flink/pull/8720#issuecomment-503219659 I will close this PR for now as we cannot reach consensus of having this feature with the community

[GitHub] [flink] bowenli86 closed pull request #8720: [FLINK-12771][hive] Support ConnectorCatalogTable in HiveCatalog

bowenli86 closed pull request #8720: [FLINK-12771][hive] Support ConnectorCatalogTable in HiveCatalog URL: https://github.com/apache/flink/pull/8720 This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] azagrebin commented on a change in pull request #8778: [FLINK-12615][coordination] Track partitions on JM

azagrebin commented on a change in pull request #8778: [FLINK-12615][coordination] Track partitions on JM URL: https://github.com/apache/flink/pull/8778#discussion_r294858360 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java

[GitHub] [flink] ex00 commented on a change in pull request #8776: [FLINK-12881][ml] Add more functionalities for ML Params and ParamInfo class

ex00 commented on a change in pull request #8776: [FLINK-12881][ml] Add more functionalities for ML Params and ParamInfo class URL: https://github.com/apache/flink/pull/8776#discussion_r294895837 ## File path:

[jira] [Updated] (FLINK-12624) Make Flink case-insensitive to meta object names

[ https://issues.apache.org/jira/browse/FLINK-12624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-12624: - Fix Version/s: (was: 1.9.0) > Make Flink case-insensitive to meta object names >

[GitHub] [flink] bowenli86 commented on a change in pull request #8769: [FLINK-12875][hive] support converting input args of char, varchar, bytes, timestamp, date for Hive functions

bowenli86 commented on a change in pull request #8769: [FLINK-12875][hive] support converting input args of char, varchar, bytes, timestamp, date for Hive functions URL: https://github.com/apache/flink/pull/8769#discussion_r294941682 ## File path:

[GitHub] [flink] xuefuz commented on a change in pull request #8769: [FLINK-12875][hive] support converting input args of char, varchar, bytes, timestamp, date for Hive functions

xuefuz commented on a change in pull request #8769: [FLINK-12875][hive] support converting input args of char, varchar, bytes, timestamp, date for Hive functions URL: https://github.com/apache/flink/pull/8769#discussion_r294952212 ## File path:

[jira] [Created] (FLINK-12892) serialize catalog table to properties for table discovery service

Bowen Li created FLINK-12892: Summary: serialize catalog table to properties for table discovery service Key: FLINK-12892 URL: https://issues.apache.org/jira/browse/FLINK-12892 Project: Flink

[GitHub] [flink] pnowojski commented on a change in pull request #8455: [FLINK-12284, FLINK-12637][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode

pnowojski commented on a change in pull request #8455: [FLINK-12284,FLINK-12637][Network,Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode URL: https://github.com/apache/flink/pull/8455#discussion_r294997472 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8766: [FLINK-12664][hive] Implement TableSink to write Hive tables

bowenli86 commented on a change in pull request #8766: [FLINK-12664][hive] Implement TableSink to write Hive tables URL: https://github.com/apache/flink/pull/8766#discussion_r294998500 ## File path:

[GitHub] [flink] asfgit closed pull request #8769: [FLINK-12875][hive] support converting input args of char, varchar, bytes, timestamp, date for Hive functions

asfgit closed pull request #8769: [FLINK-12875][hive] support converting input args of char, varchar, bytes, timestamp, date for Hive functions URL: https://github.com/apache/flink/pull/8769 This is an automated message

[jira] [Closed] (FLINK-12714) confusion about flink time window TimeWindow#getWindowStartWithOffset

[ https://issues.apache.org/jira/browse/FLINK-12714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenshuai Hou closed FLINK-12714. Resolution: Fixed just saw this in flink doc. For example, with an event-time-based windowing

[GitHub] [flink] bowenli86 commented on issue #8769: [FLINK-12875][hive] support converting input args of char, varchar, bytes, timestamp, date for Hive functions

bowenli86 commented on issue #8769: [FLINK-12875][hive] support converting input args of char, varchar, bytes, timestamp, date for Hive functions URL: https://github.com/apache/flink/pull/8769#issuecomment-503235582 @xuefuz I've updated the PR. Can you take another look?

[GitHub] [flink] xuefuz commented on a change in pull request #8769: [FLINK-12875][hive] support converting input args of char, varchar, bytes, timestamp, date for Hive functions

xuefuz commented on a change in pull request #8769: [FLINK-12875][hive] support converting input args of char, varchar, bytes, timestamp, date for Hive functions URL: https://github.com/apache/flink/pull/8769#discussion_r294952212 ## File path:

[GitHub] [flink] xuefuz commented on a change in pull request #8769: [FLINK-12875][hive] support converting input args of char, varchar, bytes, timestamp, date for Hive functions

xuefuz commented on a change in pull request #8769: [FLINK-12875][hive] support converting input args of char, varchar, bytes, timestamp, date for Hive functions URL: https://github.com/apache/flink/pull/8769#discussion_r294959778 ## File path:

[GitHub] [flink] xuefuz commented on a change in pull request #8766: [FLINK-12664][hive] Implement TableSink to write Hive tables

xuefuz commented on a change in pull request #8766: [FLINK-12664][hive] Implement TableSink to write Hive tables URL: https://github.com/apache/flink/pull/8766#discussion_r294971444 ## File path:

[jira] [Assigned] (FLINK-12885) Rename "Job Cluster" to "Application Cluster" in READMEs and Documentation

[ https://issues.apache.org/jira/browse/FLINK-12885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reassigned FLINK-12885: Assignee: Konstantin Knauf > Rename "Job Cluster" to "Application Cluster" in

[jira] [Updated] (FLINK-12892) serialize catalog table to properties for table discovery service

[ https://issues.apache.org/jira/browse/FLINK-12892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12892: --- Labels: pull-request-available (was: ) > serialize catalog table to properties for table

[GitHub] [flink] bowenli86 opened a new pull request #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service

bowenli86 opened a new pull request #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service URL: https://github.com/apache/flink/pull/8784 ## What is the purpose of the change This PR enables serialization of catalog table to properties

[GitHub] [flink] bowenli86 commented on a change in pull request #8769: [FLINK-12875][hive] support converting input args of char, varchar, bytes, timestamp, date for Hive functions

bowenli86 commented on a change in pull request #8769: [FLINK-12875][hive] support converting input args of char, varchar, bytes, timestamp, date for Hive functions URL: https://github.com/apache/flink/pull/8769#discussion_r294982933 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #8455: [FLINK-12284, FLINK-12637][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode

pnowojski commented on a change in pull request #8455: [FLINK-12284,FLINK-12637][Network,Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode URL: https://github.com/apache/flink/pull/8455#discussion_r294995097 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #8455: [FLINK-12284, FLINK-12637][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode

pnowojski commented on a change in pull request #8455: [FLINK-12284,FLINK-12637][Network,Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode URL: https://github.com/apache/flink/pull/8455#discussion_r294997884 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #8455: [FLINK-12284, FLINK-12637][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode

pnowojski commented on a change in pull request #8455: [FLINK-12284,FLINK-12637][Network,Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode URL: https://github.com/apache/flink/pull/8455#discussion_r294997472 ## File path:

[GitHub] [flink] xuefuz commented on a change in pull request #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service

xuefuz commented on a change in pull request #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service URL: https://github.com/apache/flink/pull/8784#discussion_r294998709 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service

bowenli86 commented on a change in pull request #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service URL: https://github.com/apache/flink/pull/8784#discussion_r295008984 ## File path:

[GitHub] [flink] bowenli86 commented on issue #8770: [FLINK-12658][hive] Integrate Flink with Hive GenericUDF

bowenli86 commented on issue #8770: [FLINK-12658][hive] Integrate Flink with Hive GenericUDF URL: https://github.com/apache/flink/pull/8770#issuecomment-503304569 cc @xuefuz @JingsongLi This is an automated message from the

[GitHub] [flink] xuefuz commented on a change in pull request #8766: [FLINK-12664][hive] Implement TableSink to write Hive tables

xuefuz commented on a change in pull request #8766: [FLINK-12664][hive] Implement TableSink to write Hive tables URL: https://github.com/apache/flink/pull/8766#discussion_r294972707 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8766: [FLINK-12664][hive] Implement TableSink to write Hive tables

bowenli86 commented on a change in pull request #8766: [FLINK-12664][hive] Implement TableSink to write Hive tables URL: https://github.com/apache/flink/pull/8766#discussion_r294994713 ## File path: flink-connectors/flink-connector-hive/pom.xml ## @@ -364,6 +364,10 @@

[jira] [Commented] (FLINK-12887) Schedule UnfencedMessage would lost envelope info

[ https://issues.apache.org/jira/browse/FLINK-12887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16867023#comment-16867023 ] Till Rohrmann commented on FLINK-12887: --- I think the current contract is that you cannot schedule

[GitHub] [flink] bowenli86 commented on a change in pull request #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service

bowenli86 commented on a change in pull request #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service URL: https://github.com/apache/flink/pull/8784#discussion_r295019001 ## File path:

[GitHub] [flink] xuefuz commented on a change in pull request #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service

xuefuz commented on a change in pull request #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service URL: https://github.com/apache/flink/pull/8784#discussion_r295003074 ## File path:

[GitHub] [flink] bowenli86 commented on issue #8769: [FLINK-12875][hive] support converting input args of char, varchar, bytes, timestamp, date for Hive functions

bowenli86 commented on issue #8769: [FLINK-12875][hive] support converting input args of char, varchar, bytes, timestamp, date for Hive functions URL: https://github.com/apache/flink/pull/8769#issuecomment-503289283 Merging

[GitHub] [flink] bowenli86 commented on a change in pull request #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service

bowenli86 commented on a change in pull request #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service URL: https://github.com/apache/flink/pull/8784#discussion_r295008984 ## File path:

[jira] [Created] (FLINK-12891) evaluate converting hadoop/hive writable between Hive functions and Flink

Bowen Li created FLINK-12891: Summary: evaluate converting hadoop/hive writable between Hive functions and Flink Key: FLINK-12891 URL: https://issues.apache.org/jira/browse/FLINK-12891 Project: Flink

[GitHub] [flink] xuefuz commented on a change in pull request #8766: [FLINK-12664][hive] Implement TableSink to write Hive tables

xuefuz commented on a change in pull request #8766: [FLINK-12664][hive] Implement TableSink to write Hive tables URL: https://github.com/apache/flink/pull/8766#discussion_r294972707 ## File path:

[GitHub] [flink] flinkbot commented on issue #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service

flinkbot commented on issue #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service URL: https://github.com/apache/flink/pull/8784#issuecomment-503269309 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[GitHub] [flink] pnowojski commented on issue #8768: [FLINK-12143] Fix file system dynamic class loading on create

pnowojski commented on issue #8768: [FLINK-12143] Fix file system dynamic class loading on create URL: https://github.com/apache/flink/pull/8768#issuecomment-503280434 Travis builds seem to be still constantly failing. I've restarted the builds one more time.

[GitHub] [flink] xuefuz commented on a change in pull request #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service

xuefuz commented on a change in pull request #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service URL: https://github.com/apache/flink/pull/8784#discussion_r294998015 ## File path:

[GitHub] [flink] xuefuz commented on a change in pull request #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service

xuefuz commented on a change in pull request #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service URL: https://github.com/apache/flink/pull/8784#discussion_r295010310 ## File path:

[GitHub] [flink] xuefuz commented on a change in pull request #8766: [FLINK-12664][hive] Implement TableSink to write Hive tables

xuefuz commented on a change in pull request #8766: [FLINK-12664][hive] Implement TableSink to write Hive tables URL: https://github.com/apache/flink/pull/8766#discussion_r294971779 ## File path:

[GitHub] [flink] bowenli86 commented on issue #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service

bowenli86 commented on issue #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service URL: https://github.com/apache/flink/pull/8784#issuecomment-503272209 cc @xuefuz @lirui-apache @zjuwangg

[GitHub] [flink] xuefuz commented on a change in pull request #8769: [FLINK-12875][hive] support converting input args of char, varchar, bytes, timestamp, date for Hive functions

xuefuz commented on a change in pull request #8769: [FLINK-12875][hive] support converting input args of char, varchar, bytes, timestamp, date for Hive functions URL: https://github.com/apache/flink/pull/8769#discussion_r294987573 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service

bowenli86 commented on a change in pull request #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service URL: https://github.com/apache/flink/pull/8784#discussion_r295001539 ## File path:

[GitHub] [flink] xuefuz commented on a change in pull request #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service

xuefuz commented on a change in pull request #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service URL: https://github.com/apache/flink/pull/8784#discussion_r295001595 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service

bowenli86 commented on a change in pull request #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service URL: https://github.com/apache/flink/pull/8784#discussion_r295000272 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service

bowenli86 commented on a change in pull request #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service URL: https://github.com/apache/flink/pull/8784#discussion_r295001200 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service

bowenli86 commented on a change in pull request #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service URL: https://github.com/apache/flink/pull/8784#discussion_r295000272 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service

bowenli86 commented on a change in pull request #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service URL: https://github.com/apache/flink/pull/8784#discussion_r295010635 ## File path:

[jira] [Updated] (FLINK-12841) Unify catalog meta-objects implementations

[ https://issues.apache.org/jira/browse/FLINK-12841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-12841: - Summary: Unify catalog meta-objects implementations (was: Unify catalog meta-objects implementations

[GitHub] [flink] bowenli86 opened a new pull request #8786: [FLINK-12877][table][hive] Unify catalog database implementations

bowenli86 opened a new pull request #8786: [FLINK-12877][table][hive] Unify catalog database implementations URL: https://github.com/apache/flink/pull/8786 ## What is the purpose of the change This PR unifies catalog database implementations. ## Brief change log -

[jira] [Updated] (FLINK-12877) Unify catalog database implementations

[ https://issues.apache.org/jira/browse/FLINK-12877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12877: --- Labels: pull-request-available (was: ) > Unify catalog database implementations >

[jira] [Closed] (FLINK-12875) support converting input args of char, varchar, bytes, timestamp, date for Hive functions

[ https://issues.apache.org/jira/browse/FLINK-12875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-12875. Resolution: Fixed merged in 1.9.0: 9a01d1162dbe5fe97dcc89f4db502348c904d150 > support converting input

[GitHub] [flink] asfgit closed pull request #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service

asfgit closed pull request #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service URL: https://github.com/apache/flink/pull/8784 This is an automated message from the Apache Git

[jira] [Closed] (FLINK-12892) serialize catalog table to properties for table discovery service

[ https://issues.apache.org/jira/browse/FLINK-12892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-12892. Resolution: Fixed merged in 1.9.0: 26de0faab65dfdc08d91393824944ca2fd43fb9b > serialize catalog table to

[jira] [Commented] (FLINK-12626) Client should not register table-source-sink twice in TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-12626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16867130#comment-16867130 ] Bowen Li commented on FLINK-12626: -- Closing this as it's fixed as part of FLINK-12604 > Client should

[jira] [Closed] (FLINK-12626) Client should not register table-source-sink twice in TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-12626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-12626. Resolution: Fixed > Client should not register table-source-sink twice in TableEnvironment >

[jira] [Created] (FLINK-12894) Document how to configure and use catalogs in SQL CLI in Chinese

Bowen Li created FLINK-12894: Summary: Document how to configure and use catalogs in SQL CLI in Chinese Key: FLINK-12894 URL: https://issues.apache.org/jira/browse/FLINK-12894 Project: Flink

[jira] [Commented] (FLINK-12627) Document how to configure and use catalogs in SQL CLI

[ https://issues.apache.org/jira/browse/FLINK-12627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16867139#comment-16867139 ] Bowen Li commented on FLINK-12627: -- ticket for corresponding Chinese doc > Document how to configure

[jira] [Updated] (FLINK-12627) Document how to configure and use catalogs in SQL CLI

[ https://issues.apache.org/jira/browse/FLINK-12627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-12627: - Component/s: Documentation Connectors / Hive > Document how to configure and use

[GitHub] [flink] flinkbot commented on issue #8785: [FLINK-11480][hive] Create HiveTableFactory that creates TableSource/…

flinkbot commented on issue #8785: [FLINK-11480][hive] Create HiveTableFactory that creates TableSource/… URL: https://github.com/apache/flink/pull/8785#issuecomment-503315938 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] xuefuz commented on a change in pull request #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service

xuefuz commented on a change in pull request #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service URL: https://github.com/apache/flink/pull/8784#discussion_r295033563 ## File path:

[jira] [Updated] (FLINK-12877) Unify catalog database implementations

[ https://issues.apache.org/jira/browse/FLINK-12877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-12877: - Summary: Unify catalog database implementations (was: Unify catalog database implementations and

[GitHub] [flink] flinkbot commented on issue #8786: [FLINK-12877][table][hive] Unify catalog database implementations

flinkbot commented on issue #8786: [FLINK-12877][table][hive] Unify catalog database implementations URL: https://github.com/apache/flink/pull/8786#issuecomment-503340376 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[jira] [Created] (FLINK-12893) check certain properties that are not supported when alter database in HiveCatalog

Bowen Li created FLINK-12893: Summary: check certain properties that are not supported when alter database in HiveCatalog Key: FLINK-12893 URL: https://issues.apache.org/jira/browse/FLINK-12893 Project:

[jira] [Updated] (FLINK-11480) Create HiveTableFactory that creates TableSource/Sink from a Hive table

[ https://issues.apache.org/jira/browse/FLINK-11480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11480: --- Labels: pull-request-available (was: ) > Create HiveTableFactory that creates

[GitHub] [flink] xuefuz opened a new pull request #8785: [FLINK-11480][hive] Create HiveTableFactory that creates TableSource/…

xuefuz opened a new pull request #8785: [FLINK-11480][hive] Create HiveTableFactory that creates TableSource/… URL: https://github.com/apache/flink/pull/8785 …Sink from a Hive table ## What is the purpose of the change Create HiveTableFactory that creates

[jira] [Commented] (FLINK-12841) Unify catalog meta-objects implementations

[ https://issues.apache.org/jira/browse/FLINK-12841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16867088#comment-16867088 ] Bowen Li commented on FLINK-12841: -- [~dawidwys] Make sense to me, I was also rethinking that part. I

[GitHub] [flink] bowenli86 commented on a change in pull request #8786: [FLINK-12877][table][hive] Unify catalog database implementations

bowenli86 commented on a change in pull request #8786: [FLINK-12877][table][hive] Unify catalog database implementations URL: https://github.com/apache/flink/pull/8786#discussion_r295069631 ## File path: flink-table/flink-table-api-java/pom.xml ## @@ -58,4 +58,20 @@ under

[GitHub] [flink] bowenli86 removed a comment on issue #8770: [FLINK-12658][hive] Integrate Flink with Hive GenericUDF

bowenli86 removed a comment on issue #8770: [FLINK-12658][hive] Integrate Flink with Hive GenericUDF URL: https://github.com/apache/flink/pull/8770#issuecomment-503304569 cc @xuefuz @JingsongLi This is an automated message

[GitHub] [flink] bowenli86 commented on issue #8770: [FLINK-12658][hive] Integrate Flink with Hive GenericUDF

bowenli86 commented on issue #8770: [FLINK-12658][hive] Integrate Flink with Hive GenericUDF URL: https://github.com/apache/flink/pull/8770#issuecomment-503350970 @flinkbot attention @xuefuz @JingsongLi This is an automated

[GitHub] [flink] bowenli86 commented on issue #8786: [FLINK-12877][table][hive] Unify catalog database implementations

bowenli86 commented on issue #8786: [FLINK-12877][table][hive] Unify catalog database implementations URL: https://github.com/apache/flink/pull/8786#issuecomment-503350827 cc @xuefuz @lirui-apache @zjuwangg This is an

[GitHub] [flink] xuefuz commented on a change in pull request #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service

xuefuz commented on a change in pull request #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service URL: https://github.com/apache/flink/pull/8784#discussion_r295034137 ## File path:

[GitHub] [flink] bowenli86 commented on issue #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service

bowenli86 commented on issue #8784: [FLINK-12892][table][hive] serialize catalog table to properties for table discovery service URL: https://github.com/apache/flink/pull/8784#issuecomment-503330403 @xuefuz Thanks for your review! Merging

[GitHub] [flink] bowenli86 commented on a change in pull request #8785: [FLINK-11480][hive] Create HiveTableFactory that creates TableSource/…

bowenli86 commented on a change in pull request #8785: [FLINK-11480][hive] Create HiveTableFactory that creates TableSource/… URL: https://github.com/apache/flink/pull/8785#discussion_r295065597 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8785: [FLINK-11480][hive] Create HiveTableFactory that creates TableSource/…

bowenli86 commented on a change in pull request #8785: [FLINK-11480][hive] Create HiveTableFactory that creates TableSource/… URL: https://github.com/apache/flink/pull/8785#discussion_r295064463 ## File path: flink-connectors/flink-connector-hive/pom.xml ## @@ -59,6

[GitHub] [flink] bowenli86 commented on a change in pull request #8785: [FLINK-11480][hive] Create HiveTableFactory that creates TableSource/…

bowenli86 commented on a change in pull request #8785: [FLINK-11480][hive] Create HiveTableFactory that creates TableSource/… URL: https://github.com/apache/flink/pull/8785#discussion_r295065132 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8785: [FLINK-11480][hive] Create HiveTableFactory that creates TableSource/…

bowenli86 commented on a change in pull request #8785: [FLINK-11480][hive] Create HiveTableFactory that creates TableSource/… URL: https://github.com/apache/flink/pull/8785#discussion_r295067033 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8785: [FLINK-11480][hive] Create HiveTableFactory that creates TableSource/…

bowenli86 commented on a change in pull request #8785: [FLINK-11480][hive] Create HiveTableFactory that creates TableSource/… URL: https://github.com/apache/flink/pull/8785#discussion_r295067100 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8785: [FLINK-11480][hive] Create HiveTableFactory that creates TableSource/…

bowenli86 commented on a change in pull request #8785: [FLINK-11480][hive] Create HiveTableFactory that creates TableSource/… URL: https://github.com/apache/flink/pull/8785#discussion_r295064676 ## File path: flink-connectors/flink-connector-hive/pom.xml ## @@ -59,6

[GitHub] [flink] bowenli86 commented on a change in pull request #8785: [FLINK-11480][hive] Create HiveTableFactory that creates TableSource/…

bowenli86 commented on a change in pull request #8785: [FLINK-11480][hive] Create HiveTableFactory that creates TableSource/… URL: https://github.com/apache/flink/pull/8785#discussion_r295067658 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8785: [FLINK-11480][hive] Create HiveTableFactory that creates TableSource/…

bowenli86 commented on a change in pull request #8785: [FLINK-11480][hive] Create HiveTableFactory that creates TableSource/… URL: https://github.com/apache/flink/pull/8785#discussion_r295067152 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8785: [FLINK-11480][hive] Create HiveTableFactory that creates TableSource/…

bowenli86 commented on a change in pull request #8785: [FLINK-11480][hive] Create HiveTableFactory that creates TableSource/… URL: https://github.com/apache/flink/pull/8785#discussion_r295064252 ## File path: flink-connectors/flink-connector-hive/pom.xml ## @@ -59,6

[GitHub] [flink] bowenli86 commented on a change in pull request #8785: [FLINK-11480][hive] Create HiveTableFactory that creates TableSource/…

bowenli86 commented on a change in pull request #8785: [FLINK-11480][hive] Create HiveTableFactory that creates TableSource/… URL: https://github.com/apache/flink/pull/8785#discussion_r295067806 ## File path:

  1   2   3   4   >