[jira] [Updated] (FLINK-15232) User doesn't know what's wrong: Print match candidates to improve NoMatchingTableFactoryException

2019-12-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15232: - Summary: User doesn't know what's wrong: Print match candidates to improve

[jira] [Updated] (FLINK-15232) Print match candidates to improve NoMatchingTableFactoryException

2019-12-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15232: - Parent: (was: FLINK-14644) Issue Type: Bug (was: Sub-task) > Print match

[jira] [Updated] (FLINK-15232) Print match candidates to improve NoMatchingTableFactoryException

2019-12-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15232: - Description: Currently, all the required properties should exist and match, otherwise, 

[jira] [Updated] (FLINK-15232) Print match candidates to improve NoMatchingTableFactoryException

2019-12-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15232: - Priority: Blocker (was: Critical) > Print match candidates to improve

[jira] [Created] (FLINK-15240) is_generic key is missing for Flink table stored in HiveCatalog

2019-12-12 Thread Bowen Li (Jira)
Bowen Li created FLINK-15240: Summary: is_generic key is missing for Flink table stored in HiveCatalog Key: FLINK-15240 URL: https://issues.apache.org/jira/browse/FLINK-15240 Project: Flink

[jira] [Closed] (FLINK-14719) Making Semantic configurable in Flinkkafkaproducer to support exactly-once semantic in Table API

2019-12-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-14719. --- Resolution: Not A Problem > Making Semantic configurable in Flinkkafkaproducer to support exactly-once >

[jira] [Comment Edited] (FLINK-15237) CsvTableSource and ref class better to Extract into a module

2019-12-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16995432#comment-16995432 ] Jark Wu edited comment on FLINK-15237 at 12/13/19 7:49 AM: --- In the future,

[jira] [Commented] (FLINK-14719) Making Semantic configurable in Flinkkafkaproducer to support exactly-once semantic in Table API

2019-12-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16995434#comment-16995434 ] Jark Wu commented on FLINK-14719: - Thanks [~chaiyq]. > Making Semantic configurable in

[jira] [Commented] (FLINK-15237) CsvTableSource and ref class better to Extract into a module

2019-12-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16995432#comment-16995432 ] Jark Wu commented on FLINK-15237: - In the future, CsvTableSource will be consumed by

[GitHub] [flink] lirui-apache commented on issue #10514: [FLINK-15167][sql-client] Catalogs should be created and registered with user class loader as context loader

2019-12-12 Thread GitBox
lirui-apache commented on issue #10514: [FLINK-15167][sql-client] Catalogs should be created and registered with user class loader as context loader URL: https://github.com/apache/flink/pull/10514#issuecomment-565338210 @KurtYoung Updated to address your comment. Please take another look.

[GitHub] [flink] flinkbot edited a comment on issue #10547: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter.

2019-12-12 Thread GitBox
flinkbot edited a comment on issue #10547: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter. URL: https://github.com/apache/flink/pull/10547#issuecomment-564981482 ## CI report: * 8c8421107db848d42584e65373a0c6763d8c3852 Travis:

[GitHub] [flink] danny0405 commented on a change in pull request #10536: [FLINK-15191][connectors / kafka]Fix can't create table source for Kafka if watermark or computed column is defined.

2019-12-12 Thread GitBox
danny0405 commented on a change in pull request #10536: [FLINK-15191][connectors / kafka]Fix can't create table source for Kafka if watermark or computed column is defined. URL: https://github.com/apache/flink/pull/10536#discussion_r357518211 ## File path:

[jira] [Commented] (FLINK-15239) TM Metaspace memory leak

2019-12-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16995427#comment-16995427 ] Jingsong Lee commented on FLINK-15239: -- CC: [~kevin.cyj] > TM Metaspace memory leak >

[jira] [Updated] (FLINK-15239) TM Metaspace memory leak

2019-12-12 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-15239: --- Description: Start a standalone cluster and then submit multiple queries for Hive tables via SQL CLI. Hive

[GitHub] [flink] wuchong commented on issue #10536: [FLINK-15191][connectors / kafka]Fix can't create table source for Kafka if watermark or computed column is defined.

2019-12-12 Thread GitBox
wuchong commented on issue #10536: [FLINK-15191][connectors / kafka]Fix can't create table source for Kafka if watermark or computed column is defined. URL: https://github.com/apache/flink/pull/10536#issuecomment-565333291 And could you add some IT cases for Kafka connector? The DDL

[jira] [Created] (FLINK-15239) TM Metaspace memory leak

2019-12-12 Thread Rui Li (Jira)
Rui Li created FLINK-15239: -- Summary: TM Metaspace memory leak Key: FLINK-15239 URL: https://issues.apache.org/jira/browse/FLINK-15239 Project: Flink Issue Type: Bug Components: Table SQL

[jira] [Closed] (FLINK-15238) A sql can't generate a valid execution plan

2019-12-12 Thread xiaojin.wy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaojin.wy closed FLINK-15238. -- Resolution: Invalid > A sql can't generate a valid execution plan >

[GitHub] [flink] flinkbot edited a comment on issue #10564: add space to exception info

2019-12-12 Thread GitBox
flinkbot edited a comment on issue #10564: add space to exception info URL: https://github.com/apache/flink/pull/10564#issuecomment-565323894 ## CI report: * 479874c66fc60d022890fac0d6cc8dc961e6e322 Travis: [PENDING](https://travis-ci.com/flink-ci/flink/builds/140908414) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #10563: [FLINK-15232][table] Print match candidates to improve NoMatchingTableFactoryException

2019-12-12 Thread GitBox
flinkbot edited a comment on issue #10563: [FLINK-15232][table] Print match candidates to improve NoMatchingTableFactoryException URL: https://github.com/apache/flink/pull/10563#issuecomment-565323860 ## CI report: * f678f927311a4bc4177e1fa9dc36f24f3211a1d0 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10562: [FLINK-15231][table-planner-blink] Do not support TIMESTAMP/DECIMAL t…

2019-12-12 Thread GitBox
flinkbot edited a comment on issue #10562: [FLINK-15231][table-planner-blink] Do not support TIMESTAMP/DECIMAL t… URL: https://github.com/apache/flink/pull/10562#issuecomment-565316871 ## CI report: * 9dc4897a577d48c9aa7c49789e8841e39cd006e7 Travis:

[GitHub] [flink] wuchong commented on a change in pull request #10536: [FLINK-15191][connectors / kafka]Fix can't create table source for Kafka if watermark or computed column is defined.

2019-12-12 Thread GitBox
wuchong commented on a change in pull request #10536: [FLINK-15191][connectors / kafka]Fix can't create table source for Kafka if watermark or computed column is defined. URL: https://github.com/apache/flink/pull/10536#discussion_r357501589 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #10536: [FLINK-15191][connectors / kafka]Fix can't create table source for Kafka if watermark or computed column is defined.

2019-12-12 Thread GitBox
wuchong commented on a change in pull request #10536: [FLINK-15191][connectors / kafka]Fix can't create table source for Kafka if watermark or computed column is defined. URL: https://github.com/apache/flink/pull/10536#discussion_r357499765 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #10536: [FLINK-15191][connectors / kafka]Fix can't create table source for Kafka if watermark or computed column is defined.

2019-12-12 Thread GitBox
wuchong commented on a change in pull request #10536: [FLINK-15191][connectors / kafka]Fix can't create table source for Kafka if watermark or computed column is defined. URL: https://github.com/apache/flink/pull/10536#discussion_r357500858 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #10536: [FLINK-15191][connectors / kafka]Fix can't create table source for Kafka if watermark or computed column is defined.

2019-12-12 Thread GitBox
wuchong commented on a change in pull request #10536: [FLINK-15191][connectors / kafka]Fix can't create table source for Kafka if watermark or computed column is defined. URL: https://github.com/apache/flink/pull/10536#discussion_r357507281 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #10536: [FLINK-15191][connectors / kafka]Fix can't create table source for Kafka if watermark or computed column is defined.

2019-12-12 Thread GitBox
wuchong commented on a change in pull request #10536: [FLINK-15191][connectors / kafka]Fix can't create table source for Kafka if watermark or computed column is defined. URL: https://github.com/apache/flink/pull/10536#discussion_r357504240 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #10536: [FLINK-15191][connectors / kafka]Fix can't create table source for Kafka if watermark or computed column is defined.

2019-12-12 Thread GitBox
wuchong commented on a change in pull request #10536: [FLINK-15191][connectors / kafka]Fix can't create table source for Kafka if watermark or computed column is defined. URL: https://github.com/apache/flink/pull/10536#discussion_r357505503 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #10536: [FLINK-15191][connectors / kafka]Fix can't create table source for Kafka if watermark or computed column is defined.

2019-12-12 Thread GitBox
wuchong commented on a change in pull request #10536: [FLINK-15191][connectors / kafka]Fix can't create table source for Kafka if watermark or computed column is defined. URL: https://github.com/apache/flink/pull/10536#discussion_r357505704 ## File path:

[jira] [Commented] (FLINK-15223) Csv connector should unescape delimiter parameter characters

2019-12-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16995415#comment-16995415 ] Jingsong Lee commented on FLINK-15223: -- After offline discussion with [~danny0405] . We should not

[jira] [Commented] (FLINK-15194) Directories in distributed caches are not extracted in Yarn Per Job Cluster Mode

2019-12-12 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16995405#comment-16995405 ] Yang Wang commented on FLINK-15194: --- [~zhongwei] Many thanks for your quick response. [~trohrmann] 

[GitHub] [flink] wangyang0918 removed a comment on issue #10550: [FLINK-15194] Support registering directory as cache file in Yarn per-job mode

2019-12-12 Thread GitBox
wangyang0918 removed a comment on issue #10550: [FLINK-15194] Support registering directory as cache file in Yarn per-job mode URL: https://github.com/apache/flink/pull/10550#issuecomment-565324321 @walterddr @tillrohrmann Could you help to review the PR?

[GitHub] [flink] wangyang0918 commented on issue #10550: [FLINK-15194] Support registering directory as cache file in Yarn per-job mode

2019-12-12 Thread GitBox
wangyang0918 commented on issue #10550: [FLINK-15194] Support registering directory as cache file in Yarn per-job mode URL: https://github.com/apache/flink/pull/10550#issuecomment-565324321 @walterddr @tillrohrmann Could you help to review the PR?

[GitHub] [flink] flinkbot commented on issue #10564: add space to exception info

2019-12-12 Thread GitBox
flinkbot commented on issue #10564: add space to exception info URL: https://github.com/apache/flink/pull/10564#issuecomment-565323894 ## CI report: * 479874c66fc60d022890fac0d6cc8dc961e6e322 UNKNOWN Bot commands The @flinkbot bot supports the following commands:

[GitHub] [flink] flinkbot commented on issue #10563: [FLINK-15232][table] Print match candidates to improve NoMatchingTableFactoryException

2019-12-12 Thread GitBox
flinkbot commented on issue #10563: [FLINK-15232][table] Print match candidates to improve NoMatchingTableFactoryException URL: https://github.com/apache/flink/pull/10563#issuecomment-565323860 ## CI report: * f678f927311a4bc4177e1fa9dc36f24f3211a1d0 UNKNOWN Bot

[GitHub] [flink] flinkbot edited a comment on issue #10562: [FLINK-15231][table-planner-blink] Do not support TIMESTAMP/DECIMAL t…

2019-12-12 Thread GitBox
flinkbot edited a comment on issue #10562: [FLINK-15231][table-planner-blink] Do not support TIMESTAMP/DECIMAL t… URL: https://github.com/apache/flink/pull/10562#issuecomment-565316871 ## CI report: * 9dc4897a577d48c9aa7c49789e8841e39cd006e7 Travis:

[jira] [Commented] (FLINK-13910) Many serializable classes have no explicit 'serialVersionUID'

2019-12-12 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16995397#comment-16995397 ] Yun Tang commented on FLINK-13910: -- [~aljoscha], the errors I provided are not related with

[jira] [Commented] (FLINK-14719) Making Semantic configurable in Flinkkafkaproducer to support exactly-once semantic in Table API

2019-12-12 Thread chaiyongqiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16995396#comment-16995396 ] chaiyongqiang commented on FLINK-14719: --- [~jark], thanks. I'll handle this myself on flink1.8

[jira] [Commented] (FLINK-15194) Directories in distributed caches are not extracted in Yarn Per Job Cluster Mode

2019-12-12 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16995394#comment-16995394 ] Wei Zhong commented on FLINK-15194: --- [~fly_in_gis] I have tested in a real Yarn cluster and it works.

[GitHub] [flink] flinkbot commented on issue #10564: add space to exception info

2019-12-12 Thread GitBox
flinkbot commented on issue #10564: add space to exception info URL: https://github.com/apache/flink/pull/10564#issuecomment-565319044 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

[GitHub] [flink] wangyang0918 commented on a change in pull request #10528: [FLINK-15179] Kubernetes Session CLI use generic ExecutorCLI, not custom one

2019-12-12 Thread GitBox
wangyang0918 commented on a change in pull request #10528: [FLINK-15179] Kubernetes Session CLI use generic ExecutorCLI, not custom one URL: https://github.com/apache/flink/pull/10528#discussion_r357465722 ## File path:

[GitHub] [flink] natsumehu opened a new pull request #10564: add space to exception info

2019-12-12 Thread GitBox
natsumehu opened a new pull request #10564: add space to exception info URL: https://github.com/apache/flink/pull/10564 ## 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

[GitHub] [flink] JingsongLi edited a comment on issue #10563: [FLINK-15232][table] Print match candidates to improve NoMatchingTableFactoryException

2019-12-12 Thread GitBox
JingsongLi edited a comment on issue #10563: [FLINK-15232][table] Print match candidates to improve NoMatchingTableFactoryException URL: https://github.com/apache/flink/pull/10563#issuecomment-565317681 CC: @wuchong @KurtYoung @twalthr @dawidwys The error message will be:

[jira] [Updated] (FLINK-15238) A sql can't generate a valid execution plan

2019-12-12 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15238: --- Component/s: (was: Table SQL / Client) Table SQL / Planner > A sql can't

[GitHub] [flink] JingsongLi commented on issue #10563: [FLINK-15232][table] Print match candidates to improve NoMatchingTableFactoryException

2019-12-12 Thread GitBox
JingsongLi commented on issue #10563: [FLINK-15232][table] Print match candidates to improve NoMatchingTableFactoryException URL: https://github.com/apache/flink/pull/10563#issuecomment-565317681 CC: @wuchong @KurtYoung @twalthr @dawidwys The error message will be: ```

[GitHub] [flink] flinkbot commented on issue #10563: [FLINK-15232][table] Print match candidates to improve NoMatchingTableFactoryException

2019-12-12 Thread GitBox
flinkbot commented on issue #10563: [FLINK-15232][table] Print match candidates to improve NoMatchingTableFactoryException URL: https://github.com/apache/flink/pull/10563#issuecomment-565317403 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[jira] [Updated] (FLINK-15238) A sql can't generate a valid execution plan

2019-12-12 Thread xiaojin.wy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaojin.wy updated FLINK-15238: --- Description: *The table and the query is like this:* CREATE TABLE `scott_emp` ( > empno INT, >

[jira] [Updated] (FLINK-15238) A sql can't generate a valid execution plan

2019-12-12 Thread xiaojin.wy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaojin.wy updated FLINK-15238: --- Description: The table and the query is like this: CREATE TABLE `scott_emp` (CREATE TABLE

[GitHub] [flink] flinkbot commented on issue #10562: [FLINK-15231][table-planner-blink] Do not support TIMESTAMP/DECIMAL t…

2019-12-12 Thread GitBox
flinkbot commented on issue #10562: [FLINK-15231][table-planner-blink] Do not support TIMESTAMP/DECIMAL t… URL: https://github.com/apache/flink/pull/10562#issuecomment-565316871 ## CI report: * 9dc4897a577d48c9aa7c49789e8841e39cd006e7 UNKNOWN Bot commands The

[GitHub] [flink] KurtYoung commented on a change in pull request #10514: [FLINK-15167][sql-client] Catalogs should be created and registered with user class loader as context loader

2019-12-12 Thread GitBox
KurtYoung commented on a change in pull request #10514: [FLINK-15167][sql-client] Catalogs should be created and registered with user class loader as context loader URL: https://github.com/apache/flink/pull/10514#discussion_r357499331 ## File path:

[jira] [Updated] (FLINK-15232) Print match candidates to improve NoMatchingTableFactoryException

2019-12-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15232: --- Labels: pull-request-available (was: ) > Print match candidates to improve

[GitHub] [flink] KurtYoung commented on a change in pull request #10514: [FLINK-15167][sql-client] Catalogs should be created and registered with user class loader as context loader

2019-12-12 Thread GitBox
KurtYoung commented on a change in pull request #10514: [FLINK-15167][sql-client] Catalogs should be created and registered with user class loader as context loader URL: https://github.com/apache/flink/pull/10514#discussion_r357499331 ## File path:

[GitHub] [flink] JingsongLi opened a new pull request #10563: [FLINK-15232][table] Print match candidates to improve NoMatchingTableFactoryException

2019-12-12 Thread GitBox
JingsongLi opened a new pull request #10563: [FLINK-15232][table] Print match candidates to improve NoMatchingTableFactoryException URL: https://github.com/apache/flink/pull/10563 ## What is the purpose of the change Currently, all the required properties should exist and match,

[jira] [Created] (FLINK-15238) A sql can't generate a valid execution plan

2019-12-12 Thread xiaojin.wy (Jira)
xiaojin.wy created FLINK-15238: -- Summary: A sql can't generate a valid execution plan Key: FLINK-15238 URL: https://issues.apache.org/jira/browse/FLINK-15238 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on issue #10547: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter.

2019-12-12 Thread GitBox
flinkbot edited a comment on issue #10547: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter. URL: https://github.com/apache/flink/pull/10547#issuecomment-564981482 ## CI report: * 8c8421107db848d42584e65373a0c6763d8c3852 Travis:

[jira] [Commented] (FLINK-14941) The AbstractTableInputFormat#nextRecord in hbase connector will handle the same rowkey twice once encountered any exception

2019-12-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16995382#comment-16995382 ] Jark Wu commented on FLINK-14941: - 1.11.0: 127ef48ec510663debb31e96a0bca9322625e2fd 1.10.0:

[jira] [Resolved] (FLINK-14941) The AbstractTableInputFormat#nextRecord in hbase connector will handle the same rowkey twice once encountered any exception

2019-12-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-14941. - Fix Version/s: 1.10.0 Resolution: Fixed > The AbstractTableInputFormat#nextRecord in hbase

[GitHub] [flink] wuchong merged pull request #10314: [FLINK-14941][hbase] The AbstractTableInputFormat#nextRecord in hbase connector will handle the same rowkey twice once encountered any exception

2019-12-12 Thread GitBox
wuchong merged pull request #10314: [FLINK-14941][hbase] The AbstractTableInputFormat#nextRecord in hbase connector will handle the same rowkey twice once encountered any exception URL: https://github.com/apache/flink/pull/10314

[jira] [Created] (FLINK-15237) CsvTableSource and ref class better to Extract into a module

2019-12-12 Thread xiaodao (Jira)
xiaodao created FLINK-15237: --- Summary: CsvTableSource and ref class better to Extract into a module Key: FLINK-15237 URL: https://issues.apache.org/jira/browse/FLINK-15237 Project: Flink Issue

[jira] [Commented] (FLINK-15066) Cannot run multiple `insert into csvTable values ()`

2019-12-12 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16995376#comment-16995376 ] Kurt Young commented on FLINK-15066: [~danny0405] I'm not sure if this issue relates to INSERT

[jira] [Commented] (FLINK-13808) Checkpoints expired by timeout may leak RocksDB files

2019-12-12 Thread Congxian Qiu(klion26) (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16995375#comment-16995375 ] Congxian Qiu(klion26) commented on FLINK-13808: --- [~sewen] FYI, create an issue to track

[jira] [Updated] (FLINK-15236) Add a safety net to limit the number of concurrent checkpoints on TM side

2019-12-12 Thread Congxian Qiu(klion26) (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-15236: -- Summary: Add a safety net to limit the number of concurrent checkpoints on TM

[jira] [Created] (FLINK-15236) Add a safety net for concurrent checkpoints on TM side

2019-12-12 Thread Congxian Qiu(klion26) (Jira)
Congxian Qiu(klion26) created FLINK-15236: - Summary: Add a safety net for concurrent checkpoints on TM side Key: FLINK-15236 URL: https://issues.apache.org/jira/browse/FLINK-15236 Project:

[jira] [Assigned] (FLINK-15231) Wrong HeapVector in AbstractHeapVector.createHeapColumn

2019-12-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-15231: --- Assignee: Zhenghua Gao > Wrong HeapVector in AbstractHeapVector.createHeapColumn >

[GitHub] [flink] flinkbot edited a comment on issue #10547: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter.

2019-12-12 Thread GitBox
flinkbot edited a comment on issue #10547: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter. URL: https://github.com/apache/flink/pull/10547#issuecomment-564981482 ## CI report: * 8c8421107db848d42584e65373a0c6763d8c3852 Travis:

[GitHub] [flink] flinkbot commented on issue #10562: [FLINK-15231][table-planner-blink] Do not support TIMESTAMP/DECIMAL t…

2019-12-12 Thread GitBox
flinkbot commented on issue #10562: [FLINK-15231][table-planner-blink] Do not support TIMESTAMP/DECIMAL t… URL: https://github.com/apache/flink/pull/10562#issuecomment-565309365 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Created] (FLINK-15235) create a Flink distribution for hive that includes all Hive dependencies

2019-12-12 Thread Bowen Li (Jira)
Bowen Li created FLINK-15235: Summary: create a Flink distribution for hive that includes all Hive dependencies Key: FLINK-15235 URL: https://issues.apache.org/jira/browse/FLINK-15235 Project: Flink

[jira] [Updated] (FLINK-15231) Wrong HeapVector in AbstractHeapVector.createHeapColumn

2019-12-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15231: --- Labels: pull-request-available (was: ) > Wrong HeapVector in

[GitHub] [flink] docete opened a new pull request #10562: [FLINK-15231][table-planner-blink] Do not support TIMESTAMP/DECIMAL t…

2019-12-12 Thread GitBox
docete opened a new pull request #10562: [FLINK-15231][table-planner-blink] Do not support TIMESTAMP/DECIMAL t… URL: https://github.com/apache/flink/pull/10562 …ypes for HeapVector ## What is the purpose of the change For TIMESTAMP WITHOUT TIME ZONE/TIMESTAMP WITH LOCAL TIME

[jira] [Comment Edited] (FLINK-15230) flink1.9.1 table API JSON schema array type exception

2019-12-12 Thread kevin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16995372#comment-16995372 ] kevin edited comment on FLINK-15230 at 12/13/19 5:36 AM: -

[GitHub] [flink] flinkbot edited a comment on issue #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter.

2019-12-12 Thread GitBox
flinkbot edited a comment on issue #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter. URL: https://github.com/apache/flink/pull/10492#issuecomment-563110907 ## CI report: * bef118a977b3aa635fc748260d07b0d5079b2c0e Travis:

[jira] [Updated] (FLINK-15234) hive table created from flink catalog table cannot have null properties in parameters

2019-12-12 Thread Bowen Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-15234: - Fix Version/s: 1.11.0 > hive table created from flink catalog table cannot have null properties in >

[jira] [Created] (FLINK-15234) hive table created from flink catalog table cannot have null properties in parameters

2019-12-12 Thread Bowen Li (Jira)
Bowen Li created FLINK-15234: Summary: hive table created from flink catalog table cannot have null properties in parameters Key: FLINK-15234 URL: https://issues.apache.org/jira/browse/FLINK-15234

[jira] [Commented] (FLINK-15230) flink1.9.1 table API JSON schema array type exception

2019-12-12 Thread kevin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16995372#comment-16995372 ] kevin commented on FLINK-15230: --- StreamExecutionEnvironment env =

[jira] [Issue Comment Deleted] (FLINK-15230) flink1.9.1 table API JSON schema array type exception

2019-12-12 Thread kevin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] kevin updated FLINK-15230: -- Comment: was deleted (was: StreamExecutionEnvironment env =

[jira] [Commented] (FLINK-15230) flink1.9.1 table API JSON schema array type exception

2019-12-12 Thread kevin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16995371#comment-16995371 ] kevin commented on FLINK-15230: --- StreamExecutionEnvironment env =

[jira] [Comment Edited] (FLINK-15231) Wrong HeapVector in AbstractHeapVector.createHeapColumn

2019-12-12 Thread Zhenghua Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16995368#comment-16995368 ] Zhenghua Gao edited comment on FLINK-15231 at 12/13/19 5:27 AM:

[jira] [Commented] (FLINK-15231) Wrong HeapVector in AbstractHeapVector.createHeapColumn

2019-12-12 Thread Zhenghua Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16995368#comment-16995368 ] Zhenghua Gao commented on FLINK-15231: -- [~jark] pls assign this to me and i will make a PR soon >

[jira] [Assigned] (FLINK-15232) Print match candidates to improve NoMatchingTableFactoryException

2019-12-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-15232: --- Assignee: Jingsong Lee > Print match candidates to improve NoMatchingTableFactoryException >

[jira] [Commented] (FLINK-15230) flink1.9.1 table API JSON schema array type exception

2019-12-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16995367#comment-16995367 ] Jark Wu commented on FLINK-15230: - Could you show the code (e.g. how to register the source table)? >

[jira] [Updated] (FLINK-15233) Improve Kafka connector properties make append update-mode as default

2019-12-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-15233: Fix Version/s: 1.10.0 Issue Type: Improvement (was: Bug) > Improve Kafka connector properties

[jira] [Commented] (FLINK-15233) Improve Kafka connector properties make append update-mode as default

2019-12-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16995365#comment-16995365 ] Jark Wu commented on FLINK-15233: - cc [~twalthr] > Improve Kafka connector properties make append

[jira] [Created] (FLINK-15233) Improve Kafka connector properties make append update-mode as default

2019-12-12 Thread Jark Wu (Jira)
Jark Wu created FLINK-15233: --- Summary: Improve Kafka connector properties make append update-mode as default Key: FLINK-15233 URL: https://issues.apache.org/jira/browse/FLINK-15233 Project: Flink

[GitHub] [flink] flinkbot edited a comment on issue #10514: [FLINK-15167][sql-client] Catalogs should be created and registered with user class loader as context loader

2019-12-12 Thread GitBox
flinkbot edited a comment on issue #10514: [FLINK-15167][sql-client] Catalogs should be created and registered with user class loader as context loader URL: https://github.com/apache/flink/pull/10514#issuecomment-564036207 ## CI report: * 02fcf77d77efced460517bb6f6e3a3fbfee4dcc2

[GitHub] [flink] danny0405 commented on a change in pull request #10536: [FLINK-15191][connectors / kafka]Fix can't create table source for Kafka if watermark or computed column is defined.

2019-12-12 Thread GitBox
danny0405 commented on a change in pull request #10536: [FLINK-15191][connectors / kafka]Fix can't create table source for Kafka if watermark or computed column is defined. URL: https://github.com/apache/flink/pull/10536#discussion_r357476447 ## File path:

[jira] [Commented] (FLINK-14647) Improve the exception message when required property is not matched

2019-12-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16995362#comment-16995362 ] Jingsong Lee commented on FLINK-14647: -- Hi [~nicholasjiang] [~jark] , I created 

[GitHub] [flink] danny0405 commented on a change in pull request #10536: [FLINK-15191][connectors / kafka]Fix can't create table source for Kafka if watermark or computed column is defined.

2019-12-12 Thread GitBox
danny0405 commented on a change in pull request #10536: [FLINK-15191][connectors / kafka]Fix can't create table source for Kafka if watermark or computed column is defined. URL: https://github.com/apache/flink/pull/10536#discussion_r357487533 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #10536: [FLINK-15191][connectors / kafka]Fix can't create table source for Kafka if watermark or computed column is defined.

2019-12-12 Thread GitBox
danny0405 commented on a change in pull request #10536: [FLINK-15191][connectors / kafka]Fix can't create table source for Kafka if watermark or computed column is defined. URL: https://github.com/apache/flink/pull/10536#discussion_r357487460 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #10536: [FLINK-15191][connectors / kafka]Fix can't create table source for Kafka if watermark or computed column is defined.

2019-12-12 Thread GitBox
danny0405 commented on a change in pull request #10536: [FLINK-15191][connectors / kafka]Fix can't create table source for Kafka if watermark or computed column is defined. URL: https://github.com/apache/flink/pull/10536#discussion_r357477111 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #10536: [FLINK-15191][connectors / kafka]Fix can't create table source for Kafka if watermark or computed column is defined.

2019-12-12 Thread GitBox
danny0405 commented on a change in pull request #10536: [FLINK-15191][connectors / kafka]Fix can't create table source for Kafka if watermark or computed column is defined. URL: https://github.com/apache/flink/pull/10536#discussion_r357487617 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #10536: [FLINK-15191][connectors / kafka]Fix can't create table source for Kafka if watermark or computed column is defined.

2019-12-12 Thread GitBox
danny0405 commented on a change in pull request #10536: [FLINK-15191][connectors / kafka]Fix can't create table source for Kafka if watermark or computed column is defined. URL: https://github.com/apache/flink/pull/10536#discussion_r357487293 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #10536: [FLINK-15191][connectors / kafka]Fix can't create table source for Kafka if watermark or computed column is defined.

2019-12-12 Thread GitBox
danny0405 commented on a change in pull request #10536: [FLINK-15191][connectors / kafka]Fix can't create table source for Kafka if watermark or computed column is defined. URL: https://github.com/apache/flink/pull/10536#discussion_r357476122 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #10536: [FLINK-15191][connectors / kafka]Fix can't create table source for Kafka if watermark or computed column is defined.

2019-12-12 Thread GitBox
danny0405 commented on a change in pull request #10536: [FLINK-15191][connectors / kafka]Fix can't create table source for Kafka if watermark or computed column is defined. URL: https://github.com/apache/flink/pull/10536#discussion_r357478162 ## File path:

[jira] [Created] (FLINK-15232) Print match candidates to improve NoMatchingTableFactoryException

2019-12-12 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-15232: Summary: Print match candidates to improve NoMatchingTableFactoryException Key: FLINK-15232 URL: https://issues.apache.org/jira/browse/FLINK-15232 Project: Flink

[jira] [Commented] (FLINK-15231) Wrong HeapVector in AbstractHeapVector.createHeapColumn

2019-12-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16995360#comment-16995360 ] Jingsong Lee commented on FLINK-15231: -- Modified version to 1.11, it is not a user bug. So let's

[jira] [Updated] (FLINK-15231) Wrong HeapVector in AbstractHeapVector.createHeapColumn

2019-12-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15231: - Fix Version/s: (was: 1.10.0) > Wrong HeapVector in AbstractHeapVector.createHeapColumn >

[jira] [Updated] (FLINK-15231) Wrong HeapVector in AbstractHeapVector.createHeapColumn

2019-12-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-15231: - Fix Version/s: 1.11.0 > Wrong HeapVector in AbstractHeapVector.createHeapColumn >

[GitHub] [flink] flinkbot edited a comment on issue #10561: [FLINK-15001] [table-planner-blink] The digest of sub-plan reuse should contain retraction traits for stream physical nodes

2019-12-12 Thread GitBox
flinkbot edited a comment on issue #10561: [FLINK-15001] [table-planner-blink] The digest of sub-plan reuse should contain retraction traits for stream physical nodes URL: https://github.com/apache/flink/pull/10561#issuecomment-565279600 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #10560: FLINK-15174 added certificate pinning for SSL mutual auth to further protect cluster

2019-12-12 Thread GitBox
flinkbot edited a comment on issue #10560: FLINK-15174 added certificate pinning for SSL mutual auth to further protect cluster URL: https://github.com/apache/flink/pull/10560#issuecomment-565227470 ## CI report: * 7b7bf78b902196e3365caf9fe2febe33386051ba Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10547: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter.

2019-12-12 Thread GitBox
flinkbot edited a comment on issue #10547: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter. URL: https://github.com/apache/flink/pull/10547#issuecomment-564981482 ## CI report: * 8c8421107db848d42584e65373a0c6763d8c3852 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter.

2019-12-12 Thread GitBox
flinkbot edited a comment on issue #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter. URL: https://github.com/apache/flink/pull/10492#issuecomment-563110907 ## CI report: * bef118a977b3aa635fc748260d07b0d5079b2c0e Travis:

[jira] [Updated] (FLINK-15230) flink1.9.1 table API JSON schema array type exception

2019-12-12 Thread kevin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] kevin updated FLINK-15230: -- Description: strings: { type: 'array', items: { type: 'string' } }    .field("strings",

  1   2   3   4   5   6   7   >