[GitHub] [flink] flinkbot edited a comment on pull request #13278: [FLINK-19091][python] Introduce expression DSL for Python Table API

flinkbot edited a comment on pull request #13278: URL: https://github.com/apache/flink/pull/13278#issuecomment-683294857 ## CI report: * 6d8f3760ff006b281650174e97dfa391536de270 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13204: [FLINK-16080][docs-zh]Translate \docs\dev\table\hive\hive_streaming.zh.md into Chinese

flinkbot edited a comment on pull request #13204: URL: https://github.com/apache/flink/pull/13204#issuecomment-677254693 ## CI report: * 9fe54340baebe9ba84297a4c974752d24cded3f1 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13272: [FLINK-18695][network] Netty fakes heap buffer allocationn with direct buffers

flinkbot edited a comment on pull request #13272: URL: https://github.com/apache/flink/pull/13272#issuecomment-682346986 ## CI report: * d34257206e16c6b9757046cf2c7d71d687ab75eb Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-19088) flink sql 1.11 HbaseTableSource Supports FilterPushDown

[ https://issues.apache.org/jira/browse/FLINK-19088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187142#comment-17187142 ] Nicholas Jiang commented on FLINK-19088: [~Leonard Xu], Support for HBaseTableSo

[jira] [Comment Edited] (FLINK-19092) Parse comment on computed column failed

[ https://issues.apache.org/jira/browse/FLINK-19092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187132#comment-17187132 ] Nicholas Jiang edited comment on FLINK-19092 at 8/30/20, 3:54 AM:

[jira] [Commented] (FLINK-19070) Hive connector should throw a meaningful exception if user reads/writes ACID tables

[ https://issues.apache.org/jira/browse/FLINK-19070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187133#comment-17187133 ] Nicholas Jiang commented on FLINK-19070: [~lirui], I would like to pick this iss

[jira] [Commented] (FLINK-19092) Parse comment on computed column failed

[ https://issues.apache.org/jira/browse/FLINK-19092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187132#comment-17187132 ] Nicholas Jiang commented on FLINK-19092: [~Leonard Xu], as you describe, DDL of

[GitHub] [flink] dianfu commented on a change in pull request #13273: [FLINK-18801][docs][python] Add a "10 minutes to Table API" document under the "Python API" -> "User Guide" -> "Table API" section

dianfu commented on a change in pull request #13273: URL: https://github.com/apache/flink/pull/13273#discussion_r479712648 ## File path: docs/dev/python/user-guide/table/10_minutes_to_table_api.md ## @@ -0,0 +1,719 @@ +--- +title: "10 Minutes to Table API" +nav-parent_id: pytho

[GitHub] [flink] flinkbot edited a comment on pull request #13204: [FLINK-16080][docs-zh]Translate \docs\dev\table\hive\hive_streaming.zh.md into Chinese

flinkbot edited a comment on pull request #13204: URL: https://github.com/apache/flink/pull/13204#issuecomment-677254693 ## CI report: * f3ff67413489210527790afa12a9f50b63ced883 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13278: [FLINK-19091][python] Introduce expression DSL for Python Table API

flinkbot edited a comment on pull request #13278: URL: https://github.com/apache/flink/pull/13278#issuecomment-683294857 ## CI report: * ce936d3569bc01243648a82fb4a14d1ed619cfb4 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-18592) StreamingFileSink fails due to truncating HDFS file failure

[ https://issues.apache.org/jira/browse/FLINK-18592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187131#comment-17187131 ] JIAN WANG commented on FLINK-18592: --- Hi [~gaoyunhaii] ，your concern is correct. If res

[GitHub] [flink] dianfu commented on a change in pull request #13273: [FLINK-18801][docs][python] Add a "10 minutes to Table API" document under the "Python API" -> "User Guide" -> "Table API" section

dianfu commented on a change in pull request #13273: URL: https://github.com/apache/flink/pull/13273#discussion_r479712335 ## File path: docs/dev/python/user-guide/table/10_minutes_to_table_api.md ## @@ -0,0 +1,712 @@ +--- +title: "10 Minutes to Table API" +nav-parent_id: pytho

[GitHub] [flink] dianfu commented on a change in pull request #13273: [FLINK-18801][docs][python] Add a "10 minutes to Table API" document under the "Python API" -> "User Guide" -> "Table API" section

dianfu commented on a change in pull request #13273: URL: https://github.com/apache/flink/pull/13273#discussion_r479712238 ## File path: docs/dev/python/user-guide/table/10_minutes_to_table_api.md ## @@ -0,0 +1,712 @@ +--- +title: "10 Minutes to Table API" +nav-parent_id: pytho

[GitHub] [flink] dianfu commented on a change in pull request #13273: [FLINK-18801][docs][python] Add a "10 minutes to Table API" document under the "Python API" -> "User Guide" -> "Table API" section

dianfu commented on a change in pull request #13273: URL: https://github.com/apache/flink/pull/13273#discussion_r479712085 ## File path: docs/dev/python/user-guide/table/10_minutes_to_table_api.md ## @@ -0,0 +1,712 @@ +--- +title: "10 Minutes to Table API" +nav-parent_id: pytho

[GitHub] [flink] flinkbot edited a comment on pull request #13272: [FLINK-18695][network] Netty fakes heap buffer allocationn with direct buffers

flinkbot edited a comment on pull request #13272: URL: https://github.com/apache/flink/pull/13272#issuecomment-682346986 ## CI report: * d34257206e16c6b9757046cf2c7d71d687ab75eb Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13204: [FLINK-16080][docs-zh]Translate \docs\dev\table\hive\hive_streaming.zh.md into Chinese

flinkbot edited a comment on pull request #13204: URL: https://github.com/apache/flink/pull/13204#issuecomment-677254693 ## CI report: * f3ff67413489210527790afa12a9f50b63ced883 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13278: [FLINK-19091][python] Introduce expression DSL for Python Table API

flinkbot edited a comment on pull request #13278: URL: https://github.com/apache/flink/pull/13278#issuecomment-683294857 ## CI report: * ce936d3569bc01243648a82fb4a14d1ed619cfb4 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13272: [FLINK-18695][network] Netty fakes heap buffer allocationn with direct buffers

flinkbot edited a comment on pull request #13272: URL: https://github.com/apache/flink/pull/13272#issuecomment-682346986 ## CI report: * d34257206e16c6b9757046cf2c7d71d687ab75eb Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] gaoyunhaii commented on pull request #13272: [FLINK-18695][network] Netty fakes heap buffer allocationn with direct buffers

gaoyunhaii commented on pull request #13272: URL: https://github.com/apache/flink/pull/13272#issuecomment-683366363 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, plea

[jira] [Commented] (FLINK-19093) "Elasticsearch (v6.3.1) sink end-to-end test" failed with "SubtaskCheckpointCoordinatorImpl was closed without closing asyncCheckpointRunnable 1"

[ https://issues.apache.org/jira/browse/FLINK-19093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187130#comment-17187130 ] Dian Fu commented on FLINK-19093: - cc [~zjwang] [~roman_khachatryan] > "Elasticsearch (

[jira] [Updated] (FLINK-19093) "Elasticsearch (v6.3.1) sink end-to-end test" failed with "SubtaskCheckpointCoordinatorImpl was closed without closing asyncCheckpointRunnable 1"

[ https://issues.apache.org/jira/browse/FLINK-19093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19093: Labels: test-stability (was: ) > "Elasticsearch (v6.3.1) sink end-to-end test" failed with > "SubtaskChe

[jira] [Created] (FLINK-19093) "Elasticsearch (v6.3.1) sink end-to-end test" failed with "SubtaskCheckpointCoordinatorImpl was closed without closing asyncCheckpointRunnable 1"

Dian Fu created FLINK-19093: --- Summary: "Elasticsearch (v6.3.1) sink end-to-end test" failed with "SubtaskCheckpointCoordinatorImpl was closed without closing asyncCheckpointRunnable 1" Key: FLINK-19093 URL: https://iss

[jira] [Commented] (FLINK-18374) HadoopS3RecoverableWriterITCase.testRecoverAfterMultiplePersistsStateWithMultiPart produced no output for 900 seconds

[ https://issues.apache.org/jira/browse/FLINK-18374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187128#comment-17187128 ] Dian Fu commented on FLINK-18374: - https://dev.azure.com/apache-flink/apache-flink/_buil

[GitHub] [flink] flinkbot edited a comment on pull request #13268: [FLINK-19053][hotfix][doc] Fix Flink Kafka Connector Dependency Error

flinkbot edited a comment on pull request #13268: URL: https://github.com/apache/flink/pull/13268#issuecomment-682283788 ## CI report: * 5357812df45c42860e95630891367a410f6bc34b Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13268: [FLINK-19053][hotfix][doc] Fix Flink Kafka Connector Dependency Error

flinkbot edited a comment on pull request #13268: URL: https://github.com/apache/flink/pull/13268#issuecomment-682283788 ## CI report: * 5357812df45c42860e95630891367a410f6bc34b Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-19053) Flink Kafka Connector Dependency Error

[ https://issues.apache.org/jira/browse/FLINK-19053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187077#comment-17187077 ] Fin-chan commented on FLINK-19053: -- [~aljoscha] i fixed that! please assgin me，and revi

[GitHub] [flink] flinkbot edited a comment on pull request #13277: [FLINK-19089][Connectors / Kafka] Replace ReentrantLock with ReentrantReadWriteLock in ClosableBlockingQueue

flinkbot edited a comment on pull request #13277: URL: https://github.com/apache/flink/pull/13277#issuecomment-683239187 ## CI report: * d3243272d6a5ff0f2a5378e302338293463da8d2 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-19053) Flink Kafka Connector Dependency Error

[ https://issues.apache.org/jira/browse/FLINK-19053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19053: --- Labels: pull-request-available (was: ) > Flink Kafka Connector Dependency Error > -

[GitHub] [flink] flinkbot edited a comment on pull request #13268: [FLINK-19053][hotfix][doc] Fix Flink Kafka Connector Dependency Error

flinkbot edited a comment on pull request #13268: URL: https://github.com/apache/flink/pull/13268#issuecomment-682283788 ## CI report: * 5357812df45c42860e95630891367a410f6bc34b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] Fin-chan commented on pull request #13268: [FLINK-18988][hotfix][doc] Fix Flink Kafka Connector Dependency Error

Fin-chan commented on pull request #13268: URL: https://github.com/apache/flink/pull/13268#issuecomment-683326798 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] flinkbot edited a comment on pull request #11830: [FLINK-17096] [table] Support state ttl for Mini-Batch Group Agg using StateTtlConfig

flinkbot edited a comment on pull request #11830: URL: https://github.com/apache/flink/pull/11830#issuecomment-616574921 ## CI report: * 5643f360cb2e60a85bd3253241c31497e20c08d2 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #11830: [FLINK-17096] [table] Support state ttl for Mini-Batch Group Agg using StateTtlConfig

flinkbot edited a comment on pull request #11830: URL: https://github.com/apache/flink/pull/11830#issuecomment-616574921 ## CI report: * Unknown: [CANCELED](TBD) * 5643f360cb2e60a85bd3253241c31497e20c08d2 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620

[GitHub] [flink] flinkbot edited a comment on pull request #11830: [FLINK-17096] [table] Support state ttl for Mini-Batch Group Agg using StateTtlConfig

flinkbot edited a comment on pull request #11830: URL: https://github.com/apache/flink/pull/11830#issuecomment-616574921 ## CI report: * Unknown: [CANCELED](TBD) * 5643f360cb2e60a85bd3253241c31497e20c08d2 UNKNOWN Bot commands The @flinkbot bot supports the fol

[GitHub] [flink] lsyldliu commented on pull request #11830: [FLINK-17096] [table] Support state ttl for Mini-Batch Group Agg using StateTtlConfig

lsyldliu commented on pull request #11830: URL: https://github.com/apache/flink/pull/11830#issuecomment-683317167 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] flinkbot edited a comment on pull request #13278: [FLINK-19091][python] Introduce expression DSL for Python Table API

flinkbot edited a comment on pull request #13278: URL: https://github.com/apache/flink/pull/13278#issuecomment-683294857 ## CI report: * ce936d3569bc01243648a82fb4a14d1ed619cfb4 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-19092) Parse comment on computed column failed

Leonard Xu created FLINK-19092: -- Summary: Parse comment on computed column failed Key: FLINK-19092 URL: https://issues.apache.org/jira/browse/FLINK-19092 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #13277: [FLINK-19089][Connectors / Kafka] Replace ReentrantLock with ReentrantReadWriteLock in ClosableBlockingQueue

flinkbot edited a comment on pull request #13277: URL: https://github.com/apache/flink/pull/13277#issuecomment-683239187 ## CI report: * d27a55972f2461d7504a73b85074523b8a55638f Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13277: [FLINK-19089][Connectors / Kafka] Replace ReentrantLock with ReentrantReadWriteLock in ClosableBlockingQueue

flinkbot edited a comment on pull request #13277: URL: https://github.com/apache/flink/pull/13277#issuecomment-683239187 ## CI report: * d27a55972f2461d7504a73b85074523b8a55638f Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13278: [FLINK-19091][python] Introduce expression DSL for Python Table API

flinkbot edited a comment on pull request #13278: URL: https://github.com/apache/flink/pull/13278#issuecomment-683294857 ## CI report: * ce936d3569bc01243648a82fb4a14d1ed619cfb4 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #13278: [FLINK-19091][python] Introduce expression DSL for Python Table API

flinkbot commented on pull request #13278: URL: https://github.com/apache/flink/pull/13278#issuecomment-683294857 ## CI report: * ce936d3569bc01243648a82fb4a14d1ed619cfb4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #13278: [FLINK-19091][python] Introduce expression DSL for Python Table API

flinkbot commented on pull request #13278: URL: https://github.com/apache/flink/pull/13278#issuecomment-683291991 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[jira] [Updated] (FLINK-19091) Introduce expression DSL for Python Table API

[ https://issues.apache.org/jira/browse/FLINK-19091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19091: --- Labels: pull-request-available (was: ) > Introduce expression DSL for Python Table API > --

[GitHub] [flink] dianfu opened a new pull request #13278: [FLINK-19091][python] Introduce expression DSL for Python Table API

dianfu opened a new pull request #13278: URL: https://github.com/apache/flink/pull/13278 ## What is the purpose of the change *This pull request introduces expression DSL for Python Table API* ## Brief change log - *Introduce class Expression class which defines fu

[jira] [Created] (FLINK-19091) Introduce expression DSL for Python Table API

Dian Fu created FLINK-19091: --- Summary: Introduce expression DSL for Python Table API Key: FLINK-19091 URL: https://issues.apache.org/jira/browse/FLINK-19091 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-19090) Translate "Local Cluster" of "Clusters & Depolyment" page into Chinese

Huang Xiao created FLINK-19090: -- Summary: Translate "Local Cluster" of "Clusters & Depolyment" page into Chinese Key: FLINK-19090 URL: https://issues.apache.org/jira/browse/FLINK-19090 Project: Flink

[jira] [Commented] (FLINK-19015) java.lang.RuntimeException: Could not instantiate generated class 'GroupAggsHandler$15'

[ https://issues.apache.org/jira/browse/FLINK-19015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17186959#comment-17186959 ] gkgkgk commented on FLINK-19015: [~any] maybe you can use "Integer" replace "Int" > jav

[GitHub] [flink] flinkbot edited a comment on pull request #13277: [FLINK-19089][Connectors / Kafka] Replace ReentrantLock with ReentrantReadWriteLock in ClosableBlockingQueue

flinkbot edited a comment on pull request #13277: URL: https://github.com/apache/flink/pull/13277#issuecomment-683239187 ## CI report: * d27a55972f2461d7504a73b85074523b8a55638f Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13277: [FLINK-19089][Connectors / Kafka] Replace ReentrantLock with ReentrantReadWriteLock in ClosableBlockingQueue

flinkbot edited a comment on pull request #13277: URL: https://github.com/apache/flink/pull/13277#issuecomment-683239187 ## CI report: * d6be96d65aff9af67e8af0a2cb3edf68cc084940 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Comment Edited] (FLINK-19038) It doesn't support to call Table.limit() continuously

[ https://issues.apache.org/jira/browse/FLINK-19038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17185585#comment-17185585 ] Nicholas Jiang edited comment on FLINK-19038 at 8/29/20, 8:50 AM:

[GitHub] [flink] pyscala commented on pull request #13276: [FLINK-18604][connectors/HBase] HBase ConnectorDescriptor can not work in Table API

pyscala commented on pull request #13276: URL: https://github.com/apache/flink/pull/13276#issuecomment-683257195 Hi @JingsongLi , appreciate for your time to review this PR,thanks This is an automated message from the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #13277: [FLINK-19089][Connectors / Kafka] Replace ReentrantLock with ReentrantReadWriteLock in ClosableBlockingQueue

flinkbot edited a comment on pull request #13277: URL: https://github.com/apache/flink/pull/13277#issuecomment-683239187 ## CI report: * d6be96d65aff9af67e8af0a2cb3edf68cc084940 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #13277: [FLINK-19089][Connectors / Kafka] Replace ReentrantLock with ReentrantReadWriteLock in ClosableBlockingQueue

flinkbot edited a comment on pull request #13277: URL: https://github.com/apache/flink/pull/13277#issuecomment-683239187 ## CI report: * d6be96d65aff9af67e8af0a2cb3edf68cc084940 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result