[
https://issues.apache.org/jira/browse/FLINK-17875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-17875:
---
Labels: pull-request-available (was: )
> Support state TTL for remote functions
>
tzulitai opened a new pull request #116:
URL: https://github.com/apache/flink-statefun/pull/116
This is an initial support for state TTL for remote functions.
Users define state TTL in their YAML modules like so:
```
functions:
- function:
states:
- name:
becketqin commented on pull request #12306:
URL: https://github.com/apache/flink/pull/12306#issuecomment-63121
Thanks for updating the patch and fix the bugs. +1 to merge the PR.
This is an automated message from the
[
https://issues.apache.org/jira/browse/FLINK-17953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117407#comment-17117407
]
godfrey he commented on FLINK-17953:
blink planner does not require the order filed must be time
flinkbot edited a comment on pull request #12323:
URL: https://github.com/apache/flink/pull/12323#issuecomment-633592742
## CI report:
* 32ca1d9dfc0cb2ab212c123240de70d084f7bc12 Azure:
[
https://issues.apache.org/jira/browse/FLINK-17953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-17953:
Comment: was deleted
(was: In streaming jobs, there are also the same kind of problems if the source
is
zjffdu commented on pull request #339:
URL: https://github.com/apache/flink-web/pull/339#issuecomment-634440256
@MarkSfik @morsapaes Thanks for the review, I have updated the post
This is an automated message from the Apache
flinkbot edited a comment on pull request #12334:
URL: https://github.com/apache/flink/pull/12334#issuecomment-633879796
## CI report:
* e3f49ff243a1ef02b1fe3caeb4001e42d2c38636 Azure:
[
https://issues.apache.org/jira/browse/FLINK-17581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117402#comment-17117402
]
Cedric Chen edited comment on FLINK-17581 at 5/27/20, 5:19 AM:
---
Hi
[
https://issues.apache.org/jira/browse/FLINK-17581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117402#comment-17117402
]
Nuo Chen commented on FLINK-17581:
--
Hi [~rmetzger] , I'm a starter and I am willing to do it!
>
JingsongLi commented on a change in pull request #12323:
URL: https://github.com/apache/flink/pull/12323#discussion_r430861320
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/FileSystemOptions.java
##
@@ -132,12 +133,12 @@
JingsongLi commented on a change in pull request #12323:
URL: https://github.com/apache/flink/pull/12323#discussion_r430861320
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/FileSystemOptions.java
##
@@ -132,12 +133,12 @@
JingsongLi commented on a change in pull request #12323:
URL: https://github.com/apache/flink/pull/12323#discussion_r430859922
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/PartitionCommitPolicy.java
##
@@ -121,4 +122,20
JingsongLi commented on a change in pull request #12323:
URL: https://github.com/apache/flink/pull/12323#discussion_r430859222
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/EmptyMetaStoreFactory.java
##
@@ -0,0 +1,65 @@
JingsongLi commented on a change in pull request #12323:
URL: https://github.com/apache/flink/pull/12323#discussion_r430859222
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/EmptyMetaStoreFactory.java
##
@@ -0,0 +1,65 @@
[
https://issues.apache.org/jira/browse/FLINK-17925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117398#comment-17117398
]
Jingsong Lee commented on FLINK-17925:
--
I have no obvious tendency, but I think "process-time" can
flinkbot edited a comment on pull request #12334:
URL: https://github.com/apache/flink/pull/12334#issuecomment-633879796
## CI report:
* 054aceb94feb7fd66916f4502de647b9b0f0a949 Azure:
flinkbot edited a comment on pull request #12275:
URL: https://github.com/apache/flink/pull/12275#issuecomment-631915106
## CI report:
* 2b848a7895db6b1b5263a5242e39b822fa30cecc Azure:
[
https://issues.apache.org/jira/browse/FLINK-17955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117391#comment-17117391
]
Jingsong Lee commented on FLINK-17955:
--
PR: [https://github.com/apache/flink/pull/12334]
>
Jingsong Lee created FLINK-17955:
Summary: BucketLifeCycleListener should just in Buckets
Key: FLINK-17955
URL: https://issues.apache.org/jira/browse/FLINK-17955
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-17925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117388#comment-17117388
]
Jark Wu commented on FLINK-17925:
-
I prefer "processing-time" because it is the concept glossary in
flinkbot edited a comment on pull request #12275:
URL: https://github.com/apache/flink/pull/12275#issuecomment-631915106
## CI report:
* 2b848a7895db6b1b5263a5242e39b822fa30cecc Azure:
wuchong commented on pull request #12320:
URL: https://github.com/apache/flink/pull/12320#issuecomment-634421914
Hi @twalthr , I can see the benefit to have a hierarchy in the format
interfaces. What do you think about to use the first proposal in our offline
discussion? That
godfreyhe commented on pull request #11397:
URL: https://github.com/apache/flink/pull/11397#issuecomment-634418854
@twalthr I have updated this pr, please have a look if you have time, thanks
This is an automated message
[
https://issues.apache.org/jira/browse/FLINK-17953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117379#comment-17117379
]
Dian Fu commented on FLINK-17953:
-
In streaming jobs, there are also the same kind of problems if the
Tzu-Li (Gordon) Tai created FLINK-17954:
---
Summary: Do not multiplex remote function state into single
PersistedTable
Key: FLINK-17954
URL: https://issues.apache.org/jira/browse/FLINK-17954
zzchun opened a new pull request #12348:
URL: https://github.com/apache/flink/pull/12348
## What is the purpose of the change
fix typo in ThreadDumpInfo
## Does this pull request potentially affect one of the following parts:
- Dependencies (does it add or
flinkbot edited a comment on pull request #12275:
URL: https://github.com/apache/flink/pull/12275#issuecomment-631915106
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
klion26 opened a new pull request #342:
URL: https://github.com/apache/flink-web/pull/342
Currently, we use Ubuntu:18.10 to build the docker image, but Ubuntu:18.10
has reached the end of life.
In this commit we change to the closest LTS version 18.04
kl0u commented on a change in pull request #12179:
URL: https://github.com/apache/flink/pull/12179#discussion_r429985424
##
File path:
flink-clients/src/main/java/org/apache/flink/client/cli/ClientOptions.java
##
@@ -0,0 +1,68 @@
+/*
+ * Licensed to the Apache Software
flinkbot edited a comment on pull request #12331:
URL: https://github.com/apache/flink/pull/12331#issuecomment-633846311
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
flinkbot commented on pull request #12333:
URL: https://github.com/apache/flink/pull/12333#issuecomment-633861568
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
danny0405 commented on a change in pull request #12275:
URL: https://github.com/apache/flink/pull/12275#discussion_r430239805
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/DescriptorProperties.java
##
@@ -610,7 +626,9 @@ public
azagrebin commented on a change in pull request #12278:
URL: https://github.com/apache/flink/pull/12278#discussion_r430441131
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolImpl.java
##
@@ -112,6 +114,9 @@
/** The
flinkbot commented on pull request #12326:
URL: https://github.com/apache/flink/pull/12326#issuecomment-633780190
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
wtog commented on a change in pull request #12179:
URL: https://github.com/apache/flink/pull/12179#discussion_r430522062
##
File path:
flink-clients/src/main/java/org/apache/flink/client/cli/ClientOptions.java
##
@@ -0,0 +1,68 @@
+/*
+ * Licensed to the Apache Software
flinkbot edited a comment on pull request #12325:
URL: https://github.com/apache/flink/pull/12325#issuecomment-633600802
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
azagrebin commented on a change in pull request #12256:
URL: https://github.com/apache/flink/pull/12256#discussion_r429801548
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/SlotOccupationTest.java
##
@@ -0,0 +1,83 @@
+/*
+ * Licensed to
wuchong merged pull request #12254:
URL: https://github.com/apache/flink/pull/12254
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to
tillrohrmann commented on a change in pull request #12315:
URL: https://github.com/apache/flink/pull/12315#discussion_r429966710
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/ResourceInformationReflector.java
##
@@ -151,7 +151,9 @@ void
zhengcanbin opened a new pull request #12329:
URL: https://github.com/apache/flink/pull/12329
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring
tillrohrmann closed pull request #12315:
URL: https://github.com/apache/flink/pull/12315
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to
flinkbot commented on pull request #12331:
URL: https://github.com/apache/flink/pull/12331#issuecomment-633836671
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
[
https://issues.apache.org/jira/browse/FLINK-17926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-17926:
---
Labels: pull-request-available (was: )
> Can't build flink-web docker image because of EOL
twalthr closed pull request #12331:
URL: https://github.com/apache/flink/pull/12331
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to
flinkbot commented on pull request #12348:
URL: https://github.com/apache/flink/pull/12348#issuecomment-634390040
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
klion26 commented on pull request #342:
URL: https://github.com/apache/flink-web/pull/342#issuecomment-633880466
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
flinkbot commented on pull request #12344:
URL: https://github.com/apache/flink/pull/12344#issuecomment-634010415
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
TisonKun merged pull request #12277:
URL: https://github.com/apache/flink/pull/12277
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go
flinkbot edited a comment on pull request #12321:
URL: https://github.com/apache/flink/pull/12321#issuecomment-633558255
## CI report:
* 56bdc3a61f65cb30b48cf7f932520be02ebed734 Azure:
zjffdu commented on pull request #339:
URL: https://github.com/apache/flink-web/pull/339#issuecomment-633606084
Thanks @morsapaes , I have updated the PR
This is an automated message from the Apache Git Service.
To respond
DashShen commented on a change in pull request #9898:
URL: https://github.com/apache/flink/pull/9898#discussion_r430186202
##
File path: flink-connectors/flink-sql-connector-hbase/pom.xml
##
@@ -0,0 +1,102 @@
+
+
+http://maven.apache.org/POM/4.0.0;
+
sjwiesman commented on a change in pull request #12257:
URL: https://github.com/apache/flink/pull/12257#discussion_r430690241
##
File path: docs/dev/connectors/kafka.md
##
@@ -152,16 +86,14 @@ The constructor accepts the following arguments:
- "bootstrap.servers" (comma
flinkbot edited a comment on pull request #12028:
URL: https://github.com/apache/flink/pull/12028#issuecomment-625656822
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
lgo opened a new pull request #12345:
URL: https://github.com/apache/flink/pull/12345
## WIP
I was hoping to get a first round of feedback for this implementation. This
branch is currently passing tests, but there was additional work to clean it up:
- [ ] More testing of the
LakeShen commented on pull request #11499:
URL: https://github.com/apache/flink/pull/11499#issuecomment-633992991
Sorry，I've been concentrating on my work lately，I don't have free time to
solve this problem. If you hava free time to solve it , please to do that. I'm
so sorry to say it.
lirui-apache commented on a change in pull request #12323:
URL: https://github.com/apache/flink/pull/12323#discussion_r430220278
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/PartitionCommitPolicy.java
##
@@ -121,4 +122,20
dawidwys opened a new pull request #12325:
URL: https://github.com/apache/flink/pull/12325
## What is the purpose of the change
Add documentation on the `fromValues` clause.
## Does this pull request potentially affect one of the following parts:
- Dependencies (does
zjuwangg commented on pull request #12028:
URL: https://github.com/apache/flink/pull/12028#issuecomment-633774808
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
flinkbot edited a comment on pull request #12344:
URL: https://github.com/apache/flink/pull/12344#issuecomment-634021233
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
flinkbot commented on pull request #12338:
URL: https://github.com/apache/flink/pull/12338#issuecomment-633933390
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
flinkbot edited a comment on pull request #12345:
URL: https://github.com/apache/flink/pull/12345#issuecomment-634034354
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
nielsbasjes commented on a change in pull request #11245:
URL: https://github.com/apache/flink/pull/11245#discussion_r430425933
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/util/EnvironmentInformation.java
##
@@ -103,6 +103,15 @@ public static String
wuchong merged pull request #12343:
URL: https://github.com/apache/flink/pull/12343
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to
XBaith commented on a change in pull request #12237:
URL: https://github.com/apache/flink/pull/12237#discussion_r430014031
##
File path: docs/training/streaming_analytics.zh.md
##
@@ -27,125 +27,101 @@ under the License.
* This will be replaced by the TOC
{:toc}
-## Event
flinkbot edited a comment on pull request #12281:
URL: https://github.com/apache/flink/pull/12281#issuecomment-632080083
## CI report:
* 082d175c44b62e1848b2896f8478eb2091b39e86 Azure:
flinkbot edited a comment on pull request #12251:
URL: https://github.com/apache/flink/pull/12251#issuecomment-630873924
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
flinkbot edited a comment on pull request #12348:
URL: https://github.com/apache/flink/pull/12348#issuecomment-634392378
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
austince commented on pull request #12056:
URL: https://github.com/apache/flink/pull/12056#issuecomment-633650241
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
godfreyhe opened a new pull request #12326:
URL: https://github.com/apache/flink/pull/12326
## What is the purpose of the change
*ValueInterval requires the upper class should be consistent with lower
class, while in some case (e.g. SELECT c, SUM(a) FROM T WHERE a > 0.1 AND a <
HuangXingBo commented on pull request #12328:
URL: https://github.com/apache/flink/pull/12328#issuecomment-633799246
It is the nightly build in my free Azure account.
https://dev.azure.com/hxbks2ks/FLINK-TEST/_build/results?buildId=282=artifacts=publishedArtifacts.
And I test the wheel
flinkbot edited a comment on pull request #12324:
URL: https://github.com/apache/flink/pull/12324#issuecomment-633592835
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
zhengcanbin closed pull request #12327:
URL: https://github.com/apache/flink/pull/12327
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to
flinkbot edited a comment on pull request #12313:
URL: https://github.com/apache/flink/pull/12313#issuecomment-633389597
## CI report:
* 07ab8aa279380cc6584c9602a1c344dfb2294074 Azure:
rkhachatryan commented on pull request #12292:
URL: https://github.com/apache/flink/pull/12292#issuecomment-633727252
Thanks for the feedback @pnowojski ,
I've addressed the issues (except [this
one](https://github.com/apache/flink/pull/12292#discussion_r429887132)).
flinkbot edited a comment on pull request #12290:
URL: https://github.com/apache/flink/pull/12290#issuecomment-632566330
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
EchoLee5 opened a new pull request #12337:
URL: https://github.com/apache/flink/pull/12337
## What is the purpose of the change
If we registered our own joblistener, when job execution ends, onJobExecuted
method will be executed
## Brief change log
Changes
becketqin commented on pull request #12306:
URL: https://github.com/apache/flink/pull/12306#issuecomment-633606359
BTW, I think we do need more tests for the patch.
This is an automated message from the Apache Git Service.
KarmaGYZ commented on pull request #12315:
URL: https://github.com/apache/flink/pull/12315#issuecomment-633776377
Thanks a lot for the review @tillrohrmann . I've updated PR and verified it
with Yarn 3.1.0.
This is an
rmetzger closed pull request #12296:
URL: https://github.com/apache/flink/pull/12296
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go
wangyang0918 commented on pull request #12317:
URL: https://github.com/apache/flink/pull/12317#issuecomment-634380791
The changes looks really good to me. +1 for merging.
This is an automated message from the Apache Git
wangyang0918 commented on pull request #12296:
URL: https://github.com/apache/flink/pull/12296#issuecomment-633792306
The changes look really good to me now.
@klion26 Do you have other concerns?
This is an automated
Shadowell opened a new pull request #341:
URL: https://github.com/apache/flink-web/pull/341
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above
KarmaGYZ commented on a change in pull request #12315:
URL: https://github.com/apache/flink/pull/12315#discussion_r430118921
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/ResourceInformationReflector.java
##
@@ -151,7 +151,9 @@ void
rmetzger commented on pull request #12251:
URL: https://github.com/apache/flink/pull/12251#issuecomment-634005552
Note, this change is breaking the e2e tests:
rmetzger commented on pull request #12340:
URL: https://github.com/apache/flink/pull/12340#issuecomment-634201576
I'm not saying you should do it the way I would have done it :) And yeah, it
would be a lot of noise in our pom files for such a tiny change.
rkhachatryan commented on pull request #12258:
URL: https://github.com/apache/flink/pull/12258#issuecomment-633844876
Obsoleted by #12332
This is an automated message from the Apache Git Service.
To respond to the message,
azagrebin commented on a change in pull request #11245:
URL: https://github.com/apache/flink/pull/11245#discussion_r430332353
##
File path: docs/ops/deployment/kubernetes.md
##
@@ -159,6 +159,8 @@ with the `kubectl` command:
## Appendix
### Common cluster resource
azagrebin closed pull request #12307:
URL: https://github.com/apache/flink/pull/12307
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go
[
https://issues.apache.org/jira/browse/FLINK-17953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-17953:
Description:
For a simple batch job tested in blink planner:
{code:java}
INSERT INTO results
SELECT id,
rmetzger commented on pull request #12296:
URL: https://github.com/apache/flink/pull/12296#issuecomment-633963217
Thanks for the review. Will merge.
This is an automated message from the Apache Git Service.
To respond to the
zentol commented on a change in pull request #12268:
URL: https://github.com/apache/flink/pull/12268#discussion_r429961569
##
File path: tools/ci/watchdog.sh
##
@@ -0,0 +1,122 @@
+#!/usr/bin/env bash
morsapaes commented on a change in pull request #339:
URL: https://github.com/apache/flink-web/pull/339#discussion_r429974813
##
File path: _posts/2020-05-25-flink-on-zeppelin.md
##
@@ -0,0 +1,83 @@
+---
+layout: post
+title: "Flink on Zeppelin Notebooks for Interactive Data
flinkbot edited a comment on pull request #12264:
URL: https://github.com/apache/flink/pull/12264#issuecomment-631349883
## CI report:
* 19c5f57b94cc56b70002031618c32d9e6f68effb UNKNOWN
* bb313e40f5a72dbf20cd0a8b48267063fd4f00af UNKNOWN
*
Dian Fu created FLINK-17953:
---
Summary: OverWindow doesn't support to order by non-time attribute
in batch mode for Table API program
Key: FLINK-17953
URL: https://issues.apache.org/jira/browse/FLINK-17953
JingsongLi merged pull request #12314:
URL: https://github.com/apache/flink/pull/12314
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go
zentol commented on pull request #12340:
URL: https://github.com/apache/flink/pull/12340#issuecomment-634127129
A separate profile is imo overkill, when all we really need is to move one
entry.
This is an automated message
klion26 commented on a change in pull request #12296:
URL: https://github.com/apache/flink/pull/12296#discussion_r430257105
##
File path: docs/ops/deployment/native_kubernetes.zh.md
##
@@ -92,73 +90,73 @@ $ ./bin/kubernetes-session.sh \
-Dkubernetes.container.image=
{%
flinkbot commented on pull request #12323:
URL: https://github.com/apache/flink/pull/12323#issuecomment-633592742
## CI report:
* c22d8ec0765bdfe50423a5a80d6641129f94e544 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #12078:
URL: https://github.com/apache/flink/pull/12078#issuecomment-626611802
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
1 - 100 of 489 matches
Mail list logo
