wangyang0918 commented on a change in pull request #9984:
[FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.
URL: https://github.com/apache/flink/pull/9984#discussion_r354210083
##
File path:
zentol merged pull request #10363: [FLINK-14104][build] Upgrade to flink-shaded
9.0
URL: https://github.com/apache/flink/pull/10363
This is an automated message from the Apache Git Service.
To respond to the message, please
wangyang0918 commented on a change in pull request #9984:
[FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.
URL: https://github.com/apache/flink/pull/9984#discussion_r354208892
##
File path:
carp84 commented on a change in pull request #10329:
[FLINK-12785][StateBackend] RocksDB savepoint recovery can use a lot of
unmanaged memory
URL: https://github.com/apache/flink/pull/10329#discussion_r354209108
##
File path:
TisonKun commented on issue #10408: [FLINK-14992][client] Add job listener to
execution environments
URL: https://github.com/apache/flink/pull/10408#issuecomment-562057572
I address the comments. Will rebase later.
This is
zhuzhurk commented on a change in pull request #10427: [FLINK-14566] Enable to
get/set whether an operator uses managed memory
URL: https://github.com/apache/flink/pull/10427#discussion_r354207645
##
File path:
flink-core/src/main/java/org/apache/flink/api/dag/Transformation.java
zhuzhurk commented on a change in pull request #10427: [FLINK-14566] Enable to
get/set whether an operator uses managed memory
URL: https://github.com/apache/flink/pull/10427#discussion_r354207645
##
File path:
flink-core/src/main/java/org/apache/flink/api/dag/Transformation.java
klion26 commented on a change in pull request #10409: [FLINK-14918]
[flink-end-to-end-perf-tests] Add performance e2e test module and scripts
URL: https://github.com/apache/flink/pull/10409#discussion_r354184876
##
File path: tools/jenkins/restapi_common.py
##
@@ -0,0
klion26 commented on a change in pull request #10409: [FLINK-14918]
[flink-end-to-end-perf-tests] Add performance e2e test module and scripts
URL: https://github.com/apache/flink/pull/10409#discussion_r354204395
##
File path: tools/jenkins/run_case.py
##
@@ -0,0 +1,131 @@
klion26 commented on a change in pull request #10409: [FLINK-14918]
[flink-end-to-end-perf-tests] Add performance e2e test module and scripts
URL: https://github.com/apache/flink/pull/10409#discussion_r354206567
##
File path: tools/jenkins/utils.py
##
@@ -0,0 +1,70 @@
klion26 commented on a change in pull request #10409: [FLINK-14918]
[flink-end-to-end-perf-tests] Add performance e2e test module and scripts
URL: https://github.com/apache/flink/pull/10409#discussion_r354183164
##
File path: tools/jenkins/restapi_common.py
##
@@ -0,0
klion26 commented on a change in pull request #10409: [FLINK-14918]
[flink-end-to-end-perf-tests] Add performance e2e test module and scripts
URL: https://github.com/apache/flink/pull/10409#discussion_r354206465
##
File path: tools/jenkins/utils.py
##
@@ -0,0 +1,70 @@
klion26 commented on a change in pull request #10409: [FLINK-14918]
[flink-end-to-end-perf-tests] Add performance e2e test module and scripts
URL: https://github.com/apache/flink/pull/10409#discussion_r354199881
##
File path: tools/jenkins/restapi_common.py
##
@@ -0,0
klion26 commented on a change in pull request #10409: [FLINK-14918]
[flink-end-to-end-perf-tests] Add performance e2e test module and scripts
URL: https://github.com/apache/flink/pull/10409#discussion_r354202268
##
File path: tools/jenkins/restapi_common.py
##
@@ -0,0
klion26 commented on a change in pull request #10409: [FLINK-14918]
[flink-end-to-end-perf-tests] Add performance e2e test module and scripts
URL: https://github.com/apache/flink/pull/10409#discussion_r354200974
##
File path: tools/jenkins/restapi_common.py
##
@@ -0,0
klion26 commented on a change in pull request #10409: [FLINK-14918]
[flink-end-to-end-perf-tests] Add performance e2e test module and scripts
URL: https://github.com/apache/flink/pull/10409#discussion_r354184888
##
File path: tools/jenkins/restapi_common.py
##
@@ -0,0
klion26 commented on a change in pull request #10409: [FLINK-14918]
[flink-end-to-end-perf-tests] Add performance e2e test module and scripts
URL: https://github.com/apache/flink/pull/10409#discussion_r354202705
##
File path: tools/jenkins/restapi_common.py
##
@@ -0,0
klion26 commented on a change in pull request #10409: [FLINK-14918]
[flink-end-to-end-perf-tests] Add performance e2e test module and scripts
URL: https://github.com/apache/flink/pull/10409#discussion_r354185294
##
File path: tools/jenkins/restapi_common.py
##
@@ -0,0
klion26 commented on a change in pull request #10409: [FLINK-14918]
[flink-end-to-end-perf-tests] Add performance e2e test module and scripts
URL: https://github.com/apache/flink/pull/10409#discussion_r354175138
##
File path: tools/jenkins/restapi_common.py
##
@@ -0,0
klion26 commented on a change in pull request #10409: [FLINK-14918]
[flink-end-to-end-perf-tests] Add performance e2e test module and scripts
URL: https://github.com/apache/flink/pull/10409#discussion_r354172620
##
File path: tools/jenkins/restapi_common.py
##
@@ -0,0
klion26 commented on a change in pull request #10409: [FLINK-14918]
[flink-end-to-end-perf-tests] Add performance e2e test module and scripts
URL: https://github.com/apache/flink/pull/10409#discussion_r354203132
##
File path: tools/jenkins/run_case.py
##
@@ -0,0 +1,131 @@
klion26 commented on a change in pull request #10409: [FLINK-14918]
[flink-end-to-end-perf-tests] Add performance e2e test module and scripts
URL: https://github.com/apache/flink/pull/10409#discussion_r354197180
##
File path: tools/jenkins/restapi_common.py
##
@@ -0,0
klion26 commented on a change in pull request #10409: [FLINK-14918]
[flink-end-to-end-perf-tests] Add performance e2e test module and scripts
URL: https://github.com/apache/flink/pull/10409#discussion_r354184006
##
File path: tools/jenkins/restapi_common.py
##
@@ -0,0
aljoscha commented on issue #10408: [FLINK-14992][client] Add job listener to
execution environments
URL: https://github.com/apache/flink/pull/10408#issuecomment-562055537
Also, feel free to rebase on master and squash into final commits when
you're done with addressing the comments. That
zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes]
Implement ResourceManager for Kubernetes.
URL: https://github.com/apache/flink/pull/9984#discussion_r354205253
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-15031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-15031:
-
Assignee: Zhu Zhu
> Calculate required shuffle memory cases before allocating slots in
aljoscha commented on a change in pull request #10408: [FLINK-14992][client]
Add job listener to execution environments
URL: https://github.com/apache/flink/pull/10408#discussion_r354204878
##
File path:
flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java
carp84 commented on a change in pull request #10329:
[FLINK-12785][StateBackend] RocksDB savepoint recovery can use a lot of
unmanaged memory
URL: https://github.com/apache/flink/pull/10329#discussion_r354204039
##
File path:
carp84 commented on a change in pull request #10329:
[FLINK-12785][StateBackend] RocksDB savepoint recovery can use a lot of
unmanaged memory
URL: https://github.com/apache/flink/pull/10329#discussion_r354204499
##
File path:
zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes]
Implement ResourceManager for Kubernetes.
URL: https://github.com/apache/flink/pull/9984#discussion_r354203645
##
File path:
wangyang0918 commented on a change in pull request #9984:
[FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.
URL: https://github.com/apache/flink/pull/9984#discussion_r354203808
##
File path:
wangyang0918 commented on a change in pull request #9984:
[FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.
URL: https://github.com/apache/flink/pull/9984#discussion_r354202847
##
File path:
zhuzhurk commented on a change in pull request #10427: [FLINK-14566] Enable to
get/set whether an operator uses managed memory
URL: https://github.com/apache/flink/pull/10427#discussion_r354196126
##
File path:
flink-core/src/main/java/org/apache/flink/api/dag/Transformation.java
TisonKun commented on a change in pull request #10408: [FLINK-14992][client]
Add job listener to execution environments
URL: https://github.com/apache/flink/pull/10408#discussion_r354202101
##
File path:
flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java
TisonKun commented on a change in pull request #10408: [FLINK-14992][client]
Add job listener to execution environments
URL: https://github.com/apache/flink/pull/10408#discussion_r354202037
##
File path:
flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java
wangyang0918 commented on a change in pull request #9984:
[FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.
URL: https://github.com/apache/flink/pull/9984#discussion_r354201105
##
File path:
TisonKun commented on a change in pull request #10408: [FLINK-14992][client]
Add job listener to execution environments
URL: https://github.com/apache/flink/pull/10408#discussion_r354200552
##
File path:
flink-core/src/main/java/org/apache/flink/core/execution/JobClient.java
zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes]
Implement ResourceManager for Kubernetes.
URL: https://github.com/apache/flink/pull/9984#discussion_r354179274
##
File path:
TisonKun commented on a change in pull request #10408: [FLINK-14992][client]
Add job listener to execution environments
URL: https://github.com/apache/flink/pull/10408#discussion_r354200321
##
File path:
TisonKun commented on a change in pull request #10408: [FLINK-14992][client]
Add job listener to execution environments
URL: https://github.com/apache/flink/pull/10408#discussion_r354199784
##
File path:
flink-clients/src/test/java/org/apache/flink/client/program/ClientTest.java
aljoscha commented on a change in pull request #10408: [FLINK-14992][client]
Add job listener to execution environments
URL: https://github.com/apache/flink/pull/10408#discussion_r354200182
##
File path:
flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java
wangyang0918 commented on a change in pull request #9984:
[FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.
URL: https://github.com/apache/flink/pull/9984#discussion_r354199195
##
File path:
xintongsong commented on a change in pull request #10146:
[FLINK-14188][runtime] TaskExecutor derive and register with default slot
resource profile
URL: https://github.com/apache/flink/pull/10146#discussion_r354198697
##
File path:
zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes]
Implement ResourceManager for Kubernetes.
URL: https://github.com/apache/flink/pull/9984#discussion_r354198627
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-15074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
gameking updated FLINK-15074:
-
Summary: Connection timed out, Standalone cluster (was: Connection timed
out, Standalone)
>
wangyang0918 commented on a change in pull request #9984:
[FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.
URL: https://github.com/apache/flink/pull/9984#discussion_r35419
##
File path:
wangyang0918 commented on a change in pull request #9984:
[FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.
URL: https://github.com/apache/flink/pull/9984#discussion_r354197703
##
File path:
flinkbot edited a comment on issue #10126: [FLINK-14590][python] Unify the
working directory of Java process and Python process when submitting python
jobs via "flink run -py"
URL: https://github.com/apache/flink/pull/10126#issuecomment-551413525
## CI report:
*
zhuzhurk commented on a change in pull request #10427: [FLINK-14566] Enable to
get/set whether an operator uses managed memory
URL: https://github.com/apache/flink/pull/10427#discussion_r354196126
##
File path:
flink-core/src/main/java/org/apache/flink/api/dag/Transformation.java
aljoscha commented on a change in pull request #10408: [FLINK-14992][client]
Add job listener to execution environments
URL: https://github.com/apache/flink/pull/10408#discussion_r354197011
##
File path:
flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java
wangyang0918 commented on a change in pull request #9984:
[FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.
URL: https://github.com/apache/flink/pull/9984#discussion_r354197125
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-14781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu resolved FLINK-14781.
-
Resolution: Fixed
Fixed in 1.10.0: 4b95648975056db58c6d5a669aad9d6fbd6e9f99
> [ZH] clarify that a
[
https://issues.apache.org/jira/browse/FLINK-14781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-14781:
Fix Version/s: 1.10.0
> [ZH] clarify that a RocksDB dependency in pom.xml may not be needed
>
wangyang0918 commented on a change in pull request #9984:
[FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.
URL: https://github.com/apache/flink/pull/9984#discussion_r354196649
##
File path:
aljoscha commented on a change in pull request #10408: [FLINK-14992][client]
Add job listener to execution environments
URL: https://github.com/apache/flink/pull/10408#discussion_r354195897
##
File path:
flink-core/src/main/java/org/apache/flink/core/execution/JobClient.java
wuchong merged pull request #10206: [FLINK-14781] [docs-zh] correct the
state_backends.zh external link and some other things
URL: https://github.com/apache/flink/pull/10206
This is an automated message from the Apache Git
zhuzhurk commented on a change in pull request #10427: [FLINK-14566] Enable to
get/set whether an operator uses managed memory
URL: https://github.com/apache/flink/pull/10427#discussion_r354196126
##
File path:
flink-core/src/main/java/org/apache/flink/api/dag/Transformation.java
aljoscha commented on a change in pull request #10408: [FLINK-14992][client]
Add job listener to execution environments
URL: https://github.com/apache/flink/pull/10408#discussion_r354195543
##
File path:
flink-clients/src/test/java/org/apache/flink/client/program/ClientTest.java
flinkbot commented on issue #10434: [FLINK-15072][client] Hijack executeAsync
instead of execute in context environment
URL: https://github.com/apache/flink/pull/10434#issuecomment-562048009
## CI report:
* 3657f8be3e9a8eb83712a9eeafe0bc8e3c182c95 : UNKNOWN
Bot
flinkbot commented on issue #10435: [FLINK-13955][runtime] migrate
ContinuousFileReaderOperator to the mailbox execution model
URL: https://github.com/apache/flink/pull/10435#issuecomment-562048103
## CI report:
* d07737bd54c586aa87204c6ac298309f432cc06c : UNKNOWN
Bot
aljoscha commented on a change in pull request #10408: [FLINK-14992][client]
Add job listener to execution environments
URL: https://github.com/apache/flink/pull/10408#discussion_r354194861
##
File path:
flinkbot commented on issue #10432: [FLINK-13450][table api] Use StrictMath
instead of Math for exp
URL: https://github.com/apache/flink/pull/10432#issuecomment-562047809
## CI report:
* a69782464ce80d238c4ea94045b603738d62d13c : UNKNOWN
Bot commands
The
flinkbot commented on issue #10433: [FLINK-15071] YARN vcore capacity check can
not pass when use large slotPerTaskManager
URL: https://github.com/apache/flink/pull/10433#issuecomment-562047908
## CI report:
* ad17546e86c7273f447591448b9bea9dafa83d8e : UNKNOWN
Bot
aljoscha commented on issue #10408: [FLINK-14992][client] Add job listener to
execution environments
URL: https://github.com/apache/flink/pull/10408#issuecomment-562047708
Yes, the `JobContext` seems good to me! What do you think, @zjffdu?
flinkbot edited a comment on issue #10431: [FLINK-15067][table] Pass
configuration to the underlying ExecutionEnvironment from TableEnvironment
URL: https://github.com/apache/flink/pull/10431#issuecomment-562033619
## CI report:
* e0b1afaebe5bd4fc07e61785a38ef82f55e16f69 :
flinkbot edited a comment on issue #10430: [FLINK-14019][python][cli] Add
command-line options for managing Python UDF environment and dependencies.
URL: https://github.com/apache/flink/pull/10430#issuecomment-562033539
## CI report:
* 735df4f522069f08b8b4b26a0018a6440293c507 :
wangyang0918 commented on a change in pull request #9984:
[FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.
URL: https://github.com/apache/flink/pull/9984#discussion_r354193828
##
File path:
wangyang0918 commented on a change in pull request #9984:
[FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.
URL: https://github.com/apache/flink/pull/9984#discussion_r354193534
##
File path:
klion26 commented on issue #10344: [FLINK-14264][StateBackend][Rest] Expose
state backend in checkpoint rest api
URL: https://github.com/apache/flink/pull/10344#issuecomment-562047203
Currently, I set the default value of "stateBackend" to "disabled", because
when I run job(disabled
flinkbot edited a comment on issue #10415: [FLINK-15049][table-planner-blink]
Compile error when hash join with …
URL: https://github.com/apache/flink/pull/10415#issuecomment-561528911
## CI report:
* e838831b098e3043b6576aec5ba38ee6bdc29422 : FAILURE
zhuzhurk commented on a change in pull request #10427: [FLINK-14566] Enable to
get/set whether an operator uses managed memory
URL: https://github.com/apache/flink/pull/10427#discussion_r354193194
##
File path:
flink-core/src/main/java/org/apache/flink/api/dag/Transformation.java
wangyang0918 commented on a change in pull request #9984:
[FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.
URL: https://github.com/apache/flink/pull/9984#discussion_r354193043
##
File path:
wangyang0918 commented on a change in pull request #9984:
[FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.
URL: https://github.com/apache/flink/pull/9984#discussion_r354193089
##
File path:
wangyang0918 commented on a change in pull request #9984:
[FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.
URL: https://github.com/apache/flink/pull/9984#discussion_r354192518
##
File path:
flinkbot edited a comment on issue #10406: [FLINK-15045][runtime] Only log
RestartStrategy in legacy scheduling mode
URL: https://github.com/apache/flink/pull/10406#issuecomment-561380440
## CI report:
* 0effd7f6b294b7f2da91c7681aa6e8ae51390efc : UNKNOWN
*
wangyang0918 commented on a change in pull request #9984:
[FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.
URL: https://github.com/apache/flink/pull/9984#discussion_r354192518
##
File path:
wangyang0918 commented on a change in pull request #9984:
[FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.
URL: https://github.com/apache/flink/pull/9984#discussion_r354191889
##
File path:
gameking created FLINK-15074:
Summary: Connection timed out, Standalone
Key: FLINK-15074
URL: https://issues.apache.org/jira/browse/FLINK-15074
Project: Flink
Issue Type: Bug
wangyang0918 commented on a change in pull request #9984:
[FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.
URL: https://github.com/apache/flink/pull/9984#discussion_r354191588
##
File path:
zhuzhurk commented on a change in pull request #10427: [FLINK-14566] Enable to
get/set whether an operator uses managed memory
URL: https://github.com/apache/flink/pull/10427#discussion_r354191429
##
File path:
flink-core/src/main/java/org/apache/flink/api/dag/Transformation.java
wangyang0918 commented on a change in pull request #9984:
[FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.
URL: https://github.com/apache/flink/pull/9984#discussion_r354191336
##
File path:
JingsongLi commented on a change in pull request #10427: [FLINK-14566] Enable
to get/set whether an operator uses managed memory
URL: https://github.com/apache/flink/pull/10427#discussion_r354191173
##
File path:
wangyang0918 commented on a change in pull request #9984:
[FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.
URL: https://github.com/apache/flink/pull/9984#discussion_r354191336
##
File path:
wangyang0918 commented on a change in pull request #9984:
[FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.
URL: https://github.com/apache/flink/pull/9984#discussion_r354190944
##
File path:
wangyang0918 commented on a change in pull request #9984:
[FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.
URL: https://github.com/apache/flink/pull/9984#discussion_r354190647
##
File path:
wangyang0918 commented on a change in pull request #9984:
[FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.
URL: https://github.com/apache/flink/pull/9984#discussion_r354190715
##
File path:
flinkbot edited a comment on issue #10344: [FLINK-14264][StateBackend][Rest]
Expose state backend in checkpoint rest api
URL: https://github.com/apache/flink/pull/10344#issuecomment-559371382
## CI report:
* fbd6e8914b49348a275657130ebdd9413d7d17c6 : SUCCESS
wangyang0918 commented on a change in pull request #9984:
[FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.
URL: https://github.com/apache/flink/pull/9984#discussion_r354189844
##
File path:
JingsongLi commented on a change in pull request #10427: [FLINK-14566] Enable
to get/set whether an operator uses managed memory
URL: https://github.com/apache/flink/pull/10427#discussion_r354189419
##
File path:
flinkbot edited a comment on issue #10316: [FLINK-14624][table-blink] Support
computed column as rowtime attribute
URL: https://github.com/apache/flink/pull/10316#issuecomment-558248395
## CI report:
* 3624bce085de9f708f4d5fb4a8a7617884c0adf8 : FAILURE
flinkbot edited a comment on issue #10306: [FLINK-13943][table-api] Provide
utility method to convert Flink table to Java List
URL: https://github.com/apache/flink/pull/10306#issuecomment-558027199
## CI report:
* 0b265d192e2a6024e5817317be0317136208ccaf : SUCCESS
zhijiangW commented on a change in pull request #9984: [FLINK-9495][kubernetes]
Implement ResourceManager for Kubernetes.
URL: https://github.com/apache/flink/pull/9984#discussion_r354188862
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-15072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen updated FLINK-15072:
--
Description: See also the pull request.
> Hijack executeAsync instead of execute in context
wsry commented on a change in pull request #10375: [FLINK-14845][runtime]
Introduce data compression to reduce disk and network IO of shuffle.
URL: https://github.com/apache/flink/pull/10375#discussion_r354188018
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-14890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-14890.
Fix Version/s: 1.10.0
Resolution: Fixed
Implemented on master in
WeiZhong94 commented on issue #10389: [FLINK-14198][python] Add "type" and
"rtype" options to flink python API docstrings of table.py and
table_environment.py
URL: https://github.com/apache/flink/pull/10389#issuecomment-562042910
@HuangXingBo Thanks for your review! I have removed the
flinkbot edited a comment on issue #10249: [FLINK-14847][hive] Support
retrieving Hive PK constraints
URL: https://github.com/apache/flink/pull/10249#issuecomment-555440054
## CI report:
* bd253651412e9ca6857cf0ba299bdd1bf544c2c4 : SUCCESS
WeiZhong94 commented on a change in pull request #10389: [FLINK-14198][python]
Add "type" and "rtype" options to flink python API docstrings of table.py and
table_environment.py
URL: https://github.com/apache/flink/pull/10389#discussion_r354187503
##
File path:
aljoscha commented on issue #10286: [FLINK-14890] [tests] Add missing test
harnesses for broadcast functions
URL: https://github.com/apache/flink/pull/10286#issuecomment-562042753
Thanks! I merged this and put some minor changes on top.
aljoscha closed pull request #10286: [FLINK-14890] [tests] Add missing test
harnesses for broadcast functions
URL: https://github.com/apache/flink/pull/10286
This is an automated message from the Apache Git Service.
To
701 - 800 of 920 matches
Mail list logo