[jira] [Commented] (FLINK-20531) Flink docs are not building anymore due to builder change

[ https://issues.apache.org/jira/browse/FLINK-20531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17246339#comment-17246339 ] Robert Metzger commented on FLINK-20531: I'm still discussing with apache infra

[jira] [Commented] (FLINK-20526) Enable logback scan configuration by default

[ https://issues.apache.org/jira/browse/FLINK-20526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17246337#comment-17246337 ] xiaozilong commented on FLINK-20526: The configuration scan is enabled by default fo

[GitHub] [flink] flinkbot edited a comment on pull request #14344: [docs] fix typos in Basic Concepts documentation

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

[GitHub] [flink] flinkbot edited a comment on pull request #14331: [FLINK-20514][python] Introduce StreamExecPythonGroupTableAggregateRule and StreamExecPythonGroupTableAggregate

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

[GitHub] [flink] flinkbot edited a comment on pull request #14317: [FLINK-20482][python] Support General Python UDF for Map Operation in Python Table API

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

[GitHub] [flink] 1996fanrui closed pull request #13885: [FLINK-19911] add read buffer for input stream

1996fanrui closed pull request #13885: URL: https://github.com/apache/flink/pull/13885 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [flink] 1996fanrui commented on pull request #13885: [FLINK-19911] add read buffer for input stream

1996fanrui commented on pull request #13885: URL: https://github.com/apache/flink/pull/13885#issuecomment-741595105 @StephanEwen Sorry, because I ignored the copyright. I will close this PR. This is an automated message f

[jira] [Created] (FLINK-20545) SQLClientSchemaRegistryITCase compilation failed

Echo Lee created FLINK-20545: Summary: SQLClientSchemaRegistryITCase compilation failed Key: FLINK-20545 URL: https://issues.apache.org/jira/browse/FLINK-20545 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-20543) Fix typo in upsert kafka docs

[ https://issues.apache.org/jira/browse/FLINK-20543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20543: --- Assignee: xiaozilong > Fix typo in upsert kafka docs > - > >

[GitHub] [flink] flinkbot commented on pull request #14344: [docs] fix typos in Basic Concepts documentation

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

[jira] [Closed] (FLINK-20543) Fix typo in upsert kafka docs

[ https://issues.apache.org/jira/browse/FLINK-20543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20543. --- Fix Version/s: 1.12.1 1.13.0 Resolution: Fixed Fixed in - master: cf881b48d67de4

[GitHub] [flink] wuchong merged pull request #14343: [FLINK-20543][docs] Fix typo in upsert kafka docs.

wuchong merged pull request #14343: URL: https://github.com/apache/flink/pull/14343 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] HuangXingBo commented on pull request #14317: [FLINK-20482][python] Support General Python UDF for Map Operation in Python Table API

HuangXingBo commented on pull request #14317: URL: https://github.com/apache/flink/pull/14317#issuecomment-741582206 @dianfu Thanks a lot for the review. I have addressed the comments at the latest commit. This is an automat

[GitHub] [flink] flinkbot edited a comment on pull request #13907: [FLINK-19942][Connectors / JDBC]Support sink parallelism configuration to JDBC connector

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

[jira] [Updated] (FLINK-20544) ConcurrentModificationException when writing to hive and fail over happened

[ https://issues.apache.org/jira/browse/FLINK-20544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20544: Component/s: Connectors / FileSystem > ConcurrentModificationException when writing to hive and fail over

[jira] [Commented] (FLINK-20254) HiveTableSourceITCase.testStreamPartitionReadByCreateTime times out

[ https://issues.apache.org/jira/browse/FLINK-20254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17246323#comment-17246323 ] Huang Xingbo commented on FLINK-20254: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Created] (FLINK-20544) ConcurrentModificationException when writing to hive and fail over happened

zhuxiaoshang created FLINK-20544: Summary: ConcurrentModificationException when writing to hive and fail over happened Key: FLINK-20544 URL: https://issues.apache.org/jira/browse/FLINK-20544 Project:

[GitHub] [flink] flinkbot commented on pull request #14344: [docs] fix typos in Basic Concepts documentation

flinkbot commented on pull request #14344: URL: https://github.com/apache/flink/pull/14344#issuecomment-741576051 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

[GitHub] [flink] dianfu closed pull request #14322: [FLINK-20508][python] Introduce PythonStreamGroupTableAggregateOperator

dianfu closed pull request #14322: URL: https://github.com/apache/flink/pull/14322 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to t

[jira] [Commented] (FLINK-13595) KafkaITCase.testBigRecordJob fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17246319#comment-17246319 ] Huang Xingbo commented on FLINK-13595: -- [https://dev.azure.com/apache-flink/apache-

[GitHub] [flink] flinkbot edited a comment on pull request #14337: [FLINK-20512][table-planner-blink] Introduce getDesc(), getOutputType(), replaceInput(int, ExecEdge, ExecNode) methods for ExecNode

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

[GitHub] [flink] flinkbot edited a comment on pull request #14335: [FLINK-20511][table-planner-blink] Deprecate the classes in scala `nodes.exec` package

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

[GitHub] [flink] Ivan0626 opened a new pull request #14344: [docs] fix typos in Basic Concepts documentation

Ivan0626 opened a new pull request #14344: URL: https://github.com/apache/flink/pull/14344 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them o

[GitHub] [flink] dianfu commented on a change in pull request #14322: [FLINK-20508][python] Introduce PythonStreamGroupTableAggregateOperator

dianfu commented on a change in pull request #14322: URL: https://github.com/apache/flink/pull/14322#discussion_r539045210 ## File path: flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/aggregate/AbstractPythonStreamAggregateOperator.java ## @@ -0,0 +

[GitHub] [flink] flinkbot edited a comment on pull request #13907: [FLINK-19942][Connectors / JDBC]Support sink parallelism configuration to JDBC connector

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

[GitHub] [flink] V1ncentzzZ commented on a change in pull request #13907: [FLINK-19942][Connectors / JDBC]Support sink parallelism configuration to JDBC connector

V1ncentzzZ commented on a change in pull request #13907: URL: https://github.com/apache/flink/pull/13907#discussion_r539042698 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcExecutionOptions.java ## @@ -66,12 +76,13 @@ pub

[GitHub] [flink] V1ncentzzZ commented on a change in pull request #13907: [FLINK-19942][Connectors / JDBC]Support sink parallelism configuration to JDBC connector

V1ncentzzZ commented on a change in pull request #13907: URL: https://github.com/apache/flink/pull/13907#discussion_r539042698 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcExecutionOptions.java ## @@ -66,12 +76,13 @@ pub

[GitHub] [flink] flinkbot edited a comment on pull request #13581: [FLINK-17331] Explicitly get the ByteBuf length of all classes which …

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

[GitHub] [flink] HuangXingBo commented on a change in pull request #14317: [FLINK-20482][python] Support General Python UDF for Map Operation in Python Table API

HuangXingBo commented on a change in pull request #14317: URL: https://github.com/apache/flink/pull/14317#discussion_r539047765 ## File path: flink-python/pyflink/table/tests/test_row_based_operation.py ## @@ -0,0 +1,67 @@ +##

[GitHub] [flink] V1ncentzzZ commented on a change in pull request #14343: [FLINK-20543][docs] Fix typo in upsert kafka docs.

V1ncentzzZ commented on a change in pull request #14343: URL: https://github.com/apache/flink/pull/14343#discussion_r539050804 ## File path: docs/dev/table/connectors/upsert-kafka.zh.md ## @@ -80,11 +80,11 @@ CREATE TABLE pageviews ( -- 计算 pv、uv 并插入到 upsert-kafka sink INSERT

[jira] [Updated] (FLINK-20543) Fix typo in upsert kafka docs

[ https://issues.apache.org/jira/browse/FLINK-20543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20543: Component/s: Table SQL / Ecosystem > Fix typo in upsert kafka docs > - > >

[GitHub] [flink] wuchong commented on a change in pull request #14343: [FLINK-20543][docs] Fix typo in upsert kafka docs.

wuchong commented on a change in pull request #14343: URL: https://github.com/apache/flink/pull/14343#discussion_r539048913 ## File path: docs/dev/table/connectors/upsert-kafka.zh.md ## @@ -80,11 +80,11 @@ CREATE TABLE pageviews ( -- 计算 pv、uv 并插入到 upsert-kafka sink INSERT INT

[GitHub] [flink] HuangXingBo commented on a change in pull request #14317: [FLINK-20482][python] Support General Python UDF for Map Operation in Python Table API

HuangXingBo commented on a change in pull request #14317: URL: https://github.com/apache/flink/pull/14317#discussion_r539046967 ## File path: flink-python/pyflink/table/table.py ## @@ -759,6 +759,27 @@ def drop_columns(self, *fields: Union[str, Expression]) -> 'Table':

[jira] [Updated] (FLINK-20527) Support side output for late events in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-20527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20527: Summary: Support side output for late events in Flink SQL (was: how to add a side output for flink sql wa

[jira] [Commented] (FLINK-20527) how to add a side output for flink sql watermaker?

[ https://issues.apache.org/jira/browse/FLINK-20527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17246310#comment-17246310 ] Jark Wu commented on FLINK-20527: - Yes. Let's open this issue to collect ideas how to su

[GitHub] [flink] V1ncentzzZ commented on pull request #14343: [FLINK-20543][docs] Fix typo in upsert kafka docs.

V1ncentzzZ commented on pull request #14343: URL: https://github.com/apache/flink/pull/14343#issuecomment-741566038 cc @wuchong This is an automated message from the Apache Git Service. To respond to the message, please log

[jira] [Comment Edited] (FLINK-19435) jdbc JDBCOutputFormat open function invoke Class.forName(drivername)

[ https://issues.apache.org/jira/browse/FLINK-19435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17246309#comment-17246309 ] Jark Wu edited comment on FLINK-19435 at 12/9/20, 6:35 AM: --- [~

[jira] [Assigned] (FLINK-19435) jdbc JDBCOutputFormat open function invoke Class.forName(drivername)

[ https://issues.apache.org/jira/browse/FLINK-19435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-19435: --- Assignee: Kezhu Wang > jdbc JDBCOutputFormat open function invoke Class.forName(drivername) > -

[GitHub] [flink] flinkbot edited a comment on pull request #14343: [FLINK-20543][docs] Fix typo in upsert kafka docs.

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

[GitHub] [flink] zhuxiaoshang commented on pull request #14343: [FLINK-20543][docs] Fix typo in upsert kafka docs.

zhuxiaoshang commented on pull request #14343: URL: https://github.com/apache/flink/pull/14343#issuecomment-741565766 LGTM. This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Commented] (FLINK-19435) jdbc JDBCOutputFormat open function invoke Class.forName(drivername)

[ https://issues.apache.org/jira/browse/FLINK-19435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17246309#comment-17246309 ] Jark Wu commented on FLINK-19435: - [~kezhuw], you are right. The current {{PostgresDiale

[GitHub] [flink] flinkbot edited a comment on pull request #13907: [FLINK-19942][Connectors / JDBC]Support sink parallelism configuration to JDBC connector

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

[GitHub] [flink] dianfu commented on a change in pull request #14317: [FLINK-20482][python] Support General Python UDF for Map Operation in Python Table API

dianfu commented on a change in pull request #14317: URL: https://github.com/apache/flink/pull/14317#discussion_r538946963 ## File path: flink-python/pyflink/table/table.py ## @@ -759,6 +759,27 @@ def drop_columns(self, *fields: Union[str, Expression]) -> 'Table':

[GitHub] [flink] zhuxiaoshang commented on a change in pull request #13907: [FLINK-19942][Connectors / JDBC]Support sink parallelism configuration to JDBC connector

zhuxiaoshang commented on a change in pull request #13907: URL: https://github.com/apache/flink/pull/13907#discussion_r539043341 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcExecutionOptions.java ## @@ -66,12 +76,13 @@ p

[GitHub] [flink] V1ncentzzZ commented on a change in pull request #13907: [FLINK-19942][Connectors / JDBC]Support sink parallelism configuration to JDBC connector

V1ncentzzZ commented on a change in pull request #13907: URL: https://github.com/apache/flink/pull/13907#discussion_r539042698 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcExecutionOptions.java ## @@ -66,12 +76,13 @@ pub

[GitHub] [flink] zhuxiaoshang commented on a change in pull request #13907: [FLINK-19942][Connectors / JDBC]Support sink parallelism configuration to JDBC connector

zhuxiaoshang commented on a change in pull request #13907: URL: https://github.com/apache/flink/pull/13907#discussion_r539039936 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcExecutionOptions.java ## @@ -66,12 +76,13 @@ p

[GitHub] [flink] zhisheng17 commented on a change in pull request #13907: [FLINK-19942][Connectors / JDBC]Support sink parallelism configuration to JDBC connector

zhisheng17 commented on a change in pull request #13907: URL: https://github.com/apache/flink/pull/13907#discussion_r539038786 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcExecutionOptions.java ## @@ -66,12 +76,13 @@ pub

[GitHub] [flink] V1ncentzzZ commented on a change in pull request #13907: [FLINK-19942][Connectors / JDBC]Support sink parallelism configuration to JDBC connector

V1ncentzzZ commented on a change in pull request #13907: URL: https://github.com/apache/flink/pull/13907#discussion_r539037013 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcExecutionOptions.java ## @@ -66,12 +76,13 @@ pub

[jira] [Commented] (FLINK-20329) Elasticsearch7DynamicSinkITCase hangs

[ https://issues.apache.org/jira/browse/FLINK-20329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17246301#comment-17246301 ] Huang Xingbo commented on FLINK-20329: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink] zhuxiaoshang commented on a change in pull request #13907: [FLINK-19942][Connectors / JDBC]Support sink parallelism configuration to JDBC connector

zhuxiaoshang commented on a change in pull request #13907: URL: https://github.com/apache/flink/pull/13907#discussion_r539033397 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcExecutionOptions.java ## @@ -55,6 +61,10 @@ pu

[GitHub] [flink] zhisheng17 commented on a change in pull request #13907: [FLINK-19942][Connectors / JDBC]Support sink parallelism configuration to JDBC connector

zhisheng17 commented on a change in pull request #13907: URL: https://github.com/apache/flink/pull/13907#discussion_r535869471 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcExecutionOptions.java ## @@ -55,6 +61,10 @@ publ

[jira] [Closed] (FLINK-20542) flink-1.11.2 - stream join stream savepoint fail

[ https://issues.apache.org/jira/browse/FLINK-20542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 谢波 closed FLINK-20542. -- Resolution: Not A Problem > flink-1.11.2 - stream join stream savepoint fail > ---

[GitHub] [flink] wuchong merged pull request #14269: [hotfix][javadocs] Fix typo

wuchong merged pull request #14269: URL: https://github.com/apache/flink/pull/14269 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[jira] [Closed] (FLINK-20470) MissingNode can't be casted to ObjectNode when deserializing JSON

[ https://issues.apache.org/jira/browse/FLINK-20470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20470. --- Fix Version/s: 1.12.1 1.13.0 Resolution: Fixed Fixed in - master: 29e122d539caeb

[GitHub] [flink] wuchong commented on pull request #13932: [FLINK-19947][Connectors / Common]Support sink parallelism configuration for Print connector

wuchong commented on pull request #13932: URL: https://github.com/apache/flink/pull/13932#issuecomment-741541023 cc @fsk119 This is an automated message from the Apache Git Service. To respond to the message, please log on t

[GitHub] [flink] wuchong commented on pull request #13907: [FLINK-19942][Connectors / JDBC]Support sink parallelism configuration to JDBC connector

wuchong commented on pull request #13907: URL: https://github.com/apache/flink/pull/13907#issuecomment-741541002 cc @fsk119 This is an automated message from the Apache Git Service. To respond to the message, please log on t

[GitHub] [flink] flinkbot edited a comment on pull request #14343: [FLINK-20543][docs] Fix typo in upsert kafka docs.

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

[GitHub] [flink] flinkbot edited a comment on pull request #14314: [FLINK-20492][runtime] Add implementations of cancelTask() and finish…

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

[GitHub] [flink] wuchong merged pull request #14316: [FLINK-20470]MissingNode can't be casted to ObjectNode when deserializing JSON

wuchong merged pull request #14316: URL: https://github.com/apache/flink/pull/14316 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] flinkbot commented on pull request #14343: [FLINK-20543][docs] Fix typo in upsert kafka docs.

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

[GitHub] [flink] flinkbot edited a comment on pull request #14342: [FLINK-20541][client] ClusterID is not used in the method!

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

[GitHub] [flink] flinkbot commented on pull request #14343: [FLINK-20543][docs] Fix typo in upsert kafka docs.

flinkbot commented on pull request #14343: URL: https://github.com/apache/flink/pull/14343#issuecomment-741526999 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-20543) Fix typo in upsert kafka docs

[ https://issues.apache.org/jira/browse/FLINK-20543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20543: --- Labels: pull-request-available (was: ) > Fix typo in upsert kafka docs > --

[GitHub] [flink] V1ncentzzZ opened a new pull request #14343: [FLINK-20543][docs] Fix typo in upsert kafka docs.

V1ncentzzZ opened a new pull request #14343: URL: https://github.com/apache/flink/pull/14343 ## What is the purpose of the change Fix typo in upsert kafka docs. ## Brief change log *(for example:)* - *The TaskInfo is stored in the blob store on job creat

[jira] [Created] (FLINK-20543) Fix typo in upsert kafka docs

xiaozilong created FLINK-20543: -- Summary: Fix typo in upsert kafka docs Key: FLINK-20543 URL: https://issues.apache.org/jira/browse/FLINK-20543 Project: Flink Issue Type: Bug Component

[GitHub] [flink] flinkbot commented on pull request #14342: [FLINK-20541][client] ClusterID is not used in the method!

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

[GitHub] [flink] flinkbot edited a comment on pull request #14340: [FLINK-20533][datadog] Add Histogram support

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

[jira] [Closed] (FLINK-20500) UpsertKafkaTableITCase.testTemporalJoin test failed

[ https://issues.apache.org/jira/browse/FLINK-20500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20500. --- Resolution: Fixed Fixed in - master: b82585fb78309f45f421d932ad0b43ebf62150ea - release-1.12: 3454d4367a6

[GitHub] [flink] wuchong merged pull request #14334: [FLINK-20500][upsert-kafka] Fix unstable UpsertKafkaTableITCase.testTemporalJoin

wuchong merged pull request #14334: URL: https://github.com/apache/flink/pull/14334 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] wuchong closed pull request #14339: [FLINK-20419][table-planner-blink] Avoid dynamic partition grouping if the input defines collation

wuchong closed pull request #14339: URL: https://github.com/apache/flink/pull/14339 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] wuchong commented on pull request #14339: [FLINK-20419][table-planner-blink] Avoid dynamic partition grouping if the input defines collation

wuchong commented on pull request #14339: URL: https://github.com/apache/flink/pull/14339#issuecomment-741518678 I have merge the commits in #14333 This is an automated message from the Apache Git Service. To respond to the m

[jira] [Closed] (FLINK-20419) Insert fails due to failure to generate execution plan

[ https://issues.apache.org/jira/browse/FLINK-20419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20419. --- Resolution: Fixed > Insert fails due to failure to generate execution plan > ---

[jira] [Assigned] (FLINK-20419) Insert fails due to failure to generate execution plan

[ https://issues.apache.org/jira/browse/FLINK-20419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20419: --- Assignee: Rui Li > Insert fails due to failure to generate execution plan > ---

[GitHub] [flink] flinkbot commented on pull request #14342: [FLINK-20541][client] ClusterID is not used in the method!

flinkbot commented on pull request #14342: URL: https://github.com/apache/flink/pull/14342#issuecomment-741518528 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] [Comment Edited] (FLINK-20419) Insert fails due to failure to generate execution plan

[ https://issues.apache.org/jira/browse/FLINK-20419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245830#comment-17245830 ] Jark Wu edited comment on FLINK-20419 at 12/9/20, 4:26 AM: --- Fi

[GitHub] [flink] wuchong merged pull request #14333: [BP-1.12][FLINK-20419][table][hive] Avoid dynamic partition grouping if the input defines collation

wuchong merged pull request #14333: URL: https://github.com/apache/flink/pull/14333 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[jira] [Updated] (FLINK-20541) ClusterID is not used in the method!

[ https://issues.apache.org/jira/browse/FLINK-20541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20541: --- Labels: pull-request-available (was: ) > ClusterID is not used in the method! > ---

[GitHub] [flink] wuchong merged pull request #14330: [FLINK-20500][upsert-kafka] Fix unstable UpsertKafkaTableITCase.testT…

wuchong merged pull request #14330: URL: https://github.com/apache/flink/pull/14330 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[jira] [Reopened] (FLINK-20541) ClusterID is not used in the method!

[ https://issues.apache.org/jira/browse/FLINK-20541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lixiaobao reopened FLINK-20541: --- > ClusterID is not used in the method! > > > Key: F

[GitHub] [flink] q977734161 opened a new pull request #14342: [FLINK-20541][client] ClusterID is not used in the method!

q977734161 opened a new pull request #14342: URL: https://github.com/apache/flink/pull/14342 the "ClusterID" before method "run(configuration,applicationConfiguration)" of class org.apache.flink.client.cli.ApplicationDeployer is not used! -

[GitHub] [flink] KarmaGYZ commented on pull request #13581: [FLINK-17331] Explicitly get the ByteBuf length of all classes which …

KarmaGYZ commented on pull request #13581: URL: https://github.com/apache/flink/pull/13581#issuecomment-741513858 cc @curcur Rebased to the latest master branch. This is an automated message from the Apache Git Service. To re

[GitHub] [flink] flinkbot edited a comment on pull request #14341: [FLINK-20496][state backends] RocksDB partitioned index/filters option.

flinkbot edited a comment on pull request #14341: URL: https://github.com/apache/flink/pull/14341#issuecomment-740887981 ## CI report: * 01903f147f2a66dc1bb51359e15f4eb9714b3129 UNKNOWN * 30584219a51b9fcf400e7124356422d3ce3dcbf2 Azure: [PENDING](https://dev.azure.com/apache-fl

[jira] [Comment Edited] (FLINK-20540) Failed connecting to jdbc:postgresql://flink-postgres.cdn-flink:5432flink via JDBC

[ https://issues.apache.org/jira/browse/FLINK-20540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17246277#comment-17246277 ] Leonard Xu edited comment on FLINK-20540 at 12/9/20, 3:56 AM:

[jira] [Commented] (FLINK-20540) Failed connecting to jdbc:postgresql://flink-postgres.cdn-flink:5432flink via JDBC

[ https://issues.apache.org/jira/browse/FLINK-20540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17246277#comment-17246277 ] Leonard Xu commented on FLINK-20540: [~kgzhang] Thanks for your report,  The defaul

[GitHub] [flink] flinkbot edited a comment on pull request #14341: [FLINK-20496][state backends] RocksDB partitioned index/filters option.

flinkbot edited a comment on pull request #14341: URL: https://github.com/apache/flink/pull/14341#issuecomment-740887981 ## CI report: * 01903f147f2a66dc1bb51359e15f4eb9714b3129 UNKNOWN * 30584219a51b9fcf400e7124356422d3ce3dcbf2 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Updated] (FLINK-20542) flink-1.11.2 - stream join stream savepoint fail

[ https://issues.apache.org/jira/browse/FLINK-20542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 谢波 updated FLINK-20542: --- Description: I have a SQL job that uses stream join stream, but at savepoint, the job fails. I can't manually trigg

[jira] [Updated] (FLINK-20542) flink-1.11.2 - stream join stream savepoint fail

[ https://issues.apache.org/jira/browse/FLINK-20542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 谢波 updated FLINK-20542: --- Description: I have a SQL job that uses stream join stream, but at savepoint, the job fails. I can't manually trigg

[GitHub] [flink] liuyufei9527 commented on pull request #14341: [FLINK-20496][state backends] RocksDB partitioned index/filters option.

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

[jira] [Updated] (FLINK-20542) flink-1.11.2 - stream join stream savepoint fail

[ https://issues.apache.org/jira/browse/FLINK-20542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 谢波 updated FLINK-20542: --- Environment: 1.11.2 2.11   {color:#ff}tEnv.getConfig.setIdleStateRetentionTime(Time.hours(12), Time.hours(24

[jira] [Updated] (FLINK-20542) flink-1.11.2 - stream join stream savepoint fail

[ https://issues.apache.org/jira/browse/FLINK-20542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 谢波 updated FLINK-20542: --- Environment: 1.11.2 2.11   {color:#ff}tEnv.getConfig.setIdleStateRetentionTime(Time.hours(12), Time.hours(

[jira] [Created] (FLINK-20542) flink-1.11.2 - stream join stream savepoint fail

谢波 created FLINK-20542: -- Summary: flink-1.11.2 - stream join stream savepoint fail Key: FLINK-20542 URL: https://issues.apache.org/jira/browse/FLINK-20542 Project: Flink Issue Type: Bug Environ

[GitHub] [flink] flinkbot edited a comment on pull request #14335: [FLINK-20511][table-planner-blink] Deprecate the classes in scala `nodes.exec` package

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

[GitHub] [flink] flinkbot edited a comment on pull request #14337: [FLINK-20512][table-planner-blink] Introduce getDesc(), getOutputType(), replaceInput(int, ExecEdge, ExecNode) methods for ExecNode

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

[GitHub] [flink] flinkbot edited a comment on pull request #13581: [FLINK-17331] Explicitly get the ByteBuf length of all classes which …

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

[GitHub] [flink] flinkbot edited a comment on pull request #14337: [FLINK-20512][table-planner-blink] Introduce getDesc(), getOutputType(), replaceInput(int, ExecEdge, ExecNode) methods for ExecNode

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

[GitHub] [flink] flinkbot edited a comment on pull request #14335: [FLINK-20511][table-planner-blink] Deprecate the classes in scala `nodes.exec` package

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

[GitHub] [flink] flinkbot edited a comment on pull request #13581: [FLINK-17331] Explicitly get the ByteBuf length of all classes which …

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

[jira] [Closed] (FLINK-20541) ClusterID is not used in the method!

[ https://issues.apache.org/jira/browse/FLINK-20541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lixiaobao closed FLINK-20541. - Resolution: Cannot Reproduce > ClusterID is not used in the method! > --

[jira] [Created] (FLINK-20541) ClusterID is not used in the method!

lixiaobao created FLINK-20541: - Summary: ClusterID is not used in the method! Key: FLINK-20541 URL: https://issues.apache.org/jira/browse/FLINK-20541 Project: Flink Issue Type: Improvement

[GitHub] [flink] V1ncentzzZ commented on a change in pull request #14315: [FLINK-20478][table-planner-blink] Adjust the explain result for blink planner

V1ncentzzZ commented on a change in pull request #14315: URL: https://github.com/apache/flink/pull/14315#discussion_r538954554 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/nodes/exec/TestingBatchExecNode.scala ## @@ -23

  1   2   3   4   >