flinkbot commented on issue #9888: [hotfix][doc]fix typos in richfunction
URL: https://github.com/apache/flink/pull/9888#issuecomment-541391905
## CI report:
* b37d86b0fbc58892a68e821239b7083dffc46d75 : UNKNOWN
Bot commands
The @flinkbot bot supports the following
buptljy commented on a change in pull request #9843: [FLINK-14296] [Table SQL]
Use Optional for optional parameters in parser module
URL: https://github.com/apache/flink/pull/9843#discussion_r334265001
##
File path:
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/pa
flinkbot commented on issue #9888: [hotfix][doc]fix typos in richfunction
URL: https://github.com/apache/flink/pull/9888#issuecomment-541391094
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use
wangxlong opened a new pull request #9888: [hotfix][doc]fix typos in
richfunction
URL: https://github.com/apache/flink/pull/9888
## What is the purpose of the change
Fix typos in RichFunction annotation. For only RichFilterFunction has open
method to extend, so we should change FilterFu
[
https://issues.apache.org/jira/browse/FLINK-14275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16950225#comment-16950225
]
hailong wang commented on FLINK-14275:
--
Hi [~jark], I have some confusion. Accordin
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 #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
TisonKun commented on issue #9881: [FLINK-14377] Parse Executor-relevant
ProgramOptions to ConfigOptions
URL: https://github.com/apache/flink/pull/9881#issuecomment-541385115
@kl0u thanks for opening this pull requests. The purpose of it looks good to
me. My concern contains
1. For
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
xuyang1706 commented on issue #9184: [FLINK-13339][ml] Add an implementation of
pipeline's api
URL: https://github.com/apache/flink/pull/9184#issuecomment-541383212
> @xuyang1706 Thanks for updating the patch. the patch LGTM overall. I
created a PR with some minor improvements against your
xuyang1706 commented on issue #9184: [FLINK-13339][ml] Add an implementation of
pipeline's api
URL: https://github.com/apache/flink/pull/9184#issuecomment-541380802
> Thanks for the contribution @xuyang1706 and the reviews @becketqin .
Overall it looks good to me. I only left a minor comme
xuyang1706 commented on a change in pull request #9184: [FLINK-13339][ml] Add
an implementation of pipeline's api
URL: https://github.com/apache/flink/pull/9184#discussion_r334260628
##
File path:
flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/MLEnvironmentFa
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
[
flinkbot edited a comment on issue #9887: [FLINK-14215] [docs] add environment
variable configuration
URL: https://github.com/apache/flink/pull/9887#issuecomment-541371856
## CI report:
* 59ed4592c6d1d5eb5acc681bfa34bc279a781a3d : FAILURE
[Build](https://travis-ci.com/flink-ci/f
flinkbot edited a comment on issue #9887: [FLINK-14215] [docs] add environment
variable configuration
URL: https://github.com/apache/flink/pull/9887#issuecomment-541371856
## CI report:
* 59ed4592c6d1d5eb5acc681bfa34bc279a781a3d : PENDING
[Build](https://travis-ci.com/flink-ci/f
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
[
flinkbot commented on issue #9887: [FLINK-14215] [docs] add environment
variable configuration
URL: https://github.com/apache/flink/pull/9887#issuecomment-541371856
## CI report:
* 59ed4592c6d1d5eb5acc681bfa34bc279a781a3d : UNKNOWN
Bot commands
The @flinkbot bot s
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
[
flinkbot commented on issue #9887: [FLINK-14215] add environment variable
configuration
URL: https://github.com/apache/flink/pull/9887#issuecomment-541370639
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull reque
[
https://issues.apache.org/jira/browse/FLINK-14215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-14215:
---
Labels: pull-request-available (was: )
> Add Docs for TM and JM Environment Variable Settin
HuangZhenQiu opened a new pull request #9887: [FLINK-14215] add environment
variable configuration
URL: https://github.com/apache/flink/pull/9887
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather th
walterddr commented on a change in pull request #9184: [FLINK-13339][ml] Add an
implementation of pipeline's api
URL: https://github.com/apache/flink/pull/9184#discussion_r334254798
##
File path:
flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/MLEnvironmentFac
becketqin commented on issue #9184: [FLINK-13339][ml] Add an implementation of
pipeline's api
URL: https://github.com/apache/flink/pull/9184#issuecomment-541362792
@xuyang1706 Thanks for updating the patch. the patch LGTM overall. I created
a PR with some minor improvements against your br
[
https://issues.apache.org/jira/browse/FLINK-14309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16950111#comment-16950111
]
Jiangjie Qin commented on FLINK-14309:
--
[~trohrmann] This patch just fixes the test
walterddr commented on a change in pull request #8468:
[FLINK-12399][table][table-planner] Fix FilterableTableSource does not change
after applyPredicate
URL: https://github.com/apache/flink/pull/8468#discussion_r334245784
##
File path:
flink-table/flink-table-planner/src/test/sca
[
https://issues.apache.org/jira/browse/FLINK-14027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-14027:
---
Assignee: Wei Zhong
> Add documentation for Python user-defined functions
> ---
[
https://issues.apache.org/jira/browse/FLINK-14208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng closed FLINK-14208.
---
Resolution: Resolved
> Optimize Python UDFs with parameters of constant values
> ---
[
https://issues.apache.org/jira/browse/FLINK-14208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16950066#comment-16950066
]
Hequn Cheng commented on FLINK-14208:
-
Resolved in 1.10.0 via: ddfed72813281255f119f
[
https://issues.apache.org/jira/browse/FLINK-14208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-14208:
---
Labels: pull-request-available (was: )
> Optimize Python UDFs with parameters of constant v
hequn8128 closed pull request #9858: [FLINK-14208][python] Optimize Python UDFs
with parameters of constant values
URL: https://github.com/apache/flink/pull/9858
This is an automated message from the Apache Git Service.
To r
flinkbot edited a comment on issue #9858: [FLINK-14208][python] Optimize Python
UDFs with parameters of constant values
URL: https://github.com/apache/flink/pull/9858#issuecomment-539830457
## CI report:
* 5b6f4eb6008d7f2656fce8c2fbd7b43d7b8a0cf0 : FAILURE
[Build](https://travis
[
https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16950063#comment-16950063
]
liupengcheng commented on FLINK-14123:
--
[~xintongsong] I think it's a common case,
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
[
https://issues.apache.org/jira/browse/FLINK-14275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16950061#comment-16950061
]
Jark Wu commented on FLINK-14275:
-
Hi [~hailong wang],
1) we should not provide the ful
flinkbot edited a comment on issue #9886: [FLINK-14027][python][doc] Add
documentation for Python user-defined functions.
URL: https://github.com/apache/flink/pull/9886#issuecomment-541326107
## CI report:
* e431c1c28a35dd86e60a0892ff0e0d15b8da7245 : FAILURE
[Build](https://trav
flinkbot edited a comment on issue #9858: [FLINK-14208][python] Optimize Python
UDFs with parameters of constant values
URL: https://github.com/apache/flink/pull/9858#issuecomment-539830457
## CI report:
* 5b6f4eb6008d7f2656fce8c2fbd7b43d7b8a0cf0 : FAILURE
[Build](https://travis
[
https://issues.apache.org/jira/browse/FLINK-14275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16950055#comment-16950055
]
hailong wang commented on FLINK-14275:
--
Hi, [~jark], thanks for you tip. In my side
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 #9886: [FLINK-14027][python][doc] Add
documentation for Python user-defined functions.
URL: https://github.com/apache/flink/pull/9886#issuecomment-541326107
## CI report:
* e431c1c28a35dd86e60a0892ff0e0d15b8da7245 : PENDING
[Build](https://trav
flinkbot edited a comment on issue #9858: [FLINK-14208][python] Optimize Python
UDFs with parameters of constant values
URL: https://github.com/apache/flink/pull/9858#issuecomment-539830457
## CI report:
* 5b6f4eb6008d7f2656fce8c2fbd7b43d7b8a0cf0 : FAILURE
[Build](https://travis
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 commented on issue #9886: [FLINK-14027][python][doc] Add documentation
for Python user-defined functions.
URL: https://github.com/apache/flink/pull/9886#issuecomment-541326107
## CI report:
* e431c1c28a35dd86e60a0892ff0e0d15b8da7245 : UNKNOWN
Bot commands
hequn8128 commented on issue #9858: [FLINK-14208][python] Optimize Python UDFs
with parameters of constant values
URL: https://github.com/apache/flink/pull/9858#issuecomment-541325992
@HuangXingBo Thanks a lot for the update. LGTM, will merge this when Travis
passed.
-
flinkbot commented on issue #9886: [FLINK-14027][python][doc] Add documentation
for Python user-defined functions.
URL: https://github.com/apache/flink/pull/9886#issuecomment-541324020
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
[
https://issues.apache.org/jira/browse/FLINK-14027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-14027:
---
Labels: pull-request-available (was: )
> Add documentation for Python user-defined function
xuyang1706 commented on a change in pull request #9184: [FLINK-13339][ml] Add
an implementation of pipeline's api
URL: https://github.com/apache/flink/pull/9184#discussion_r334236991
##
File path:
flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/MLEnvironmentFa
WeiZhong94 opened a new pull request #9886: [FLINK-14027][python][doc] Add
documentation for Python user-defined functions.
URL: https://github.com/apache/flink/pull/9886
## What is the purpose of the change
*This pull request adds documentation for Python user-defined functions.*
[
https://issues.apache.org/jira/browse/FLINK-14367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-14367:
Description:
Currently, the {{RexNodeToExpressionConverter}} in both planners are not fully
support. Ther
flinkbot edited a comment on issue #9858: [FLINK-14208][python] Optimize Python
UDFs with parameters of constant values
URL: https://github.com/apache/flink/pull/9858#issuecomment-539830457
## CI report:
* 5b6f4eb6008d7f2656fce8c2fbd7b43d7b8a0cf0 : FAILURE
[Build](https://travis
TisonKun commented on a change in pull request #9881: [FLINK-14377] Parse
Executor-relevant ProgramOptions to ConfigOptions
URL: https://github.com/apache/flink/pull/9881#discussion_r334236287
##
File path:
flink-clients/src/main/java/org/apache/flink/client/cli/ExecutionParameterP
hequn8128 commented on a change in pull request #9858: [FLINK-14208][python]
Optimize Python UDFs with parameters of constant values
URL: https://github.com/apache/flink/pull/9858#discussion_r334235662
##
File path: flink-python/pyflink/table/tests/test_udf.py
##
@@ -112,6
hequn8128 commented on issue #9858: [FLINK-14208][python] Optimize Python UDFs
with parameters of constant values
URL: https://github.com/apache/flink/pull/9858#issuecomment-541321281
I have created a new
jira([FLINK-14383](https://issues.apache.org/jira/browse/FLINK-14383)) for the
time
[
https://issues.apache.org/jira/browse/FLINK-14383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-14383:
---
Assignee: Huang Xingbo
> Support python UDFs with constant value of time interval types
> -
Hequn Cheng created FLINK-14383:
---
Summary: Support python UDFs with constant value of time interval
types
Key: FLINK-14383
URL: https://issues.apache.org/jira/browse/FLINK-14383
Project: Flink
Yang Wang created FLINK-14382:
-
Summary: Wrong local FLINK_PLUGINS_DIR is set to flink-conf.yaml
of jobmanager and taskmanager on Yarn
Key: FLINK-14382
URL: https://issues.apache.org/jira/browse/FLINK-14382
flinkbot edited a comment on issue #9858: [FLINK-14208][python] Optimize Python
UDFs with parameters of constant values
URL: https://github.com/apache/flink/pull/9858#issuecomment-539830457
## CI report:
* 5b6f4eb6008d7f2656fce8c2fbd7b43d7b8a0cf0 : FAILURE
[Build](https://travis
TisonKun commented on a change in pull request #9820: [FLINK-14290] Decouple
plan translation from job execution/ClusterClient
URL: https://github.com/apache/flink/pull/9820#discussion_r334234669
##
File path:
flink-clients/src/main/java/org/apache/flink/client/program/ClusterClien
[
https://issues.apache.org/jira/browse/FLINK-14212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16950018#comment-16950018
]
Hequn Cheng commented on FLINK-14212:
-
Resolved in 1.10.0 via: 345bfefd91c5a1a309ff1
[
https://issues.apache.org/jira/browse/FLINK-14212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng closed FLINK-14212.
---
Resolution: Fixed
> Support Python UDFs without arguments
> -
>
flinkbot edited a comment on issue #9858: [FLINK-14208][python] Optimize Python
UDFs with parameters of constant values
URL: https://github.com/apache/flink/pull/9858#issuecomment-539830457
## CI report:
* 5b6f4eb6008d7f2656fce8c2fbd7b43d7b8a0cf0 : FAILURE
[Build](https://travis
hequn8128 closed pull request #9865: [FLINK-14212][python] Support no-argument
Python UDFs.
URL: https://github.com/apache/flink/pull/9865
This is an automated message from the Apache Git Service.
To respond to the message,
TisonKun commented on a change in pull request #9820: [FLINK-14290] Decouple
plan translation from job execution/ClusterClient
URL: https://github.com/apache/flink/pull/9820#discussion_r334234669
##
File path:
flink-clients/src/main/java/org/apache/flink/client/program/ClusterClien
HuangXingBo commented on issue #9858: [FLINK-14208][python] Optimize Python
UDFs with parameters of constant values
URL: https://github.com/apache/flink/pull/9858#issuecomment-541318216
> @HuangXingBo I find that there are problems for supporting the time
Interval type in Pytho
TisonKun commented on a change in pull request #9820: [FLINK-14290] Decouple
plan translation from job execution/ClusterClient
URL: https://github.com/apache/flink/pull/9820#discussion_r334234469
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/
TisonKun commented on a change in pull request #9820: [FLINK-14290] Decouple
plan translation from job execution/ClusterClient
URL: https://github.com/apache/flink/pull/9820#discussion_r334234314
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/
TisonKun commented on a change in pull request #9820: [FLINK-14290] Decouple
plan translation from job execution/ClusterClient
URL: https://github.com/apache/flink/pull/9820#discussion_r334234276
##
File path:
flink-clients/src/main/java/org/apache/flink/client/FlinkPipelineTransla
[
https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16950010#comment-16950010
]
Xintong Song commented on FLINK-14123:
--
Good point. FLIP-49 does not fix this probl
[
https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16950006#comment-16950006
]
liupengcheng commented on FLINK-14123:
--
[~xintongsong] I still have some doubt abou
aljoscha commented on issue #9820: [FLINK-14290] Decouple plan translation from
job execution/ClusterClient
URL: https://github.com/apache/flink/pull/9820#issuecomment-541313769
@TisonKun @kl0u you could have another look now.
---
hequn8128 commented on issue #9858: [FLINK-14208][python] Optimize Python UDFs
with parameters of constant values
URL: https://github.com/apache/flink/pull/9858#issuecomment-541312088
@HuangXingBo I find that there are problems for supporting the time Interval
type in Python due to the equ
ifndef-SleePy commented on issue #9885: [FLINK-14344][checkpointing] Snapshots
master hook state asynchronously
URL: https://github.com/apache/flink/pull/9885#issuecomment-541311402
@flinkbot attention @pnowojski
This is an
hequn8128 commented on issue #9865: [FLINK-14212][python] Support no-argument
Python UDFs.
URL: https://github.com/apache/flink/pull/9865#issuecomment-541310126
@WeiZhong94 Thanks a lot for the update. Also thank you all for the review.
LGTM, will merge this once travis passed.
flinkbot edited a comment on issue #9865: [FLINK-14212][python] Support
no-argument Python UDFs.
URL: https://github.com/apache/flink/pull/9865#issuecomment-539919841
## CI report:
* bf1d566ea2f91d61c2f436bb92b5337088b7 : SUCCESS
[Build](https://travis-ci.com/flink-ci/flink/
flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends]
Support on-disk state storage for spill-able heap backend
URL: https://github.com/apache/flink/pull/9501#issuecomment-523769032
## CI report:
* 6107a00876759dcef075592c8bfa56764f66b6fa : FAILURE
[Build](htt
[
https://issues.apache.org/jira/browse/FLINK-12576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-12576:
Fix Version/s: (was: 1.9.0)
1.9.2
> inputQueueLength metric does not work for Local
[
https://issues.apache.org/jira/browse/FLINK-14328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-14328:
Fix Version/s: (was: 1.9.0)
1.9.2
> JobCluster cannot reach TaskManager in K8s
> --
[
https://issues.apache.org/jira/browse/FLINK-14215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-14215:
Fix Version/s: (was: 1.9.0)
1.9.2
> Add Docs for TM and JM Environment Variable Set
[
https://issues.apache.org/jira/browse/FLINK-14072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-14072:
Fix Version/s: (was: 1.10.0)
(was: 1.9.0)
1.9.2
> Add a thir
[
https://issues.apache.org/jira/browse/FLINK-14327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-14327:
Fix Version/s: (was: 1.9.0)
1.9.2
> Getting "Could not forward element to next oper
flinkbot edited a comment on issue #9865: [FLINK-14212][python] Support
no-argument Python UDFs.
URL: https://github.com/apache/flink/pull/9865#issuecomment-539919841
## CI report:
* bf1d566ea2f91d61c2f436bb92b5337088b7 : SUCCESS
[Build](https://travis-ci.com/flink-ci/flink/
[
https://issues.apache.org/jira/browse/FLINK-14225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16949981#comment-16949981
]
Gary Yao commented on FLINK-14225:
--
If there are no objections, I will remove these var
flinkbot edited a comment on issue #9885: [FLINK-14344][checkpointing]
Snapshots master hook state asynchronously
URL: https://github.com/apache/flink/pull/9885#issuecomment-541299624
## CI report:
* d0c426e6ff61dcad1de4c7d3e9a2a16416e77e54 : SUCCESS
[Build](https://travis-ci.co
[
https://issues.apache.org/jira/browse/FLINK-14004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-14004:
-
Affects Version/s: 1.8.0
1.9.0
> Define SourceReader interface to verify the inte
[
https://issues.apache.org/jira/browse/FLINK-14004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-14004:
-
Summary: Define SourceReaderOperator to verify the integration with
StreamOneInputProcessor (was: Defin
[
https://issues.apache.org/jira/browse/FLINK-14004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-14004:
-
Description: We already refactored the task input and output in runtime
stack for considering the requir
flinkbot edited a comment on issue #9865: [FLINK-14212][python] Support
no-argument Python UDFs.
URL: https://github.com/apache/flink/pull/9865#issuecomment-539919841
## CI report:
* bf1d566ea2f91d61c2f436bb92b5337088b7 : SUCCESS
[Build](https://travis-ci.com/flink-ci/flink/
[
https://issues.apache.org/jira/browse/FLINK-14004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-14004:
-
Fix Version/s: 1.10.0
> Define SourceReader interface to verify the integration with
> StreamOneInputPr
[
https://issues.apache.org/jira/browse/FLINK-14004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang resolved FLINK-14004.
--
Resolution: Fixed
Merged in master: cee9bf0ab6c1d6b1678070ff2e05f0aa34f26dc0
> Define SourceReader in
jinglining commented on issue #9798: [FLINK-14176][web]Web Ui add log url for
taskmanager of vertex
URL: https://github.com/apache/flink/pull/9798#issuecomment-541305771
Hi, @zentol . I have added screeshot.
This is an automa
jinglining commented on issue #9798: [FLINK-14176][web]Web Ui add log url for
taskmanager of vertex
URL: https://github.com/apache/flink/pull/9798#issuecomment-541305694
screens
zhijiangW merged pull request #9646: [FLINK-14004][runtime] Define
SourceReaderOperator to verify the integration with StreamOneInputProcessor
URL: https://github.com/apache/flink/pull/9646
This is an automated message from
zhijiangW commented on issue #9646: [FLINK-14004][runtime] Define
SourceReaderOperator to verify the integration with StreamOneInputProcessor
URL: https://github.com/apache/flink/pull/9646#issuecomment-541305664
Thanks for the review @pnowojski and I fixed the above nit comments.
Th
[
https://issues.apache.org/jira/browse/FLINK-14318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16949972#comment-16949972
]
Till Rohrmann commented on FLINK-14318:
---
Another instance: https://api.travis-ci.o
flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends]
Support on-disk state storage for spill-able heap backend
URL: https://github.com/apache/flink/pull/9501#issuecomment-523769032
## CI report:
* 6107a00876759dcef075592c8bfa56764f66b6fa : FAILURE
[Build](htt
WeiZhong94 commented on issue #9865: [FLINK-14212][python] Support no-argument
Python UDFs.
URL: https://github.com/apache/flink/pull/9865#issuecomment-541303687
> > @JingsongLi I noticed that the "getScalarFunction" method in
"ScalarSqlFunction" of blink planner was replaced by "makeFunct
flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends]
Support on-disk state storage for spill-able heap backend
URL: https://github.com/apache/flink/pull/9501#issuecomment-523769032
## CI report:
* 6107a00876759dcef075592c8bfa56764f66b6fa : FAILURE
[Build](htt
JingsongLi commented on issue #9865: [FLINK-14212][python] Support no-argument
Python UDFs.
URL: https://github.com/apache/flink/pull/9865#issuecomment-541302996
> @JingsongLi I noticed that the "getScalarFunction" method in
"ScalarSqlFunction" of blink planner was replaced by "makeFunctio
carp84 commented on a change in pull request #9501: [FLINK-12697] [State
Backends] Support on-disk state storage for spill-able heap backend
URL: https://github.com/apache/flink/pull/9501#discussion_r334227853
##
File path:
flink-state-backends/flink-statebackend-heap-spillable/src
flinkbot edited a comment on issue #9646: [FLINK-14004][runtime] Define
SourceReaderOperator to verify the integration with StreamOneInputProcessor
URL: https://github.com/apache/flink/pull/9646#issuecomment-529229460
## CI report:
* 4f286e24aa0bb04d8e6cc81d64dc7e9ac642b012 : FA
flinkbot edited a comment on issue #9885: [FLINK-14344][checkpointing]
Snapshots master hook state asynchronously
URL: https://github.com/apache/flink/pull/9885#issuecomment-541299624
## CI report:
* d0c426e6ff61dcad1de4c7d3e9a2a16416e77e54 : PENDING
[Build](https://travis-ci.co
1 - 100 of 141 matches
Mail list logo
