dalongliu created FLINK-27660:
-
Summary: Table API support create function using customed jar
Key: FLINK-27660
URL: https://issues.apache.org/jira/browse/FLINK-27660
Project: Flink
Issue Type: Su
dalongliu created FLINK-27659:
-
Summary: Planner support to use jar which is registered by "USING
JAR" syntax
Key: FLINK-27659
URL: https://issues.apache.org/jira/browse/FLINK-27659
Project: Flink
dalongliu created FLINK-27658:
-
Summary: Introduce MutableURLClassLoader allow to register and
remove user jar dynamically
Key: FLINK-27658
URL: https://issues.apache.org/jira/browse/FLINK-27658
Project:
Hi Yuan!
> How about abtract the LookupCache to a higher level with a common Cache?
Can you give an example of such upper - level Cache usage? It's not
clear for me currently. I think it's unnecessary to have such high
level abstraction, if nowhere in the code we won't operate with
objects as ins
Hi, Jark, Timo. Nice to have an agreement!
Thanks for Jark's inputs about the multiple version Flink. I have already
updated the FLIP in the rejected alternatives about details.
1. We should definitely just use LogicalTypeJsonSerializer and not a second
JSON representation.
Our concern is mainly
Juntao Hu created FLINK-27657:
-
Summary: Implement remote operator state backend in PyFlink
Key: FLINK-27657
URL: https://issues.apache.org/jira/browse/FLINK-27657
Project: Flink
Issue Type: Sub-
Hi Godfrey,
Thanks for your reply.
Sounds good to me.
> I think we should also introduce a config option
We can add this option to the FLIP. I prefer a option for
FileSystemConnector, maybe a enum.
Best,
Jingsong
On Tue, May 17, 2022 at 10:31 AM godfrey he wrote:
> Hi Jingsong,
>
> Thanks f
Hi Jingsong,
Thanks for the feedback.
>One concern I have is that we read the footer for each file, and this may
>be a bit costly in some cases. Is it possible for us to have some
> hierarchical way
yes, if there are thousands of orc/parquet files, it may take a long time.
So we can introduce a
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: Z
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
Hi, everyone.
Thanks for your feedback for FLIP-229: Introduces Join Hint for Flink SQL Batch
Job[1] on the discussion thread[2].
I'd like to start a vote for it. The vote will be open for at least 72 hours
unless there is an objection or not enough votes.
--
Best！
Xuyang
[1]
https:/
Thanks Gyula. It looks good to me. I could do a favor during the release
also.
Please feel free to ping me to help the doc, release and test work :)
Best,
Aitozi
Yang Wang 于2022年5月16日周一 21:57写道：
> Thanks Gyula for sharing the progress. It is very likely we could have the
> first release candida
James Busche created FLINK-27654:
Summary: Older jackson-databind found in
/flink-kubernetes-shaded-1.0-SNAPSHOT.jar
Key: FLINK-27654
URL: https://issues.apache.org/jira/browse/FLINK-27654
Project: Fl
wawa created FLINK-27653:
Summary: Pulsar Connector bug: The startCursor has been setted
default value of "MessageId.earliest", Every time to restart the job，the
Consumer will do the seek operation.
Key: FLINK-27653
URL:
Hi Konstantin,
Maybe change it to the following:
1. POST: http://{jm_rest_address:port}/blocklist/taskmanagers/{id}
Merge is not allowed. If the {id} already exists, return error. Otherwise,
create a new item.
2. POST: http://{jm_rest_address:port}/blocklist/taskmanagers/{id}:merge
Merge is allo
Jane Chan created FLINK-27652:
-
Summary: CompactManager.Rewriter cannot handle different partition
keys invoked compaction
Key: FLINK-27652
URL: https://issues.apache.org/jira/browse/FLINK-27652
Project:
dalongliu created FLINK-27651:
-
Summary: Support CREATE FUNCTION USING JAR syntax
Key: FLINK-27651
URL: https://issues.apache.org/jira/browse/FLINK-27651
Project: Flink
Issue Type: Sub-task
Simon Paradis created FLINK-27650:
-
Summary: First environment variable of top level pod template is
lost
Key: FLINK-27650
URL: https://issues.apache.org/jira/browse/FLINK-27650
Project: Flink
Thanks Gyula for sharing the progress. It is very likely we could have the
first release candidate next Monday.
Best,
Yang
Gyula Fóra 于2022年5月16日周一 20:50写道：
> Hi Devs!
>
> We are on track for our planned 1.0.0 release timeline. There are no
> outstanding blocker issues on JIRA for the release.
Sorry, the command is parsed as reference.
The real command is :
" > taskmanager.out "
Best,
Weihua
> 2022年5月16日 下午9:52，Weihua Hu 写道：
>
> Hi,
>
> Flink redirects stdout to the taskmanager.out when starting TaskManager.
> If taskmanager.out is deleted, Flink cannot automatically create
> t
Hi,
Flink redirects stdout to the taskmanager.out when starting TaskManager.
If taskmanager.out is deleted, Flink cannot automatically create
taskmanager.out, which means any subsequent output to stdout will be lost.
If you want to clean up the content of taskmanager.out, you can try using:
Martijn Visser created FLINK-27649:
--
Summary: Reduce the number of outputted log lines by
Elasticsearch6SinkE2ECase and Elasticsearch7SinkE2ECase
Key: FLINK-27649
URL: https://issues.apache.org/jira/browse/FLINK-
Gyula Fora created FLINK-27648:
--
Summary: Review example YAMLs in the documentation
Key: FLINK-27648
URL: https://issues.apache.org/jira/browse/FLINK-27648
Project: Flink
Issue Type: Improvement
Gyula Fora created FLINK-27647:
--
Summary: Improve Metrics documentation to include newly added
metrics
Key: FLINK-27647
URL: https://issues.apache.org/jira/browse/FLINK-27647
Project: Flink
Iss
Gyula Fora created FLINK-27646:
--
Summary: Create Roadmap page for Flink Kubernetes operator
Key: FLINK-27646
URL: https://issues.apache.org/jira/browse/FLINK-27646
Project: Flink
Issue Type: Imp
Gyula Fora created FLINK-27645:
--
Summary: Update overview / supported features page for 1.0.0
Key: FLINK-27645
URL: https://issues.apache.org/jira/browse/FLINK-27645
Project: Flink
Issue Type: I
Gyula Fora created FLINK-27644:
--
Summary: Update CRD documentation with new spec/status changes
Key: FLINK-27644
URL: https://issues.apache.org/jira/browse/FLINK-27644
Project: Flink
Issue Type:
Gyula Fora created FLINK-27643:
--
Summary: Document new deployment lifecycle features for the
operator
Key: FLINK-27643
URL: https://issues.apache.org/jira/browse/FLINK-27643
Project: Flink
Issu
Martijn Visser created FLINK-27642:
--
Summary: Make sure that the Elasticsearch E2E tests only try a
limited amount of retries in case of test failures
Key: FLINK-27642
URL: https://issues.apache.org/jira/browse/F
Hi Devs!
We are on track for our planned 1.0.0 release timeline. There are no
outstanding blocker issues on JIRA for the release.
There are 3 outstanding new feature PRs. They are all in pretty good shape
and should be merged within a day:
https://github.com/apache/flink-kubernetes-operator/pull/
Robert Wu created FLINK-27641:
-
Summary: Create view lost Time attribute in Hive Catalog
Key: FLINK-27641
URL: https://issues.apache.org/jira/browse/FLINK-27641
Project: Flink
Issue Type: Bug
Piotr Nowojski created FLINK-27640:
--
Summary: Flink not compiling, flink-connector-hive_2.12 is missing
pentaho-aggdesigner-algorithm:jar:5.1.5-jhyde
Key: FLINK-27640
URL: https://issues.apache.org/jira/browse/F
Hi Lijie,
hm, maybe the following is more appropriate in that case
POST: http://{jm_rest_address:port}/blocklist/taskmanagers/{id}:merge
Best,
Konstantin
Am Mo., 16. Mai 2022 um 07:05 Uhr schrieb Lijie Wang <
wangdachui9...@gmail.com>:
> Hi Konstantin,
> thanks for your feedback.
>
> From wha
lvycc created FLINK-27639:
-
Summary: Flink JOIN uses the now() function when inserting data,
resulting in data that cannot be deleted
Key: FLINK-27639
URL: https://issues.apache.org/jira/browse/FLINK-27639
Pr
Hi, Boot.
For DirectedOutput, I guess you want to split stream.
For splitting stream, you can use side_output[1]
[1]:
https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/datastream/side_output/
Best regards,
Yuxia
- 原始邮件 -
发件人: "Boot" <331233...@qq.com.INVALID>
收件人: "
The correct class name is DirectedOutput
---Original---
From: "Boot"<331233...@qq.com>
Date: Mon, May 16, 2022 17:19 PM
To: "user"
Spongebob created FLINK-27638:
-
Summary: failed to join with table function
Key: FLINK-27638
URL: https://issues.apache.org/jira/browse/FLINK-27638
Project: Flink
Issue Type: Bug
Compon
Hi dev,
FLIP-226 [1] Has been accepted.
There [2] were 3 binding votes in favor. None against. Votes are in the
order of arrival:
- Binding: Jing Zhang
- Binding: Jark Wu
- Binding: Jingsong Lee
[1]
https://cwiki.apache.org/confluence/display/FLINK/FLIP-226%3A+Introduce+Schema+Evolution+on+Table
+1 (binding)
Best,
Jingsong
On Mon, May 16, 2022 at 2:15 PM Jark Wu wrote:
> +1 (binding)
>
> Best,
> Jark
>
> On Mon, 16 May 2022 at 13:50, Jing Zhang wrote:
>
> > +1
> > Thanks @ Jingsong for driving this topic.
> >
> > Best,
> > Jing Zhang
> >
> > Jingsong Li 于2022年5月12日周四 17:06写道：
> >
> >
Lijie Wang created FLINK-27637:
--
Summary: Optimize the log information when the asynchronous part
of checkpoint is canceled
Key: FLINK-27637
URL: https://issues.apache.org/jira/browse/FLINK-27637
Project
Qingsheng Ren created FLINK-27636:
-
Summary: Add data type coverage and sync / async tests for catalog
in connector testing framework
Key: FLINK-27636
URL: https://issues.apache.org/jira/browse/FLINK-27636
Qingsheng Ren created FLINK-27635:
-
Summary: Add data type coverage and abilities test cases for table
connectors in testing framework
Key: FLINK-27635
URL: https://issues.apache.org/jira/browse/FLINK-27635
Qingsheng Ren created FLINK-27634:
-
Summary: Add component failure cases in connector testing framework
Key: FLINK-27634
URL: https://issues.apache.org/jira/browse/FLINK-27634
Project: Flink
Qingsheng Ren created FLINK-27633:
-
Summary: Add FLIP-33 metric validation case in connector testing
framework
Key: FLINK-27633
URL: https://issues.apache.org/jira/browse/FLINK-27633
Project: Flink
Qingsheng Ren created FLINK-27632:
-
Summary: Improve connector testing framework to support more cases
Key: FLINK-27632
URL: https://issues.apache.org/jira/browse/FLINK-27632
Project: Flink
I
Hi Jinsong,
Good question!
The delayQueue is very similar to incompleteElements in
UnorderedStreamElementQueue, it only records the references of in-flight
retry elements, the core value is for the ease of a fast scan when force
flush during endInput and less refactor for existing logic.
Users n
46 matches
Mail list logo
