TisonKun commented on issue #9575: [FLINK-13912][client] Remove
ClusterClient#getClusterConnectionInfo
URL: https://github.com/apache/flink/pull/9575#issuecomment-527327642
@tillrohrmann I think this pr is mergeable. Please take a look :-)
--
TisonKun commented on issue #9509: [FLINK-13750][client] Separate
client/cluster-side high-availability services
URL: https://github.com/apache/flink/pull/9509#issuecomment-527327430
Close in favor of based on #9575
This is
TisonKun closed pull request #9509: [FLINK-13750][client] Separate
client/cluster-side high-availability services
URL: https://github.com/apache/flink/pull/9509
This is an automated message from the Apache Git Service.
To re
flinkbot edited a comment on issue #9478: [FLINK-13766][task] Refactor the
implementation of StreamInputProcessor based on StreamTaskInput#emitNext
URL: https://github.com/apache/flink/pull/9478#issuecomment-522374042
## CI report:
* 1530600eaf36324966f343c277437e48c2416dc2 : FAI
flinkbot edited a comment on issue #9478: [FLINK-13766][task] Refactor the
implementation of StreamInputProcessor based on StreamTaskInput#emitNext
URL: https://github.com/apache/flink/pull/9478#issuecomment-522374042
## CI report:
* 1530600eaf36324966f343c277437e48c2416dc2 : FAI
[
https://issues.apache.org/jira/browse/FLINK-12164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-12164.
---
Fix Version/s: 1.9.1
Resolution: Fixed
Fixed via
1.10.0:
c0454ef64e71095cd38e6ba958e
flinkbot edited a comment on issue #9478: [FLINK-13766][task] Refactor the
implementation of StreamInputProcessor based on StreamTaskInput#emitNext
URL: https://github.com/apache/flink/pull/9478#issuecomment-522374042
## CI report:
* 1530600eaf36324966f343c277437e48c2416dc2 : FAI
zhijiangW commented on a change in pull request #9483: [FLINK-13767][task]
Migrate isFinished method from AvailabilityListener to AsyncDataInput
URL: https://github.com/apache/flink/pull/9483#discussion_r320085530
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/st
[
https://issues.apache.org/jira/browse/FLINK-13612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16921150#comment-16921150
]
weiyunqing commented on FLINK-13612:
[~klion26]
java.lang.NullPointerException at
flinkbot edited a comment on issue #9478: [FLINK-13766][task] Refactor the
implementation of StreamInputProcessor based on StreamTaskInput#emitNext
URL: https://github.com/apache/flink/pull/9478#issuecomment-522374042
## CI report:
* 1530600eaf36324966f343c277437e48c2416dc2 : FAI
[
https://issues.apache.org/jira/browse/FLINK-13906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16921135#comment-16921135
]
Jark Wu commented on FLINK-13906:
-
Hi [~hequn8128] [~WeiZhong], I would suggest you can
[
https://issues.apache.org/jira/browse/FLINK-13612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16921133#comment-16921133
]
Congxian Qiu(klion26) commented on FLINK-13612:
---
[~Vow] could you please s
flinkbot edited a comment on issue #9478: [FLINK-13766][task] Refactor the
implementation of StreamInputProcessor based on StreamTaskInput#emitNext
URL: https://github.com/apache/flink/pull/9478#issuecomment-522374042
## CI report:
* 1530600eaf36324966f343c277437e48c2416dc2 : FAI
flinkbot edited a comment on issue #9416: [FLINK-13646][build system] Add basic
ARM CI job definition
URL: https://github.com/apache/flink/pull/9416#issuecomment-520285701
## CI report:
* dbf749f0d0c3167265287b182dd1ea7b4aed84c1 : FAILURE
[Build](https://travis-ci.com/flink-ci/f
xuefuz commented on a change in pull request #9580: [FLINK-13930][hive] Support
Hive version 3.1.x
URL: https://github.com/apache/flink/pull/9580#discussion_r320076211
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveGeneri
[
https://issues.apache.org/jira/browse/FLINK-13612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16921124#comment-16921124
]
weiyunqing commented on FLINK-13612:
[~klion26] Yes, it still exists.
> StateDescri
[
https://issues.apache.org/jira/browse/FLINK-13025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16921121#comment-16921121
]
limbo commented on FLINK-13025:
---
I think a universal connector can be very nice, and I ju
xuefuz commented on a change in pull request #9580: [FLINK-13930][hive] Support
Hive version 3.1.x
URL: https://github.com/apache/flink/pull/9580#discussion_r320073639
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/client/HiveS
xuefuz commented on a change in pull request #9580: [FLINK-13930][hive] Support
Hive version 3.1.x
URL: https://github.com/apache/flink/pull/9580#discussion_r320073372
##
File path:
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/functions/hive/HiveSimple
[
https://issues.apache.org/jira/browse/FLINK-13943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1692#comment-1692
]
Kurt Young commented on FLINK-13943:
cc [~twalthr]
> Provide api to convert flink t
Jeff Zhang created FLINK-13943:
--
Summary: Provide api to convert flink table to java List
Key: FLINK-13943
URL: https://issues.apache.org/jira/browse/FLINK-13943
Project: Flink
Issue Type: Impro
theopenlab-ci[bot] commented on issue #9416: [FLINK-13646][build system] Add
basic ARM CI job definition
URL: https://github.com/apache/flink/pull/9416#issuecomment-527273514
Build succeeded.
- [flink-build-arm64-core
](https://logs.openlabtesting.org/logs/16/9416/39cc2828bc5b128447
flinkbot edited a comment on issue #9416: [FLINK-13646][build system] Add basic
ARM CI job definition
URL: https://github.com/apache/flink/pull/9416#issuecomment-520285701
## CI report:
* dbf749f0d0c3167265287b182dd1ea7b4aed84c1 : FAILURE
[Build](https://travis-ci.com/flink-ci/f
flinkbot edited a comment on issue #9416: [FLINK-13646][build system] Add basic
ARM CI job definition
URL: https://github.com/apache/flink/pull/9416#issuecomment-520285701
## CI report:
* dbf749f0d0c3167265287b182dd1ea7b4aed84c1 : FAILURE
[Build](https://travis-ci.com/flink-ci/f
wangxiyuan commented on issue #9416: [FLINK-13646][build system] Add basic ARM
CI job definition
URL: https://github.com/apache/flink/pull/9416#issuecomment-527268203
check_arm
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/FLINK-13395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ke Li updated FLINK-13395:
--
Summary: Add source and sink connector for Alibaba Log Service (was: Add
source and sink connector for Aliyun
[
https://issues.apache.org/jira/browse/FLINK-13609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16921068#comment-16921068
]
Joao Boto commented on FLINK-13609:
---
[~kkl0u] I understand what you say about timestam
[
https://issues.apache.org/jira/browse/FLINK-12847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16921059#comment-16921059
]
Bowen Li commented on FLINK-12847:
--
Hi [~carp84], that'll be great :) Do you know how t
flinkbot edited a comment on issue #9587: [FLINK-13685][yarn] Validate YARN
deployment against YARN scheduler maximum vcore size
URL: https://github.com/apache/flink/pull/9587#issuecomment-526997659
## CI report:
* 667c738c79302b11cad210edbfb007866be29fdf : FAILURE
[Build](https
[
https://issues.apache.org/jira/browse/FLINK-13940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16921044#comment-16921044
]
Jimmy Weibel Rasmussen commented on FLINK-13940:
I do agree that the sol
tillrohrmann closed pull request #9568: [Flink-12164][tests] Harden
JobMasterTest#testJobFailureWhenTaskExecutorHeartbeatTimeout
URL: https://github.com/apache/flink/pull/9568
This is an automated message from the Apache Git
flinkbot edited a comment on issue #9596: [FLINK-13445] Add
'jobmanager.containerized.heap-cutoff-{min,ratio}' …
URL: https://github.com/apache/flink/pull/9596#issuecomment-527151332
## CI report:
* d28b03f8a7e7832544172047411e02db2cb90a8a : UNKNOWN
* 45e170dfb0fd9ff73061f5800
flinkbot edited a comment on issue #9587: [FLINK-13685][yarn] Validate YARN
deployment against YARN scheduler maximum vcore size
URL: https://github.com/apache/flink/pull/9587#issuecomment-526997659
## CI report:
* 667c738c79302b11cad210edbfb007866be29fdf : FAILURE
[Build](https
flinkbot edited a comment on issue #9587: [FLINK-13685][yarn] Validate YARN
deployment against YARN scheduler maximum vcore size
URL: https://github.com/apache/flink/pull/9587#issuecomment-526997659
## CI report:
* 667c738c79302b11cad210edbfb007866be29fdf : FAILURE
[Build](https
[
https://issues.apache.org/jira/browse/FLINK-13685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16921030#comment-16921030
]
Josh YEH commented on FLINK-13685:
--
Hi [~bamrabi] [~gyfora] [~Tison] [~fly_in_gis],
I
josh0yeh commented on issue #9587: [FLINK-13685][yarn] Validate YARN deployment
against YARN scheduler maximum vcore size
URL: https://github.com/apache/flink/pull/9587#issuecomment-527231307
Hi @TisonKun Please feel free to review this PR.
-
josh0yeh commented on issue #9587: [FLINK-13685][yarn] Validate YARN deployment
against YARN scheduler maximum vcore size
URL: https://github.com/apache/flink/pull/9587#issuecomment-527229739
Hi @rmetzger my apology. I made a typo error in jira number. I just
corrected it and updated my PR
josh0yeh commented on issue #9587: [FLINK-13686][yarn] Validate YARN deployment
against YARN scheduler maximum vcore size
URL: https://github.com/apache/flink/pull/9587#issuecomment-527228452
Hi @rmetzger, thanks for adding label for my PR. Sorry I didn't add labels.
However, I believe th
flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file
replication config for yarn configuration
URL: https://github.com/apache/flink/pull/8303#issuecomment-511684151
## CI report:
* 6a7ca58b4a04f6dce250045e021702e67e82b893 : FAILURE
[Build](https://travis
flinkbot edited a comment on issue #9596: [FLINK-13445] Add
'jobmanager.containerized.heap-cutoff-{min,ratio}' …
URL: https://github.com/apache/flink/pull/9596#issuecomment-527151332
## CI report:
* d28b03f8a7e7832544172047411e02db2cb90a8a : UNKNOWN
* 45e170dfb0fd9ff73061f5800
flinkbot edited a comment on issue #9596: [FLINK-13445] Add
'jobmanager.containerized.heap-cutoff-{min,ratio}' …
URL: https://github.com/apache/flink/pull/9596#issuecomment-527151332
## CI report:
* d28b03f8a7e7832544172047411e02db2cb90a8a : UNKNOWN
* 45e170dfb0fd9ff73061f5800
1u0 commented on issue #9548: [hotfix] [docs] Fix typo
URL: https://github.com/apache/flink/pull/9548#issuecomment-527219545
Hi @YngwieWang, no worries.
I've cherry-picked and combined your changes in my fork
(https://github.com/1u0/flink/tree/pr-9538-docs-hotfix), but I cannot merge
flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file
replication config for yarn configuration
URL: https://github.com/apache/flink/pull/8303#issuecomment-511684151
## CI report:
* 6a7ca58b4a04f6dce250045e021702e67e82b893 : FAILURE
[Build](https://travis
flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file
replication config for yarn configuration
URL: https://github.com/apache/flink/pull/8303#issuecomment-511684151
## CI report:
* 6a7ca58b4a04f6dce250045e021702e67e82b893 : FAILURE
[Build](https://travis
flinkbot edited a comment on issue #9597: [FLINK-13941][fs-connector] Do not
delete partial part files from S3.
URL: https://github.com/apache/flink/pull/9597#issuecomment-527190094
## CI report:
* 284dde7bc7c8a889120ec6faf03374969a366be9 : SUCCESS
[Build](https://travis-ci.com/
HuangZhenQiu commented on issue #8303: [FLINK-12343] [flink-yarn] add file
replication config for yarn configuration
URL: https://github.com/apache/flink/pull/8303#issuecomment-527202411
@tillrohrmann @wangyang0918 Yes. Thanks for pointing out theoretic
feasibility. We do this for a use c
flinkbot edited a comment on issue #9597: [FLINK-13941][fs-connector] Do not
delete partial part files from S3.
URL: https://github.com/apache/flink/pull/9597#issuecomment-527190094
## CI report:
* 284dde7bc7c8a889120ec6faf03374969a366be9 : PENDING
[Build](https://travis-ci.com/
flinkbot commented on issue #9597: [FLINK-13941][fs-connector] Do not delete
partial part files from S3.
URL: https://github.com/apache/flink/pull/9597#issuecomment-527190094
## CI report:
* 284dde7bc7c8a889120ec6faf03374969a366be9 : UNKNOWN
-
flinkbot edited a comment on issue #9565: [FLINK-12501] Use
SpecificRecord.getSchema in AvroFactory
URL: https://github.com/apache/flink/pull/9565#issuecomment-526522446
## CI report:
* 247e51b1cba1bed7eaa64798623865e13c2a8c8b : CANCELED
[Build](https://travis-ci.com/flink-ci/fl
flinkbot commented on issue #9597: [FLINK-13941][fs-connector] Do not delete
partial part files from S3.
URL: https://github.com/apache/flink/pull/9597#issuecomment-527188085
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to revie
zhijiangW commented on a change in pull request #9483: [FLINK-13767][task]
Migrate isFinished method from AvailabilityListener to AsyncDataInput
URL: https://github.com/apache/flink/pull/9483#discussion_r320002964
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/st
kl0u commented on issue #9597: [FLINK-13941][fs-connector] Do not delete
partial part files from S3.
URL: https://github.com/apache/flink/pull/9597#issuecomment-527187563
R @aljoscha
This is an automated message from the Apac
[
https://issues.apache.org/jira/browse/FLINK-13941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-13941:
---
Labels: pull-request-available (was: )
> Prevent data-loss by not cleaning up small part fi
kl0u opened a new pull request #9597: [FLINK-13941][fs-connector] Do not delete
partial part files from S3.
URL: https://github.com/apache/flink/pull/9597
## What is the purpose of the change
Fixes potential data-loss in the `StreamingFileSink` that can happen after
restoring from a
flinkbot edited a comment on issue #9596: [FLINK-13445] Add
'jobmanager.containerized.heap-cutoff-{min,ratio}' …
URL: https://github.com/apache/flink/pull/9596#issuecomment-527151332
## CI report:
* d28b03f8a7e7832544172047411e02db2cb90a8a : UNKNOWN
* 45e170dfb0fd9ff73061f5800
[
https://issues.apache.org/jira/browse/FLINK-13616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-13616.
---
Resolution: Done
Done via a054799ed59d961df6d10fc8215b5820e70694ba
> Update BucketingSinkMi
tillrohrmann closed pull request #9590: [FLINK-13616][Tests] Update
BucketingSinkMigrationTest to restore from 1.9 savepoint
URL: https://github.com/apache/flink/pull/9590
This is an automated message from the Apache Git Ser
[
https://issues.apache.org/jira/browse/FLINK-13615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-13615.
---
Resolution: Done
Done via 7752c91884eab87350263b7ab3d106aea5c11467
> Update CEPMigrationTes
tillrohrmann closed pull request #9589: [FLINK-13615][Tests] Update
CEPMigrationTest to restore from 1.9 savepoint
URL: https://github.com/apache/flink/pull/9589
This is an automated message from the Apache Git Service.
To r
[
https://issues.apache.org/jira/browse/FLINK-13617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-13617.
---
Resolution: Done
Done via a2f7b2cc485491a964f3879578fac1d6d8f58778
> Update FlinkKafkaProdu
tillrohrmann closed pull request #9592: [FLINK-13617] Update
FlinkKafkaProducer011MigrationTest to restore from 1.9 savepoint
URL: https://github.com/apache/flink/pull/9592
This is an automated message from the Apache Git Se
flinkbot edited a comment on issue #9565: [FLINK-12501] Use
SpecificRecord.getSchema in AvroFactory
URL: https://github.com/apache/flink/pull/9565#issuecomment-526522446
## CI report:
* 247e51b1cba1bed7eaa64798623865e13c2a8c8b : CANCELED
[Build](https://travis-ci.com/flink-ci/fl
tillrohrmann closed pull request #9594: [FLINK-13618] Update
FlinkKafkaConsumerBaseMigrationTest to restore from 1.9 savepoint
URL: https://github.com/apache/flink/pull/9594
This is an automated message from the Apache Git S
[
https://issues.apache.org/jira/browse/FLINK-13618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-13618.
---
Resolution: Done
Done via c83ba1079aa7ad59a6014dda6c69503c78b34202
> Update FlinkKafkaConsu
[
https://issues.apache.org/jira/browse/FLINK-13940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16920892#comment-16920892
]
Kostas Kloudas commented on FLINK-13940:
Actually I think not deleting anything
flinkbot edited a comment on issue #9596: [FLINK-13445] Add
'jobmanager.containerized.heap-cutoff-{min,ratio}' …
URL: https://github.com/apache/flink/pull/9596#issuecomment-527151332
## CI report:
* d28b03f8a7e7832544172047411e02db2cb90a8a : UNKNOWN
* 45e170dfb0fd9ff73061f5800
flinkbot edited a comment on issue #9564:
[FLINK-12481][FLINK-12482][FLINK-12958] Streaming runtime: integrate mailbox
for timer triggers, checkpoints and AsyncWaitOperator
URL: https://github.com/apache/flink/pull/9564#issuecomment-526487220
## CI report:
* 3c6c3d69983136fb8bfa
aljoscha commented on issue #9565: [FLINK-12501] Use SpecificRecord.getSchema
in AvroFactory
URL: https://github.com/apache/flink/pull/9565#issuecomment-527158574
@flinkbot run travis
This is an automated message from the Apa
tillrohrmann edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add
file replication config for yarn configuration
URL: https://github.com/apache/flink/pull/8303#issuecomment-527157816
Ah I think I misunderstood the problem the whole time. @HuangZhenQiu did you
intend to increase
tillrohrmann commented on issue #8303: [FLINK-12343] [flink-yarn] add file
replication config for yarn configuration
URL: https://github.com/apache/flink/pull/8303#issuecomment-527157816
Ah I think I misunderstood the problem the whole time. @HuangZhenQiu did you
intend to increase the rep
tillrohrmann commented on a change in pull request #8303: [FLINK-12343]
[flink-yarn] add file replication config for yarn configuration
URL: https://github.com/apache/flink/pull/8303#discussion_r319968797
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClus
flinkbot edited a comment on issue #9596: [FLINK-13445] Add
'jobmanager.containerized.heap-cutoff-{min,ratio}' …
URL: https://github.com/apache/flink/pull/9596#issuecomment-527151332
## CI report:
* d28b03f8a7e7832544172047411e02db2cb90a8a : UNKNOWN
* 45e170dfb0fd9ff73061f5800
[
https://issues.apache.org/jira/browse/FLINK-4399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16920867#comment-16920867
]
Biao Liu commented on FLINK-4399:
-
Hi [~till.rohrmann], thanks for feedback!
{quote}Inst
flinkbot commented on issue #9596: [FLINK-13445] Add
'jobmanager.containerized.heap-cutoff-{min,ratio}' …
URL: https://github.com/apache/flink/pull/9596#issuecomment-527151332
## CI report:
* d28b03f8a7e7832544172047411e02db2cb90a8a : UNKNOWN
flinkbot commented on issue #9596: [FLINK-13445] Add
'jobmanager.containerized.heap-cutoff-{min,ratio}' …
URL: https://github.com/apache/flink/pull/9596#issuecomment-527148930
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to revi
dmvk opened a new pull request #9596: [FLINK-13445] Add
'jobmanager.containerized.heap-cutoff-{min,ratio}' …
URL: https://github.com/apache/flink/pull/9596
## What is the purpose of the change
* Distinguish Memory Configuration for TaskManager and JobManager
## Brief
[
https://issues.apache.org/jira/browse/FLINK-13445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-13445:
---
Labels: pull-request-available (was: )
> Distinguishing Memory Configuration for TaskManage
[
https://issues.apache.org/jira/browse/FLINK-13612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16920844#comment-16920844
]
Congxian Qiu(klion26) commented on FLINK-13612:
---
[~Vow] Does this problem
flinkbot edited a comment on issue #9545: [FLINK-13355][docs] Add documentation
for Temporal Table Join in blink planner
URL: https://github.com/apache/flink/pull/9545#issuecomment-525381895
## CI report:
* 88e894661cfb3d8bc1b61540bc03dd2315706b63 : SUCCESS
[Build](https://travi
flinkbot edited a comment on issue #9564:
[FLINK-12481][FLINK-12482][FLINK-12958] Streaming runtime: integrate mailbox
for timer triggers, checkpoints and AsyncWaitOperator
URL: https://github.com/apache/flink/pull/9564#issuecomment-526487220
## CI report:
* 3c6c3d69983136fb8bfa
flinkbot edited a comment on issue #9589: [FLINK-13615][Tests] Update
CEPMigrationTest to restore from 1.9 savepoint
URL: https://github.com/apache/flink/pull/9589#issuecomment-527014107
## CI report:
* e6d656832639f50f6d62da4249ddda72b8ec4b8a : FAILURE
[Build](https://travis-ci
flinkbot edited a comment on issue #9564:
[FLINK-12481][FLINK-12482][FLINK-12958] Streaming runtime: integrate mailbox
for timer triggers, checkpoints and AsyncWaitOperator
URL: https://github.com/apache/flink/pull/9564#issuecomment-526487220
## CI report:
* 3c6c3d69983136fb8bfa
flinkbot edited a comment on issue #9575: [FLINK-13912][client] Remove
ClusterClient#getClusterConnectionInfo
URL: https://github.com/apache/flink/pull/9575#issuecomment-526608245
## CI report:
* b511754c50bd15675d802e3e60294b2a6ffed65a : CANCELED
[Build](https://travis-ci.com/f
Fabian Hueske created FLINK-13942:
-
Summary: Add Overview page for Getting Started section
Key: FLINK-13942
URL: https://issues.apache.org/jira/browse/FLINK-13942
Project: Flink
Issue Type: S
Kostas Kloudas created FLINK-13941:
--
Summary: Prevent data-loss by not cleaning up small part files
from S3.
Key: FLINK-13941
URL: https://issues.apache.org/jira/browse/FLINK-13941
Project: Flink
flinkbot edited a comment on issue #9564:
[FLINK-12481][FLINK-12482][FLINK-12958] Streaming runtime: integrate mailbox
for timer triggers, checkpoints and AsyncWaitOperator
URL: https://github.com/apache/flink/pull/9564#issuecomment-526484775
Thanks a lot for your contribution to the Apach
[
https://issues.apache.org/jira/browse/FLINK-13940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16920822#comment-16920822
]
Kostas Kloudas commented on FLINK-13940:
I am also leaning towards this solution
[
https://issues.apache.org/jira/browse/FLINK-13940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas reassigned FLINK-13940:
--
Assignee: Kostas Kloudas
> S3RecoverableWriter causes job to get stuck in recovery
>
flinkbot edited a comment on issue #9564:
[FLINK-12481][FLINK-12482][FLINK-12958] Streaming runtime: integrate mailbox
for timer triggers, checkpoints and AsyncWaitOperator
URL: https://github.com/apache/flink/pull/9564#issuecomment-526487220
## CI report:
* 3c6c3d69983136fb8bfa
flinkbot edited a comment on issue #9564:
[FLINK-12481][FLINK-12482][FLINK-12958] Streaming runtime: integrate mailbox
for timer triggers, checkpoints and AsyncWaitOperator
URL: https://github.com/apache/flink/pull/9564#issuecomment-526484775
Thanks a lot for your contribution to the Apach
1u0 commented on a change in pull request #9564:
[FLINK-12481][FLINK-12482][FLINK-12958] Streaming runtime: integrate mailbox
for timer triggers, checkpoints and AsyncWaitOperator
URL: https://github.com/apache/flink/pull/9564#discussion_r319927204
##
File path:
flink-runtime/src/
flinkbot edited a comment on issue #9564:
[FLINK-12481][FLINK-12482][FLINK-12958] Streaming runtime: integrate mailbox
for timer triggers, checkpoints and AsyncWaitOperator
URL: https://github.com/apache/flink/pull/9564#issuecomment-526487220
## CI report:
* 3c6c3d69983136fb8bfa
[
https://issues.apache.org/jira/browse/FLINK-12750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-12750:
-
Assignee: Fabian Hueske
> Gettting Started - Docker Playground - Interactive SQL Playgr
[
https://issues.apache.org/jira/browse/FLINK-13940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16920800#comment-16920800
]
Aljoscha Krettek commented on FLINK-13940:
--
I think the solution is to never cl
flinkbot edited a comment on issue #9564:
[FLINK-12481][FLINK-12482][FLINK-12958] Streaming runtime: integrate mailbox
for timer triggers, checkpoints and AsyncWaitOperator
URL: https://github.com/apache/flink/pull/9564#issuecomment-526484775
Thanks a lot for your contribution to the Apach
1u0 commented on a change in pull request #9564:
[FLINK-12481][FLINK-12482][FLINK-12958] Streaming runtime: integrate mailbox
for timer triggers, checkpoints and AsyncWaitOperator
URL: https://github.com/apache/flink/pull/9564#discussion_r319924248
##
File path:
flink-runtime/src/
flinkbot edited a comment on issue #9564:
[FLINK-12481][FLINK-12482][FLINK-12958] Streaming runtime: integrate mailbox
for timer triggers, checkpoints and AsyncWaitOperator
URL: https://github.com/apache/flink/pull/9564#issuecomment-526484775
Thanks a lot for your contribution to the Apach
1u0 commented on a change in pull request #9564:
[FLINK-12481][FLINK-12482][FLINK-12958] Streaming runtime: integrate mailbox
for timer triggers, checkpoints and AsyncWaitOperator
URL: https://github.com/apache/flink/pull/9564#discussion_r319923615
##
File path:
flink-streaming-ja
[
https://issues.apache.org/jira/browse/FLINK-13568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu resolved FLINK-13568.
-
Resolution: Fixed
1.10.0: 6094a52abea4caa3914c807dee40cf9eadbe63a0
1.9.1: 1f0c67087f19b10d1218af30282414
flinkbot edited a comment on issue #9354: [FLINK-13568][sql-parser] DDL create
table doesn't allow STRING data …
URL: https://github.com/apache/flink/pull/9354#issuecomment-518082256
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
1 - 100 of 255 matches
Mail list logo
