flinkbot edited a comment on issue #9929: [BP-1.9][FLINK-12122] Add support for
spreading slots out across all TaskExecutors
URL: https://github.com/apache/flink/pull/9929#issuecomment-543216984
## CI report:
* 54c386c5c9e0e45bf8d44a0acf6b6c778c36441c : PENDING
[Build](https://t
[
https://issues.apache.org/jira/browse/FLINK-5413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-5413:
--
Labels: pull-request-available (was: )
> Convert TableEnvironmentITCases to unit tests
> -
flinkbot edited a comment on issue #9928: [FLINK-12122] Add support for
spreading slots out across all TaskExecutors
URL: https://github.com/apache/flink/pull/9928#issuecomment-543204040
## CI report:
* 1f0eed38301790afdbbd981d2a9853fa240e10df : FAILURE
[Build](https://travis-ci
twalthr closed pull request #3565: [FLINK-5413] [table] Convert
TableEnvironmentITCases to unit tests
URL: https://github.com/apache/flink/pull/3565
This is an automated message from the Apache Git Service.
To respond to the
twalthr commented on issue #3565: [FLINK-5413] [table] Convert
TableEnvironmentITCases to unit tests
URL: https://github.com/apache/flink/pull/3565#issuecomment-543228746
This PR is not relevant anymore as the old planner is replaced by the new
Blink planner. I will close this PR and the c
flinkbot edited a comment on issue #9918: [Flink-14370] Debugging KafkaProducer
failures
URL: https://github.com/apache/flink/pull/9918#issuecomment-542836528
## CI report:
* 7785824dd3e7df011aff20426b7ff3d5ee908fbc : FAILURE
[Build](https://travis-ci.com/flink-ci/flink/builds/1
flinkbot edited a comment on issue #9916: [FLINK-14408][Table-Planner]UDF's
open method is invoked to initialize when sql is optimized in oldPlanner
URL: https://github.com/apache/flink/pull/9916#issuecomment-542764294
## CI report:
* cd122b399a8dc12c3c604d7db6dea012ee7c0c7f : SU
flinkbot edited a comment on issue #9900: [FLINK-14366][tests] Annotate
MiniCluster tests in flink-tests with AlsoRunWithSchedulerNG
URL: https://github.com/apache/flink/pull/9900#issuecomment-542033352
## CI report:
* a69bbc4f6eb0eac5509a989ebd5a4f31d8b028d6 : FAILURE
[Build](h
flinkbot commented on issue #9930: [FLINK-12848][table] Fix invalid row type
caching
URL: https://github.com/apache/flink/pull/9930#issuecomment-543227145
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request.
twalthr opened a new pull request #9930: [FLINK-12848][table] Fix invalid row
type caching
URL: https://github.com/apache/flink/pull/9930
## What is the purpose of the change
This PR fixes a critical bug related to the lookup of rows with same types
but different field names. We avo
hailong wang created FLINK-14441:
Summary: Fix ValueLiteralExpression#getValueAs when valueClass is
Period.class
Key: FLINK-14441
URL: https://issues.apache.org/jira/browse/FLINK-14441
Project: Flink
flinkbot edited a comment on issue #9255: [FLINK-13034] Introduce isEmpty
method for MapState
URL: https://github.com/apache/flink/pull/9255#issuecomment-515870480
## CI report:
* de863750b7262d091d2e7dd82767b8f9b2e2c52a : SUCCESS
[Build](https://travis-ci.com/flink-ci/flink/bui
flinkbot edited a comment on issue #9884: [FLINK-14266][table] Introduce
RowCsvInputFormat to new CSV module
URL: https://github.com/apache/flink/pull/9884#issuecomment-541276093
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to r
twalthr commented on a change in pull request #9884: [FLINK-14266][table]
Introduce RowCsvInputFormat to new CSV module
URL: https://github.com/apache/flink/pull/9884#discussion_r336064018
##
File path:
flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/RowCsvInputF
twalthr commented on a change in pull request #9884: [FLINK-14266][table]
Introduce RowCsvInputFormat to new CSV module
URL: https://github.com/apache/flink/pull/9884#discussion_r336062841
##
File path:
flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/RowCsvInputF
twalthr commented on a change in pull request #9884: [FLINK-14266][table]
Introduce RowCsvInputFormat to new CSV module
URL: https://github.com/apache/flink/pull/9884#discussion_r336061142
##
File path:
flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/RowCsvInputF
flinkbot edited a comment on issue #9921: [FLINK-14130][client] Remove
ClusterClient.run() methods
URL: https://github.com/apache/flink/pull/9921#issuecomment-543089913
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your
flinkbot edited a comment on issue #9778: [FLINK-14206][runtime] Let
fullRestart metric count both full restarts and fine grained restarts
URL: https://github.com/apache/flink/pull/9778#issuecomment-535430586
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot
GJL commented on a change in pull request #9778: [FLINK-14206][runtime] Let
fullRestart metric count both full restarts and fine grained restarts
URL: https://github.com/apache/flink/pull/9778#discussion_r336061177
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/
GJL commented on a change in pull request #9778: [FLINK-14206][runtime] Let
fullRestart metric count both full restarts and fine grained restarts
URL: https://github.com/apache/flink/pull/9778#discussion_r336055383
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/
aljoscha commented on a change in pull request #9921: [FLINK-14130][client]
Remove ClusterClient.run() methods
URL: https://github.com/apache/flink/pull/9921#discussion_r336060677
##
File path:
flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java
##
@@
GJL commented on a change in pull request #9778: [FLINK-14206][runtime] Let
fullRestart metric count both full restarts and fine grained restarts
URL: https://github.com/apache/flink/pull/9778#discussion_r336048716
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/
aljoscha commented on a change in pull request #9921: [FLINK-14130][client]
Remove ClusterClient.run() methods
URL: https://github.com/apache/flink/pull/9921#discussion_r336060375
##
File path:
flink-clients/src/main/java/org/apache/flink/client/program/ContextEnvironment.java
###
GJL commented on a change in pull request #9778: [FLINK-14206][runtime] Let
fullRestart metric count both full restarts and fine grained restarts
URL: https://github.com/apache/flink/pull/9778#discussion_r336058791
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/
GJL commented on a change in pull request #9778: [FLINK-14206][runtime] Let
fullRestart metric count both full restarts and fine grained restarts
URL: https://github.com/apache/flink/pull/9778#discussion_r336055383
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/
GJL commented on a change in pull request #9778: [FLINK-14206][runtime] Let
fullRestart metric count both full restarts and fine grained restarts
URL: https://github.com/apache/flink/pull/9778#discussion_r336027927
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/
flinkbot edited a comment on issue #9916: [FLINK-14408][Table-Planner]UDF's
open method is invoked to initialize when sql is optimized in oldPlanner
URL: https://github.com/apache/flink/pull/9916#issuecomment-542755222
Thanks a lot for your contribution to the Apache Flink project. I'm the
flinkbot commented on issue #9929: [BP-1.9][FLINK-12122] Add support for
spreading slots out across all TaskExecutors
URL: https://github.com/apache/flink/pull/9929#issuecomment-543216984
## CI report:
* 54c386c5c9e0e45bf8d44a0acf6b6c778c36441c : UNKNOWN
Bot commands
flinkbot edited a comment on issue #9927: [FLINK-14397][hive] Failed to run
Hive UDTF with array arguments
URL: https://github.com/apache/flink/pull/9927#issuecomment-543180251
## CI report:
* 14b59100e851fa7494838f1b5c68b4dc732da590 : SUCCESS
[Build](https://travis-ci.com/flink
flinkbot edited a comment on issue #9928: [FLINK-12122] Add support for
spreading slots out across all TaskExecutors
URL: https://github.com/apache/flink/pull/9928#issuecomment-543204040
## CI report:
* 1f0eed38301790afdbbd981d2a9853fa240e10df : FAILURE
[Build](https://travis-ci
wangxlong commented on issue #9916: [FLINK-14408][Table-Planner]UDF's open
method is invoked to initialize when sql is optimized in oldPlanner
URL: https://github.com/apache/flink/pull/9916#issuecomment-543216657
@flinkbot run travis
flinkbot edited a comment on issue #9918: [Flink-14370] Debugging KafkaProducer
failures
URL: https://github.com/apache/flink/pull/9918#issuecomment-542836528
## CI report:
* 7785824dd3e7df011aff20426b7ff3d5ee908fbc : FAILURE
[Build](https://travis-ci.com/flink-ci/flink/builds/1
flinkbot edited a comment on issue #9916: [FLINK-14408][Table-Planner]UDF's
open method is invoked to initialize when sql is optimized in oldPlanner
URL: https://github.com/apache/flink/pull/9916#issuecomment-542764294
## CI report:
* cd122b399a8dc12c3c604d7db6dea012ee7c0c7f : SU
flinkbot edited a comment on issue #9912: [FLINK-14370][kafka][test-stability]
Fix the cascading failure in kaProducerTestBase.
URL: https://github.com/apache/flink/pull/9912#issuecomment-542713850
## CI report:
* c1fe0487729f91e54bb58b2ed0913dda8d00b5f6 : FAILURE
[Build](https:
flinkbot edited a comment on issue #9759: [FLINK-14169][history-server] Cleanup
expired jobs from history server
URL: https://github.com/apache/flink/pull/9759#issuecomment-534556628
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
flinkbot edited a comment on issue #9883: [FLINK-13818][web]: Check whether web
submission are enabled
URL: https://github.com/apache/flink/pull/9883#issuecomment-541277967
## CI report:
* d0647856d0adbe2fdb4ac79dae44e383dd3eb44d : FAILURE
[Build](https://travis-ci.com/flink-ci/
flinkbot edited a comment on issue #9894: [FLINK-14342][table][python] Remove
method FunctionDefinition#getLanguage.
URL: https://github.com/apache/flink/pull/9894#issuecomment-541555428
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
aljoscha commented on issue #9759: [FLINK-14169][history-server] Cleanup
expired jobs from history server
URL: https://github.com/apache/flink/pull/9759#issuecomment-543213869
This looks good now, I refactored the commit into two to separate the pure
test refactoring from adding the new te
twalthr commented on a change in pull request #9894:
[FLINK-14342][table][python] Remove method FunctionDefinition#getLanguage.
URL: https://github.com/apache/flink/pull/9894#discussion_r336048014
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/t
flinkbot edited a comment on issue #9900: [FLINK-14366][tests] Annotate
MiniCluster tests in flink-tests with AlsoRunWithSchedulerNG
URL: https://github.com/apache/flink/pull/9900#issuecomment-542026880
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I he
flinkbot edited a comment on issue #9255: [FLINK-13034] Introduce isEmpty
method for MapState
URL: https://github.com/apache/flink/pull/9255#issuecomment-515870480
## CI report:
* de863750b7262d091d2e7dd82767b8f9b2e2c52a : SUCCESS
[Build](https://travis-ci.com/flink-ci/flink/bui
Zhu Zhu created FLINK-14440:
---
Summary: Enable BatchFineGrainedRecoveryITCase to pass with
scheduler NG
Key: FLINK-14440
URL: https://issues.apache.org/jira/browse/FLINK-14440
Project: Flink
Issue
flinkbot edited a comment on issue #8468: [FLINK-12399][table][table-planner]
Fix FilterableTableSource does not change after applyPredicate
URL: https://github.com/apache/flink/pull/8468#issuecomment-524372146
## CI report:
* baae1632aabac35e6e08b402065857c4d67491f2 : FAILURE
[
Zhu Zhu created FLINK-14439:
---
Summary: RestartPipelinedRegionStrategy leverage tracked partition
availability for better failover experience in DefaultScheduler
Key: FLINK-14439
URL: https://issues.apache.org/jira/brow
flinkbot edited a comment on issue #9861: [FLINK-14237][yarn] No need to rename
shipped Flink jar
URL: https://github.com/apache/flink/pull/9861#issuecomment-539888511
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your
tillrohrmann commented on issue #9861: [FLINK-14237][yarn] No need to rename
shipped Flink jar
URL: https://github.com/apache/flink/pull/9861#issuecomment-543206508
What's the state of the merging @TisonKun?
This is an automa
flinkbot edited a comment on issue #9910: [FLINK-14405][runtime] Align
ResourceProfile/ResourceSpec fields with the new TaskExecutor memory setups.
URL: https://github.com/apache/flink/pull/9910#issuecomment-542638190
Thanks a lot for your contribution to the Apache Flink project. I'm the
azagrebin commented on a change in pull request #9910: [FLINK-14405][runtime]
Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory
setups.
URL: https://github.com/apache/flink/pull/9910#discussion_r336044023
##
File path:
flink-table/flink-table-planner-blink
azagrebin commented on a change in pull request #9910: [FLINK-14405][runtime]
Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory
setups.
URL: https://github.com/apache/flink/pull/9910#discussion_r336044023
##
File path:
flink-table/flink-table-planner-blink
flinkbot edited a comment on issue #9910: [FLINK-14405][runtime] Align
ResourceProfile/ResourceSpec fields with the new TaskExecutor memory setups.
URL: https://github.com/apache/flink/pull/9910#issuecomment-542638190
Thanks a lot for your contribution to the Apache Flink project. I'm the
flinkbot edited a comment on issue #9918: [Flink-14370] Debugging KafkaProducer
failures
URL: https://github.com/apache/flink/pull/9918#issuecomment-542830264
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull requ
flinkbot edited a comment on issue #9780: [FLINK-14042] [flink-table-planner]
Fix TemporalTable row schema always inferred as nullable
URL: https://github.com/apache/flink/pull/9780#issuecomment-535560331
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I
azagrebin commented on a change in pull request #9910: [FLINK-14405][runtime]
Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory
setups.
URL: https://github.com/apache/flink/pull/9910#discussion_r336044023
##
File path:
flink-table/flink-table-planner-blink
flinkbot edited a comment on issue #8468: [FLINK-12399][table][table-planner]
Fix FilterableTableSource does not change after applyPredicate
URL: https://github.com/apache/flink/pull/8468#issuecomment-493155027
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkb
azagrebin commented on a change in pull request #9910: [FLINK-14405][runtime]
Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory
setups.
URL: https://github.com/apache/flink/pull/9910#discussion_r336042781
##
File path:
flink-runtime/src/main/java/org/apach
flinkbot commented on issue #9928: [FLINK-12122] Add support for spreading
slots out across all TaskExecutors
URL: https://github.com/apache/flink/pull/9928#issuecomment-543204040
## CI report:
* 1f0eed38301790afdbbd981d2a9853fa240e10df : UNKNOWN
Bot commands
The
flinkbot edited a comment on issue #9926: [FLINK-14004][runtime,test] Add test
coverage for stateful SourceReaderOperator implementation
URL: https://github.com/apache/flink/pull/9926#issuecomment-543157822
## CI report:
* a479e12af659bfb557d2d4092ab55c5290b98684 : SUCCESS
[Buil
twalthr commented on issue #9780: [FLINK-14042] [flink-table-planner] Fix
TemporalTable row schema always inferred as nullable
URL: https://github.com/apache/flink/pull/9780#issuecomment-543203656
We can also discuss the location once you wrote the test. Maybe
`TimeAttributesITCase` could
KurtYoung commented on issue #8468: [FLINK-12399][table][table-planner] Fix
FilterableTableSource does not change after applyPredicate
URL: https://github.com/apache/flink/pull/8468#issuecomment-543203366
@flinkbot run travis
azagrebin commented on a change in pull request #9910: [FLINK-14405][runtime]
Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory
setups.
URL: https://github.com/apache/flink/pull/9910#discussion_r336041467
##
File path:
flink-runtime/src/main/java/org/apach
flinkbot edited a comment on issue #9912: [FLINK-14370][kafka][test-stability]
Fix the cascading failure in kaProducerTestBase.
URL: https://github.com/apache/flink/pull/9912#issuecomment-542713850
## CI report:
* c1fe0487729f91e54bb58b2ed0913dda8d00b5f6 : FAILURE
[Build](https:
flinkbot edited a comment on issue #9883: [FLINK-13818][web]: Check whether web
submission are enabled
URL: https://github.com/apache/flink/pull/9883#issuecomment-541277967
## CI report:
* d0647856d0adbe2fdb4ac79dae44e383dd3eb44d : FAILURE
[Build](https://travis-ci.com/flink-ci/
flinkbot commented on issue #9929: [BP-1.9][FLINK-12122] Add support for
spreading slots out across all TaskExecutors
URL: https://github.com/apache/flink/pull/9929#issuecomment-543201771
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the communit
[
https://issues.apache.org/jira/browse/FLINK-14364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16953802#comment-16953802
]
Jiayi Liao commented on FLINK-14364:
[~twalthr] I just thought it's not worth it. We
[
https://issues.apache.org/jira/browse/FLINK-12122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16953801#comment-16953801
]
Till Rohrmann commented on FLINK-12122:
---
I've opened a PR to fix this problem in F
tillrohrmann opened a new pull request #9929: [BP-1.9][FLINK-12122] Add support
for spreading slots out across all TaskExecutors
URL: https://github.com/apache/flink/pull/9929
Backport of #9928 to `release-1.9`.
This is an au
flinkbot edited a comment on issue #9255: [FLINK-13034] Introduce isEmpty
method for MapState
URL: https://github.com/apache/flink/pull/9255#issuecomment-515870480
## CI report:
* de863750b7262d091d2e7dd82767b8f9b2e2c52a : SUCCESS
[Build](https://travis-ci.com/flink-ci/flink/bui
zhuzhurk commented on a change in pull request #9783: [FLINK-14040][travis]
Enable MiniCluster tests based on schedulerNG in Flink cron build
URL: https://github.com/apache/flink/pull/9783#discussion_r336026749
##
File path: tools/travis/stage.sh
##
@@ -126,6 +127,10 @@ fl
flinkbot edited a comment on issue #9255: [FLINK-13034] Introduce isEmpty
method for MapState
URL: https://github.com/apache/flink/pull/9255#issuecomment-515868641
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull
flinkbot commented on issue #9928: [FLINK-12122] Add support for spreading
slots out across all TaskExecutors
URL: https://github.com/apache/flink/pull/9928#issuecomment-543196767
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to
zhuzhurk commented on a change in pull request #9783: [FLINK-14040][travis]
Enable MiniCluster tests based on schedulerNG in Flink cron build
URL: https://github.com/apache/flink/pull/9783#discussion_r336026749
##
File path: tools/travis/stage.sh
##
@@ -126,6 +127,10 @@ fl
zhuzhurk commented on a change in pull request #9783: [FLINK-14040][travis]
Enable MiniCluster tests based on schedulerNG in Flink cron build
URL: https://github.com/apache/flink/pull/9783#discussion_r336026749
##
File path: tools/travis/stage.sh
##
@@ -126,6 +127,10 @@ fl
[
https://issues.apache.org/jira/browse/FLINK-12122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12122:
---
Labels: pull-request-available (was: )
> Spread out tasks evenly across all available regis
flinkbot edited a comment on issue #9783: [FLINK-14040][travis] Enable
MiniCluster tests based on schedulerNG in Flink cron build
URL: https://github.com/apache/flink/pull/9783#issuecomment-535844880
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help
Myasuka commented on issue #9255: [FLINK-13034] Introduce isEmpty method for
MapState
URL: https://github.com/apache/flink/pull/9255#issuecomment-543195627
Rebase with latest master branch to re-trigger new CI build.
This is
tillrohrmann opened a new pull request #9928: [FLINK-12122] Add support for
spreading slots out across all TaskExecutors
URL: https://github.com/apache/flink/pull/9928
## What is the purpose of the change
This PR adds support for spreading slots out across all currently registered
`
zhuzhurk commented on a change in pull request #9783: [FLINK-14040][travis]
Enable MiniCluster tests based on schedulerNG in Flink cron build
URL: https://github.com/apache/flink/pull/9783#discussion_r336030644
##
File path: tools/travis/stage.sh
##
@@ -201,8 +213,27 @@ fu
zhuzhurk commented on a change in pull request #9783: [FLINK-14040][travis]
Enable MiniCluster tests based on schedulerNG in Flink cron build
URL: https://github.com/apache/flink/pull/9783#discussion_r336030644
##
File path: tools/travis/stage.sh
##
@@ -201,8 +213,27 @@ fu
zhuzhurk commented on a change in pull request #9783: [FLINK-14040][travis]
Enable MiniCluster tests based on schedulerNG in Flink cron build
URL: https://github.com/apache/flink/pull/9783#discussion_r336030555
##
File path: .travis.yml
##
@@ -152,6 +156,10 @@ jobs:
flinkbot edited a comment on issue #9910: [FLINK-14405][runtime] Align
ResourceProfile/ResourceSpec fields with the new TaskExecutor memory setups.
URL: https://github.com/apache/flink/pull/9910#issuecomment-542638190
Thanks a lot for your contribution to the Apache Flink project. I'm the
flinkbot edited a comment on issue #9386: [FLINK-13601][tests] Harden
RegionFailoverITCase by recording info when checkpoint just completed
URL: https://github.com/apache/flink/pull/9386#issuecomment-519209689
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbo
azagrebin commented on a change in pull request #9910: [FLINK-14405][runtime]
Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory
setups.
URL: https://github.com/apache/flink/pull/9910#discussion_r336028586
##
File path:
flink-core/src/main/java/org/apache/f
vthinkxie edited a comment on issue #9883: [FLINK-13818][web]: Check whether
web submission are enabled
URL: https://github.com/apache/flink/pull/9883#issuecomment-543175674
I have removed the compatible code as you insist.
I don't think it is valuable enough to start an ML to discuss so
flinkbot edited a comment on issue #9905: [FLINK-14396][network] Implement
rudimentary non-blocking network output
URL: https://github.com/apache/flink/pull/9905#issuecomment-542178315
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
Myasuka commented on issue #9386: [FLINK-13601][tests] Harden
RegionFailoverITCase by recording info when checkpoint just completed
URL: https://github.com/apache/flink/pull/9386#issuecomment-543192776
@zentol If current `lastCompletedCheckpointId` is `chk-3`, when task starts
checkpointi
zhijiangW commented on a change in pull request #9905: [FLINK-14396][network]
Implement rudimentary non-blocking network output
URL: https://github.com/apache/flink/pull/9905#discussion_r336027531
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/
flinkbot edited a comment on issue #9783: [FLINK-14040][travis] Enable
MiniCluster tests based on schedulerNG in Flink cron build
URL: https://github.com/apache/flink/pull/9783#issuecomment-535844880
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help
[
https://issues.apache.org/jira/browse/FLINK-14309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16953788#comment-16953788
]
Jiangjie Qin commented on FLINK-14309:
--
[~trohrmann] Thanks for the explanation. It
zhuzhurk commented on a change in pull request #9783: [FLINK-14040][travis]
Enable MiniCluster tests based on schedulerNG in Flink cron build
URL: https://github.com/apache/flink/pull/9783#discussion_r336026749
##
File path: tools/travis/stage.sh
##
@@ -126,6 +127,10 @@ fl
flinkbot edited a comment on issue #9927: [FLINK-14397][hive] Failed to run
Hive UDTF with array arguments
URL: https://github.com/apache/flink/pull/9927#issuecomment-543180251
## CI report:
* 14b59100e851fa7494838f1b5c68b4dc732da590 : PENDING
[Build](https://travis-ci.com/flink
flinkbot edited a comment on issue #9912: [FLINK-14370][kafka][test-stability]
Fix the cascading failure in kaProducerTestBase.
URL: https://github.com/apache/flink/pull/9912#issuecomment-542705661
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help th
flinkbot edited a comment on issue #9916: [FLINK-14408][Table-Planner]UDF's
open method is invoked to initialize when sql is optimized in oldPlanner
URL: https://github.com/apache/flink/pull/9916#issuecomment-542764294
## CI report:
* cd122b399a8dc12c3c604d7db6dea012ee7c0c7f : SU
flinkbot edited a comment on issue #9905: [FLINK-14396][network] Implement
rudimentary non-blocking network output
URL: https://github.com/apache/flink/pull/9905#issuecomment-542178315
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
zhijiangW commented on a change in pull request #9905: [FLINK-14396][network]
Implement rudimentary non-blocking network output
URL: https://github.com/apache/flink/pull/9905#discussion_r336024356
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partiti
flinkbot edited a comment on issue #9890:
[FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF
URL: https://github.com/apache/flink/pull/9890#issuecomment-541418126
## CI report:
* ec7f1a70fd420d25326e49ac1f4de878d4aae481 : FAILURE
[Build](https://trav
flinkbot edited a comment on issue #9832: [FLINK-11843] Bind lifespan of
Dispatcher to leader session
URL: https://github.com/apache/flink/pull/9832#issuecomment-537039262
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review y
flinkbot edited a comment on issue #9883: [FLINK-13818][web]: Check whether web
submission are enabled
URL: https://github.com/apache/flink/pull/9883#issuecomment-541277967
## CI report:
* d0647856d0adbe2fdb4ac79dae44e383dd3eb44d : FAILURE
[Build](https://travis-ci.com/flink-ci/
GJL commented on a change in pull request #9832: [FLINK-11843] Bind lifespan of
Dispatcher to leader session
URL: https://github.com/apache/flink/pull/9832#discussion_r336020164
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/runner/SessionDispatcherLe
GJL commented on a change in pull request #9832: [FLINK-11843] Bind lifespan of
Dispatcher to leader session
URL: https://github.com/apache/flink/pull/9832#discussion_r336014644
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/runner/DefaultDispatcherRu
GJL commented on a change in pull request #9832: [FLINK-11843] Bind lifespan of
Dispatcher to leader session
URL: https://github.com/apache/flink/pull/9832#discussion_r335895994
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/runner/DefaultDispatcherRu
201 - 300 of 680 matches
Mail list logo
