[GitHub] [flink] flinkbot commented on pull request #14419: [FLINK-20650][k8s] Rename the command "native-k8s" to "run" based on the changes in docker-entrypoint.sh

2020-12-17 Thread GitBox
flinkbot commented on pull request #14419: URL: https://github.com/apache/flink/pull/14419#issuecomment-747932005 ## CI report: * 3906f10b3bb3896e8370f5e9a8d8014c96be9076 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #14415: [FLINK-19880][formats] Fix JsonRowFormatFactory's support for the format.ignore-parse-errors property.

2020-12-17 Thread GitBox
flinkbot edited a comment on pull request #14415: URL: https://github.com/apache/flink/pull/14415#issuecomment-747584734 ## CI report: * 91b26c741c5cc1b578123830c6981e5e3fca9767 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14417: [FLINK-20668][table-planner-blink] Introduce translateToExecNode method for FlinkPhysicalRel

2020-12-17 Thread GitBox
flinkbot edited a comment on pull request #14417: URL: https://github.com/apache/flink/pull/14417#issuecomment-747849155 ## CI report: * 67c73bdacc77bab17d60526487c13fe6693e4904 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14416: [hotfix][k8s] Fix k8s ha service doc.

2020-12-17 Thread GitBox
flinkbot edited a comment on pull request #14416: URL: https://github.com/apache/flink/pull/14416#issuecomment-747844139 ## CI report: * baee37d34012ad05bf5414ab9b6a81cfe19f881a Azure:

[jira] [Commented] (FLINK-10868) Flink's JobCluster ResourceManager doesn't use maximum-failed-containers as limit of resource acquirement

2020-12-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251576#comment-17251576 ] Xintong Song commented on FLINK-10868: -- [~ZhenqiuHuang], I think adding counting metrics for

[GitHub] [flink] flinkbot edited a comment on pull request #13876: [FLINK-18382][docs] Translate Kafka SQL connector documentation into Chinese

2020-12-17 Thread GitBox
flinkbot edited a comment on pull request #13876: URL: https://github.com/apache/flink/pull/13876#issuecomment-720337850 ## CI report: * cdcae6f6464fff54bd1040031039d688370d8866 Azure:

[jira] [Comment Edited] (FLINK-20671) Partition doesn't commit until the end of partition

2020-12-17 Thread zhuxiaoshang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251570#comment-17251570 ] zhuxiaoshang edited comment on FLINK-20671 at 12/18/20, 7:51 AM: -

[jira] [Updated] (FLINK-20630) [Kinesis][DynamoDB] DynamoDB Streams Consumer fails to consume from Latest

2020-12-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20630: - Fix Version/s: 1.13.0 > [Kinesis][DynamoDB] DynamoDB Streams Consumer fails to consume from

[jira] [Updated] (FLINK-20629) [Kinesis][EFO] Migrate from DescribeStream to DescribeStreamSummary

2020-12-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20629: - Fix Version/s: 1.13.0 > [Kinesis][EFO] Migrate from DescribeStream to DescribeStreamSummary >

[jira] [Commented] (FLINK-20476) New File Sink end-to-end test Failed

2020-12-17 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251572#comment-17251572 ] Yun Gao commented on FLINK-20476: -  Yes, there should be something changed at that time, but currently

[jira] [Commented] (FLINK-20671) Partition doesn't commit until the end of partition

2020-12-17 Thread zhuxiaoshang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251570#comment-17251570 ] zhuxiaoshang commented on FLINK-20671: -- Maybe the reason is bucket is always active until no data

[GitHub] [flink] godfreyhe commented on pull request #14417: [FLINK-20668][table-planner-blink] Introduce translateToExecNode method for FlinkPhysicalRel

2020-12-17 Thread GitBox
godfreyhe commented on pull request #14417: URL: https://github.com/apache/flink/pull/14417#issuecomment-747924128 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on pull request #14417: [FLINK-20668][table-planner-blink] Introduce translateToExecNode method for FlinkPhysicalRel

2020-12-17 Thread GitBox
flinkbot edited a comment on pull request #14417: URL: https://github.com/apache/flink/pull/14417#issuecomment-747849155 ## CI report: * 67c73bdacc77bab17d60526487c13fe6693e4904 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14415: [FLINK-19880][formats] Fix JsonRowFormatFactory's support for the format.ignore-parse-errors property.

2020-12-17 Thread GitBox
flinkbot edited a comment on pull request #14415: URL: https://github.com/apache/flink/pull/14415#issuecomment-747584734 ## CI report: * 91b26c741c5cc1b578123830c6981e5e3fca9767 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14416: [hotfix][k8s] Fix k8s ha service doc.

2020-12-17 Thread GitBox
flinkbot edited a comment on pull request #14416: URL: https://github.com/apache/flink/pull/14416#issuecomment-747844139 ## CI report: * baee37d34012ad05bf5414ab9b6a81cfe19f881a Azure:

[GitHub] [flink] wuchong commented on a change in pull request #14415: [FLINK-19880][formats] Fix JsonRowFormatFactory's support for the format.ignore-parse-errors property.

2020-12-17 Thread GitBox
wuchong commented on a change in pull request #14415: URL: https://github.com/apache/flink/pull/14415#discussion_r545620784 ## File path: flink-formats/flink-json/src/test/java/org/apache/flink/formats/json/JsonRowFormatFactoryTest.java ## @@ -128,6 +152,14 @@ private void

[GitHub] [flink] flinkbot commented on pull request #14419: [FLINK-20650][k8s] Rename the command "native-k8s" to "run" based on the changes in docker-entrypoint.sh

2020-12-17 Thread GitBox
flinkbot commented on pull request #14419: URL: https://github.com/apache/flink/pull/14419#issuecomment-747922179 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

[GitHub] [flink] wangyang0918 opened a new pull request #14419: [FLINK-20650][k8s] Rename the command "native-k8s" to "run" based on the changes in docker-entrypoint.sh

2020-12-17 Thread GitBox
wangyang0918 opened a new pull request #14419: URL: https://github.com/apache/flink/pull/14419 ## What is the purpose of the change `native-k8s` command has been removed in https://github.com/apache/flink-docker/pull/49. So when the Flink client create the JobManager

[jira] [Created] (FLINK-20671) Partition doesn't commit until the end of partition

2020-12-17 Thread zhuxiaoshang (Jira)
zhuxiaoshang created FLINK-20671: Summary: Partition doesn't commit until the end of partition Key: FLINK-20671 URL: https://issues.apache.org/jira/browse/FLINK-20671 Project: Flink Issue

[GitHub] [flink] tzulitai commented on a change in pull request #14406: [FLINK-20629][Kinesis] Migrate from DescribeStream to DescribeStreamSummary

2020-12-17 Thread GitBox
tzulitai commented on a change in pull request #14406: URL: https://github.com/apache/flink/pull/14406#discussion_r545617043 ## File path: docs/dev/connectors/kinesis.zh.md ## @@ -1,5 +1,5 @@ --- -title: "Amazon AWS Kinesis Streams Connector" +title: "Amazon Kinesis Data

[GitHub] [flink] tzulitai commented on pull request #14406: [FLINK-20629][Kinesis] Migrate from DescribeStream to DescribeStreamSummary

2020-12-17 Thread GitBox
tzulitai commented on pull request #14406: URL: https://github.com/apache/flink/pull/14406#issuecomment-747917896 Since I don't think this changes anything to the user interface, I'm fine with merging this for 1.12.1 as well.

[jira] [Assigned] (FLINK-20630) [Kinesis][DynamoDB] DynamoDB Streams Consumer fails to consume from Latest

2020-12-17 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-20630: --- Assignee: Danny Cranmer > [Kinesis][DynamoDB] DynamoDB Streams Consumer

[GitHub] [flink] flinkbot edited a comment on pull request #14416: [hotfix][k8s] Fix k8s ha service doc.

2020-12-17 Thread GitBox
flinkbot edited a comment on pull request #14416: URL: https://github.com/apache/flink/pull/14416#issuecomment-747844139 ## CI report: * baee37d34012ad05bf5414ab9b6a81cfe19f881a Azure:

[jira] [Assigned] (FLINK-20629) [Kinesis][EFO] Migrate from DescribeStream to DescribeStreamSummary

2020-12-17 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-20629: --- Assignee: Danny Cranmer > [Kinesis][EFO] Migrate from DescribeStream to

[jira] [Updated] (FLINK-20630) [Kinesis][DynamoDB] DynamoDB Streams Consumer fails to consume from Latest

2020-12-17 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-20630: Priority: Blocker (was: Major) > [Kinesis][DynamoDB] DynamoDB Streams Consumer

[jira] [Updated] (FLINK-20670) Support query hints for Flink SQL

2020-12-17 Thread Shuo Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuo Cheng updated FLINK-20670: --- Description: Now Flink has supported dynamic table options based on the Hint framework of Calcite.

[jira] [Updated] (FLINK-20670) Support query hints for Flink SQL

2020-12-17 Thread Shuo Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuo Cheng updated FLINK-20670: --- Description: Now Flink has supported dynamic table options based on the Hint framework of Calcite.

[jira] [Created] (FLINK-20670) Support query hints for Flink SQL

2020-12-17 Thread Shuo Cheng (Jira)
Shuo Cheng created FLINK-20670: -- Summary: Support query hints for Flink SQL Key: FLINK-20670 URL: https://issues.apache.org/jira/browse/FLINK-20670 Project: Flink Issue Type: New Feature

[GitHub] [flink-docker] tzulitai commented on pull request #47: Add GPG key for 1.11.3 release

2020-12-17 Thread GitBox
tzulitai commented on pull request #47: URL: https://github.com/apache/flink-docker/pull/47#issuecomment-747916108 +1, please make sure to rerun the tests before merging This is an automated message from the Apache Git

[GitHub] [flink] fsk119 commented on a change in pull request #14371: [FLINK-20546][kafka]fix method misuse in DynamicTableFactoryTest

2020-12-17 Thread GitBox
fsk119 commented on a change in pull request #14371: URL: https://github.com/apache/flink/pull/14371#discussion_r545611977 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactoryTest.java ##

[GitHub] [flink-web] tzulitai commented on pull request #399: Add Apache Flink release 1.11.3

2020-12-17 Thread GitBox
tzulitai commented on pull request #399: URL: https://github.com/apache/flink-web/pull/399#issuecomment-747915017 +1, LGTM This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] cxiiiiiii commented on pull request #14415: [FLINK-19880][formats] Fix JsonRowFormatFactory's support for the format.ignore-parse-errors property.

2020-12-17 Thread GitBox
cxiii commented on pull request #14415: URL: https://github.com/apache/flink/pull/14415#issuecomment-747912845 @wuchong hi jark, could you help to review this pr since the ci has passed. tks! This is an automated

[GitHub] [flink] flinkbot edited a comment on pull request #14412: [FLINK-20639][python] Use list to optimize the Row used by Python UDAF intermediate results

2020-12-17 Thread GitBox
flinkbot edited a comment on pull request #14412: URL: https://github.com/apache/flink/pull/14412#issuecomment-747440830 ## CI report: * 0fdc8def8ceaee2359cbabf9b93b3c50ff4f0348 Azure:

[GitHub] [flink] wanglijie95 commented on a change in pull request #14416: [hotfix][k8s] Fix k8s ha service doc.

2020-12-17 Thread GitBox
wanglijie95 commented on a change in pull request #14416: URL: https://github.com/apache/flink/pull/14416#discussion_r545607574 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/highavailability/KubernetesHaServices.java ## @@ -42,7 +42,7 @@ import

[GitHub] [flink] flinkbot edited a comment on pull request #13876: [FLINK-18382][docs] Translate Kafka SQL connector documentation into Chinese

2020-12-17 Thread GitBox
flinkbot edited a comment on pull request #13876: URL: https://github.com/apache/flink/pull/13876#issuecomment-720337850 ## CI report: * a6e72cdc72f44909872f7324c62833b7726a44a9 Azure:

[GitHub] [flink] shuiqiangchen commented on a change in pull request #14401: [FLINK-20621][python] Refactor the TypeInformation implementation in Python DataStream API.

2020-12-17 Thread GitBox
shuiqiangchen commented on a change in pull request #14401: URL: https://github.com/apache/flink/pull/14401#discussion_r545606417 ## File path: flink-python/pyflink/common/typeinfo.py ## @@ -431,45 +430,47 @@ def from_internal_type(self, obj): return tuple(values)

[jira] [Comment Edited] (FLINK-18983) Job doesn't changed to failed if close function has blocked

2020-12-17 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251540#comment-17251540 ] Yuan Mei edited comment on FLINK-18983 at 12/18/20, 6:40 AM: - Hey,

[jira] [Comment Edited] (FLINK-18983) Job doesn't changed to failed if close function has blocked

2020-12-17 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251540#comment-17251540 ] Yuan Mei edited comment on FLINK-18983 at 12/18/20, 6:40 AM: - Hey,

[jira] [Commented] (FLINK-18983) Job doesn't changed to failed if close function has blocked

2020-12-17 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251540#comment-17251540 ] Yuan Mei commented on FLINK-18983: -- Hey, [~liuyufei]. You are absolutely right: Having failed tasks and

[GitHub] [flink] wuchong commented on pull request #14361: [FLINK-19435][connectors/jdbc] Fix deadlock when loading different driver classes concurrently using Class.forName

2020-12-17 Thread GitBox
wuchong commented on pull request #14361: URL: https://github.com/apache/flink/pull/14361#issuecomment-747901269 Sorry for the late response. We were on business trip of Flink Forward Asia. I will review this PR later today.

[GitHub] [flink] flinkbot edited a comment on pull request #14415: [FLINK-19880][formats] Fix JsonRowFormatFactory's support for the format.ignore-parse-errors property.

2020-12-17 Thread GitBox
flinkbot edited a comment on pull request #14415: URL: https://github.com/apache/flink/pull/14415#issuecomment-747584734 ## CI report: * 91b26c741c5cc1b578123830c6981e5e3fca9767 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13876: [FLINK-18382][docs] Translate Kafka SQL connector documentation into Chinese

2020-12-17 Thread GitBox
flinkbot edited a comment on pull request #13876: URL: https://github.com/apache/flink/pull/13876#issuecomment-720337850 ## CI report: * a6e72cdc72f44909872f7324c62833b7726a44a9 Azure:

[GitHub] [flink] HuangZhenQiu commented on pull request #8952: [FLINK-10868][flink-yarn] Add failure rater for resource manager

2020-12-17 Thread GitBox
HuangZhenQiu commented on pull request #8952: URL: https://github.com/apache/flink/pull/8952#issuecomment-747899670 @xintongsong Thanks for reviewing the PR. I replied to your comments on the Jira ticket. Once we have an agreement on the implementation, I will revise the PR

[jira] [Commented] (FLINK-10868) Flink's JobCluster ResourceManager doesn't use maximum-failed-containers as limit of resource acquirement

2020-12-17 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251539#comment-17251539 ] Zhenqiu Huang commented on FLINK-10868: --- Hi [~xintongsong] I just found you commented on the jira

[GitHub] [flink] PatrickRen commented on a change in pull request #13876: [FLINK-18382][docs] Translate Kafka SQL connector documentation into Chinese

2020-12-17 Thread GitBox
PatrickRen commented on a change in pull request #13876: URL: https://github.com/apache/flink/pull/13876#discussion_r545600084 ## File path: docs/dev/table/connectors/kafka.zh.md ## @@ -75,185 +72,181 @@ CREATE TABLE kafkaTable ( -Connector Options +连接器配置项

[GitHub] [flink] PatrickRen commented on pull request #13876: [FLINK-18382][docs] Translate Kafka SQL connector documentation into Chinese

2020-12-17 Thread GitBox
PatrickRen commented on pull request #13876: URL: https://github.com/apache/flink/pull/13876#issuecomment-747898339 Hi @wuchong and @V1ncentzzZ , I re-translated Kafka SQL connector's documentation and also fixed a typo in the original English doc. Since the sql-connector-download-table

[GitHub] [flink] flinkbot edited a comment on pull request #14377: [FLINK-19905][Connector][jdbc] The Jdbc-connector's 'lookup.max-retries' option initial value is 1 in JdbcLookupFunction

2020-12-17 Thread GitBox
flinkbot edited a comment on pull request #14377: URL: https://github.com/apache/flink/pull/14377#issuecomment-744303277 ## CI report: * c0e212ed51c103765ada525c54ba3d83614f929a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14387: [FLINK-19691][Connector][jdbc] Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

2020-12-17 Thread GitBox
flinkbot edited a comment on pull request #14387: URL: https://github.com/apache/flink/pull/14387#issuecomment-745165624 ## CI report: * 6f24479fca0414f440f2bf2590fdbb4308db8bb8 Azure:

[jira] [Commented] (FLINK-20552) JdbcDynamicTableSink doesn't sink buffered data on checkpoint

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251536#comment-17251536 ] Jark Wu commented on FLINK-20552: - Hi [~meijies], are you still working on this? >

[jira] [Updated] (FLINK-20552) JdbcDynamicTableSink doesn't sink buffered data on checkpoint

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20552: Fix Version/s: 1.13.0 > JdbcDynamicTableSink doesn't sink buffered data on checkpoint >

[jira] [Updated] (FLINK-20644) Check return type of ScalarFunction eval method shouldn't be void

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20644: Summary: Check return type of ScalarFunction eval method shouldn't be void (was: Check return type of

[jira] [Updated] (FLINK-20644) Check return type of ScalarFunction eval method

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20644: Summary: Check return type of ScalarFunction eval method (was: table api use UDF(ScalarFunction ) if

[jira] [Commented] (FLINK-20495) Elasticsearch6DynamicSinkITCase Hang

2020-12-17 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251532#comment-17251532 ] Huang Xingbo commented on FLINK-20495: --

[GitHub] [flink] flinkbot edited a comment on pull request #14377: [FLINK-19905][Connector][jdbc] The Jdbc-connector's 'lookup.max-retries' option initial value is 1 in JdbcLookupFunction

2020-12-17 Thread GitBox
flinkbot edited a comment on pull request #14377: URL: https://github.com/apache/flink/pull/14377#issuecomment-744303277 ## CI report: * c0e212ed51c103765ada525c54ba3d83614f929a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14387: [FLINK-19691][Connector][jdbc] Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

2020-12-17 Thread GitBox
flinkbot edited a comment on pull request #14387: URL: https://github.com/apache/flink/pull/14387#issuecomment-745165624 ## CI report: * 1f2f6e1075b11988e06013f648d1796b4e978a48 Azure:

[jira] [Commented] (FLINK-20632) Missing docker images for 1.12 release

2020-12-17 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251526#comment-17251526 ] Yang Wang commented on FLINK-20632: --- I remember [~chesnay] said in the ML that apache does not allow

[GitHub] [flink] xiaoHoly commented on a change in pull request #14377: [FLINK-19905][Connector][jdbc] The Jdbc-connector's 'lookup.max-retries' option initial value is 1 in JdbcLookupFunction

2020-12-17 Thread GitBox
xiaoHoly commented on a change in pull request #14377: URL: https://github.com/apache/flink/pull/14377#discussion_r545584101 ## File path: flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcLookupTableITCase.java ## @@ -120,7 +120,7

[GitHub] [flink] flinkbot edited a comment on pull request #14387: [FLINK-19691][Connector][jdbc] Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

2020-12-17 Thread GitBox
flinkbot edited a comment on pull request #14387: URL: https://github.com/apache/flink/pull/14387#issuecomment-745165624 ## CI report: * 1f2f6e1075b11988e06013f648d1796b4e978a48 Azure:

[jira] [Commented] (FLINK-20665) FileNotFoundException when restore from latest Checkpoint

2020-12-17 Thread zhuxiaoshang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251524#comment-17251524 ] zhuxiaoshang commented on FLINK-20665: -- [~lzljs3620320],yes you are write,if it has been compacted,

[jira] [Commented] (FLINK-20648) Unable to restore job from savepoint when using Kubernetes based HA services

2020-12-17 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251523#comment-17251523 ] Yang Wang commented on FLINK-20648: --- [~dmvk] Thanks for creating this issue and debugging the root

[GitHub] [flink] flinkbot edited a comment on pull request #14415: [FLINK-19880][formats] Fix JsonRowFormatFactory's support for the format.ignore-parse-errors property.

2020-12-17 Thread GitBox
flinkbot edited a comment on pull request #14415: URL: https://github.com/apache/flink/pull/14415#issuecomment-747584734 ## CI report: * 054c57cbbcab6c640bac4681fc9e17c7971d9b7d Azure:

[GitHub] [flink] xiaoHoly commented on pull request #14387: [FLINK-19691][Connector][jdbc] Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

2020-12-17 Thread GitBox
xiaoHoly commented on pull request #14387: URL: https://github.com/apache/flink/pull/14387#issuecomment-747874089 @wuchong ,hi, Jark. I hope to get your advice This is an automated message from the Apache Git Service. To

[GitHub] [flink] xiaoHoly commented on pull request #14387: [FLINK-19691][Connector][jdbc] Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

2020-12-17 Thread GitBox
xiaoHoly commented on pull request #14387: URL: https://github.com/apache/flink/pull/14387#issuecomment-747872906 @wangxlong i had done ConfigOption in JdbcDynamicTableFactory with your advice and Jark'advice ,but i have no idea how to verify this configOption in

[jira] [Commented] (FLINK-20645) Extra space typo when assembling dynamic configs

2020-12-17 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251508#comment-17251508 ] Yang Wang commented on FLINK-20645: --- Hmm. I am not sure why you need to pass arguments to the

[jira] [Closed] (FLINK-20669) Add the jzlib LICENSE file in flink-python module

2020-12-17 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-20669. --- Assignee: Huang Xingbo Resolution: Fixed Fixed in - master via

[GitHub] [flink] dianfu closed pull request #14418: [FLINK-20669][python] Add the jzlib LICENSE file in flink-python module

2020-12-17 Thread GitBox
dianfu closed pull request #14418: URL: https://github.com/apache/flink/pull/14418 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] dianfu commented on a change in pull request #14401: [FLINK-20621][python] Refactor the TypeInformation implementation in Python DataStream API.

2020-12-17 Thread GitBox
dianfu commented on a change in pull request #14401: URL: https://github.com/apache/flink/pull/14401#discussion_r54555 ## File path: flink-python/pyflink/common/typeinfo.py ## @@ -91,66 +73,117 @@ def from_internal_type(self, obj): return obj -class

[GitHub] [flink] flinkbot commented on pull request #14418: [FLINK-20669][python] Add the jzlib LICENSE file in flink-python module

2020-12-17 Thread GitBox
flinkbot commented on pull request #14418: URL: https://github.com/apache/flink/pull/14418#issuecomment-747869405 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

[GitHub] [flink] HuangXingBo commented on pull request #14418: [FLINK-20669][python] Add the jzlib LICENSE file in flink-python module

2020-12-17 Thread GitBox
HuangXingBo commented on pull request #14418: URL: https://github.com/apache/flink/pull/14418#issuecomment-747868969 @zentol @dianfu Could you help review it? Thanks. This is an automated message from the Apache Git Service.

[jira] [Updated] (FLINK-20669) Add the jzlib LICENSE file in flink-python module

2020-12-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20669: --- Labels: pull-request-available (was: ) > Add the jzlib LICENSE file in flink-python module

[GitHub] [flink] HuangXingBo opened a new pull request #14418: [FLINK-20669][python] Add the jzlib LICENSE file in flink-python module

2020-12-17 Thread GitBox
HuangXingBo opened a new pull request #14418: URL: https://github.com/apache/flink/pull/14418 ## What is the purpose of the change *This pull request will add the jzlib LICENSE file in flink-python module* ## Brief change log - *Add LICENSE file `LICENSE.jzlib`*

[GitHub] [flink-docker] wangyang0918 edited a comment on pull request #49: [FLINK-20650] Rename "native-k8s" command to a more general name in docker-entrypoint.sh

2020-12-17 Thread GitBox
wangyang0918 edited a comment on pull request #49: URL: https://github.com/apache/flink-docker/pull/49#issuecomment-747409750 @tillrohrmann Yeah. I will attach the Flink PR here once created. Moreover, I am not sure whether we should wait for the response of docker guys before

[GitHub] [flink] wangyang0918 commented on a change in pull request #14416: [hotfix][k8s] Fix k8s ha service doc.

2020-12-17 Thread GitBox
wangyang0918 commented on a change in pull request #14416: URL: https://github.com/apache/flink/pull/14416#discussion_r545571110 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/highavailability/KubernetesHaServices.java ## @@ -42,7 +42,7 @@ import

[jira] [Commented] (FLINK-20645) Extra space typo when assembling dynamic configs

2020-12-17 Thread Li Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251491#comment-17251491 ] Li Wang commented on FLINK-20645: - Thanks [~karmagyz] for the reference, we will look into converting to

[jira] [Updated] (FLINK-20567) Document Error in UDTF section

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20567: Summary: Document Error in UDTF section (was: Document Error) > Document Error in UDTF section >

[GitHub] [flink] flinkbot edited a comment on pull request #14417: [FLINK-20668][table-planner-blink] Introduce translateToExecNode method for FlinkPhysicalRel

2020-12-17 Thread GitBox
flinkbot edited a comment on pull request #14417: URL: https://github.com/apache/flink/pull/14417#issuecomment-747849155 ## CI report: * 67c73bdacc77bab17d60526487c13fe6693e4904 Azure:

[jira] [Assigned] (FLINK-20567) Document Error

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20567: --- Assignee: appleyuchi > Document Error > -- > > Key: FLINK-20567 >

[jira] [Assigned] (FLINK-20576) Flink Temporal Join Hive Dim Error

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20576: --- Assignee: Leonard Xu > Flink Temporal Join Hive Dim Error > -- > >

[jira] [Updated] (FLINK-20576) Flink Temporal Join Hive Dim Error

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20576: Fix Version/s: 1.12.1 > Flink Temporal Join Hive Dim Error > -- > >

[jira] [Commented] (FLINK-20665) FileNotFoundException when restore from latest Checkpoint

2020-12-17 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251490#comment-17251490 ] Jingsong Lee commented on FLINK-20665: -- Assigned to u [~ZhuShang]. I marked this as a Blocker. We

[jira] [Assigned] (FLINK-20665) FileNotFoundException when restore from latest Checkpoint

2020-12-17 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-20665: Assignee: zhuxiaoshang > FileNotFoundException when restore from latest Checkpoint >

[jira] [Commented] (FLINK-20664) Support setting service account for TaskManager pod

2020-12-17 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251489#comment-17251489 ] Yang Wang commented on FLINK-20664: --- Since the user code is executing on the TaskManager, I am afraid

[jira] [Comment Edited] (FLINK-20665) FileNotFoundException when restore from latest Checkpoint

2020-12-17 Thread zhuxiaoshang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251486#comment-17251486 ] zhuxiaoshang edited comment on FLINK-20665 at 12/18/20, 3:55 AM: -

[GitHub] [flink] shuiqiangchen commented on a change in pull request #14401: [FLINK-20621][python] Refactor the TypeInformation implementation in Python DataStream API.

2020-12-17 Thread GitBox
shuiqiangchen commented on a change in pull request #14401: URL: https://github.com/apache/flink/pull/14401#discussion_r545557068 ## File path: flink-python/pyflink/common/typeinfo.py ## @@ -407,12 +406,12 @@ def to_internal_type(self, obj): raise

[jira] [Commented] (FLINK-20665) FileNotFoundException when restore from latest Checkpoint

2020-12-17 Thread zhuxiaoshang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251486#comment-17251486 ] zhuxiaoshang commented on FLINK-20665: -- [~lzljs3620320],I'd like to do this job. BTW,I find that if

[jira] [Updated] (FLINK-20644) table api use UDF(ScalarFunction ) if eval return Unit

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20644: Priority: Major (was: Critical) > table api use UDF(ScalarFunction ) if eval return Unit >

[jira] [Updated] (FLINK-20644) table api use UDF(ScalarFunction ) if eval return Unit

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20644: Labels: starter (was: ) > table api use UDF(ScalarFunction ) if eval return Unit >

[jira] [Updated] (FLINK-20665) FileNotFoundException when restore from latest Checkpoint

2020-12-17 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-20665: - Fix Version/s: 1.12.1 > FileNotFoundException when restore from latest Checkpoint >

[jira] [Updated] (FLINK-20665) FileNotFoundException when restore from latest Checkpoint

2020-12-17 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-20665: - Priority: Blocker (was: Major) > FileNotFoundException when restore from latest Checkpoint >

[jira] [Commented] (FLINK-20665) FileNotFoundException when restore from latest Checkpoint

2020-12-17 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251484#comment-17251484 ] Jingsong Lee commented on FLINK-20665: -- [~ZhuShang] Do you want to fix this? >

[jira] [Commented] (FLINK-20665) FileNotFoundException when restore from latest Checkpoint

2020-12-17 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251483#comment-17251483 ] Jingsong Lee commented on FLINK-20665: -- Hi [~ZhuShang], yes, we should keep old temp file for big

[GitHub] [flink] flinkbot commented on pull request #14417: [FLINK-20668][table-planner-blink] Introduce translateToExecNode method for FlinkPhysicalRel

2020-12-17 Thread GitBox
flinkbot commented on pull request #14417: URL: https://github.com/apache/flink/pull/14417#issuecomment-747849155 ## CI report: * 67c73bdacc77bab17d60526487c13fe6693e4904 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #14416: [hotfix][k8s] Fix k8s ha service doc.

2020-12-17 Thread GitBox
flinkbot edited a comment on pull request #14416: URL: https://github.com/apache/flink/pull/14416#issuecomment-747844139 ## CI report: * baee37d34012ad05bf5414ab9b6a81cfe19f881a Azure:

[jira] [Created] (FLINK-20669) Add the jzlib LICENSE file in flink-python module

2020-12-17 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-20669: Summary: Add the jzlib LICENSE file in flink-python module Key: FLINK-20669 URL: https://issues.apache.org/jira/browse/FLINK-20669 Project: Flink Issue

[jira] [Commented] (FLINK-20665) FileNotFoundException when restore from latest Checkpoint

2020-12-17 Thread zhuxiaoshang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251476#comment-17251476 ] zhuxiaoshang commented on FLINK-20665: -- When the file is big,it will be rename directly.So when

[jira] [Assigned] (FLINK-20648) Unable to restore job from savepoint when using Kubernetes based HA services

2020-12-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-20648: Assignee: Yang Wang > Unable to restore job from savepoint when using Kubernetes based

[jira] [Assigned] (FLINK-20664) Support setting service account for TaskManager pod

2020-12-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-20664: Assignee: Yang Wang > Support setting service account for TaskManager pod >

[jira] [Commented] (FLINK-20664) Support setting service account for TaskManager pod

2020-12-17 Thread Boris Lublinsky (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251475#comment-17251475 ] Boris Lublinsky commented on FLINK-20664: - Do you mean: kubernetes.taskmanager.service-account

[jira] [Updated] (FLINK-20648) Unable to restore job from savepoint when using Kubernetes based HA services

2020-12-17 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20648: - Fix Version/s: 1.12.1 > Unable to restore job from savepoint when using Kubernetes based HA

[jira] [Commented] (FLINK-20667) Configurable batch size for vectorized reader

2020-12-17 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251474#comment-17251474 ] Leonard Xu commented on FLINK-20667: The question also reported in [stack

  1   2   3   4   5   >