[
https://issues.apache.org/jira/browse/FLINK-17575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104866#comment-17104866
]
Robert Metzger commented on FLINK-17575:
In your case, it seems that offset "22405513471" is
[
https://issues.apache.org/jira/browse/FLINK-17623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Wang updated FLINK-17623:
-
Description:
There should be a way for an [[ElasticsearchSinkFunction||#L61]
[
https://issues.apache.org/jira/browse/FLINK-17623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Wang updated FLINK-17623:
-
Description:
There should be a way for an
[
https://issues.apache.org/jira/browse/FLINK-17623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Wang updated FLINK-17623:
-
Description:
There should be a way for an
[
https://issues.apache.org/jira/browse/FLINK-7267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Austin Cawley-Edwards updated FLINK-7267:
-
Comment: was deleted
(was: It might also be worth adding a common base class for
[
https://issues.apache.org/jira/browse/FLINK-17608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao closed FLINK-17608.
Resolution: Fixed
master: 7cfcd33e983c6e07eedf8c0d5514450a565710ff
> Add TM log and stdout page back
>
[
https://issues.apache.org/jira/browse/FLINK-7267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104943#comment-17104943
]
Austin Cawley-Edwards commented on FLINK-7267:
--
This seems like a reasonable feature to me.
[
https://issues.apache.org/jira/browse/FLINK-17608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-17608:
-
Description:
According to the discussion in
[
https://issues.apache.org/jira/browse/FLINK-17623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Wang updated FLINK-17623:
-
Description:
There should be a way for an [ElasticsearchSinkFunction|#L61]] implementation
to use
Yun Wang created FLINK-17623:
Summary: Elasticsearch sink should support user resource cleanup
Key: FLINK-17623
URL: https://issues.apache.org/jira/browse/FLINK-17623
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-17529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104955#comment-17104955
]
Austin Cawley-Edwards commented on FLINK-17529:
---
After more investigation, I don't think
[
https://issues.apache.org/jira/browse/FLINK-17529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104955#comment-17104955
]
Austin Cawley-Edwards edited comment on FLINK-17529 at 5/11/20, 11:01 PM:
[
https://issues.apache.org/jira/browse/FLINK-17623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Wang updated FLINK-17623:
-
Description:
There should be a way for an
[
https://issues.apache.org/jira/browse/FLINK-16921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan resolved FLINK-16921.
---
Resolution: Fixed
Thanks for the clarification [~fly_in_gis]
> "kubernetes session
Flavio Pompermaier created FLINK-17622:
--
Summary: Remove useless switch for decimal in PostresCatalog
Key: FLINK-17622
URL: https://issues.apache.org/jira/browse/FLINK-17622
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104972#comment-17104972
]
Austin Cawley-Edwards commented on FLINK-7267:
--
It might also be worth adding a common base
[
https://issues.apache.org/jira/browse/FLINK-17575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104874#comment-17104874
]
Maxim Malykhin commented on FLINK-17575:
kafka-streams has DeserializationExceptionHandler,
[
https://issues.apache.org/jira/browse/FLINK-17575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104896#comment-17104896
]
Maxim Malykhin commented on FLINK-17575:
I apologize for my English and for the overly emotional
[
https://issues.apache.org/jira/browse/FLINK-17623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Wang updated FLINK-17623:
-
Description:
There should be a way for an [ElasticsearchSinkFunction|#L61]] implementation
to use
[
https://issues.apache.org/jira/browse/FLINK-17623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Wang updated FLINK-17623:
-
Description:
There should be a way for an [ElasticsearchSinkFunction|#L61]] implementation
to use
[
https://issues.apache.org/jira/browse/FLINK-17623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Wang updated FLINK-17623:
-
Description:
There should be a way for an [ElasticsearchSinkFunction|#L61]] implementation
to use
[
https://issues.apache.org/jira/browse/FLINK-17623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Wang updated FLINK-17623:
-
Description:
There should be a way for an [ElasticsearchSinkFunction|#L61]] implementation
to use
[
https://issues.apache.org/jira/browse/FLINK-17623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Wang updated FLINK-17623:
-
Description:
There should be a way for an [ElasticsearchSinkFunction|#L61]] implementation
to use
[
https://issues.apache.org/jira/browse/FLINK-7267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104943#comment-17104943
]
Austin Cawley-Edwards edited comment on FLINK-7267 at 5/11/20, 11:46 PM:
[
https://issues.apache.org/jira/browse/FLINK-15347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104769#comment-17104769
]
Robert Metzger commented on FLINK-15347:
[
https://issues.apache.org/jira/browse/FLINK-7267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104943#comment-17104943
]
Austin Cawley-Edwards edited comment on FLINK-7267 at 5/11/20, 10:33 PM:
[
https://issues.apache.org/jira/browse/FLINK-17573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105007#comment-17105007
]
Tammy zhang commented on FLINK-17573:
-
ok, i will post the question on the u...@flink.apache.org
[
https://issues.apache.org/jira/browse/FLINK-17606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105013#comment-17105013
]
Jingsong Lee commented on FLINK-17606:
--
Hi [~knaufk], yes, it should be a public(PublicEvolving)
[
https://issues.apache.org/jira/browse/FLINK-17600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105019#comment-17105019
]
Jark Wu commented on FLINK-17600:
-
Thanks for the investigation, yes, this is a bug and is going to be
[
https://issues.apache.org/jira/browse/FLINK-17625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105041#comment-17105041
]
Jark Wu commented on FLINK-17625:
-
Sure. Assigned to you [~lsy]. It would be better to have a IT case to
[
https://issues.apache.org/jira/browse/FLINK-17625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-17625:
---
Assignee: dalongliu
> Fix ArrayIndexOutOfBoundsException in AppendOnlyTopNFunction
>
[
https://issues.apache.org/jira/browse/FLINK-17600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104996#comment-17104996
]
Leonard Xu commented on FLINK-17600:
This should not be related to
[
https://issues.apache.org/jira/browse/FLINK-17624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-17624:
---
Component/s: (was: Table SQL / Planner)
Runtime / Network
> "TPC-DS end-to-end
[
https://issues.apache.org/jira/browse/FLINK-17606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-17606:
-
Description:
{code:java}
CREATE TABLE user (
id BIGINT,
age INT,
description STRING
[
https://issues.apache.org/jira/browse/FLINK-17609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-17609:
---
Assignee: shuiqiangchen
> Execute the script directly when user specified the entry script with
[
https://issues.apache.org/jira/browse/FLINK-17592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105096#comment-17105096
]
Robert Metzger commented on FLINK-17592:
Another case:
[
https://issues.apache.org/jira/browse/FLINK-17625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105039#comment-17105039
]
dalongliu commented on FLINK-17625:
---
[~jark] Can I help to fix this bug?
> Fix
[
https://issues.apache.org/jira/browse/FLINK-17624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-17624:
--
Summary: "TPC-DS end-to-end test (Blink planner)" is unstable (was:
"TPC-DS end-to-end test (Blink
Yang Wang created FLINK-17624:
-
Summary: "TPC-DS end-to-end test (Blink planner)' is unstable
Key: FLINK-17624
URL: https://issues.apache.org/jira/browse/FLINK-17624
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-17623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105082#comment-17105082
]
Yangze Guo commented on FLINK-17623:
I think it could be a valid demand. Not sure does it make sense
[
https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105083#comment-17105083
]
Robert Metzger commented on FLINK-17274:
[
https://issues.apache.org/jira/browse/FLINK-16225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-16225:
Fix Version/s: (was: 1.10.1)
1.10.2
> Metaspace Out Of Memory should be handled as
Jark Wu created FLINK-17625:
---
Summary: Fix ArrayIndexOutOfBoundsException in
AppendOnlyTopNFunction
Key: FLINK-17625
URL: https://issues.apache.org/jira/browse/FLINK-17625
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-13682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-13682.
---
Fix Version/s: 1.11.0
Resolution: Fixed
flink-web: e33628ea470918116bb75aaa4e5580d1cc8edaff
>
[
https://issues.apache.org/jira/browse/FLINK-17625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105050#comment-17105050
]
dalongliu commented on FLINK-17625:
---
[~jark] Ok, thanks for your advice.
> Fix
[
https://issues.apache.org/jira/browse/FLINK-17573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger closed FLINK-17573.
--
Resolution: Not A Bug
> There is duplicate source data in ProcessWindowFunction
>
[
https://issues.apache.org/jira/browse/FLINK-17623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105003#comment-17105003
]
Yangze Guo commented on FLINK-17623:
It seems the {{RestHighLevelClient}} is closed by
[
https://issues.apache.org/jira/browse/FLINK-16845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin resolved FLINK-16845.
--
Fix Version/s: 1.11.0
Resolution: Implemented
Merged to master:
[
https://issues.apache.org/jira/browse/FLINK-17623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105055#comment-17105055
]
Yun Wang commented on FLINK-17623:
--
[~karmagyz] Ah I was using {{RestHighLevelClient}} as an example,
[
https://issues.apache.org/jira/browse/FLINK-16850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104102#comment-17104102
]
Tzu-Li (Gordon) Tai commented on FLINK-16850:
-
[~yunta] sure, I'll commit an initial commit
[
https://issues.apache.org/jira/browse/FLINK-17536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yangze Guo updated FLINK-17536:
---
Summary: Change the config option of slot max limitation to
"slotmanager.number-of-slots.max"
[
https://issues.apache.org/jira/browse/FLINK-17560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104103#comment-17104103
]
josson paul kalapparambath edited comment on FLINK-17560 at 5/11/20, 6:00 AM:
[
https://issues.apache.org/jira/browse/FLINK-17560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104103#comment-17104103
]
josson paul kalapparambath commented on FLINK-17560:
[~xintongsong]
Job Manager
KarmaGYZ opened a new pull request #12067:
URL: https://github.com/apache/flink/pull/12067
…manager.number-of-slots.max
## What is the purpose of the change
Change the config option of slot max limitation to
slotmanager.number-of-slots.max
## Brief change log
KarmaGYZ commented on pull request #12067:
URL: https://github.com/apache/flink/pull/12067#issuecomment-626488822
cc @GJL
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/FLINK-17536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-17536:
---
Labels: pull-request-available (was: )
> Change the config option of slot max limitation
wangyang0918 commented on pull request #12040:
URL: https://github.com/apache/flink/pull/12040#issuecomment-626488446
cc @kl0u could you help with the reviewing?
This is an automated message from the Apache Git Service.
To
jinglining commented on pull request #11752:
URL: https://github.com/apache/flink/pull/11752#issuecomment-626493911
@flinkbot run azure
This is an automated message from the Apache Git Service.
To respond to the message,
jinglining removed a comment on pull request #11752:
URL: https://github.com/apache/flink/pull/11752#issuecomment-625765695
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
JingsongLi commented on a change in pull request #11496:
URL: https://github.com/apache/flink/pull/11496#discussion_r422808641
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/DataGeneratorSource.java
##
@@ -0,0 +1,102
[
https://issues.apache.org/jira/browse/FLINK-17607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104123#comment-17104123
]
Piotr Nowojski commented on FLINK-17607:
Another instance:
[
https://issues.apache.org/jira/browse/FLINK-17607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-17607:
---
Priority: Critical (was: Major)
> TableEnvironmentITCase.testStatementSet fails on azure
>
[
https://issues.apache.org/jira/browse/FLINK-17591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-17591:
---
Priority: Critical (was: Major)
> TableEnvironmentITCase.testExecuteSqlAndToDataStream
[
https://issues.apache.org/jira/browse/FLINK-17591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-17591:
---
Priority: Major (was: Critical)
> TableEnvironmentITCase.testExecuteSqlAndToDataStream
TsReaper opened a new pull request #12069:
URL: https://github.com/apache/flink/pull/12069
## Pre-review note
This PR is waiting for #12037 to merge. The 1st commit is exactly the same
with the blocking PR. Please start reviewing from the 2nd commit. This PR will
be rebased once
flinkbot edited a comment on pull request #11981:
URL: https://github.com/apache/flink/pull/11981#issuecomment-623312081
## CI report:
* 4454b77214cd904ce395d4ae073c83cab1f03628 Azure:
flinkbot edited a comment on pull request #12004:
URL: https://github.com/apache/flink/pull/12004#issuecomment-624445192
## CI report:
* 3ac79a41395792dfecefc87a19c58468e91ede8d UNKNOWN
* 6545efc0050c0d2ae84755199cf3b5fd55e82dca Azure:
flinkbot edited a comment on pull request #11981:
URL: https://github.com/apache/flink/pull/11981#issuecomment-623312081
## CI report:
* f9be005d36b9afdf712c36338e491477206bc1c7 Azure:
flinkbot edited a comment on pull request #12033:
URL: https://github.com/apache/flink/pull/12033#issuecomment-625870561
## CI report:
* 188f7416604519b214ef83b11bb443956f059736 Azure:
flinkbot edited a comment on pull request #12062:
URL: https://github.com/apache/flink/pull/12062#issuecomment-626437386
## CI report:
* 8ea1504837c815c55f8a41a7fa887285333c62a6 Azure:
godfreyhe commented on a change in pull request #12049:
URL: https://github.com/apache/flink/pull/12049#discussion_r422826714
##
File path:
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/delegation/Planner.java
##
@@ -74,14 +76,22 @@
*/
flinkbot edited a comment on pull request #11899:
URL: https://github.com/apache/flink/pull/11899#issuecomment-618868456
## CI report:
* 4ffaa5da88576abdbfb2e221faa8823313559c99 UNKNOWN
* bf0fd0c41bd7d444f21b21d790f7286a6de3f132 Travis:
flinkbot edited a comment on pull request #11687:
URL: https://github.com/apache/flink/pull/11687#issuecomment-611445542
## CI report:
* 5bad018f00f85a7359345187a12d7938aa510d25 UNKNOWN
* d51ce7f47381d99b843278cd701dcff223761a0b UNKNOWN
*
azagrebin commented on a change in pull request #20:
URL: https://github.com/apache/flink-docker/pull/20#discussion_r422832264
##
File path: docker-entrypoint.sh
##
@@ -56,6 +58,27 @@ copy_plugins_if_required() {
done
}
+setup_usrlib() {
+ if [ -z "${USER_ARTIFACTS}" ];
Myasuka commented on pull request #8693:
URL: https://github.com/apache/flink/pull/8693#issuecomment-626524792
@rkhachatryan Would you please review this PR again?
I have split into two commits now and rebase with latest code.
[
https://issues.apache.org/jira/browse/FLINK-17416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104154#comment-17104154
]
Robert Metzger commented on FLINK-17416:
Thanks a lot!
> Flink-kubernetes doesn't work on java
flinkbot commented on pull request #12072:
URL: https://github.com/apache/flink/pull/12072#issuecomment-626524364
## CI report:
* 9046a584b295d9b431dd0b34a86dbdac89603365 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
[
https://issues.apache.org/jira/browse/FLINK-17523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz reassigned FLINK-17523:
Assignee: Dawid Wysakowicz
> Add call expression with a class of UDF
>
SteNicholas commented on pull request #12033:
URL: https://github.com/apache/flink/pull/12033#issuecomment-626495937
@Myasuka According to the discussion, I have already align the behavior of
`HeapMapState` #entries(), #keys(), #values(), and #iterator() and
`RocksDBMapState` #entries()
[
https://issues.apache.org/jira/browse/FLINK-17559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104115#comment-17104115
]
Yingjie Cao commented on FLINK-17559:
-
I wonder if you cache any data in your UDFs, for example,
[
https://issues.apache.org/jira/browse/FLINK-17607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104122#comment-17104122
]
Piotr Nowojski commented on FLINK-17607:
Could be related to FLINK-16636 or FLINK-17591, but I
Piotr Nowojski created FLINK-17607:
--
Summary: TableEnvironmentITCase.testStatementSet fails on azure
Key: FLINK-17607
URL: https://issues.apache.org/jira/browse/FLINK-17607
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-17571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104136#comment-17104136
]
Piotr Nowojski commented on FLINK-17571:
[~stevenz3wu] I'm not familiar with when, how & who is
flinkbot commented on pull request #12069:
URL: https://github.com/apache/flink/pull/12069#issuecomment-626515528
## CI report:
* d7bcba594cd7dbbe83c6ef79d6edb972f0753cdc UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot commented on pull request #12068:
URL: https://github.com/apache/flink/pull/12068#issuecomment-626515450
## CI report:
* 5522d5e814fbac1486ef37b675c805d0d1201b3c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot commented on pull request #12070:
URL: https://github.com/apache/flink/pull/12070#issuecomment-626515599
## CI report:
* f66cc3d0e89475c4b3674ee81163d16008d37686 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot commented on pull request #12071:
URL: https://github.com/apache/flink/pull/12071#issuecomment-626515702
## CI report:
* 818dd9bd7f24ee7c28afa187190fc3784dde0d35 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
pnowojski commented on a change in pull request #12016:
URL: https://github.com/apache/flink/pull/12016#discussion_r422832679
##
File path: flink-end-to-end-tests/test-scripts/test_quickstarts.sh
##
@@ -68,6 +68,13 @@ sed -i -e ''$(($position + 1))'i\
sed -i -e
shuiqiangchen commented on pull request #12061:
URL: https://github.com/apache/flink/pull/12061#issuecomment-626519077
> Thanks for the PR @shuiqiangchen !
> I think the failure of the test is caused by
https://issues.apache.org/jira/browse/FLINK-17601
> So, LGTM +1 to merged.
>
TsReaper opened a new pull request #12073:
URL: https://github.com/apache/flink/pull/12073
## Pre-review note
This PR is waiting for #12037 and #12069 to merge. The first two commits are
exactly the same with the blocking PRs. Please start reviewing from the 3rd
commit. This PR
shuiqiangchen edited a comment on pull request #12061:
URL: https://github.com/apache/flink/pull/12061#issuecomment-626519077
> Thanks for the PR @shuiqiangchen !
> I think the failure of the test is caused by
https://issues.apache.org/jira/browse/FLINK-17601
> So, LGTM +1 to merged.
wangyang0918 commented on a change in pull request #12071:
URL: https://github.com/apache/flink/pull/12071#discussion_r422832586
##
File path: flink-end-to-end-tests/test-scripts/common_kubernetes.sh
##
@@ -75,7 +75,8 @@ function start_kubernetes_if_not_running {
#
aljoscha commented on a change in pull request #11972:
URL: https://github.com/apache/flink/pull/11972#discussion_r422832081
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/ProcessingTimeoutTrigger.java
##
@@ -0,0 +1,100 @@
flinkbot edited a comment on pull request #11687:
URL: https://github.com/apache/flink/pull/11687#issuecomment-611445542
## CI report:
* 5bad018f00f85a7359345187a12d7938aa510d25 UNKNOWN
* d51ce7f47381d99b843278cd701dcff223761a0b UNKNOWN
*
aljoscha commented on pull request #11854:
URL: https://github.com/apache/flink/pull/11854#issuecomment-626523400
I can only speak to the added methods in `RuntimeContext` and the added
interface `ExternalResourceInfo`. Those look good to merge!
zentol commented on a change in pull request #20:
URL: https://github.com/apache/flink-docker/pull/20#discussion_r422837552
##
File path: docker-entrypoint.sh
##
@@ -56,6 +58,27 @@ copy_plugins_if_required() {
done
}
+setup_usrlib() {
+ if [ -z "${USER_ARTIFACTS}" ];
[
https://issues.apache.org/jira/browse/FLINK-17598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104109#comment-17104109
]
Yang Wang commented on FLINK-17598:
---
So do you mean to use StatefulSet to replace the Deployment in
[
https://issues.apache.org/jira/browse/FLINK-17556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104118#comment-17104118
]
Yingjie Cao commented on FLINK-17556:
-
Which version do you use? Is there any user code and
flinkbot edited a comment on pull request #8693:
URL: https://github.com/apache/flink/pull/8693#issuecomment-542518065
## CI report:
* b470751fa4c472828269e9b94c3bdb82e587908f Travis:
[SUCCESS](https://travis-ci.com/flink-ci/flink/builds/132086267)
*
wangyang0918 opened a new pull request #12071:
URL: https://github.com/apache/flink/pull/12071
## What is the purpose of the change
Use fixed v1.16.9 because fabric8 kubernetes-client could not work with
higher version under jdk 8u252.
## Brief change log
*
1 - 100 of 530 matches
Mail list logo
