[
https://issues.apache.org/jira/browse/FLINK-27708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zheng Hu updated FLINK-27708:
-
Fix Version/s: table-store-0.2.0
> Add background compaction task for append-only table when ingesting.
Zheng Hu created FLINK-27708:
Summary: Add background compaction task for append-only table when
ingesting.
Key: FLINK-27708
URL: https://issues.apache.org/jira/browse/FLINK-27708
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-27706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zheng Hu updated FLINK-27706:
-
Fix Version/s: table-store-0.2.0
> Refactor all subclasses of FileStoreTableITCase to use the batchSql.
Zheng Hu created FLINK-27706:
Summary: Refactor all subclasses of FileStoreTableITCase to use
the batchSql.
Key: FLINK-27706
URL: https://issues.apache.org/jira/browse/FLINK-27706
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-27679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zheng Hu updated FLINK-27679:
-
Fix Version/s: table-store-0.2.0
> Support append-only table for log store.
>
[
https://issues.apache.org/jira/browse/FLINK-27696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zheng Hu updated FLINK-27696:
-
Fix Version/s: table-store-0.2.0
> Add bin-pack strategy to split the whole bucket data files into
Zheng Hu created FLINK-27696:
Summary: Add bin-pack strategy to split the whole bucket data
files into several small splits for append-only table.
Key: FLINK-27696
URL:
Zheng Hu created FLINK-27679:
Summary: Support append-only table for log store.
Key: FLINK-27679
URL: https://issues.apache.org/jira/browse/FLINK-27679
Project: Flink
Issue Type: Sub-task
Zheng Hu created FLINK-27678:
Summary: Support append-only table for file store.
Key: FLINK-27678
URL: https://issues.apache.org/jira/browse/FLINK-27678
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-27655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zheng Hu updated FLINK-27655:
-
Fix Version/s: table-store-0.2.0
> Implement Avro File statistic collector
>
[
https://issues.apache.org/jira/browse/FLINK-27656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zheng Hu updated FLINK-27656:
-
Fix Version/s: table-store-0.2.0
> Add parquet file format
>
>
>
Zheng Hu created FLINK-27656:
Summary: Add parquet file format
Key: FLINK-27656
URL: https://issues.apache.org/jira/browse/FLINK-27656
Project: Flink
Issue Type: Sub-task
Reporter:
Zheng Hu created FLINK-27655:
Summary: Implement Avro File statistic collector
Key: FLINK-27655
URL: https://issues.apache.org/jira/browse/FLINK-27655
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-27543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zheng Hu updated FLINK-27543:
-
Summary: Hide column statistics inside the file format writer. (was:
Introduce StatsProducer to
[
https://issues.apache.org/jira/browse/FLINK-27543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zheng Hu updated FLINK-27543:
-
Summary: Hide column statistics collector inside the file format writer.
(was: Hide column statistics
[
https://issues.apache.org/jira/browse/FLINK-27543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zheng Hu updated FLINK-27543:
-
Parent: FLINK-27307
Issue Type: Sub-task (was: Improvement)
> Introduce StatsProducer to
[
https://issues.apache.org/jira/browse/FLINK-27543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17533666#comment-17533666
]
Zheng Hu commented on FLINK-27543:
--
I think a better approach is hiding the `fileStatsExtractor` or
Zheng Hu created FLINK-27553:
Summary: Clarify the semantic of RecordWriter interface.
Key: FLINK-27553
URL: https://issues.apache.org/jira/browse/FLINK-27553
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-27546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zheng Hu updated FLINK-27546:
-
Fix Version/s: table-store-0.2.0
> Add append only writer which implements the RecordWriter interface.
Zheng Hu created FLINK-27546:
Summary: Add append only writer which implements the RecordWriter
interface.
Key: FLINK-27546
URL: https://issues.apache.org/jira/browse/FLINK-27546
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-27517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zheng Hu updated FLINK-27517:
-
Fix Version/s: table-store-0.2.0
> Introduce rolling file writer to write one record each time for
Zheng Hu created FLINK-27517:
Summary: Introduce rolling file writer to write one record each
time for append-only table.
Key: FLINK-27517
URL: https://issues.apache.org/jira/browse/FLINK-27517
Project:
Zheng Hu created FLINK-27307:
Summary: Flink table store support append-only ingestion without
primary keys.
Key: FLINK-27307
URL: https://issues.apache.org/jira/browse/FLINK-27307
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-14620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451463#comment-17451463
]
Zheng Hu commented on FLINK-14620:
--
[~MartijnVisser], I don't work on this now, anyone who is
[
https://issues.apache.org/jira/browse/FLINK-21247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17313779#comment-17313779
]
Zheng Hu commented on FLINK-21247:
--
I think this will need to get merged in flink 1.13.0, otherwise
[
https://issues.apache.org/jira/browse/FLINK-21634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17302180#comment-17302180
]
Zheng Hu commented on FLINK-21634:
--
Thanks for the update, Looks good to me (from iceberg
[
https://issues.apache.org/jira/browse/FLINK-21634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17297965#comment-17297965
]
Zheng Hu commented on FLINK-21634:
--
+1, I'm currently working for building open source flink data lake
[
https://issues.apache.org/jira/browse/FLINK-21494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zheng Hu updated FLINK-21494:
-
Description:
I have two databases in my iceberg catalog, one is `default`, another one is
`test_db`.
[
https://issues.apache.org/jira/browse/FLINK-21494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zheng Hu updated FLINK-21494:
-
Description:
I have two databases in my iceberg catalog, one is `default`, another one is
`test_db`.
[
https://issues.apache.org/jira/browse/FLINK-21494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zheng Hu updated FLINK-21494:
-
Attachment: stacktrace.txt
> Could not execute statement 'USE `default`' in Flink SQL client
>
[
https://issues.apache.org/jira/browse/FLINK-21494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17290627#comment-17290627
]
Zheng Hu commented on FLINK-21494:
--
CC [~danny0405], [~fsk119], [~jark]
> Could not execute statement
Zheng Hu created FLINK-21494:
Summary: Could not execute statement 'USE `default`' in Flink SQL
client
Key: FLINK-21494
URL: https://issues.apache.org/jira/browse/FLINK-21494
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-21247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278483#comment-17278483
]
Zheng Hu edited comment on FLINK-21247 at 2/4/21, 2:24 AM:
---
[~jark], Assume
[
https://issues.apache.org/jira/browse/FLINK-21247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278483#comment-17278483
]
Zheng Hu commented on FLINK-21247:
--
[~jark], Assume that there are 5 records in iceberg table ( table
[
https://issues.apache.org/jira/browse/FLINK-20380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239553#comment-17239553
]
Zheng Hu commented on FLINK-20380:
--
Would you mind to check your jars ? Pls extract the jar and find
[
https://issues.apache.org/jira/browse/FLINK-20380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239551#comment-17239551
]
Zheng Hu commented on FLINK-20380:
--
I guess you have included a hive-metastore jar which is older than
[
https://issues.apache.org/jira/browse/FLINK-20380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239259#comment-17239259
]
Zheng Hu commented on FLINK-20380:
--
Here is the document for how to use flink with iceberg ,
[
https://issues.apache.org/jira/browse/FLINK-20380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239258#comment-17239258
]
Zheng Hu commented on FLINK-20380:
--
I think you may used a wrong version for
[
https://issues.apache.org/jira/browse/FLINK-14620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17155046#comment-17155046
]
Zheng Hu commented on FLINK-14620:
--
[~karmagyz] Please go ahead ,Mind to assign this issue to
[
https://issues.apache.org/jira/browse/FLINK-18049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17123939#comment-17123939
]
Zheng Hu commented on FLINK-18049:
--
> The Flink's documentation refers to "Avro type state" ..
Got
[
https://issues.apache.org/jira/browse/FLINK-18049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17123902#comment-17123902
]
Zheng Hu commented on FLINK-18049:
--
Thanks for your reply, [~dwysakowicz].
I read the flink document
[
https://issues.apache.org/jira/browse/FLINK-18049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17123796#comment-17123796
]
Zheng Hu commented on FLINK-18049:
--
Ping [~tiwalter], [~dwysakowicz], [~sewen] Thanks.
> The Flink
[
https://issues.apache.org/jira/browse/FLINK-18049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17121030#comment-17121030
]
Zheng Hu commented on FLINK-18049:
--
After digging into the code, we found that the
Zheng Hu created FLINK-18049:
Summary: The Flink kafka consumer job will be interrupted if the
upstream kafka producer change the AVRO schema
Key: FLINK-18049
URL: https://issues.apache.org/jira/browse/FLINK-18049
[
https://issues.apache.org/jira/browse/FLINK-14359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17116486#comment-17116486
]
Zheng Hu commented on FLINK-14359:
--
[~DaDaShen] I'm not working on this issue any more, if you are
[
https://issues.apache.org/jira/browse/FLINK-14505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17002769#comment-17002769
]
Zheng Hu commented on FLINK-14505:
--
Run this cases several times under my hosts, seems all good now.
[
https://issues.apache.org/jira/browse/FLINK-15319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17000564#comment-17000564
]
Zheng Hu commented on FLINK-15319:
--
I guess it was timeout to download the kafka binary packages
[
https://issues.apache.org/jira/browse/FLINK-14505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1606#comment-1606
]
Zheng Hu commented on FLINK-14505:
--
The Kafka SQL e2e tests have been disabled by [~gjy], I've tried
[
https://issues.apache.org/jira/browse/FLINK-14505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16995274#comment-16995274
]
Zheng Hu commented on FLINK-14505:
--
I was attending a training since the last two weeks ( sorry about
[
https://issues.apache.org/jira/browse/FLINK-14941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16983073#comment-16983073
]
Zheng Hu commented on FLINK-14941:
--
> but I agree with you we should only re-scan if it is an HBase
[
https://issues.apache.org/jira/browse/FLINK-14941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16981553#comment-16981553
]
Zheng Hu commented on FLINK-14941:
--
FYI [~jark].
> The AbstractTableInputFormat#nextRecord in hbase
Zheng Hu created FLINK-14941:
Summary: The AbstractTableInputFormat#nextRecord in hbase
connector will handle the same rowkey twice once encountered any exception
Key: FLINK-14941
URL:
[
https://issues.apache.org/jira/browse/FLINK-14672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16978941#comment-16978941
]
Zheng Hu commented on FLINK-14672:
--
Ping [~twalthr] [~ykt836] for reviewing.
> Make Executor stateful
[
https://issues.apache.org/jira/browse/FLINK-14505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16978939#comment-16978939
]
Zheng Hu commented on FLINK-14505:
--
Well, let me retry the test under my host, Thanks for the feedback
[
https://issues.apache.org/jira/browse/FLINK-14672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16978118#comment-16978118
]
Zheng Hu commented on FLINK-14672:
--
[
https://issues.apache.org/jira/browse/FLINK-14672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16978037#comment-16978037
]
Zheng Hu edited comment on FLINK-14672 at 11/20/19 6:51 AM:
Now we only have
[
https://issues.apache.org/jira/browse/FLINK-14672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16978037#comment-16978037
]
Zheng Hu commented on FLINK-14672:
--
Now we only have the embedded mode SQL to interact with Flink
[
https://issues.apache.org/jira/browse/FLINK-14505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16972241#comment-16972241
]
Zheng Hu commented on FLINK-14505:
--
Checked the log message:
{code}
[
https://issues.apache.org/jira/browse/FLINK-14505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16972217#comment-16972217
]
Zheng Hu commented on FLINK-14505:
--
Thanks all the feedbacks, let me take a look.
> SQL Client
Zheng Hu created FLINK-14703:
Summary: Port the Kafka SQL related tests.
Key: FLINK-14703
URL: https://issues.apache.org/jira/browse/FLINK-14703
Project: Flink
Issue Type: Sub-task
Zheng Hu created FLINK-14702:
Summary: Rewrite the tpch ( test_tpch.sh ) e2e tests by using the
newly introduced java framework
Key: FLINK-14702
URL: https://issues.apache.org/jira/browse/FLINK-14702
Zheng Hu created FLINK-14700:
Summary: Consider to set the random listen port in e2e flink
cluster.
Key: FLINK-14700
URL: https://issues.apache.org/jira/browse/FLINK-14700
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-14620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zheng Hu updated FLINK-14620:
-
Attachment: FLINK-14620.v01.patch
> Rewrite the elasticsearch related end-to-end tests by using the
Zheng Hu created FLINK-14620:
Summary: Rewrite the elasticsearch related end-to-end tests by
using the newly introduce e2e java framework
Key: FLINK-14620
URL: https://issues.apache.org/jira/browse/FLINK-14620
[
https://issues.apache.org/jira/browse/FLINK-11463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16958637#comment-16958637
]
Zheng Hu commented on FLINK-11463:
--
Thanks [~chesnay], Mind you help to assign this to me ? ( I will
[
https://issues.apache.org/jira/browse/FLINK-13195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16958635#comment-16958635
]
Zheng Hu commented on FLINK-13195:
--
Another question which is related to the previous comment :for
[
https://issues.apache.org/jira/browse/FLINK-13195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16958632#comment-16958632
]
Zheng Hu commented on FLINK-13195:
--
One small question: I found that we cannot accomplish the work
[
https://issues.apache.org/jira/browse/FLINK-11463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16958455#comment-16958455
]
Zheng Hu commented on FLINK-11463:
--
Ping [~chesnay] :-)
> Rework end-to-end tests in Java
>
[
https://issues.apache.org/jira/browse/FLINK-11463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16957588#comment-16957588
]
Zheng Hu commented on FLINK-11463:
--
[~chesnay], Are you working on this issues ? If not, I can make
[
https://issues.apache.org/jira/browse/FLINK-13195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16954446#comment-16954446
]
Zheng Hu commented on FLINK-13195:
--
One thing we may need to notice is: If we are in a LocalExecutor
[
https://issues.apache.org/jira/browse/FLINK-13195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16954315#comment-16954315
]
Zheng Hu commented on FLINK-13195:
--
Talked with [~danny0405] offline, he is working on some other
Zheng Hu created FLINK-14446:
Summary: Design a Java end to end test framework for supporting
more external system
Key: FLINK-14446
URL: https://issues.apache.org/jira/browse/FLINK-14446
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-14359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16951815#comment-16951815
]
Zheng Hu commented on FLINK-14359:
--
When sending bytes of Cell to HBase regionserver, the hbase client
[
https://issues.apache.org/jira/browse/FLINK-14359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16951583#comment-16951583
]
Zheng Hu commented on FLINK-14359:
--
When I'm running a testing sql query in my standalone env, I find
[
https://issues.apache.org/jira/browse/FLINK-14359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16949271#comment-16949271
]
Zheng Hu commented on FLINK-14359:
--
When run the sql-client using the packed shaded hbase lib, I found
[
https://issues.apache.org/jira/browse/FLINK-14359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16949112#comment-16949112
]
Zheng Hu commented on FLINK-14359:
--
[~jark], Thanks for your information, let me have a try..
>
[
https://issues.apache.org/jira/browse/FLINK-14359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16949091#comment-16949091
]
Zheng Hu commented on FLINK-14359:
--
One question: should we shaded the hadoop dependencies into
[
https://issues.apache.org/jira/browse/FLINK-14359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16949056#comment-16949056
]
Zheng Hu commented on FLINK-14359:
--
Creating the flink-sql-connector-hbase module is easy, the problem
[
https://issues.apache.org/jira/browse/FLINK-14359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16948164#comment-16948164
]
Zheng Hu commented on FLINK-14359:
--
Also FYI [~jark]
> Create a module called
[
https://issues.apache.org/jira/browse/FLINK-14359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16948163#comment-16948163
]
Zheng Hu commented on FLINK-14359:
--
[~lzljs3620320] I'm interested in this task, Mind to let me
Zheng Hu created FLINK-14349:
Summary: Create a Connector Descriptor for HBase so that user can
connect HBase by TableEnvironment#connect
Key: FLINK-14349
URL: https://issues.apache.org/jira/browse/FLINK-14349
81 matches
Mail list logo
