Jun Zhang created FLINK-32819:
-
Summary: flink can not parse the param `#` correctly in k8s
application mode
Key: FLINK-32819
URL: https://issues.apache.org/jira/browse/FLINK-32819
Project: Flink
Jun Zhang created FLINK-31459:
-
Summary: add UPDATE COLUMN POSITION for flink table store
Key: FLINK-31459
URL: https://issues.apache.org/jira/browse/FLINK-31459
Project: Flink
Issue Type
Jun Zhang created FLINK-31338:
-
Summary: support infer parallelism for flink table store
Key: FLINK-31338
URL: https://issues.apache.org/jira/browse/FLINK-31338
Project: Flink
Issue Type
Jun Zhang created FLINK-31258:
-
Summary: can not get kerberos keytab in flink operator
Key: FLINK-31258
URL: https://issues.apache.org/jira/browse/FLINK-31258
Project: Flink
Issue Type: Bug
Jun Zhang created FLINK-31224:
-
Summary: Add metrics for flink table store
Key: FLINK-31224
URL: https://issues.apache.org/jira/browse/FLINK-31224
Project: Flink
Issue Type: Improvement
Jun Zhang created FLINK-31128:
-
Summary: Add Create Table As for flink table store
Key: FLINK-31128
URL: https://issues.apache.org/jira/browse/FLINK-31128
Project: Flink
Issue Type: Improvement
Jun Zhang created FLINK-31028:
-
Summary: Provide different compression methods for per level
Key: FLINK-31028
URL: https://issues.apache.org/jira/browse/FLINK-31028
Project: Flink
Issue Type
Jun Zhang created FLINK-31011:
-
Summary: upgrade hiverunner version
Key: FLINK-31011
URL: https://issues.apache.org/jira/browse/FLINK-31011
Project: Flink
Issue Type: Improvement
Jun Zhang created FLINK-30871:
-
Summary: add bloom filter for orc
Key: FLINK-30871
URL: https://issues.apache.org/jira/browse/FLINK-30871
Project: Flink
Issue Type: Improvement
Jun Zhang created FLINK-30608:
-
Summary: support rename table
Key: FLINK-30608
URL: https://issues.apache.org/jira/browse/FLINK-30608
Project: Flink
Issue Type: Improvement
Reporter
Jun Zhang created FLINK-30595:
-
Summary: support create table like
Key: FLINK-30595
URL: https://issues.apache.org/jira/browse/FLINK-30595
Project: Flink
Issue Type: Improvement
Jun Zhang created FLINK-23955:
-
Summary: submit flink sql job error when flink HA on yarn is
configured
Key: FLINK-23955
URL: https://issues.apache.org/jira/browse/FLINK-23955
Project: Flink
Jun Zhang created FLINK-22975:
-
Summary: Specify port or range for k8s service
Key: FLINK-22975
URL: https://issues.apache.org/jira/browse/FLINK-22975
Project: Flink
Issue Type: Improvement
Jun Zhang created FLINK-22591:
-
Summary: add sub interface MapColumnVector for ColumnVector
Key: FLINK-22591
URL: https://issues.apache.org/jira/browse/FLINK-22591
Project: Flink
Issue Type
Jun Zhang created FLINK-21286:
-
Summary: Support BUCKET for flink sql CREATE TABLE
Key: FLINK-21286
URL: https://issues.apache.org/jira/browse/FLINK-21286
Project: Flink
Issue Type: Improvement
Jun Zhang created FLINK-21285:
-
Summary: Support MERGE INTO for flink sql
Key: FLINK-21285
URL: https://issues.apache.org/jira/browse/FLINK-21285
Project: Flink
Issue Type: Improvement
Jun Zhang created FLINK-21283:
-
Summary: Support sql extension for flink sql
Key: FLINK-21283
URL: https://issues.apache.org/jira/browse/FLINK-21283
Project: Flink
Issue Type: Improvement
Jun Zhang created FLINK-21282:
-
Summary: Support UPDATE for flink sql
Key: FLINK-21282
URL: https://issues.apache.org/jira/browse/FLINK-21282
Project: Flink
Issue Type: Improvement
Jun Zhang created FLINK-21281:
-
Summary: Support DELETE FROM for flink sql
Key: FLINK-21281
URL: https://issues.apache.org/jira/browse/FLINK-21281
Project: Flink
Issue Type: Improvement
Jun Zhang created FLINK-21198:
-
Summary: Add show create table command support for flink sql client
Key: FLINK-21198
URL: https://issues.apache.org/jira/browse/FLINK-21198
Project: Flink
Issue
Jun Zhang created FLINK-21197:
-
Summary: DESC command in sql-client should show the column comment
Key: FLINK-21197
URL: https://issues.apache.org/jira/browse/FLINK-21197
Project: Flink
Issue
Jun Zhang created FLINK-20977:
-
Summary: can not use `use` command to switch database
Key: FLINK-20977
URL: https://issues.apache.org/jira/browse/FLINK-20977
Project: Flink
Issue Type: Bug
amework, which
> may cause problems.
>
> Re: "the system will throw an exception that the type does not match",
> could your system store partition values as string type?
>
> Best,
> Jark
>
> On Tue, 5 Jan 2021 at 14:09, Jun Zhang wrote:
>
> > hi ,Jack:
>
> Jark
>
>
> On Tue, 5 Jan 2021 at 13:43, Jun Zhang wrote:
>
> > Hello dev:
> > Now I encounter a problem when using the method
> > "Catalog#listPartitions(ObjectPath, CatalogPartitionSpec)".
> > I found that the partitionSpec type in Cata
Hello dev:
Now I encounter a problem when using the method
"Catalog#listPartitions(ObjectPath, CatalogPartitionSpec)".
I found that the partitionSpec type in CatalogPartitionSpec is
Map,
This is no problem for hivecatalog, but my subclass of Catalog needs
precise types. For example,
Jun Zhang created FLINK-20809:
-
Summary: the limit push down invalid when use filter
Key: FLINK-20809
URL: https://issues.apache.org/jira/browse/FLINK-20809
Project: Flink
Issue Type: Bug
Jun Zhang created FLINK-20767:
-
Summary: add nested field support for SupportsFilterPushDown
Key: FLINK-20767
URL: https://issues.apache.org/jira/browse/FLINK-20767
Project: Flink
Issue Type
Jun Zhang created FLINK-19896:
-
Summary: Support first-n-rows deduplication in the Deduplicate
operator
Key: FLINK-19896
URL: https://issues.apache.org/jira/browse/FLINK-19896
Project: Flink
Jun Zhang created FLINK-19358:
-
Summary: when submit job on application mode with HA,the jobid
will be 00
Key: FLINK-19358
URL: https://issues.apache.org/jira/browse/FLINK-19358
Project: Flink
Jun Zhang created FLINK-19254:
-
Summary: Invalid UTF-8 start byte exception
Key: FLINK-19254
URL: https://issues.apache.org/jira/browse/FLINK-19254
Project: Flink
Issue Type: Bug
7月29日周三 上午9:56写道：
> hi Jun,
>
> Currently, sql client has supported -u option, just like:
> ./bin/sql-client.sh embedded -u "insert_statement".
>
> There is already a JIRA [1] that wants to support -f option
>
> [1] https://issues.apache.org/jira/browse/FLINK-1282
I want to execute some flink sql batch jobs regularly, such as 'insert into
select .', but I can't find a suitable method so far, so reference
hive, I changed the source code and add a '--filename' parameter so
that we can execute a sql file.
like this:
/home/flink/bin/sql-client.sh embed
Jun Zhang created FLINK-18691:
-
Summary: add HiveCatalog Construction method with HiveConf
Key: FLINK-18691
URL: https://issues.apache.org/jira/browse/FLINK-18691
Project: Flink
Issue Type
Jun Zhang created FLINK-18549:
-
Summary: flink 1.11 can not commit partition automatically
Key: FLINK-18549
URL: https://issues.apache.org/jira/browse/FLINK-18549
Project: Flink
Issue Type: Bug
Jun Zhang created FLINK-18479:
-
Summary: can not commit partition when set partition time
Key: FLINK-18479
URL: https://issues.apache.org/jira/browse/FLINK-18479
Project: Flink
Issue Type: Bug
Jun Zhang created FLINK-16818:
-
Summary: Optimize data skew when flink write data to hive dynamic
partition table
Key: FLINK-16818
URL: https://issues.apache.org/jira/browse/FLINK-16818
Project: Flink
Jun Zhang created FLINK-16799:
-
Summary: add hive partition limit when read from hive
Key: FLINK-16799
URL: https://issues.apache.org/jira/browse/FLINK-16799
Project: Flink
Issue Type
Jun Zhang created FLINK-16731:
-
Summary: Support show partitions table command in sql client
Key: FLINK-16731
URL: https://issues.apache.org/jira/browse/FLINK-16731
Project: Flink
Issue Type
Jun Zhang created FLINK-16709:
-
Summary: add a set command to set job name when submit job on sql
client
Key: FLINK-16709
URL: https://issues.apache.org/jira/browse/FLINK-16709
Project: Flink
Jun Zhang created FLINK-16646:
-
Summary: flink read orc file throw a NullPointerException
Key: FLINK-16646
URL: https://issues.apache.org/jira/browse/FLINK-16646
Project: Flink
Issue Type: Bug
Jun Zhang created FLINK-16623:
-
Summary: add the shorthand 'desc' for describe on sql client
Key: FLINK-16623
URL: https://issues.apache.org/jira/browse/FLINK-16623
Project: Flink
Jun Zhang created FLINK-16539:
-
Summary: sql client set param error
Key: FLINK-16539
URL: https://issues.apache.org/jira/browse/FLINK-16539
Project: Flink
Issue Type: Bug
Components
If the data formats of the Multi-topics are different, what do you plan to do?
On 11/26/2019 08:53??leohttps://issues.apache.org/jira/browse/FLINK-14729
Best,
Leo
Jun Zhang created FLINK-14739:
-
Summary: add failOnCastException Configuration to Json
FormatDescriptor
Key: FLINK-14739
URL: https://issues.apache.org/jira/browse/FLINK-14739
Project: Flink
Hi,everyone:
In the current flink system, use flink sql to read data
and then write it to File System with kind of formats is not supported, the
current File System Connector is only experimental [1], so I have developed a
new File System Connector.
Thanks to the suggestion of Kurt
support the partition. I will send a DISCUSS later,I hope
you can help me review it, thank you.
Best Jun
-- Original --
From: Kurt Young https://flink.apache.org/contributing/contribute-code.html
Am Di., 17. Sept. 2019 um 04:39 Uhr schrieb Jun Zhang <825875...@qq.
a DISCUSS to explain my detailed design
ideas and implementation. How do you see it?
-- Original --
From: Fabian Hueske https://flink.apache.org/contributing/contribute-code.html
Am Di., 17. Sept. 2019 um 04:39 Uhr schrieb Jun Zhang <825875...@qq.
.
-- --
??: "Kurt Young"http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-FLIP-63-Rework-table-partition-support-td32770.html
>
>
> On Tue, Sep 17, 2019 at 10:39 AM Jun Zhang <825875...@qq.com> wrote:
>
>&
Jun Zhang created FLINK-10170:
-
Summary: Support map types in descriptor-based Table API
Key: FLINK-10170
URL: https://issues.apache.org/jira/browse/FLINK-10170
Project: Flink
Issue Type
Jun Zhang created FLINK-10079:
-
Summary: Automatically resolve and register sink table name from
external catalogs
Key: FLINK-10079
URL: https://issues.apache.org/jira/browse/FLINK-10079
Project: Flink
Jun Zhang created FLINK-10064:
-
Summary: Fixed a typo in ExternalCatalogTable
Key: FLINK-10064
URL: https://issues.apache.org/jira/browse/FLINK-10064
Project: Flink
Issue Type: Bug
Jun Zhang created FLINK-10061:
-
Summary: Fix unsupported configuration in KafkaTableSink
Key: FLINK-10061
URL: https://issues.apache.org/jira/browse/FLINK-10061
Project: Flink
Issue Type: Bug
Jun Zhang created FLINK-9444:
Summary: KafkaAvroTableSource failed to work for map fields
Key: FLINK-9444
URL: https://issues.apache.org/jira/browse/FLINK-9444
Project: Flink
Issue Type: Bug
Jun Zhang created FLINK-9384:
Summary: KafkaAvroTableSource failed to work due to type mismatch
Key: FLINK-9384
URL: https://issues.apache.org/jira/browse/FLINK-9384
Project: Flink
Issue Type
54 matches
Mail list logo
