[
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
NoMatchingTableFactor
[
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 candidates
[
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,
{{NoMatc
[
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 NoMatchingTableFactoryExc
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
Issu
[
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
> s
[
https://issues.apache.org/jira/browse/FLINK-15237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16995432#comment-16995432
]
Jark Wu edited comment on FLINK-15237 at 12/13/19 7:49 AM:
---
In
[
https://issues.apache.org/jira/browse/FLINK-14719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16995434#comment-16995434
]
Jark Wu commented on FLINK-14719:
-
Thanks [~chaiyq].
> Making Semantic configurable in
[
https://issues.apache.org/jira/browse/FLINK-15237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16995432#comment-16995432
]
Jark Wu commented on FLINK-15237:
-
In the future, CsvTableSource will be consumed by Fil
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. T
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:
[SUCCES
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:
flink-table/flink-table-
[
https://issues.apache.org/jira/browse/FLINK-15239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16995427#comment-16995427
]
Jingsong Lee commented on FLINK-15239:
--
CC: [~kevin.cyj]
> TM Metaspace memory lea
[
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
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 for
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
[
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
> --
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:
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:
[PENDING](htt
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:
[FAILURE](https://travis-ci.c
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:
flink-table/flink-table-co
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:
flink-table/flink-table-ap
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:
flink-connectors/flink-con
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:
flink-table/flink-table-ap
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:
flink-table/flink-table-ap
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:
flink-table/flink-table-co
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:
flink-table/flink-table-co
[
https://issues.apache.org/jira/browse/FLINK-15223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16995415#comment-16995415
]
Jingsong Lee commented on FLINK-15223:
--
After offline discussion with [~danny0405]
[
https://issues.apache.org/jira/browse/FLINK-15194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16995405#comment-16995405
]
Yang Wang commented on FLINK-15194:
---
[~zhongwei] Many thanks for your quick response.
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?
--
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?
--
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:
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 comman
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:
[PENDING](https://travis-ci.c
[
https://issues.apache.org/jira/browse/FLINK-13910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16995397#comment-16995397
]
Yun Tang commented on FLINK-13910:
--
[~aljoscha], the errors I provided are not related
[
https://issues.apache.org/jira/browse/FLINK-14719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16995396#comment-16995396
]
chaiyongqiang commented on FLINK-14719:
---
[~jark], thanks. I'll handle this mysel
[
https://issues.apache.org/jira/browse/FLINK-15194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16995394#comment-16995394
]
Wei Zhong commented on FLINK-15194:
---
[~fly_in_gis] I have tested in a real Yarn cluste
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 com
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: flink-dist/src/main/flink-bin/kubernetes-bin/kubernetes-session
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 we
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:
```
[
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 genera
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:
```
The
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 co
[
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,
> enam
[
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 `scott_em
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 @fli
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:
flink-table/flink-sql-client/src
[
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 NoMatchingTableF
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:
flink-table/flink-sql-client/src
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,
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
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:
[SUCCES
[
https://issues.apache.org/jira/browse/FLINK-14941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16995382#comment-16995382
]
Jark Wu commented on FLINK-14941:
-
1.11.0: 127ef48ec510663debb31e96a0bca9322625e2fd
1.10
[
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 connec
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
---
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
[
https://issues.apache.org/jira/browse/FLINK-15066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16995376#comment-16995376
]
Kurt Young commented on FLINK-15066:
[~danny0405] I'm not sure if this issue relates
[
https://issues.apache.org/jira/browse/FLINK-13808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16995375#comment-16995375
]
Congxian Qiu(klion26) commented on FLINK-13808:
---
[~sewen] FYI, create an i
[
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
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: Flin
[
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
>
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:
[SUCCES
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 re
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
[
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 AbstractHeapVector.createHeapC
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 Z
[
https://issues.apache.org/jira/browse/FLINK-15230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16995372#comment-16995372
]
kevin edited comment on FLINK-15230 at 12/13/19 5:36 AM:
-
Stream
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:
[SUCCES
[
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
> pa
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
Project
[
https://issues.apache.org/jira/browse/FLINK-15230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16995372#comment-16995372
]
kevin commented on FLINK-15230:
---
StreamExecutionEnvironment env =
StreamExecutionEnvironm
[
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 =
StreamExecutionEnvironment.getExecutionEnvironmen
[
https://issues.apache.org/jira/browse/FLINK-15230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16995371#comment-16995371
]
kevin commented on FLINK-15230:
---
StreamExecutionEnvironment env =
StreamExecutionEnvironm
[
https://issues.apache.org/jira/browse/FLINK-15231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16995368#comment-16995368
]
Zhenghua Gao edited comment on FLINK-15231 at 12/13/19 5:27 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-15231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16995368#comment-16995368
]
Zhenghua Gao commented on FLINK-15231:
--
[~jark] pls assign this to me and i will ma
[
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
> --
[
https://issues.apache.org/jira/browse/FLINK-15230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16995367#comment-16995367
]
Jark Wu commented on FLINK-15230:
-
Could you show the code (e.g. how to register the sou
[
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 make
[
https://issues.apache.org/jira/browse/FLINK-15233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16995365#comment-16995365
]
Jark Wu commented on FLINK-15233:
-
cc [~twalthr]
> Improve Kafka connector properties m
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
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
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:
flink-table/flink-table-
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:
flink-table/flink-table-
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:
flink-table/flink-sql-cl
[
https://issues.apache.org/jira/browse/FLINK-14647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16995362#comment-16995362
]
Jingsong Lee commented on FLINK-14647:
--
Hi [~nicholasjiang] [~jark] , I created
ht
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:
flink-table/flink-table-
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:
flink-table/flink-table-
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:
flink-table/flink-table-
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:
flink-connectors/flink-j
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:
flink-table/flink-table-
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
[
https://issues.apache.org/jira/browse/FLINK-15231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16995360#comment-16995360
]
Jingsong Lee commented on FLINK-15231:
--
Modified version to 1.11, it is not a user
[
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
> ---
[
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
> --
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:
* 16d680adb2f2206299daab376
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:
[FAILURE](https
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:
[SUCCES
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:
[SUCCES
[
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", Types.OBJECT_ARRAY(
1 - 100 of 628 matches
Mail list logo
