[
https://issues.apache.org/jira/browse/FLINK-18602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17196817#comment-17196817
]
Shengkai Fang commented on FLINK-18602:
---
Currently
[
https://issues.apache.org/jira/browse/FLINK-19651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-19651:
--
Summary: Support the filter push down for the Jdbc connector (was: Support
filter push down
[
https://issues.apache.org/jira/browse/FLINK-19650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-19650:
--
Parent: FLINK-16987
Issue Type: Sub-task (was: New Feature)
> Support the limit push
[
https://issues.apache.org/jira/browse/FLINK-19647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-19647:
--
Parent: FLINK-16987
Issue Type: Sub-task (was: New Feature)
> Support the limit push
[
https://issues.apache.org/jira/browse/FLINK-19647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-19647:
--
Summary: Support the limit push down for the hbase connector (was: Support
limit push down
Shengkai Fang created FLINK-19647:
-
Summary: Support limit push down for hbase connector
Key: FLINK-19647
URL: https://issues.apache.org/jira/browse/FLINK-19647
Project: Flink
Issue Type:
Shengkai Fang created FLINK-19651:
-
Summary: Support filter push down for the Jdbc connector
Key: FLINK-19651
URL: https://issues.apache.org/jira/browse/FLINK-19651
Project: Flink
Issue
Shengkai Fang created FLINK-19650:
-
Summary: Support the limit push down for the Jdbc connector
Key: FLINK-19650
URL: https://issues.apache.org/jira/browse/FLINK-19650
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-19647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-19647:
--
Summary: Support limit push down for the hbase connector (was: Support
limit push down for
Shengkai Fang created FLINK-19648:
-
Summary: Support nested projection push down for hbase connector
Key: FLINK-19648
URL: https://issues.apache.org/jira/browse/FLINK-19648
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-19648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-19648:
--
Parent: FLINK-16987
Issue Type: Sub-task (was: New Feature)
> Support the nested
[
https://issues.apache.org/jira/browse/FLINK-19648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-19648:
--
Summary: Support nested projection push down for the hbase connector (was:
Support nested
[
https://issues.apache.org/jira/browse/FLINK-19648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-19648:
--
Summary: Support the nested projection push down for the hbase connector
(was: Support
[
https://issues.apache.org/jira/browse/FLINK-19651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-19651:
--
Parent: FLINK-16987
Issue Type: Sub-task (was: New Feature)
> Support filter push
[
https://issues.apache.org/jira/browse/FLINK-19639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-19639:
--
Description:
Support to push nested projection into {{TableSourceScan}}. But it may cause
Shengkai Fang created FLINK-19639:
-
Summary: Support SupportsNestedProjectionPushDown in planner
Key: FLINK-19639
URL: https://issues.apache.org/jira/browse/FLINK-19639
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-19639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17213764#comment-17213764
]
Shengkai Fang commented on FLINK-19639:
---
CC [~godfreyhe] [~jark]
> Support
[
https://issues.apache.org/jira/browse/FLINK-18826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17185716#comment-17185716
]
Shengkai Fang commented on FLINK-18826:
---
hi, all. I think it's a good idea to add an option such
Shengkai Fang created FLINK-19282:
-
Summary: Support watermark push down with WatermarkStrategy
Key: FLINK-19282
URL: https://issues.apache.org/jira/browse/FLINK-19282
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-17940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-17940:
--
Environment:
Docker Environment:
zookeeper:
image: wurstmeister/zookeeper:3.4.6
ports:
-
[
https://issues.apache.org/jira/browse/FLINK-17948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-17948:
--
Description:
My job is following:
{code:java}
CREATE TABLE currency (
currency_id
[
https://issues.apache.org/jira/browse/FLINK-17948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-17948:
--
Attachment: image-2020-05-26-22-58-02-326.png
> Strange precision performance of Timestamp
Shengkai Fang created FLINK-17948:
-
Summary: Strange precision performance of Timestamp and Decimal
Key: FLINK-17948
URL: https://issues.apache.org/jira/browse/FLINK-17948
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-17948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-17948:
--
Description:
My job is following:
{code:java}
CREATE TABLE currency (
currency_id
[
https://issues.apache.org/jira/browse/FLINK-17948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-17948:
--
Attachment: image-2020-05-26-22-56-43-835.png
> Strange precision performance of Timestamp
Shengkai Fang created FLINK-18006:
-
Summary: It will throw Invalid lambda deserialization Exception
when writing to elastic search with new format
Key: FLINK-18006
URL:
[
https://issues.apache.org/jira/browse/FLINK-17908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-17908:
--
Description: Currently Flink doesn't offer any default config value for
Kafka and use the
Shengkai Fang created FLINK-17908:
-
Summary: Vague document about Kafka config in SQL-CLI
Key: FLINK-17908
URL: https://issues.apache.org/jira/browse/FLINK-17908
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-18006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-18006:
--
Priority: Critical (was: Major)
> It will throw Invalid lambda deserialization Exception
[
https://issues.apache.org/jira/browse/FLINK-18021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120547#comment-17120547
]
Shengkai Fang edited comment on FLINK-18021 at 5/31/20, 2:08 PM:
-
It
[
https://issues.apache.org/jira/browse/FLINK-18021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120547#comment-17120547
]
Shengkai Fang commented on FLINK-18021:
---
It seems huge work if we test every pair of connectors!
[
https://issues.apache.org/jira/browse/FLINK-18006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120553#comment-17120553
]
Shengkai Fang commented on FLINK-18006:
---
It seems that it just can't write data into
Shengkai Fang created FLINK-17940:
-
Summary: It will throw NullPointerException when write data with
Avro format using new property key in SQL-Client
Key: FLINK-17940
URL:
[
https://issues.apache.org/jira/browse/FLINK-18667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17162609#comment-17162609
]
Shengkai Fang commented on FLINK-18667:
---
Hi, [~lzljs3620320] I am interested in this jiar. Could
[
https://issues.apache.org/jira/browse/FLINK-18857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-18857:
--
Description:
Currently when we use code below
{code:java}
new
[
https://issues.apache.org/jira/browse/FLINK-18857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17173603#comment-17173603
]
Shengkai Fang commented on FLINK-18857:
---
cc [~jark]
> Invalid lambda deserialization when use
Shengkai Fang created FLINK-18857:
-
Summary: Invalid lambda deserialization when use
ElasticsearchSink#Builder to build ElasticserachSink
Key: FLINK-18857
URL: https://issues.apache.org/jira/browse/FLINK-18857
[
https://issues.apache.org/jira/browse/FLINK-18779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17172112#comment-17172112
]
Shengkai Fang commented on FLINK-18779:
---
Hi [~jark], I am interested in this jira. Could you
[
https://issues.apache.org/jira/browse/FLINK-18240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17150247#comment-17150247
]
Shengkai Fang commented on FLINK-18240:
---
Hi [~jark] I'm very interested in this issue. Could you
Shengkai Fang created FLINK-18602:
-
Summary: Support specific offset for topic list for kafka
connector in table api
Key: FLINK-18602
URL: https://issues.apache.org/jira/browse/FLINK-18602
Project:
[
https://issues.apache.org/jira/browse/FLINK-18449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17157848#comment-17157848
]
Shengkai Fang commented on FLINK-18449:
---
Hi, all. I find that FlinkKafkaProducer doesn't support
[
https://issues.apache.org/jira/browse/FLINK-18602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-18602:
--
Description:
During FLINK-18449, we decide to support topic discovery for kafka connector in
[
https://issues.apache.org/jira/browse/FLINK-18449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151472#comment-17151472
]
Shengkai Fang commented on FLINK-18449:
---
I'm also fine with [~jark]'s proposal.
Although
[
https://issues.apache.org/jira/browse/FLINK-15221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17149050#comment-17149050
]
Shengkai Fang commented on FLINK-15221:
---
According to [FLIP-122
[
https://issues.apache.org/jira/browse/FLINK-18449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17149183#comment-17149183
]
Shengkai Fang commented on FLINK-18449:
---
It's my pleasure to work on this.
For the first
[
https://issues.apache.org/jira/browse/FLINK-18351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142594#comment-17142594
]
Shengkai Fang commented on FLINK-18351:
---
The reason why we have repeated logs is that
[
https://issues.apache.org/jira/browse/FLINK-18351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142594#comment-17142594
]
Shengkai Fang edited comment on FLINK-18351 at 6/23/20, 3:36 AM:
-
The
[
https://issues.apache.org/jira/browse/FLINK-18351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142905#comment-17142905
]
Shengkai Fang commented on FLINK-18351:
---
OK, I will fix this problem soon.
> ModuleManager
[
https://issues.apache.org/jira/browse/FLINK-14719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17147741#comment-17147741
]
Shengkai Fang commented on FLINK-14719:
---
In release 1.11, we still can't set `semantic` in
[
https://issues.apache.org/jira/browse/FLINK-14719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang reopened FLINK-14719:
---
> Making Semantic configurable in Flinkkafkaproducer to support exactly-once
> semantic in
[
https://issues.apache.org/jira/browse/FLINK-18449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-18449:
--
Description: In streaming api, we can use regex to find topic and enable
partiton discovery
[
https://issues.apache.org/jira/browse/FLINK-18449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-18449:
--
Description: In streaming api, we can use regex to find topic and enable
partiton discovery
Shengkai Fang created FLINK-18449:
-
Summary: Make topic discovery and partition discovery configurable
for FlinkKafkaConsumer in Table API
Key: FLINK-18449
URL: https://issues.apache.org/jira/browse/FLINK-18449
Shengkai Fang created FLINK-18296:
-
Summary: Add support for datetype TIMESTAMP_WITH_LOCAL_ZONE for
Json format
Key: FLINK-18296
URL: https://issues.apache.org/jira/browse/FLINK-18296
Project: Flink
Shengkai Fang created FLINK-18299:
-
Summary: Add keyword in json format to parse timestamp in
different standard
Key: FLINK-18299
URL: https://issues.apache.org/jira/browse/FLINK-18299
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-18296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-18296:
--
Parent: FLINK-17752
Issue Type: Sub-task (was: Bug)
> Add support for datetype
[
https://issues.apache.org/jira/browse/FLINK-18299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-18299:
--
Description:
Add keyword such as 'timestamp-format.standard' in json format to parse
[
https://issues.apache.org/jira/browse/FLINK-18299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-18299:
--
Parent: FLINK-17752
Issue Type: Sub-task (was: Bug)
> Add keyword in json format to
[
https://issues.apache.org/jira/browse/FLINK-18390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17140948#comment-17140948
]
Shengkai Fang commented on FLINK-18390:
---
Hi, [~jark]. I am willing to help. Please assign it to
[
https://issues.apache.org/jira/browse/FLINK-17544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17138957#comment-17138957
]
Shengkai Fang commented on FLINK-17544:
---
It seems that TableJdbcUpsertOutputFormat exits
[
https://issues.apache.org/jira/browse/FLINK-18093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang closed FLINK-18093.
-
Resolution: Fixed
> E2E tests manually for Elasticsearch Sink
>
Shengkai Fang created FLINK-18176:
-
Summary: Add supplement for file system connector document
Key: FLINK-18176
URL: https://issues.apache.org/jira/browse/FLINK-18176
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-18026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17127854#comment-17127854
]
Shengkai Fang commented on FLINK-18026:
---
Currently we have cases: KafkaAvro2Kafka, KafkaCsv2Kafka
[
https://issues.apache.org/jira/browse/FLINK-18093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17127853#comment-17127853
]
Shengkai Fang edited comment on FLINK-18093 at 6/8/20, 3:48 AM:
[
https://issues.apache.org/jira/browse/FLINK-18028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17127861#comment-17127861
]
Shengkai Fang commented on FLINK-18028:
---
Currently we have cases: KafkaJoinJdbc2AppendJdbc and
[
https://issues.apache.org/jira/browse/FLINK-18093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17127853#comment-17127853
]
Shengkai Fang commented on FLINK-18093:
---
Currently we have cases: Kafka2AppendEs,
[
https://issues.apache.org/jira/browse/FLINK-18028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang closed FLINK-18028.
-
Resolution: Fixed
> E2E tests manually for MySQL JDBC
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-18026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang closed FLINK-18026.
-
Resolution: Fixed
> E2E tests manually for Kafka connector and all formats
>
[
https://issues.apache.org/jira/browse/FLINK-18616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159147#comment-17159147
]
Shengkai Fang commented on FLINK-18616:
---
Hi, [~lzljs3620320] I am interested in this issue. Could
[
https://issues.apache.org/jira/browse/FLINK-18747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17166852#comment-17166852
]
Shengkai Fang commented on FLINK-18747:
---
[~lhao] Yes. Debezium uses the same json format.
> Make
[
https://issues.apache.org/jira/browse/FLINK-18747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17166839#comment-17166839
]
Shengkai Fang commented on FLINK-18747:
---
Currently, we have implemented TIMESTAMP_WITH_LOCAL_ZONE
[
https://issues.apache.org/jira/browse/FLINK-16528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17161858#comment-17161858
]
Shengkai Fang commented on FLINK-16528:
---
Hi, [~app-tarush] I am also interested in this jira. Do
[
https://issues.apache.org/jira/browse/FLINK-17427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17161964#comment-17161964
]
Shengkai Fang commented on FLINK-17427:
---
Hi, [~jark] I'm interested in this Jira. Could you assign
[
https://issues.apache.org/jira/browse/FLINK-16384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17161969#comment-17161969
]
Shengkai Fang commented on FLINK-16384:
---
Hi, [~jark]. Could you assign it to me? It's my pleasure
[
https://issues.apache.org/jira/browse/FLINK-16528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-16528:
--
Attachment: PushProjectIntoTableSourceScanRule.java
> Support Limit push down for streaming
[
https://issues.apache.org/jira/browse/FLINK-16528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-16528:
--
Attachment: (was: PushProjectIntoTableSourceScanRule.java)
> Support Limit push down for
Shengkai Fang created FLINK-18958:
-
Summary: Lose column comment when create table
Key: FLINK-18958
URL: https://issues.apache.org/jira/browse/FLINK-18958
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-20880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-20880:
--
Component/s: (was: API / Core)
Formats (JSON, Avro, Parquet, ORC,
[
https://issues.apache.org/jira/browse/FLINK-20273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-20273:
--
Description:
The
Shengkai Fang created FLINK-20273:
-
Summary: Fix Table api Kafka connector Sink Partitioner Document
Error
Key: FLINK-20273
URL: https://issues.apache.org/jira/browse/FLINK-20273
Project: Flink
Shengkai Fang created FLINK-20271:
-
Summary: ArrayIndexOutOfBounds When using Rank
Key: FLINK-20271
URL: https://issues.apache.org/jira/browse/FLINK-20271
Project: Flink
Issue Type: Bug
Shengkai Fang created FLINK-20272:
-
Summary: Wrong result of Rank Function
Key: FLINK-20272
URL: https://issues.apache.org/jira/browse/FLINK-20272
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-20362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239014#comment-17239014
]
Shengkai Fang commented on FLINK-20362:
---
ok. I will fix it.
> Broken Link in
[
https://issues.apache.org/jira/browse/FLINK-20370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239139#comment-17239139
]
Shengkai Fang commented on FLINK-20370:
---
I am not sure whether this Jira will take the example
[
https://issues.apache.org/jira/browse/FLINK-20372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239152#comment-17239152
]
Shengkai Fang commented on FLINK-20372:
---
ok. Please assign it to me.
> flink sql kafka connector
Shengkai Fang created FLINK-20321:
-
Summary: Get NPE when using AvroDeserializationSchema to
deserialize null input
Key: FLINK-20321
URL: https://issues.apache.org/jira/browse/FLINK-20321
Project:
[
https://issues.apache.org/jira/browse/FLINK-20314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17238474#comment-17238474
]
Shengkai Fang commented on FLINK-20314:
---
Please assign it to me [~jark] . I will fix it.
> Empty
[
https://issues.apache.org/jira/browse/FLINK-20121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17235996#comment-17235996
]
Shengkai Fang edited comment on FLINK-20121 at 11/25/20, 8:45 AM:
--
E2E
[
https://issues.apache.org/jira/browse/FLINK-20121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17235996#comment-17235996
]
Shengkai Fang edited comment on FLINK-20121 at 11/25/20, 8:46 AM:
--
E2E
[
https://issues.apache.org/jira/browse/FLINK-20121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang closed FLINK-20121.
-
Resolution: Fixed
> Test the upsert-kafka Connector
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-20734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254365#comment-17254365
]
Shengkai Fang commented on FLINK-20734:
---
Could you give us more information about how to reproduce
[
https://issues.apache.org/jira/browse/FLINK-20760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-20760:
--
Description: The link in pic is broken. The [usage of Java
[
https://issues.apache.org/jira/browse/FLINK-20760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-20760:
--
Description: The link in pic is broken. The [usage of Java
[
https://issues.apache.org/jira/browse/FLINK-20760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang updated FLINK-20760:
--
Attachment: image-2020-12-24-15-56-04-643.png
> Broken doc link in Apache Flink Code Style
Shengkai Fang created FLINK-20760:
-
Summary: Broken doc link in Apache Flink Code Style and Quality
Guide
Key: FLINK-20760
URL: https://issues.apache.org/jira/browse/FLINK-20760
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-20760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254733#comment-17254733
]
Shengkai Fang commented on FLINK-20760:
---
[~liqi25] Sure.
> Broken doc link in Apache Flink Code
[
https://issues.apache.org/jira/browse/FLINK-17752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang closed FLINK-17752.
-
Resolution: Fixed
> Align the timestamp format with Flink SQL types in JSON format
>
[
https://issues.apache.org/jira/browse/FLINK-20128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231347#comment-17231347
]
Shengkai Fang commented on FLINK-20128:
---
[~dian.fu] In my local enviroment, my java code are
[
https://issues.apache.org/jira/browse/FLINK-20128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231243#comment-17231243
]
Shengkai Fang commented on FLINK-20128:
---
I don't get the expected bug by sql-client and java table
[
https://issues.apache.org/jira/browse/FLINK-18784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17233197#comment-17233197
]
Shengkai Fang commented on FLINK-18784:
---
This work has been done during the watermark push down.
1 - 100 of 1004 matches
Mail list logo