klion26 commented on a change in pull request #9805: [FLINK-11635][docs-zh]
translate dev/stream/state/checkpointing into Chinese
URL: https://github.com/apache/flink/pull/9805#discussion_r334222850
##
File path: docs/dev/stream/state/checkpointing.zh.md
##
@@ -25,146
klion26 commented on a change in pull request #9805: [FLINK-11635][docs-zh]
translate dev/stream/state/checkpointing into Chinese
URL: https://github.com/apache/flink/pull/9805#discussion_r334223320
##
File path: docs/dev/stream/state/checkpointing.zh.md
##
@@ -25,146
klion26 commented on a change in pull request #9805: [FLINK-11635][docs-zh]
translate dev/stream/state/checkpointing into Chinese
URL: https://github.com/apache/flink/pull/9805#discussion_r334223081
##
File path: docs/dev/stream/state/checkpointing.zh.md
##
@@ -25,146
klion26 commented on a change in pull request #9805: [FLINK-11635][docs-zh]
translate dev/stream/state/checkpointing into Chinese
URL: https://github.com/apache/flink/pull/9805#discussion_r334223253
##
File path: docs/dev/stream/state/checkpointing.zh.md
##
@@ -25,146
klion26 commented on a change in pull request #9805: [FLINK-11635][docs-zh]
translate dev/stream/state/checkpointing into Chinese
URL: https://github.com/apache/flink/pull/9805#discussion_r334222780
##
File path: docs/dev/stream/state/checkpointing.zh.md
##
@@ -25,146
klion26 commented on a change in pull request #9805: [FLINK-11635][docs-zh]
translate dev/stream/state/checkpointing into Chinese
URL: https://github.com/apache/flink/pull/9805#discussion_r334223449
##
File path: docs/dev/stream/state/checkpointing.zh.md
##
@@ -173,30
klion26 commented on a change in pull request #9805: [FLINK-11635][docs-zh]
translate dev/stream/state/checkpointing into Chinese
URL: https://github.com/apache/flink/pull/9805#discussion_r334223394
##
File path: docs/dev/stream/state/checkpointing.zh.md
##
@@ -25,146
klion26 commented on a change in pull request #9805: [FLINK-11635][docs-zh]
translate dev/stream/state/checkpointing into Chinese
URL: https://github.com/apache/flink/pull/9805#discussion_r334223138
##
File path: docs/dev/stream/state/checkpointing.zh.md
##
@@ -25,146
klion26 commented on a change in pull request #9805: [FLINK-11635][docs-zh]
translate dev/stream/state/checkpointing into Chinese
URL: https://github.com/apache/flink/pull/9805#discussion_r334223491
##
File path: docs/dev/stream/state/checkpointing.zh.md
##
@@ -173,30
klion26 commented on a change in pull request #9805: [FLINK-11635][docs-zh]
translate dev/stream/state/checkpointing into Chinese
URL: https://github.com/apache/flink/pull/9805#discussion_r33422
##
File path: docs/dev/stream/state/checkpointing.zh.md
##
@@ -25,146
klion26 commented on a change in pull request #9805: [FLINK-11635][docs-zh]
translate dev/stream/state/checkpointing into Chinese
URL: https://github.com/apache/flink/pull/9805#discussion_r334224348
##
File path: docs/dev/stream/state/checkpointing.zh.md
##
@@ -173,30
klion26 commented on a change in pull request #9805: [FLINK-11635][docs-zh]
translate dev/stream/state/checkpointing into Chinese
URL: https://github.com/apache/flink/pull/9805#discussion_r334223536
##
File path: docs/dev/stream/state/checkpointing.zh.md
##
@@ -173,30
klion26 commented on a change in pull request #9805: [FLINK-11635][docs-zh]
translate dev/stream/state/checkpointing into Chinese
URL: https://github.com/apache/flink/pull/9805#discussion_r334223179
##
File path: docs/dev/stream/state/checkpointing.zh.md
##
@@ -25,146
klion26 commented on a change in pull request #9805: [FLINK-11635][docs-zh]
translate dev/stream/state/checkpointing into Chinese
URL: https://github.com/apache/flink/pull/9805#discussion_r334223542
##
File path: docs/dev/stream/state/checkpointing.zh.md
##
@@ -173,30
flinkbot edited a comment on issue #9760: [FLINK-13982][runtime] Implement
memory calculation logics
URL: https://github.com/apache/flink/pull/9760#issuecomment-534565595
## CI report:
* 6bc9773c54eed0b1646ec67413cb3855c1057d87 : FAILURE
flinkbot edited a comment on issue #9882: [FLINK-14380][Flink-Core] Type
Extractor Setter
URL: https://github.com/apache/flink/pull/9882#issuecomment-541191860
## CI report:
* be39b56629b779f39b546e61315a2373d26e683c : FAILURE
[
https://issues.apache.org/jira/browse/FLINK-14381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-14381:
---
Assignee: Jingsong Lee
> Partition field names should be got from CatalogTable instead of
xintongsong commented on a change in pull request #9693: [FLINK-13984] Separate
on-heap and off-heap managed memory pools
URL: https://github.com/apache/flink/pull/9693#discussion_r334223099
##
File path:
klion26 commented on a change in pull request #9805: [FLINK-11635][docs-zh]
translate dev/stream/state/checkpointing into Chinese
URL: https://github.com/apache/flink/pull/9805#discussion_r334222594
##
File path: docs/dev/stream/state/checkpointing.zh.md
##
@@ -25,146
klion26 commented on a change in pull request #9805: [FLINK-11635][docs-zh]
translate dev/stream/state/checkpointing into Chinese
URL: https://github.com/apache/flink/pull/9805#discussion_r334222583
##
File path: docs/dev/stream/state/checkpointing.zh.md
##
@@ -25,146
klion26 commented on a change in pull request #9805: [FLINK-11635][docs-zh]
translate dev/stream/state/checkpointing into Chinese
URL: https://github.com/apache/flink/pull/9805#discussion_r334223024
##
File path: docs/dev/stream/state/checkpointing.zh.md
##
@@ -25,146
klion26 commented on a change in pull request #9805: [FLINK-11635][docs-zh]
translate dev/stream/state/checkpointing into Chinese
URL: https://github.com/apache/flink/pull/9805#discussion_r334223245
##
File path: docs/dev/stream/state/checkpointing.zh.md
##
@@ -25,146
klion26 commented on a change in pull request #9805: [FLINK-11635][docs-zh]
translate dev/stream/state/checkpointing into Chinese
URL: https://github.com/apache/flink/pull/9805#discussion_r334222550
##
File path: docs/dev/stream/state/checkpointing.zh.md
##
@@ -25,146
klion26 commented on a change in pull request #9805: [FLINK-11635][docs-zh]
translate dev/stream/state/checkpointing into Chinese
URL: https://github.com/apache/flink/pull/9805#discussion_r334222640
##
File path: docs/dev/stream/state/checkpointing.zh.md
##
@@ -25,146
klion26 commented on a change in pull request #9805: [FLINK-11635][docs-zh]
translate dev/stream/state/checkpointing into Chinese
URL: https://github.com/apache/flink/pull/9805#discussion_r334223360
##
File path: docs/dev/stream/state/checkpointing.zh.md
##
@@ -25,146
klion26 commented on a change in pull request #9805: [FLINK-11635][docs-zh]
translate dev/stream/state/checkpointing into Chinese
URL: https://github.com/apache/flink/pull/9805#discussion_r334222736
##
File path: docs/dev/stream/state/checkpointing.zh.md
##
@@ -25,146
klion26 commented on a change in pull request #9805: [FLINK-11635][docs-zh]
translate dev/stream/state/checkpointing into Chinese
URL: https://github.com/apache/flink/pull/9805#discussion_r334223461
##
File path: docs/dev/stream/state/checkpointing.zh.md
##
@@ -173,30
klion26 commented on a change in pull request #9805: [FLINK-11635][docs-zh]
translate dev/stream/state/checkpointing into Chinese
URL: https://github.com/apache/flink/pull/9805#discussion_r334222482
##
File path: docs/dev/stream/state/checkpointing.zh.md
##
@@ -25,146
klion26 commented on a change in pull request #9805: [FLINK-11635][docs-zh]
translate dev/stream/state/checkpointing into Chinese
URL: https://github.com/apache/flink/pull/9805#discussion_r334222411
##
File path: docs/dev/stream/state/checkpointing.zh.md
##
@@ -25,146
danny0405 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_r334222975
##
File path:
danny0405 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_r334222935
##
File path:
danny0405 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_r334222831
##
File path:
xintongsong commented on a change in pull request #9693: [FLINK-13984] Separate
on-heap and off-heap managed memory pools
URL: https://github.com/apache/flink/pull/9693#discussion_r334223063
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/memory/KeyedBudget.java
xintongsong commented on a change in pull request #9693: [FLINK-13984] Separate
on-heap and off-heap managed memory pools
URL: https://github.com/apache/flink/pull/9693#discussion_r334223624
##
File path:
xintongsong commented on issue #9760: [FLINK-13982][runtime] Implement memory
calculation logics
URL: https://github.com/apache/flink/pull/9760#issuecomment-541295591
Thanks @tillrohrmann.
PR is updated and rebased. Travis passed:
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_r334216686
##
File path: flink-python/pyflink/table/tests/test_udf.py
##
@@
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_r334222347
##
File path: flink-python/pyflink/fn_execution/operations.py
##
@@
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_r334216406
##
File path: flink-python/pyflink/table/tests/test_udf.py
##
@@
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_r334218101
##
File path: flink-python/pyflink/proto/flink-fn-execution.proto
##
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_r333997884
##
File path:
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_r334217523
##
File path: flink-python/pyflink/table/tests/test_udf.py
##
@@
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 :
wuchong commented on issue #9823: [FLINK-14273][table-planner] Improve
exception message when signature validation of UDAF is failed
URL: https://github.com/apache/flink/pull/9823#issuecomment-541290026
Ignore the message above. I will add the test and merge this PR when travis
pass.
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_r333993423
##
File path:
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 :
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 :
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
[
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
[
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:
[
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
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
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
[
https://issues.apache.org/jira/browse/FLINK-14225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16949981#comment-16949981
]
Gary Yao commented on FLINK-14225:
--
If there are no objections, I will remove these variables on
[
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
[
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
[
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
[
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
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
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
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:
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:
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
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,
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
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:
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
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
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
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
[
https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16950063#comment-16950063
]
liupengcheng commented on FLINK-14123:
--
[~xintongsong] I think it's a common case, because I just
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
[
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=16950066#comment-16950066
]
Hequn Cheng commented on FLINK-14208:
-
Resolved in 1.10.0 via:
[
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
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
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
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:
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
[
https://issues.apache.org/jira/browse/FLINK-14275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16950055#comment-16950055
]
hailong wang commented on FLINK-14275:
--
Hi, [~jark], thanks for you tip. In my side, we just need
[
https://issues.apache.org/jira/browse/FLINK-14275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16950061#comment-16950061
]
Jark Wu commented on FLINK-14275:
-
Hi [~hailong wang],
1) we should not provide the full power of
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
[
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
>
flinkbot commented on issue #9885: [FLINK-14344][checkpointing] Snapshots
master hook state asynchronously
URL: https://github.com/apache/flink/pull/9885#issuecomment-541296802
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to
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:
[
https://issues.apache.org/jira/browse/FLINK-14318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16949972#comment-16949972
]
Till Rohrmann commented on FLINK-14318:
---
Another instance:
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
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-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
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:
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-14344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-14344:
---
Labels: pull-request-available (was: )
> Snapshot master hook state asynchronously
>
ifndef-SleePy opened a new pull request #9885: [FLINK-14344][checkpointing]
Snapshots master hook state asynchronously
URL: https://github.com/apache/flink/pull/9885
## What is the purpose of the change
* This is based on https://github.com/apache/flink/pull/9853
* This is a
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-541299481
@flinkbot run travis
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
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
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
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
[
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
[
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
>
1 - 100 of 153 matches
Mail list logo
