[
https://issues.apache.org/jira/browse/FLINK-14237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16946565#comment-16946565
]
Zili Chen commented on FLINK-14237:
---
Hi [~trohrmann],
{{flink.jar}} is shipped as fli
[
https://issues.apache.org/jira/browse/FLINK-14306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16946564#comment-16946564
]
Dian Fu commented on FLINK-14306:
-
Sorry for this problem caused by my commit and also t
[
https://issues.apache.org/jira/browse/FLINK-14311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16946556#comment-16946556
]
Yu Li commented on FLINK-14311:
---
Another instance: https://api.travis-ci.org/v3/job/594192
flinkbot edited a comment on issue #9405: [FLINK-13668][ml] Add abstract
classes for three typical scenarios of (Flat)Mapper
URL: https://github.com/apache/flink/pull/9405#issuecomment-519901201
## CI report:
* c1fedc4de6a92bc2c5f84d0e0c3038f29fd8944f : FAILURE
[Build](https://t
[
https://issues.apache.org/jira/browse/FLINK-14196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16946553#comment-16946553
]
Yu Li edited comment on FLINK-14196 at 10/8/19 6:47 AM:
Checked
[
https://issues.apache.org/jira/browse/FLINK-14196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16946553#comment-16946553
]
Yu Li commented on FLINK-14196:
---
Checked several recent cron builds and this NPE issue nev
flinkbot commented on issue #9851: [FLINK-14341]Fix flink-python builds
failure: no such option: --prefix
URL: https://github.com/apache/flink/pull/9851#issuecomment-539365871
## CI report:
* 1007e8b66d42b613ceafb86457913381a4e27b0f : UNKNOWN
Bot commands
The @fli
flinkbot edited a comment on issue #9355: [FLINK-13577][ml] Add an util class
to build result row and generate …
URL: https://github.com/apache/flink/pull/9355#issuecomment-518089359
## CI report:
* f8f3792f7ce55735f05200c90431b20b99a42d18 : FAILURE
[Build](https://travis-ci.com
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-537049332
## CI report:
* abaae048fef753455970fac9d6ab421b660b0536 : UNKNOWN
* b96c63552ccd322adae7a41a410615e95b53
flinkbot edited a comment on issue #9831: [FLINK-14278] Extend
DispatcherResourceManagerComponentFactory.create to take ioExecutor
URL: https://github.com/apache/flink/pull/9831#issuecomment-537027384
## CI report:
* e1d37ab03c1bc62b3d45c45ee11d616ed2c78b0c : SUCCESS
[Build](htt
flinkbot edited a comment on issue #9830: [FLINK-14307] Extract JobGraphWriter
from JobGraphStore
URL: https://github.com/apache/flink/pull/9830#issuecomment-537017897
## CI report:
* ed86e6d768a1353423d969e6c9dcf5fd967c4f19 : SUCCESS
[Build](https://travis-ci.com/flink-ci/flink
flinkbot edited a comment on issue #9813: [FLINK-14287] Decouple leader address
from LeaderContender
URL: https://github.com/apache/flink/pull/9813#issuecomment-536324105
## CI report:
* b7a7e7b6dc8a16d23097911aa98852e2cf4d9c00 : FAILURE
[Build](https://travis-ci.com/flink-ci/f
flinkbot edited a comment on issue #9812: [FLINK-14286] Remove Akka specific
parsing from LeaderConnectionInfo
URL: https://github.com/apache/flink/pull/9812#issuecomment-536322371
## CI report:
* c1ca1131b02a2c555cd8386fd07aa1cfccbab161 : FAILURE
[Build](https://travis-ci.com/f
flinkbot edited a comment on issue #9811: [FLINK-14285] Remove generics from
Dispatcher factories
URL: https://github.com/apache/flink/pull/9811#issuecomment-536320588
## CI report:
* 658cddd4424505c1a904a926ad6e626abbd85cd7 : FAILURE
[Build](https://travis-ci.com/flink-ci/flin
flinkbot edited a comment on issue #9807: [FLINK-14280] Introduce
DispatcherRunner
URL: https://github.com/apache/flink/pull/9807#issuecomment-536314902
## CI report:
* 9ef8fe986e4b06d6ae8512e5051933458363511c : FAILURE
[Build](https://travis-ci.com/flink-ci/flink/builds/129597
flinkbot edited a comment on issue #9808: [FLINK-14281] Add
DispatcherRunner#getShutDownFuture
URL: https://github.com/apache/flink/pull/9808#issuecomment-536316924
## CI report:
* 02c93d5d7d69324c33461040fec5c4014eb2b8d6 : SUCCESS
[Build](https://travis-ci.com/flink-ci/flink/bu
flinkbot edited a comment on issue #9810: [FLINK-14284] Add shut down future to
Dispatcher
URL: https://github.com/apache/flink/pull/9810#issuecomment-536320582
## CI report:
* 3ea0f47e7dd76ec115db4ef583b416685107604b : FAILURE
[Build](https://travis-ci.com/flink-ci/flink/builds
flinkbot edited a comment on issue #9809: [FLINK-14282] Simplify
DispatcherResourceManagerComponent hierarchy
URL: https://github.com/apache/flink/pull/9809#issuecomment-536318695
## CI report:
* 531cd688ceb25b544833025d9b556a0d686b29c4 : FAILURE
[Build](https://travis-ci.com/fl
flinkbot edited a comment on issue #9801: [FLINK-13983][runtime] Launch task
executor with new memory calculation logics
URL: https://github.com/apache/flink/pull/9801#issuecomment-536259410
## CI report:
* 3ea28aa2186b964a7405fbd1367186db8e143836 : SUCCESS
[Build](https://travi
flinkbot edited a comment on issue #9769: [FLINK-14203][ml] add an abstract
class for mappers with rich model.
URL: https://github.com/apache/flink/pull/9769#issuecomment-534932470
## CI report:
* a69f4c99a1a61595c3a75acb56300e190b5adb65 : FAILURE
[Build](https://travis-ci.com/f
flinkbot edited a comment on issue #9523: [FLINK-13835][ml] Add class for
FeatureHasherMapper.
URL: https://github.com/apache/flink/pull/9523#issuecomment-524304525
## CI report:
* 31097ad65206951fda5e529b4c6dde0a9f51d1d8 : FAILURE
[Build](https://travis-ci.com/flink-ci/flink/bu
flinkbot commented on issue #9851: [FLINK-14341]Fix flink-python builds
failure: no such option: --prefix
URL: https://github.com/apache/flink/pull/9851#issuecomment-539356226
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to revi
xuyang1706 commented on a change in pull request #9300: [FLINK-13513][ml] Add
the FlatMapper and related classes for later al…
URL: https://github.com/apache/flink/pull/9300#discussion_r332349068
##
File path:
flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/ma
[
https://issues.apache.org/jira/browse/FLINK-14341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-14341:
---
Labels: pull-request-available (was: )
> Flink-python builds with failure: no such option:
liupc opened a new pull request #9851: [FLINK-14341]Fix flink-python builds
failure: no such option: --prefix
URL: https://github.com/apache/flink/pull/9851
## What is the purpose of the change
Currently, it reported an error on flink-python module when build flink:
```
flinkbot edited a comment on issue #9405: [FLINK-13668][ml] Add abstract
classes for three typical scenarios of (Flat)Mapper
URL: https://github.com/apache/flink/pull/9405#issuecomment-519901201
## CI report:
* c1fedc4de6a92bc2c5f84d0e0c3038f29fd8944f : FAILURE
[Build](https://t
flinkbot edited a comment on issue #9355: [FLINK-13577][ml] Add an util class
to build result row and generate …
URL: https://github.com/apache/flink/pull/9355#issuecomment-518089359
## CI report:
* f8f3792f7ce55735f05200c90431b20b99a42d18 : FAILURE
[Build](https://travis-ci.com
flinkbot edited a comment on issue #9821: [FLINK-14298] Replace
LeaderContender#getAddress with #getDescription
URL: https://github.com/apache/flink/pull/9821#issuecomment-536618253
## CI report:
* 9ca9df3eaa22965444373a3b6142798ca5559f50 : FAILURE
[Build](https://travis-ci.com/
flinkbot edited a comment on issue #9801: [FLINK-13983][runtime] Launch task
executor with new memory calculation logics
URL: https://github.com/apache/flink/pull/9801#issuecomment-536259410
## CI report:
* 3ea28aa2186b964a7405fbd1367186db8e143836 : SUCCESS
[Build](https://travi
xuyang1706 commented on issue #9355: [FLINK-13577][ml] Add an util class to
build result row and generate …
URL: https://github.com/apache/flink/pull/9355#issuecomment-539352393
> Hi @xuyang1706, I read the javadoc again and I think I have some confusion
on what you are trying to achieve.
xuyang1706 commented on a change in pull request #9355: [FLINK-13577][ml] Add
an util class to build result row and generate …
URL: https://github.com/apache/flink/pull/9355#discussion_r332347441
##
File path:
flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/ut
flinkbot edited a comment on issue #9523: [FLINK-13835][ml] Add class for
FeatureHasherMapper.
URL: https://github.com/apache/flink/pull/9523#issuecomment-524304525
## CI report:
* 31097ad65206951fda5e529b4c6dde0a9f51d1d8 : FAILURE
[Build](https://travis-ci.com/flink-ci/flink/bu
hequn8128 commented on issue #9653: [FLINK-14014][python] Introduce
PythonScalarFunctionRunner to handle the communication with Python worker for
Python ScalarFunction execution
URL: https://github.com/apache/flink/pull/9653#issuecomment-539351380
@tillrohrmann Thanks a lot for the notice.
flinkbot edited a comment on issue #9769: [FLINK-14203][ml] add an abstract
class for mappers with rich model.
URL: https://github.com/apache/flink/pull/9769#issuecomment-534932470
## CI report:
* a69f4c99a1a61595c3a75acb56300e190b5adb65 : FAILURE
[Build](https://travis-ci.com/f
dianfu commented on a change in pull request #9748:
[FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for
Python function execution
URL: https://github.com/apache/flink/pull/9748#discussion_r332346972
##
File path:
flink-table/flink-table-common/src/main/ja
[
https://issues.apache.org/jira/browse/FLINK-14280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-14280.
-
Resolution: Done
Done via 936a317e7e51b0a03f5f12e3d4c21fedaa6d328e
> Introduce DispatcherRunner
[
https://issues.apache.org/jira/browse/FLINK-14281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-14281.
-
Resolution: Done
Done via 01ad0f6fe23615484e36b4710cd0fdc3a7276bed
> Introduce DispatcherRunner
[
https://issues.apache.org/jira/browse/FLINK-14282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-14282.
-
Resolution: Done
Done via 870b56418cb795edba9d4e8e282fa91d675efd7a
> Simplify DispatcherResourc
[
https://issues.apache.org/jira/browse/FLINK-14284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-14284.
-
Resolution: Done
Done via 1c5f7558626bb8c301d564c0cbc15126d6cc1731
> Add shut down future to Di
[
https://issues.apache.org/jira/browse/FLINK-14285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-14285.
-
Resolution: Done
Done via 282dd840fe80bd71830d1c493cdb7e1d0ad5cc6e
> Simplify Dispatcher factor
Dian Fu created FLINK-14342:
---
Summary: Remove method FunctionDefinition#getLanguage
Key: FLINK-14342
URL: https://issues.apache.org/jira/browse/FLINK-14342
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-14286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-14286.
-
Resolution: Done
Done via 1082c7a470355b938ad0f7de2fa73ca5461c1bc0
> Remove Akka specific parsi
tillrohrmann closed pull request #9811: [FLINK-14285] Remove generics from
Dispatcher factories
URL: https://github.com/apache/flink/pull/9811
This is an automated message from the Apache Git Service.
To respond to the mess
tillrohrmann closed pull request #9809: [FLINK-14282] Simplify
DispatcherResourceManagerComponent hierarchy
URL: https://github.com/apache/flink/pull/9809
This is an automated message from the Apache Git Service.
To respond
tillrohrmann closed pull request #9808: [FLINK-14281] Add
DispatcherRunner#getShutDownFuture
URL: https://github.com/apache/flink/pull/9808
This is an automated message from the Apache Git Service.
To respond to the message,
tillrohrmann closed pull request #9807: [FLINK-14280] Introduce
DispatcherRunner
URL: https://github.com/apache/flink/pull/9807
This is an automated message from the Apache Git Service.
To respond to the message, please log
tillrohrmann closed pull request #9810: [FLINK-14284] Add shut down future to
Dispatcher
URL: https://github.com/apache/flink/pull/9810
This is an automated message from the Apache Git Service.
To respond to the message, ple
tillrohrmann closed pull request #9812: [FLINK-14286] Remove Akka specific
parsing from LeaderConnectionInfo
URL: https://github.com/apache/flink/pull/9812
This is an automated message from the Apache Git Service.
To respond
liupengcheng created FLINK-14341:
Summary: Flink-python builds with failure: no such option: --prefix
Key: FLINK-14341
URL: https://issues.apache.org/jira/browse/FLINK-14341
Project: Flink
Is
flinkbot edited a comment on issue #9824: [FLINK-14302]
FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if
`newPartitionsInTransaction` is empty when enable EoS
URL: https://github.com/apache/flink/pull/9824#issuecomment-536928428
## CI report:
* 87ae7
flinkbot edited a comment on issue #9735: [FLINK-14156][runtime] Submit timer
trigger letters to task's mailbox with operator's precedence
URL: https://github.com/apache/flink/pull/9735#issuecomment-533554096
## CI report:
* 51167d9aaf8082150738dc5bd8b9e2319dd01570 : SUCCESS
[Bu
flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl
URL: https://github.com/apache/flink/pull/9689#issuecomment-531747685
## CI report:
* bd2624914db1147588ea838ae542333c310290cc : SUCCESS
[Build](https://travis-ci.com/flink-ci/flink/builds/127790175)
flinkbot edited a comment on issue #9823: [FLINK-14273][Table]Add accumulator
type to actual type list in AggSqlFunction
URL: https://github.com/apache/flink/pull/9823#issuecomment-536781542
## CI report:
* 2b5531b068338321eb04cdf71714eae0d088ec0e : FAILURE
[Build](https://travi
flinkbot edited a comment on issue #9820: [FLINK-14290] Decouple plan
translation from job execution/ClusterClient
URL: https://github.com/apache/flink/pull/9820#issuecomment-536452582
## CI report:
* ff3ef7ae21616fb0295e3bdc53fa349c8f136a4b : FAILURE
[Build](https://travis-ci.c
yanghua commented on a change in pull request #9720: [FLINK-13025]
Elasticsearch 7.x support
URL: https://github.com/apache/flink/pull/9720#discussion_r332339180
##
File path:
flink-connectors/flink-sql-connector-elasticsearch7/src/main/resources/META-INF/NOTICE
##
@@ -0,
flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl
URL: https://github.com/apache/flink/pull/9689#issuecomment-531747685
## CI report:
* bd2624914db1147588ea838ae542333c310290cc : SUCCESS
[Build](https://travis-ci.com/flink-ci/flink/builds/127790175)
flinkbot edited a comment on issue #9355: [FLINK-13577][ml] Add an util class
to build result row and generate …
URL: https://github.com/apache/flink/pull/9355#issuecomment-518089359
## CI report:
* f8f3792f7ce55735f05200c90431b20b99a42d18 : FAILURE
[Build](https://travis-ci.com
klion26 commented on a change in pull request #9703: [FLINK-14038]Add default
GC options for flink on yarn to facilitate debugging
URL: https://github.com/apache/flink/pull/9703#discussion_r332335659
##
File path: flink-dist/src/main/flink-bin/bin/flink-daemon.sh
##
@@ -85
klion26 commented on a change in pull request #9703: [FLINK-14038]Add default
GC options for flink on yarn to facilitate debugging
URL: https://github.com/apache/flink/pull/9703#discussion_r332333021
##
File path: flink-dist/src/main/flink-bin/bin/config.sh
##
@@ -99,6 +99
klion26 commented on a change in pull request #9703: [FLINK-14038]Add default
GC options for flink on yarn to facilitate debugging
URL: https://github.com/apache/flink/pull/9703#discussion_r33284
##
File path: flink-dist/src/main/flink-bin/bin/flink-daemon.sh
##
@@ -85
flinkbot edited a comment on issue #9801: [FLINK-13983][runtime] Launch task
executor with new memory calculation logics
URL: https://github.com/apache/flink/pull/9801#issuecomment-536259410
## CI report:
* 3ea28aa2186b964a7405fbd1367186db8e143836 : SUCCESS
[Build](https://travi
flinkbot edited a comment on issue #9781: [FLINK-14098] Support multiple
statements for TableEnvironment.
URL: https://github.com/apache/flink/pull/9781#issuecomment-535813967
## CI report:
* ed0e04d1cd481b096d68d0c9bf36a997dcca2550 : FAILURE
[Build](https://travis-ci.com/flink-
HuangZhenQiu commented on issue #9689: [FLINK-7151] add a basic function ddl
URL: https://github.com/apache/flink/pull/9689#issuecomment-539322429
@walterddr Thanks for the comments and suggestions. For the changing of
CatalogFunctionImpl
constructor, let's wait for @bowenli86 's feedba
sunjincheng121 commented on a change in pull request #9748:
[FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for
Python function execution
URL: https://github.com/apache/flink/pull/9748#discussion_r332333999
##
File path:
flink-table/flink-table-common/src
sunjincheng121 commented on a change in pull request #9748:
[FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for
Python function execution
URL: https://github.com/apache/flink/pull/9748#discussion_r332333999
##
File path:
flink-table/flink-table-common/src
HuangZhenQiu commented on a change in pull request #9689: [FLINK-7151] add a
basic function ddl
URL: https://github.com/apache/flink/pull/9689#discussion_r332334043
##
File path:
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java
HuangZhenQiu commented on a change in pull request #9689: [FLINK-7151] add a
basic function ddl
URL: https://github.com/apache/flink/pull/9689#discussion_r332334052
##
File path:
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java
flinkbot edited a comment on issue #9416: [FLINK-13646][build system] Add basic
cron ARM CI job definition
URL: https://github.com/apache/flink/pull/9416#issuecomment-520285701
## CI report:
* dbf749f0d0c3167265287b182dd1ea7b4aed84c1 : FAILURE
[Build](https://travis-ci.com/flink
HuangZhenQiu commented on a change in pull request #9689: [FLINK-7151] add a
basic function ddl
URL: https://github.com/apache/flink/pull/9689#discussion_r332333004
##
File path:
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/api/internal/TableEnvImpl.scala
flinkbot edited a comment on issue #9819: [FLINK-14246][runtime] Annotate all
MiniCluster tests in flink-runtime with AlsoRunWithSchedulerNG
URL: https://github.com/apache/flink/pull/9819#issuecomment-536429067
## CI report:
* 94653a90b144e39f05a3e86de50225a0d538fed0 : SUCCESS
[
flinkbot edited a comment on issue #9801: [FLINK-13983][runtime] Launch task
executor with new memory calculation logics
URL: https://github.com/apache/flink/pull/9801#issuecomment-536259410
## CI report:
* 3ea28aa2186b964a7405fbd1367186db8e143836 : SUCCESS
[Build](https://travi
HuangZhenQiu commented on a change in pull request #9689: [FLINK-7151] add a
basic function ddl
URL: https://github.com/apache/flink/pull/9689#discussion_r332331898
##
File path:
flink-table/flink-sql-parser/src/test/java/org/apache/flink/sql/parser/FlinkSqlParserImplTest.java
###
[
https://issues.apache.org/jira/browse/FLINK-14340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16946472#comment-16946472
]
Congxian Qiu(klion26) commented on FLINK-14340:
---
[~sewen] as you introduce
[
https://issues.apache.org/jira/browse/FLINK-14340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Congxian Qiu(klion26) updated FLINK-14340:
--
Description:
Currently, when Flink read/write to HDFS, we do not set the DFSCl
[
https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16946470#comment-16946470
]
Xintong Song commented on FLINK-14123:
--
[~liupengcheng],
The reason we have smalle
Congxian Qiu(klion26) created FLINK-14340:
-
Summary: Specify an unique DFSClient name for Hadoop FileSystem
Key: FLINK-14340
URL: https://issues.apache.org/jira/browse/FLINK-14340
Project: Flin
flinkbot edited a comment on issue #9300: [FLINK-13513][ml] Add the FlatMapper
and related classes for later al…
URL: https://github.com/apache/flink/pull/9300#issuecomment-516849331
## CI report:
* 9b5b5ff5df053498e491d43a04f44d5ba452579c : SUCCESS
[Build](https://travis-ci.com
flinkbot edited a comment on issue #9801: [FLINK-13983][runtime] Launch task
executor with new memory calculation logics
URL: https://github.com/apache/flink/pull/9801#issuecomment-536259410
## CI report:
* 3ea28aa2186b964a7405fbd1367186db8e143836 : SUCCESS
[Build](https://travi
flinkbot edited a comment on issue #9706: [FLINK-14118][runtime]Reduce the
unnecessary flushing when there is no data available for flush.
URL: https://github.com/apache/flink/pull/9706#issuecomment-532638785
## CI report:
* 053ed30d568a00ba42d75d1a9534843c59a068af : SUCCESS
[Bu
flinkbot edited a comment on issue #9850: [FLINK-14118][benchmarks]Add network
throughput benchmark for data skew scenario.
URL: https://github.com/apache/flink/pull/9850#issuecomment-539298227
## CI report:
* b344a21f3d6d55e6fca5d9253b0b34ddb2c392e9 : PENDING
[Build](https://tr
flinkbot edited a comment on issue #9829: [FLINK-14184] [core] Add
LocalContextListener
URL: https://github.com/apache/flink/pull/9829#issuecomment-536999846
## CI report:
* 4a2644b80db9de689dd8dfe742010a6c5367ee80 : FAILURE
[Build](https://travis-ci.com/flink-ci/flink/builds/12
flinkbot edited a comment on issue #9818: [FLINK-14289][runtime] Remove
Optional fields from RecordWriter relevant classes
URL: https://github.com/apache/flink/pull/9818#issuecomment-536416616
## CI report:
* 519051016f02b8257eb1e3d5834f36c315816266 : FAILURE
[Build](https://tr
flinkbot edited a comment on issue #9804: [FLINK-14239] Fix the max watermark
in StreamSource may arrive the downstream operator early
URL: https://github.com/apache/flink/pull/9804#issuecomment-536287116
## CI report:
* cb5b4da4d8b5d877e296dd84095a328208263c15 : FAILURE
[Build]
wsry commented on issue #9758: [FLINK-14185][tests]Move unstable assertion
statement out of close method of QS test server.
URL: https://github.com/apache/flink/pull/9758#issuecomment-539302270
> What if we didn't share the stats between servers?
@zentol From the previous comment and
flinkbot edited a comment on issue #9801: [FLINK-13983][runtime] Launch task
executor with new memory calculation logics
URL: https://github.com/apache/flink/pull/9801#issuecomment-536259410
## CI report:
* 3ea28aa2186b964a7405fbd1367186db8e143836 : SUCCESS
[Build](https://travi
[
https://issues.apache.org/jira/browse/FLINK-13808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16946458#comment-16946458
]
Congxian Qiu(klion26) commented on FLINK-13808:
---
Thanks for the reply [~se
zjuwangg commented on issue #9689: [FLINK-7151] add a basic function ddl
URL: https://github.com/apache/flink/pull/9689#issuecomment-539299262
> thanks for the contribution @HuangZhenQiu and thanks for the prompt review
@bowenli86 . I think overall the approach looks very good to me and I j
flinkbot edited a comment on issue #9184: [FLINK-13339][ml] Add an
implementation of pipeline's api
URL: https://github.com/apache/flink/pull/9184#issuecomment-513425405
## CI report:
* bd7ade5e0b57dc8577d7f864afcbbb24c2513e56 : FAILURE
[Build](https://travis-ci.com/flink-ci/fli
flinkbot edited a comment on issue #9703: [FLINK-14038]Add default GC options
for flink on yarn to facilitate debugging
URL: https://github.com/apache/flink/pull/9703#issuecomment-532581942
## CI report:
* 1b930d19f27909ad5e2759eb6c5471c2ce07e8b4 : FAILURE
[Build](https://travis
flinkbot edited a comment on issue #9706: [FLINK-14118][runtime]Reduce the
unnecessary flushing when there is no data available for flush.
URL: https://github.com/apache/flink/pull/9706#issuecomment-532638785
## CI report:
* 053ed30d568a00ba42d75d1a9534843c59a068af : SUCCESS
[Bu
flinkbot commented on issue #9850: [FLINK-14118][benchmarks]Add network
throughput benchmark for data skew scenario.
URL: https://github.com/apache/flink/pull/9850#issuecomment-539298227
## CI report:
* b344a21f3d6d55e6fca5d9253b0b34ddb2c392e9 : UNKNOWN
Bot commands
flinkbot edited a comment on issue #9805: [FLINK-14227] translate
dev/stream/state/checkpointing into Chinese
URL: https://github.com/apache/flink/pull/9805#issuecomment-536295524
## CI report:
* 9ad039de6bbb953c7e2dd74b3118d80ae552f31e : FAILURE
[Build](https://travis-ci.com/fl
flinkbot edited a comment on issue #9801: [FLINK-13983][runtime] Launch task
executor with new memory calculation logics
URL: https://github.com/apache/flink/pull/9801#issuecomment-536259410
## CI report:
* 3ea28aa2186b964a7405fbd1367186db8e143836 : SUCCESS
[Build](https://travi
wsry commented on issue #9706: [FLINK-14118][runtime]Reduce the unnecessary
flushing when there is no data available for flush.
URL: https://github.com/apache/flink/pull/9706#issuecomment-539297211
@pnowojski Thanks for your comments. I have separated the benchmark commit
into a new pr htt
[
https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16946446#comment-16946446
]
liupengcheng commented on FLINK-14123:
--
[~xintongsong] Hi, thanks for your comment
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
[
zjuwangg commented on a change in pull request #9689: [FLINK-7151] add a basic
function ddl
URL: https://github.com/apache/flink/pull/9689#discussion_r332322097
##
File path:
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java
zjuwangg commented on a change in pull request #9689: [FLINK-7151] add a basic
function ddl
URL: https://github.com/apache/flink/pull/9689#discussion_r332322049
##
File path:
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java
zhuzhurk commented on a change in pull request #9846: [FLINK-14271][runtime]
Remove legacy RestartPipelinedRegionStrategy components
URL: https://github.com/apache/flink/pull/9846#discussion_r332009233
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/executiongrap
zhuzhurk commented on a change in pull request #9846: [FLINK-14271][runtime]
Remove legacy RestartPipelinedRegionStrategy components
URL: https://github.com/apache/flink/pull/9846#discussion_r332009233
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/executiongrap
1 - 100 of 623 matches
Mail list logo