[GitHub] [flink] twalthr commented on a change in pull request #8984: [FLINK-13088][table-api] Support lazy query transformation & execution on TableEnvironment

twalthr commented on a change in pull request #8984: [FLINK-13088][table-api] Support lazy query transformation & execution on TableEnvironment URL: https://github.com/apache/flink/pull/8984#discussion_r300557912 ## File path: flink-table/flink-table-api-java-bridge/src/main/java/

[GitHub] [flink] twalthr commented on a change in pull request #8984: [FLINK-13088][table-api] Support lazy query transformation & execution on TableEnvironment

twalthr commented on a change in pull request #8984: [FLINK-13088][table-api] Support lazy query transformation & execution on TableEnvironment URL: https://github.com/apache/flink/pull/8984#discussion_r300558201 ## File path: flink-table/flink-table-api-java/src/main/java/org/apa

[GitHub] [flink] twalthr commented on a change in pull request #8984: [FLINK-13088][table-api] Support lazy query transformation & execution on TableEnvironment

twalthr commented on a change in pull request #8984: [FLINK-13088][table-api] Support lazy query transformation & execution on TableEnvironment URL: https://github.com/apache/flink/pull/8984#discussion_r300557176 ## File path: flink-table/flink-table-planner/src/test/scala/org/apa

[GitHub] [flink] twalthr commented on a change in pull request #8984: [FLINK-13088][table-api] Support lazy query transformation & execution on TableEnvironment

twalthr commented on a change in pull request #8984: [FLINK-13088][table-api] Support lazy query transformation & execution on TableEnvironment URL: https://github.com/apache/flink/pull/8984#discussion_r300558483 ## File path: flink-table/flink-table-api-java/src/main/java/org/apa

[GitHub] [flink] twalthr commented on a change in pull request #8984: [FLINK-13088][table-api] Support lazy query transformation & execution on TableEnvironment

twalthr commented on a change in pull request #8984: [FLINK-13088][table-api] Support lazy query transformation & execution on TableEnvironment URL: https://github.com/apache/flink/pull/8984#discussion_r300558819 ## File path: flink-table/flink-table-api-java-bridge/src/main/java/

[GitHub] [flink] twalthr commented on a change in pull request #8984: [FLINK-13088][table-api] Support lazy query transformation & execution on TableEnvironment

twalthr commented on a change in pull request #8984: [FLINK-13088][table-api] Support lazy query transformation & execution on TableEnvironment URL: https://github.com/apache/flink/pull/8984#discussion_r300555474 ## File path: flink-table/flink-table-api-java/src/main/java/org/apa

[GitHub] [flink] twalthr commented on a change in pull request #8984: [FLINK-13088][table-api] Support lazy query transformation & execution on TableEnvironment

twalthr commented on a change in pull request #8984: [FLINK-13088][table-api] Support lazy query transformation & execution on TableEnvironment URL: https://github.com/apache/flink/pull/8984#discussion_r300557387 ## File path: flink-table/flink-table-planner/src/test/scala/org/apa

[GitHub] [flink] dawidwys merged pull request #8511: [FLINK-12319][Library/CEP]Change the logic of releasing node from recursive to non-recursive

dawidwys merged pull request #8511: [FLINK-12319][Library/CEP]Change the logic of releasing node from recursive to non-recursive URL: https://github.com/apache/flink/pull/8511 This is an automated message from the Apache Git

[jira] [Closed] (FLINK-12796) Introduce BaseArray and BaseMap to reduce conversion overhead to blink

[ https://issues.apache.org/jira/browse/FLINK-12796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-12796. -- Resolution: Implemented Fix Version/s: 1.9.0 merged in 1.9.0: 906616baeaf482662d5ba621c14e51391

[GitHub] [flink] dawidwys commented on issue #8511: [FLINK-12319][Library/CEP]Change the logic of releasing node from recursive to non-recursive

dawidwys commented on issue #8511: [FLINK-12319][Library/CEP]Change the logic of releasing node from recursive to non-recursive URL: https://github.com/apache/flink/pull/8511#issuecomment-508649623 Thank you for your contribution @liyafan82 Merging it. -

[GitHub] [flink] KurtYoung merged pull request #8682: [FLINK-12796][table-planner-blink] Introduce BaseArray and BaseMap to reduce conversion overhead to blink

KurtYoung merged pull request #8682: [FLINK-12796][table-planner-blink] Introduce BaseArray and BaseMap to reduce conversion overhead to blink URL: https://github.com/apache/flink/pull/8682 This is an automated message from

[GitHub] [flink] wuchong commented on a change in pull request #8923: [FLINK-13026][jdbc] Introduce JDBCLookupFunction

wuchong commented on a change in pull request #8923: [FLINK-13026][jdbc] Introduce JDBCLookupFunction URL: https://github.com/apache/flink/pull/8923#discussion_r300552890 ## File path: flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCTableSource.java

[GitHub] [flink] wuchong commented on a change in pull request #8923: [FLINK-13026][jdbc] Introduce JDBCLookupFunction

wuchong commented on a change in pull request #8923: [FLINK-13026][jdbc] Introduce JDBCLookupFunction URL: https://github.com/apache/flink/pull/8923#discussion_r300550448 ## File path: flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCUtils.java #

[GitHub] [flink] wuchong commented on a change in pull request #8923: [FLINK-13026][jdbc] Introduce JDBCLookupFunction

wuchong commented on a change in pull request #8923: [FLINK-13026][jdbc] Introduce JDBCLookupFunction URL: https://github.com/apache/flink/pull/8923#discussion_r300550689 ## File path: flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCLookupOptions.jav

[jira] [Resolved] (FLINK-13096) Typo in Utils

[ https://issues.apache.org/jira/browse/FLINK-13096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-13096. Resolution: Fixed Fix Version/s: 1.9.0 Fixed to master in https://github.com/apach

[GitHub] [flink] rmetzger merged pull request #8983: [FLINK-13096][Deployment/YARN]Typo in Utils

rmetzger merged pull request #8983: [FLINK-13096][Deployment/YARN]Typo in Utils URL: https://github.com/apache/flink/pull/8983 This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] dawidwys commented on a change in pull request #8984: [FLINK-13088][table-api] Support lazy query transformation & execution on TableEnvironment

dawidwys commented on a change in pull request #8984: [FLINK-13088][table-api] Support lazy query transformation & execution on TableEnvironment URL: https://github.com/apache/flink/pull/8984#discussion_r300552526 ## File path: flink-table/flink-table-api-java-bridge/src/main/java

[jira] [Commented] (FLINK-12852) Deadlock occurs when requiring exclusive buffer for RemoteInputChannel

[ https://issues.apache.org/jira/browse/FLINK-12852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16878996#comment-16878996 ] Aitozi commented on FLINK-12852: Thanks [~gaoyunhaii] for your explanation, I think over

[GitHub] [flink] becketqin commented on issue #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

becketqin commented on issue #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#issuecomment-508645233 @rmetzger I have reviewed the PR and I think the major issues have been addressed. Do

[GitHub] [flink] shaoxuan-wang commented on issue #8526: [FLINK-12597][ml] Remove the legacy flink-libraries/flink-ml

shaoxuan-wang commented on issue #8526: [FLINK-12597][ml] Remove the legacy flink-libraries/flink-ml URL: https://github.com/apache/flink/pull/8526#issuecomment-508645106 Let us merge this PR first, then reopen the #8827 . @c4e @sjwiesman @flinkbot approve all

[GitHub] [flink] dawidwys commented on a change in pull request #8984: [FLINK-13088][table-api] Support lazy query transformation & execution on TableEnvironment

dawidwys commented on a change in pull request #8984: [FLINK-13088][table-api] Support lazy query transformation & execution on TableEnvironment URL: https://github.com/apache/flink/pull/8984#discussion_r300552526 ## File path: flink-table/flink-table-api-java-bridge/src/main/java

[GitHub] [flink] JingsongLi commented on a change in pull request #8762: [FLINK-12844][table-planner-blink] Use default conversion class LocalDate/LocalTime/LocalDateTime for DateType/TimeType/Timesta

JingsongLi commented on a change in pull request #8762: [FLINK-12844][table-planner-blink] Use default conversion class LocalDate/LocalTime/LocalDateTime for DateType/TimeType/TimestampType in blink URL: https://github.com/apache/flink/pull/8762#discussion_r300550636 ## File path:

[GitHub] [flink] JingsongLi commented on issue #8682: [FLINK-12796][table-planner-blink] Introduce BaseArray and BaseMap to reduce conversion overhead to blink

JingsongLi commented on issue #8682: [FLINK-12796][table-planner-blink] Introduce BaseArray and BaseMap to reduce conversion overhead to blink URL: https://github.com/apache/flink/pull/8682#issuecomment-508640378 Travis passed in https://travis-ci.org/JingsongLi/flink/builds/554513232

[GitHub] [flink] flinkbot commented on issue #8994: [FLINK-13057][state] Correct comments in ListState class

flinkbot commented on issue #8994: [FLINK-13057][state] Correct comments in ListState class URL: https://github.com/apache/flink/pull/8994#issuecomment-508639563 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull r

[jira] [Updated] (FLINK-13057) Correct comments in ListState class

[ https://issues.apache.org/jira/browse/FLINK-13057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13057: --- Labels: pull-request-available (was: ) > Correct comments in ListState class >

[jira] [Updated] (FLINK-13106) Translate "Parallel Execution" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-13106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yelun updated FLINK-13106: -- Affects Version/s: 1.9.0 > Translate "Parallel Execution" page into Chinese >

[GitHub] [flink] hequn8128 opened a new pull request #8994: [FLINK-13057][state] Correct comments in ListState class

hequn8128 opened a new pull request #8994: [FLINK-13057][state] Correct comments in ListState class URL: https://github.com/apache/flink/pull/8994 ## What is the purpose of the change This pull request fixes the comments in `ListState`. `ListState` can be a keyed stat

[jira] [Assigned] (FLINK-13106) Translate "Parallel Execution" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-13106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yelun reassigned FLINK-13106: - Assignee: yelun > Translate "Parallel Execution" page into Chinese > --

[jira] [Updated] (FLINK-13097) Buffer depletion in SimpleCollectingOutputView throws non-obvious EOFException

[ https://issues.apache.org/jira/browse/FLINK-13097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13097: --- Component/s: Runtime / Task > Buffer depletion in SimpleCollectingOutputView throws non-obvi

[GitHub] [flink] JingsongLi commented on issue #8898: [FLINK-12936][table-planner-blink] Support intersect all / minus all to blink planner

JingsongLi commented on issue #8898: [FLINK-12936][table-planner-blink] Support intersect all / minus all to blink planner URL: https://github.com/apache/flink/pull/8898#issuecomment-508637446 Travis passed(blink planner) in https://travis-ci.org/JingsongLi/flink/builds/554510279

[jira] [Updated] (FLINK-13108) Remove duplicated type cast in generated code

[ https://issues.apache.org/jira/browse/FLINK-13108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan updated FLINK-13108: - Description: There are duplicated cast operations in the generated code. For example, to run org.apache

[jira] [Updated] (FLINK-13108) Remove duplicated type cast in generated code

[ https://issues.apache.org/jira/browse/FLINK-13108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan updated FLINK-13108: - Description: There are duplicated cast operations in the generated code. For example, to run org.apache

[GitHub] [flink] flinkbot commented on issue #8993: [FLINK-13108][Table SQL / Planner] Remove duplicated type cast in generated code

flinkbot commented on issue #8993: [FLINK-13108][Table SQL / Planner] Remove duplicated type cast in generated code URL: https://github.com/apache/flink/pull/8993#issuecomment-508636296 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[jira] [Updated] (FLINK-13108) Remove duplicated type cast in generated code

[ https://issues.apache.org/jira/browse/FLINK-13108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liya Fan updated FLINK-13108: - Description: There are duplicated cast operations in the generated code. For example, to run org.apache

[jira] [Updated] (FLINK-13108) Remove duplicated type cast in generated code

[ https://issues.apache.org/jira/browse/FLINK-13108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13108: --- Labels: pull-request-available (was: ) > Remove duplicated type cast in generated code > --

[GitHub] [flink] asfgit closed pull request #8719: [FLINK-12767][python] Support user defined connectors/format

asfgit closed pull request #8719: [FLINK-12767][python] Support user defined connectors/format URL: https://github.com/apache/flink/pull/8719 This is an automated message from the Apache Git Service. To respond to the messag

[GitHub] [flink] liyafan82 opened a new pull request #8993: [FLINK-13108][Table SQL / Planner] Remove duplicated type cast in generated code

liyafan82 opened a new pull request #8993: [FLINK-13108][Table SQL / Planner] Remove duplicated type cast in generated code URL: https://github.com/apache/flink/pull/8993 ## What is the purpose of the change There are duplicated cast operations in the generated code. For exam

[jira] [Closed] (FLINK-12767) Support user defined connectors/format

[ https://issues.apache.org/jira/browse/FLINK-12767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-12767. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in master: 80d7ba440bd7389e76536e3b91ca227f4f850

[jira] [Updated] (FLINK-13106) Translate "Parallel Execution" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-13106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13106: Summary: Translate "Parallel Execution" page into Chinese (was: Translate "parallel" page into Chinese)

[GitHub] [flink] wuchong commented on a change in pull request #7550: [FLINK-10245] [Streaming Connector] Add Pojo, Tuple, Row and Scala Product DataStream Sink and Upsert Table Sink for HBase

wuchong commented on a change in pull request #7550: [FLINK-10245] [Streaming Connector] Add Pojo, Tuple, Row and Scala Product DataStream Sink and Upsert Table Sink for HBase URL: https://github.com/apache/flink/pull/7550#discussion_r300544300 ## File path: flink-connectors/flink-

[GitHub] [flink] wuchong commented on a change in pull request #7550: [FLINK-10245] [Streaming Connector] Add Pojo, Tuple, Row and Scala Product DataStream Sink and Upsert Table Sink for HBase

wuchong commented on a change in pull request #7550: [FLINK-10245] [Streaming Connector] Add Pojo, Tuple, Row and Scala Product DataStream Sink and Upsert Table Sink for HBase URL: https://github.com/apache/flink/pull/7550#discussion_r300544710 ## File path: flink-connectors/flink

[GitHub] [flink] wuchong commented on a change in pull request #7550: [FLINK-10245] [Streaming Connector] Add Pojo, Tuple, Row and Scala Product DataStream Sink and Upsert Table Sink for HBase

wuchong commented on a change in pull request #7550: [FLINK-10245] [Streaming Connector] Add Pojo, Tuple, Row and Scala Product DataStream Sink and Upsert Table Sink for HBase URL: https://github.com/apache/flink/pull/7550#discussion_r300543142 ## File path: flink-connectors/flink

[GitHub] [flink] wisgood commented on a change in pull request #8621: [FLINK-12682][connectors] StringWriter support custom row delimiter

wisgood commented on a change in pull request #8621: [FLINK-12682][connectors] StringWriter support custom row delimiter URL: https://github.com/apache/flink/pull/8621#discussion_r300544323 ## File path: flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/str

[jira] [Updated] (FLINK-11529) Support Chinese Documentation for Apache Flink

[ https://issues.apache.org/jira/browse/FLINK-11529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-11529: -- Description: This issue is an umbrella issue for tracking fully support Chines

[GitHub] [flink] JingsongLi commented on issue #8923: [FLINK-13026][jdbc] Introduce JDBCLookupFunction

JingsongLi commented on issue #8923: [FLINK-13026][jdbc] Introduce JDBCLookupFunction URL: https://github.com/apache/flink/pull/8923#issuecomment-508633152 @wuchong Thanks review~ Code updated. This is an automated message fr

[GitHub] [flink] klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese

klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese URL: https://github.com/apache/flink/pull/8986#discussion_r300538583 ## File path: docs/ops/deployment/kubernetes.zh.md ## @@ -28,72 +28,75 @@ This page des

[GitHub] [flink] klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese

klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese URL: https://github.com/apache/flink/pull/8986#discussion_r300538503 ## File path: docs/ops/deployment/kubernetes.zh.md ## @@ -28,72 +28,75 @@ This page des

[GitHub] [flink] klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese

klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese URL: https://github.com/apache/flink/pull/8986#discussion_r300539069 ## File path: docs/ops/deployment/kubernetes.zh.md ## @@ -28,72 +28,75 @@ This page des

[GitHub] [flink] klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese

klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese URL: https://github.com/apache/flink/pull/8986#discussion_r300537721 ## File path: docs/ops/deployment/kubernetes.zh.md ## @@ -28,72 +28,75 @@ This page des

[GitHub] [flink] klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese

klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese URL: https://github.com/apache/flink/pull/8986#discussion_r300538409 ## File path: docs/ops/deployment/kubernetes.zh.md ## @@ -28,72 +28,75 @@ This page des

[GitHub] [flink] klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese

klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese URL: https://github.com/apache/flink/pull/8986#discussion_r300537894 ## File path: docs/ops/deployment/kubernetes.zh.md ## @@ -175,7 +178,7 @@ spec: po

[GitHub] [flink] klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese

klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese URL: https://github.com/apache/flink/pull/8986#discussion_r300538183 ## File path: docs/ops/deployment/kubernetes.zh.md ## @@ -28,72 +28,75 @@ This page des

[GitHub] [flink] klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese

klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese URL: https://github.com/apache/flink/pull/8986#discussion_r300538333 ## File path: docs/ops/deployment/kubernetes.zh.md ## @@ -28,72 +28,75 @@ This page des

[GitHub] [flink] klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese

klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese URL: https://github.com/apache/flink/pull/8986#discussion_r300539135 ## File path: docs/ops/deployment/kubernetes.zh.md ## @@ -28,72 +28,75 @@ This page des

[GitHub] [flink] klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese

klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese URL: https://github.com/apache/flink/pull/8986#discussion_r300537559 ## File path: docs/ops/deployment/kubernetes.zh.md ## @@ -28,72 +28,75 @@ This page des

[GitHub] [flink] klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese

klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese URL: https://github.com/apache/flink/pull/8986#discussion_r300539044 ## File path: docs/ops/deployment/kubernetes.zh.md ## @@ -28,72 +28,75 @@ This page des

[GitHub] [flink] klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese

klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese URL: https://github.com/apache/flink/pull/8986#discussion_r300537520 ## File path: docs/ops/deployment/kubernetes.zh.md ## @@ -28,72 +28,75 @@ This page des

[GitHub] [flink] klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese

klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese URL: https://github.com/apache/flink/pull/8986#discussion_r300539241 ## File path: docs/ops/deployment/kubernetes.zh.md ## @@ -28,72 +28,75 @@ This page des

[GitHub] [flink] klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese

klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese URL: https://github.com/apache/flink/pull/8986#discussion_r300538971 ## File path: docs/ops/deployment/kubernetes.zh.md ## @@ -28,72 +28,75 @@ This page des

[GitHub] [flink] klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese

klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese URL: https://github.com/apache/flink/pull/8986#discussion_r300537425 ## File path: docs/ops/deployment/kubernetes.zh.md ## @@ -28,72 +28,75 @@ This page des

[GitHub] [flink] klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese

klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese URL: https://github.com/apache/flink/pull/8986#discussion_r300539058 ## File path: docs/ops/deployment/kubernetes.zh.md ## @@ -28,72 +28,75 @@ This page des

[GitHub] [flink] klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese

klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese URL: https://github.com/apache/flink/pull/8986#discussion_r300539362 ## File path: docs/ops/deployment/kubernetes.zh.md ## @@ -28,72 +28,75 @@ This page des

[GitHub] [flink] klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese

klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese URL: https://github.com/apache/flink/pull/8986#discussion_r300538800 ## File path: docs/ops/deployment/kubernetes.zh.md ## @@ -28,72 +28,75 @@ This page des

[GitHub] [flink] klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese

klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese URL: https://github.com/apache/flink/pull/8986#discussion_r300539155 ## File path: docs/ops/deployment/kubernetes.zh.md ## @@ -28,72 +28,75 @@ This page des

[GitHub] [flink] klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese

klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese URL: https://github.com/apache/flink/pull/8986#discussion_r300539315 ## File path: docs/ops/deployment/kubernetes.zh.md ## @@ -28,72 +28,75 @@ This page des

[GitHub] [flink] klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese

klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese URL: https://github.com/apache/flink/pull/8986#discussion_r300539092 ## File path: docs/ops/deployment/kubernetes.zh.md ## @@ -28,72 +28,75 @@ This page des

[GitHub] [flink] klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese

klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese URL: https://github.com/apache/flink/pull/8986#discussion_r300539270 ## File path: docs/ops/deployment/kubernetes.zh.md ## @@ -28,72 +28,75 @@ This page des

[GitHub] [flink] klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese

klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese URL: https://github.com/apache/flink/pull/8986#discussion_r300538781 ## File path: docs/ops/deployment/kubernetes.zh.md ## @@ -28,72 +28,75 @@ This page des

[GitHub] [flink] klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese

klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese URL: https://github.com/apache/flink/pull/8986#discussion_r300539114 ## File path: docs/ops/deployment/kubernetes.zh.md ## @@ -28,72 +28,75 @@ This page des

[GitHub] [flink] klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese

klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese URL: https://github.com/apache/flink/pull/8986#discussion_r300539011 ## File path: docs/ops/deployment/kubernetes.zh.md ## @@ -28,72 +28,75 @@ This page des

[GitHub] [flink] klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese

klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese URL: https://github.com/apache/flink/pull/8986#discussion_r300537469 ## File path: docs/ops/deployment/kubernetes.zh.md ## @@ -28,72 +28,75 @@ This page des

[GitHub] [flink] klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese

klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese URL: https://github.com/apache/flink/pull/8986#discussion_r300538535 ## File path: docs/ops/deployment/kubernetes.zh.md ## @@ -28,72 +28,75 @@ This page des

[GitHub] [flink] klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese

klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese URL: https://github.com/apache/flink/pull/8986#discussion_r300537750 ## File path: docs/ops/deployment/kubernetes.zh.md ## @@ -28,72 +28,75 @@ This page des

[GitHub] [flink] klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese

klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese URL: https://github.com/apache/flink/pull/8986#discussion_r300538613 ## File path: docs/ops/deployment/kubernetes.zh.md ## @@ -28,72 +28,75 @@ This page des

[GitHub] [flink] klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese

klion26 commented on a change in pull request #8986: [FLINK-13092][docs-zh] Translate "Kubernetes" page into Chinese URL: https://github.com/apache/flink/pull/8986#discussion_r300538882 ## File path: docs/ops/deployment/kubernetes.zh.md ## @@ -28,72 +28,75 @@ This page des

[GitHub] [flink] asfgit merged pull request #8974: [FLINK-13082][table-planner-blink] Support MatchRecognize in blink planner

asfgit merged pull request #8974: [FLINK-13082][table-planner-blink] Support MatchRecognize in blink planner URL: https://github.com/apache/flink/pull/8974 This is an automated message from the Apache Git Service. To respond

[jira] [Closed] (FLINK-13082) Support MatchRecognize in blink planner

[ https://issues.apache.org/jira/browse/FLINK-13082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-13082. --- Resolution: Fixed Fixed in 1.9.0: b74980ea51884f58199f2d7dd527999ac6a6177c > Support MatchRecognize in blin

[jira] [Updated] (FLINK-13082) Support MatchRecognize in blink planner

[ https://issues.apache.org/jira/browse/FLINK-13082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13082: Fix Version/s: 1.9.0 > Support MatchRecognize in blink planner > --- >

[GitHub] [flink] guoweiM commented on a change in pull request #8985: [FLINK-13101][datastream] Introduce blockingAfterChainingOff property of StreamGraph

guoweiM commented on a change in pull request #8985: [FLINK-13101][datastream] Introduce blockingAfterChainingOff property of StreamGraph URL: https://github.com/apache/flink/pull/8985#discussion_r300542849 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming

[GitHub] [flink] godfreyhe commented on a change in pull request #8984: [FLINK-13088][table-api] Support lazy query transformation & execution on TableEnvironment

godfreyhe commented on a change in pull request #8984: [FLINK-13088][table-api] Support lazy query transformation & execution on TableEnvironment URL: https://github.com/apache/flink/pull/8984#discussion_r300542417 ## File path: flink-table/flink-table-api-java-bridge/src/main/ja

[jira] [Created] (FLINK-13108) Remove duplicated type cast in generated code

Liya Fan created FLINK-13108: Summary: Remove duplicated type cast in generated code Key: FLINK-13108 URL: https://issues.apache.org/jira/browse/FLINK-13108 Project: Flink Issue Type: Bug

[GitHub] [flink] JingsongLi commented on a change in pull request #8923: [FLINK-13026][jdbc] Introduce JDBCLookupFunction

JingsongLi commented on a change in pull request #8923: [FLINK-13026][jdbc] Introduce JDBCLookupFunction URL: https://github.com/apache/flink/pull/8923#discussion_r300540953 ## File path: flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCLookupFunction

[GitHub] [flink] JingsongLi commented on a change in pull request #8923: [FLINK-13026][jdbc] Introduce JDBCLookupFunction

JingsongLi commented on a change in pull request #8923: [FLINK-13026][jdbc] Introduce JDBCLookupFunction URL: https://github.com/apache/flink/pull/8923#discussion_r300540815 ## File path: flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCLookupFunction

[GitHub] [flink] JingsongLi commented on a change in pull request #8923: [FLINK-13026][jdbc] Introduce JDBCLookupFunction

JingsongLi commented on a change in pull request #8923: [FLINK-13026][jdbc] Introduce JDBCLookupFunction URL: https://github.com/apache/flink/pull/8923#discussion_r300540804 ## File path: flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCLookupFunction

[GitHub] [flink] danny0405 commented on a change in pull request #8962: [FLINK-13076] [table-planner-blink] Bump Calcite dependency to 1.20.0 in blink planner

danny0405 commented on a change in pull request #8962: [FLINK-13076] [table-planner-blink] Bump Calcite dependency to 1.20.0 in blink planner URL: https://github.com/apache/flink/pull/8962#discussion_r300535389 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/

[jira] [Commented] (FLINK-12852) Deadlock occurs when requiring exclusive buffer for RemoteInputChannel

[ https://issues.apache.org/jira/browse/FLINK-12852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16878958#comment-16878958 ] Yun Gao commented on FLINK-12852: - Hi [~aitozi], very thanks for concerning this issue.

[jira] [Commented] (FLINK-12619) Support TERMINATE/SUSPEND Job with Checkpoint

[ https://issues.apache.org/jira/browse/FLINK-12619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16878957#comment-16878957 ] Congxian Qiu(klion26) commented on FLINK-12619: --- There is a discussion abo

[GitHub] [flink] JingsongLi commented on a change in pull request #8682: [FLINK-12796][table-planner-blink] Introduce BaseArray and BaseMap to reduce conversion overhead to blink

JingsongLi commented on a change in pull request #8682: [FLINK-12796][table-planner-blink] Introduce BaseArray and BaseMap to reduce conversion overhead to blink URL: https://github.com/apache/flink/pull/8682#discussion_r300534318 ## File path: flink-table/flink-table-runtime-blin

[GitHub] [flink] JingsongLi commented on a change in pull request #8682: [FLINK-12796][table-planner-blink] Introduce BaseArray and BaseMap to reduce conversion overhead to blink

JingsongLi commented on a change in pull request #8682: [FLINK-12796][table-planner-blink] Introduce BaseArray and BaseMap to reduce conversion overhead to blink URL: https://github.com/apache/flink/pull/8682#discussion_r300534100 ## File path: flink-table/flink-table-planner-blin

[GitHub] [flink] JingsongLi commented on a change in pull request #8682: [FLINK-12796][table-planner-blink] Introduce BaseArray and BaseMap to reduce conversion overhead to blink

JingsongLi commented on a change in pull request #8682: [FLINK-12796][table-planner-blink] Introduce BaseArray and BaseMap to reduce conversion overhead to blink URL: https://github.com/apache/flink/pull/8682#discussion_r300534132 ## File path: flink-table/flink-table-planner-blin

[GitHub] [flink] godfreyhe commented on issue #8898: [FLINK-12936][table-planner-blink] Support intersect all / minus all to blink planner

godfreyhe commented on issue #8898: [FLINK-12936][table-planner-blink] Support intersect all / minus all to blink planner URL: https://github.com/apache/flink/pull/8898#issuecomment-508619707 LGTM, +1 to merge This is an auto

[jira] [Updated] (FLINK-13107) Port TableApi IT and UT

[ https://issues.apache.org/jira/browse/FLINK-13107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang updated FLINK-13107: --- Component/s: (was: Table SQL / Planner) Table SQL / API > Port TableApi IT and

[GitHub] [flink] TsReaper commented on a change in pull request #8682: [FLINK-12796][table-planner-blink] Introduce BaseArray and BaseMap to reduce conversion overhead to blink

TsReaper commented on a change in pull request #8682: [FLINK-12796][table-planner-blink] Introduce BaseArray and BaseMap to reduce conversion overhead to blink URL: https://github.com/apache/flink/pull/8682#discussion_r300525954 ## File path: flink-table/flink-table-planner-blink/

[GitHub] [flink] TsReaper commented on a change in pull request #8682: [FLINK-12796][table-planner-blink] Introduce BaseArray and BaseMap to reduce conversion overhead to blink

TsReaper commented on a change in pull request #8682: [FLINK-12796][table-planner-blink] Introduce BaseArray and BaseMap to reduce conversion overhead to blink URL: https://github.com/apache/flink/pull/8682#discussion_r300532471 ## File path: flink-table/flink-table-runtime-blink/

[GitHub] [flink] JingsongLi commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect all / minus all to blink planner

JingsongLi commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect all / minus all to blink planner URL: https://github.com/apache/flink/pull/8898#discussion_r300532548 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org

[GitHub] [flink] TsReaper commented on a change in pull request #8682: [FLINK-12796][table-planner-blink] Introduce BaseArray and BaseMap to reduce conversion overhead to blink

TsReaper commented on a change in pull request #8682: [FLINK-12796][table-planner-blink] Introduce BaseArray and BaseMap to reduce conversion overhead to blink URL: https://github.com/apache/flink/pull/8682#discussion_r300528464 ## File path: flink-table/flink-table-planner-blink/

[jira] [Created] (FLINK-13107) Port TableApi IT and UT

Jing Zhang created FLINK-13107: -- Summary: Port TableApi IT and UT Key: FLINK-13107 URL: https://issues.apache.org/jira/browse/FLINK-13107 Project: Flink Issue Type: Task Components: Ta

[GitHub] [flink] yanghua commented on issue #7122: [FLINK-10908][flink-yarn]Add yarn.application.priority in YarnConfigOptions

yanghua commented on issue #7122: [FLINK-10908][flink-yarn]Add yarn.application.priority in YarnConfigOptions URL: https://github.com/apache/flink/pull/7122#issuecomment-508618600 I will have another look soon. Basically, you should add the doc for the config option you provided like other

[GitHub] [flink] danny0405 commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(…

danny0405 commented on a change in pull request #8844: [FLINK-12951][table-planner] Add logic to bridge DDL to table source(… URL: https://github.com/apache/flink/pull/8844#discussion_r300519348 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api

[GitHub] [flink] JingsongLi commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect all / minus all to blink planner

JingsongLi commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect all / minus all to blink planner URL: https://github.com/apache/flink/pull/8898#discussion_r300531386 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org

  1   2   3   4   5   >