Congxian Qiu(klion26) created FLINK-18748:
-
Summary: Savepoint would be queued unexpected
Key: FLINK-18748
URL: https://issues.apache.org/jira/browse/FLINK-18748
Project: Flink
Issue
+1
Thanks Jark for driving this.
On Mon, Jul 27, 2020 at 4:14 PM Leonard Xu wrote:
> Thanks Jark
>
> +1(non-binding)
>
> Best
> Leonard
> > 在 2020年7月27日，15:32，jincheng sun 写道：
> >
> > +1（binding)
> >
> > Best,
> > Jincheng
> >
> >
> > Jark Wu 于2020年7月27日周一 上午10:01写道：
> >
> >> +1 (binding)
>
你这个不需要设置timecharateristic吗
| |
何会远
|
|
邮箱：knowfar...@163.com
|
签名由 网易邮箱大师 定制
在2020年07月29日 11:16，Benchao Li 写道：
这种情况一般是因为你的watermark生成可能有些问题，你可以在web ui上检查下watermark是否是正常的。
111 于2020年7月29日周三 上午9:58写道：
>
>
>
> 您好，请教一个问题，谢谢：
> 很简单的json，
> {"num":100,"ts":1595949526874,"vin":""}
>
Yes, The pr still needs to be improved.
In most cases, there are more than one statement in the sql file,
so -f option should support multiple statements.
however, a related PR [1] has not completed yet.
[1] https://github.com/apache/flink/pull/8738
Best,
Godfrey
Jun Zhang 于2020年7月29日周三
Leon Hao created FLINK-18747:
Summary: Make Debezium Json format support timestamp with timezone
Key: FLINK-18747
URL: https://issues.apache.org/jira/browse/FLINK-18747
Project: Flink
Issue
这种情况一般是因为你的watermark生成可能有些问题，你可以在web ui上检查下watermark是否是正常的。
111 于2020年7月29日周三 上午9:58写道：
>
>
>
> 您好，请教一个问题，谢谢：
> 很简单的json，
> {"num":100,"ts":1595949526874,"vin":""}
> {"num":200,"ts":1595949528874,"vin":""}
> {"num":200,"ts":1595949530880,"vin":""}
>
hi，godfrey：
Thanks for your reply
1. I have seen the -u parameter, but my sql file may not only include
'insert into select ', but also SET, DDL, etc.
2. I may not have noticed this issue. I took a look at this issue. I think
this issue may have some problems. For example, he finally called
您好，请教一个问题，谢谢：
很简单的json，
{"num":100,"ts":1595949526874,"vin":""}
{"num":200,"ts":1595949528874,"vin":""}
{"num":200,"ts":1595949530880,"vin":""}
{"num":300,"ts":1595949532883,"vin":""}
{"num":100,"ts":1595949534888,"vin":""}
{"num":300,"ts":1595949536892,"vin":""}
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-12828
Best,
Godfrey
Jun Zhang 于2020年7月29日周三 上午9:22写道：
> I want
Dian Fu created FLINK-18746:
---
Summary: WindowStaggerTest.testWindowStagger failed
Key: FLINK-18746
URL: https://issues.apache.org/jira/browse/FLINK-18746
Project: Flink
Issue Type: Bug
Dian Fu created FLINK-18745:
---
Summary: 'SQL Client end-to-end test (Old planner) Elasticsearch
(v7.5.1)' failed to download Elasticsearch
Key: FLINK-18745
URL: https://issues.apache.org/jira/browse/FLINK-18745
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
Thank you.
Why do i get this as flink version when installed 1.11.0
513848@LP0101226 /cygdrive/c/users/513848/softwares/flink-1.11.0
$ flink --version
log4j:WARN No appenders could be found for logger
(org.apache.flink.client.cli.C
liFrontend).
log4j:WARN Please initialize the log4j system
tao wang created FLINK-18744:
Summary: resume from modified savepoint dirctionary: No such file
or directory
Key: FLINK-18744
URL: https://issues.apache.org/jira/browse/FLINK-18744
Project: Flink
weizheng created FLINK-18743:
Summary: Modify English link to Chinese link
Key: FLINK-18743
URL: https://issues.apache.org/jira/browse/FLINK-18743
Project: Flink
Issue Type: Improvement
Matt Wang created FLINK-18742:
-
Summary: Configuration args do not take effect at client
Key: FLINK-18742
URL: https://issues.apache.org/jira/browse/FLINK-18742
Project: Flink
Issue Type:
+1 (binding)
Best,
Hequn
On Tue, Jul 28, 2020 at 2:58 PM Aljoscha Krettek
wrote:
> +1 (binding)
>
> Aljoscha
>
> On 28.07.20 04:12, Dian Fu wrote:
> > Thanks for driving this Shuiqiang.
> >
> > +1
> >
> > Regards,
> > Dian
> >
> >> 在 2020年7月27日，下午3:33，jincheng sun 写道：
> >>
> >> +1(binding)
>
Hi Kurt,
Thanks for the comments.
You are right that the FLIP lacks a proper discussion about the impact of the
optimizer. I have added the section to talk about how the cache table works
with the optimizer. I hope this could resolve your concern. Please let me know
if you have any further
Hi Maganti
Flink community decides to not support windows script from Flink-1.10.1 [1],
and you could still use Cygwin or WSL to run Flink on windows [2].
[1] https://issues.apache.org/jira/browse/FLINK-16683
[2]
Truong Duc Kien created FLINK-18740:
---
Summary: Support rate limiter in the universal kafka connector
Key: FLINK-18740
URL: https://issues.apache.org/jira/browse/FLINK-18740
Project: Flink
mzz created FLINK-18741:
---
Summary: ProcessWindowFunction's process function exception
Key: FLINK-18741
URL: https://issues.apache.org/jira/browse/FLINK-18741
Project: Flink
Issue Type: Bug
Hi,
It's a good idea to start with a minimum size of API and add useful ones
when we find it is truly useful.
>From my side, I'm also ok with the partitionCustom() method. Thanks David
for your feedback!
Best,
Hequn
On Mon, Jul 27, 2020 at 8:57 PM Aljoscha Krettek
wrote:
> Hi,
>
> I'm also
Andrey Zagrebin created FLINK-18739:
---
Summary: Implement MergingSharedSlotProfileRetriever
Key: FLINK-18739
URL: https://issues.apache.org/jira/browse/FLINK-18739
Project: Flink
Issue
Hi, all
I open a new discussion of FLIP-132[1] which based on our consensus on current
thread.
Let me keep communication in the new thread, please let me know if you have any
concerns.
Best
Leonard
[1]
Hello everyone,
Currently, user can correlate temporal table by temporal table join to enrich
their fact table, a temporal table can be a changing history table which tracks
the changes(e.g. database changelog) or a changing dimensioned table which
materializes the changes(e.g. database
Xintong Song created FLINK-18738:
Summary: Revisit resource management model for python processes.
Key: FLINK-18738
URL: https://issues.apache.org/jira/browse/FLINK-18738
Project: Flink
weizheng created FLINK-18737:
Summary: translate jdbc connector
Key: FLINK-18737
URL: https://issues.apache.org/jira/browse/FLINK-18737
Project: Flink
Issue Type: Improvement
Piotr Nowojski created FLINK-18736:
--
Summary: Source chaining with N-Ary Stream Operator in Flink
Key: FLINK-18736
URL: https://issues.apache.org/jira/browse/FLINK-18736
Project: Flink
+1 (binding)
Aljoscha
On 28.07.20 04:12, Dian Fu wrote:
Thanks for driving this Shuiqiang.
+1
Regards,
Dian
在 2020年7月27日，下午3:33，jincheng sun 写道：
+1(binding)
Best,
Jincheng
Shuiqiang Chen 于2020年7月24日周五 下午8:32写道：
Hi everyone,
I would like to start the vote for FLIP-130[1], which is
29 matches
Mail list logo
