flinkbot edited a comment on issue #10082: [FLINK-14164][runtime] Add a meter
‘numberOfRestarts’ to show number of restarts as well as its rate
URL: https://github.com/apache/flink/pull/10082#issuecomment-549698167
## CI report:
* 9ad21545cdce68c8892941e8f33a89147bddb1f6 : PENDIN
flinkbot edited a comment on issue #10060: [FLINK-14546] [flink-json] Support
map type in flink-json
URL: https://github.com/apache/flink/pull/10060#issuecomment-548313242
## CI report:
* c68dc12d24be4ef19efc1ef42246e6018c4f6e8d : SUCCESS
[Build](https://travis-ci.com/flink-ci/f
flinkbot commented on issue #10083: [FLINK-14472][runtime]Implement
back-pressure monitor with non-blocking outputs.
URL: https://github.com/apache/flink/pull/10083#issuecomment-549704821
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the communit
[
https://issues.apache.org/jira/browse/FLINK-14472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-14472:
---
Labels: pull-request-available (was: )
> Implement back-pressure monitor with non-blocking
wsry opened a new pull request #10083: [FLINK-14472][runtime]Implement
back-pressure monitor with non-blocking outputs.
URL: https://github.com/apache/flink/pull/10083
## What is the purpose of the change
Currently back-pressure monitor relies on detecting task threads that are
stuck in
zhuzhurk commented on a change in pull request #10076: [FLINK-14465][runtime]
Let `StandaloneJobClusterEntrypoint` use user code class loader
URL: https://github.com/apache/flink/pull/10076#discussion_r342418215
##
File path:
flink-clients/src/main/java/org/apache/flink/client/prog
Jark Wu created FLINK-14610:
---
Summary: Add documentation for how to use watermark syntax in DDL
Key: FLINK-14610
URL: https://issues.apache.org/jira/browse/FLINK-14610
Project: Flink
Issue Type: Su
libenchao commented on a change in pull request #10060: [FLINK-14546]
[flink-json] Support map type in flink-json
URL: https://github.com/apache/flink/pull/10060#discussion_r342414169
##
File path:
flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDeserial
Danny Chen created FLINK-14609:
--
Summary: Add doc for Flink SQL computed columns
Key: FLINK-14609
URL: https://issues.apache.org/jira/browse/FLINK-14609
Project: Flink
Issue Type: Sub-task
flinkbot commented on issue #10082: [FLINK-14164][runtime] Add a meter
‘numberOfRestarts’ to show number of restarts as well as its rate
URL: https://github.com/apache/flink/pull/10082#issuecomment-549698167
## CI report:
* 9ad21545cdce68c8892941e8f33a89147bddb1f6 : UNKNOWN
libenchao commented on a change in pull request #10060: [FLINK-14546]
[flink-json] Support map type in flink-json
URL: https://github.com/apache/flink/pull/10060#discussion_r342410101
##
File path:
flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDeserial
[
https://issues.apache.org/jira/browse/FLINK-14608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-14608:
---
Description: According to
[https://flink.apache.org/contributing/code-style-and-quality-java.html],
Kurt Young created FLINK-14608:
--
Summary: avoid using Java Streams in JsonRowDeserializationSchema
Key: FLINK-14608
URL: https://issues.apache.org/jira/browse/FLINK-14608
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-14498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yingjie Cao closed FLINK-14498.
---
> Introduce NetworkBufferPool#isAvailable() for non-blocking output
> --
guoweiM commented on a change in pull request #10076: [FLINK-14465][runtime]
Let `StandaloneJobClusterEntrypoint` use user code class loader
URL: https://github.com/apache/flink/pull/10076#discussion_r342405496
##
File path:
flink-container/src/main/java/org/apache/flink/container/
KurtYoung commented on a change in pull request #10060: [FLINK-14546]
[flink-json] Support map type in flink-json
URL: https://github.com/apache/flink/pull/10060#discussion_r342405648
##
File path:
flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDeserial
KurtYoung commented on a change in pull request #10060: [FLINK-14546]
[flink-json] Support map type in flink-json
URL: https://github.com/apache/flink/pull/10060#discussion_r342405648
##
File path:
flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDeserial
guoweiM commented on a change in pull request #10076: [FLINK-14465][runtime]
Let `StandaloneJobClusterEntrypoint` use user code class loader
URL: https://github.com/apache/flink/pull/10076#discussion_r342405496
##
File path:
flink-container/src/main/java/org/apache/flink/container/
flinkbot commented on issue #10082: [FLINK-14164][runtime] Add a meter
‘numberOfRestarts’ to show number of restarts as well as its rate
URL: https://github.com/apache/flink/pull/10082#issuecomment-549688949
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot.
[
https://issues.apache.org/jira/browse/FLINK-14164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-14164:
---
Labels: pull-request-available (was: )
> Add a metric to show failover count regarding fine
hequn8128 commented on a change in pull request #10017: [FLINK-14019][python]
add support for managing environment and dependencies of Python UDF in Flink
Python API
URL: https://github.com/apache/flink/pull/10017#discussion_r341950747
##
File path: flink-python/pyflink/common/depe
hequn8128 commented on a change in pull request #10017: [FLINK-14019][python]
add support for managing environment and dependencies of Python UDF in Flink
Python API
URL: https://github.com/apache/flink/pull/10017#discussion_r342395415
##
File path:
flink-python/src/main/java/org/
hequn8128 commented on a change in pull request #10017: [FLINK-14019][python]
add support for managing environment and dependencies of Python UDF in Flink
Python API
URL: https://github.com/apache/flink/pull/10017#discussion_r342050046
##
File path:
flink-python/src/main/java/org/
hequn8128 commented on a change in pull request #10017: [FLINK-14019][python]
add support for managing environment and dependencies of Python UDF in Flink
Python API
URL: https://github.com/apache/flink/pull/10017#discussion_r342403304
##
File path:
flink-python/src/main/java/org/
hequn8128 commented on a change in pull request #10017: [FLINK-14019][python]
add support for managing environment and dependencies of Python UDF in Flink
Python API
URL: https://github.com/apache/flink/pull/10017#discussion_r342010724
##
File path: flink-python/pyflink/common/test
hequn8128 commented on a change in pull request #10017: [FLINK-14019][python]
add support for managing environment and dependencies of Python UDF in Flink
Python API
URL: https://github.com/apache/flink/pull/10017#discussion_r342031800
##
File path: flink-python/pom.xml
##
hequn8128 commented on a change in pull request #10017: [FLINK-14019][python]
add support for managing environment and dependencies of Python UDF in Flink
Python API
URL: https://github.com/apache/flink/pull/10017#discussion_r342372266
##
File path:
flink-python/src/main/java/org/
hequn8128 commented on a change in pull request #10017: [FLINK-14019][python]
add support for managing environment and dependencies of Python UDF in Flink
Python API
URL: https://github.com/apache/flink/pull/10017#discussion_r341476050
##
File path:
flink-python/src/main/java/org/
hequn8128 commented on a change in pull request #10017: [FLINK-14019][python]
add support for managing environment and dependencies of Python UDF in Flink
Python API
URL: https://github.com/apache/flink/pull/10017#discussion_r342373918
##
File path:
flink-python/src/main/java/org/
hequn8128 commented on a change in pull request #10017: [FLINK-14019][python]
add support for managing environment and dependencies of Python UDF in Flink
Python API
URL: https://github.com/apache/flink/pull/10017#discussion_r342009003
##
File path: flink-python/pyflink/common/depe
zhuzhurk opened a new pull request #10082: [FLINK-14164][runtime] Add a meter
‘numberOfRestarts’ to show number of restarts as well as its rate
URL: https://github.com/apache/flink/pull/10082
## What is the purpose of the change
This PR is to add a meter ‘numberOfRestarts’ to sho
hequn8128 commented on a change in pull request #10017: [FLINK-14019][python]
add support for managing environment and dependencies of Python UDF in Flink
Python API
URL: https://github.com/apache/flink/pull/10017#discussion_r342354936
##
File path:
flink-python/src/main/java/org/
hequn8128 commented on a change in pull request #10017: [FLINK-14019][python]
add support for managing environment and dependencies of Python UDF in Flink
Python API
URL: https://github.com/apache/flink/pull/10017#discussion_r342049265
##
File path:
flink-python/src/main/java/org/
hequn8128 commented on a change in pull request #10017: [FLINK-14019][python]
add support for managing environment and dependencies of Python UDF in Flink
Python API
URL: https://github.com/apache/flink/pull/10017#discussion_r342365852
##
File path:
flink-python/src/main/java/org/
hequn8128 commented on a change in pull request #10017: [FLINK-14019][python]
add support for managing environment and dependencies of Python UDF in Flink
Python API
URL: https://github.com/apache/flink/pull/10017#discussion_r342009550
##
File path: flink-python/pyflink/common/depe
hequn8128 commented on a change in pull request #10017: [FLINK-14019][python]
add support for managing environment and dependencies of Python UDF in Flink
Python API
URL: https://github.com/apache/flink/pull/10017#discussion_r342368907
##
File path:
flink-python/src/main/java/org/
hequn8128 commented on a change in pull request #10017: [FLINK-14019][python]
add support for managing environment and dependencies of Python UDF in Flink
Python API
URL: https://github.com/apache/flink/pull/10017#discussion_r341476368
##
File path:
flink-python/src/main/java/org/
hequn8128 commented on a change in pull request #10017: [FLINK-14019][python]
add support for managing environment and dependencies of Python UDF in Flink
Python API
URL: https://github.com/apache/flink/pull/10017#discussion_r342395626
##
File path:
flink-python/src/main/java/org/
hequn8128 commented on a change in pull request #10017: [FLINK-14019][python]
add support for managing environment and dependencies of Python UDF in Flink
Python API
URL: https://github.com/apache/flink/pull/10017#discussion_r342377276
##
File path:
flink-python/src/main/java/org/
hequn8128 commented on a change in pull request #10017: [FLINK-14019][python]
add support for managing environment and dependencies of Python UDF in Flink
Python API
URL: https://github.com/apache/flink/pull/10017#discussion_r342351699
##
File path:
flink-python/src/main/java/org/
hequn8128 commented on a change in pull request #10017: [FLINK-14019][python]
add support for managing environment and dependencies of Python UDF in Flink
Python API
URL: https://github.com/apache/flink/pull/10017#discussion_r342006956
##
File path: flink-python/pyflink/common/depe
flinkbot edited a comment on issue #10081: [FLINK-14605][hive] Use Hive-1.1.0
as the profile to test against 1.1.x
URL: https://github.com/apache/flink/pull/10081#issuecomment-549666964
## CI report:
* c8a2505e137a9bdf9eadcc3c562b851285787965 : SUCCESS
[Build](https://travis-ci.
KurtYoung commented on a change in pull request #9864: [FLINK-14254][table]
Introduce FileSystemOutputFormat for batch
URL: https://github.com/apache/flink/pull/9864#discussion_r342396703
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/files
JingsongLi commented on a change in pull request #9864: [FLINK-14254][table]
Introduce FileSystemOutputFormat for batch
URL: https://github.com/apache/flink/pull/9864#discussion_r342394854
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/file
JingsongLi commented on a change in pull request #9864: [FLINK-14254][table]
Introduce FileSystemOutputFormat for batch
URL: https://github.com/apache/flink/pull/9864#discussion_r342394368
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/file
flinkbot edited a comment on issue #10060: [FLINK-14546] [flink-json] Support
map type in flink-json
URL: https://github.com/apache/flink/pull/10060#issuecomment-548313242
## CI report:
* c68dc12d24be4ef19efc1ef42246e6018c4f6e8d : SUCCESS
[Build](https://travis-ci.com/flink-ci/f
wuchong commented on a change in pull request #10039: [FLINK-14262][table]
Support referencing function with fully/partially qualified names in SQL
URL: https://github.com/apache/flink/pull/10039#discussion_r342376155
##
File path:
flink-table/flink-table-planner-blink/src/test/sc
wuchong commented on a change in pull request #10039: [FLINK-14262][table]
Support referencing function with fully/partially qualified names in SQL
URL: https://github.com/apache/flink/pull/10039#discussion_r342376155
##
File path:
flink-table/flink-table-planner-blink/src/test/sc
wuchong commented on a change in pull request #10039: [FLINK-14262][table]
Support referencing function with fully/partially qualified names in SQL
URL: https://github.com/apache/flink/pull/10039#discussion_r342375742
##
File path:
flink-table/flink-table-planner-blink/src/test/sc
wuchong commented on a change in pull request #10039: [FLINK-14262][table]
Support referencing function with fully/partially qualified names in SQL
URL: https://github.com/apache/flink/pull/10039#discussion_r342388213
##
File path:
flink-table/flink-table-planner-blink/src/main/sc
wuchong commented on a change in pull request #10039: [FLINK-14262][table]
Support referencing function with fully/partially qualified names in SQL
URL: https://github.com/apache/flink/pull/10039#discussion_r342393287
##
File path:
flink-table/flink-table-planner-blink/src/main/ja
wuchong commented on a change in pull request #10039: [FLINK-14262][table]
Support referencing function with fully/partially qualified names in SQL
URL: https://github.com/apache/flink/pull/10039#discussion_r342380567
##
File path:
flink-table/flink-table-planner-blink/src/main/ja
[
https://issues.apache.org/jira/browse/FLINK-14607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-14607:
Description:
Currently a pending request can only be fulfilled when a physical
slot({{AllocatedSlot}}) be
[
https://issues.apache.org/jira/browse/FLINK-14607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-14607:
Description:
Currently a pending request can only be fulfilled when a physical
slot({{AllocatedSlot}}) be
[
https://issues.apache.org/jira/browse/FLINK-14607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-14607:
Description:
Currently a pending request can only be fulfilled when a physical
slot({{AllocatedSlot}}) be
[
https://issues.apache.org/jira/browse/FLINK-14607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-14607:
Description:
Currently a pending request can only be fulfilled when a physical
slot({{AllocatedSlot}}) be
[
https://issues.apache.org/jira/browse/FLINK-14607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-14607:
Summary: SharedSlot cannot fulfill pending slot requests before it's
completely released (was: SharedSlot
Zhu Zhu created FLINK-14607:
---
Summary: SharedSlot cannot fulfill pending slot requests before
it's totally released
Key: FLINK-14607
URL: https://issues.apache.org/jira/browse/FLINK-14607
Project: Flink
flinkbot edited a comment on issue #10081: [FLINK-14605][hive] Use Hive-1.1.0
as the profile to test against 1.1.x
URL: https://github.com/apache/flink/pull/10081#issuecomment-549666964
## CI report:
* c8a2505e137a9bdf9eadcc3c562b851285787965 : PENDING
[Build](https://travis-ci.
Zhu Zhu created FLINK-14606:
---
Summary: Simplify params of Execution#processFail
Key: FLINK-14606
URL: https://issues.apache.org/jira/browse/FLINK-14606
Project: Flink
Issue Type: Sub-task
zhuzhurk commented on a change in pull request #10067: [FLINK-14375][runtime]
Avoid to notify scheduler about fake or outdated state update
URL: https://github.com/apache/flink/pull/10067#discussion_r342386939
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/execu
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
flinkbot commented on issue #10081: [FLINK-14605][hive] Use Hive-1.1.0 as the
profile to test against 1.1.x
URL: https://github.com/apache/flink/pull/10081#issuecomment-549666964
## CI report:
* c8a2505e137a9bdf9eadcc3c562b851285787965 : UNKNOWN
Bot commands
The @
flinkbot edited a comment on issue #10060: [FLINK-14546] [flink-json] Support
map type in flink-json
URL: https://github.com/apache/flink/pull/10060#issuecomment-548313242
## CI report:
* c68dc12d24be4ef19efc1ef42246e6018c4f6e8d : SUCCESS
[Build](https://travis-ci.com/flink-ci/f
[
https://issues.apache.org/jira/browse/FLINK-14604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei Zhong updated FLINK-14604:
--
Issue Type: Task (was: Improvement)
> Bump commons-cli to 1.4
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-12675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16967243#comment-16967243
]
Jiayi Liao commented on FLINK-12675:
[~thw] Since the FLIP-27 design will be updated
flinkbot edited a comment on issue #10067: [FLINK-14375][runtime] Avoid to
notify scheduler about fake or outdated state update
URL: https://github.com/apache/flink/pull/10067#issuecomment-548812084
## CI report:
* d3341d9f0bff2cb97bd0b5bf507725ae6d670b88 : SUCCESS
[Build](https
flinkbot edited a comment on issue #10071: [FLINK-14371][runtime, tests] Enable
ClassLoaderITCase/WindowCheckpointingITCase/EventTimeWindowCheckpointingITCase
for NG scheduling
URL: https://github.com/apache/flink/pull/10071#issuecomment-549017258
## CI report:
* 80b38a072f3c5a4
flinkbot edited a comment on issue #10060: [FLINK-14546] [flink-json] Support
map type in flink-json
URL: https://github.com/apache/flink/pull/10060#issuecomment-548313242
## CI report:
* c68dc12d24be4ef19efc1ef42246e6018c4f6e8d : SUCCESS
[Build](https://travis-ci.com/flink-ci/f
flinkbot edited a comment on issue #10042: [FLINK-11466][e2e] Design the e2e
java framework so that the Kafka streaming tests and Kafka SQL tests can
running on it
URL: https://github.com/apache/flink/pull/10042#issuecomment-547792578
## CI report:
* b523eace793d9168a2816e50891d
flinkbot commented on issue #10081: [FLINK-14605][hive] Use Hive-1.1.0 as the
profile to test against 1.1.x
URL: https://github.com/apache/flink/pull/10081#issuecomment-549661353
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to r
walterddr 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_r342379204
##
File path:
flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/uti
walterddr 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_r342379344
##
File path:
flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/uti
lirui-apache commented on issue #10081: [FLINK-14605][hive] Use Hive-1.1.0 as
the profile to test against 1.1.x
URL: https://github.com/apache/flink/pull/10081#issuecomment-549660903
cc @bowenli86 @xuefuz @zjuwangg
This is a
[
https://issues.apache.org/jira/browse/FLINK-14605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-14605:
---
Labels: pull-request-available (was: )
> Use Hive-1.1.0 as the profile to test against 1.1.
walterddr 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_r342377733
##
File path:
flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/uti
lirui-apache opened a new pull request #10081: [FLINK-14605][hive] Use
Hive-1.1.0 as the profile to test against 1.1.x
URL: https://github.com/apache/flink/pull/10081
## What is the purpose of the change
Test against Hive-1.1.0.
## Brief change log
- Changed t
libenchao commented on a change in pull request #10060: [FLINK-14546]
[flink-json] Support map type in flink-json
URL: https://github.com/apache/flink/pull/10060#discussion_r342379414
##
File path:
flink-formats/flink-json/src/test/java/org/apache/flink/formats/json/JsonRowDeserial
Rui Li created FLINK-14605:
--
Summary: Use Hive-1.1.0 as the profile to test against 1.1.x
Key: FLINK-14605
URL: https://issues.apache.org/jira/browse/FLINK-14605
Project: Flink
Issue Type: Test
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
Wei Zhong created FLINK-14604:
-
Summary: Bump commons-cli to 1.4
Key: FLINK-14604
URL: https://issues.apache.org/jira/browse/FLINK-14604
Project: Flink
Issue Type: Improvement
Component
flinkbot edited a comment on issue #10060: [FLINK-14546] [flink-json] Support
map type in flink-json
URL: https://github.com/apache/flink/pull/10060#issuecomment-548313242
## CI report:
* c68dc12d24be4ef19efc1ef42246e6018c4f6e8d : SUCCESS
[Build](https://travis-ci.com/flink-ci/f
flinkbot edited a comment on issue #10059: [FLINK-14543][table] Support
partition for temporary table
URL: https://github.com/apache/flink/pull/10059#issuecomment-548289939
## CI report:
* 4937b8b139bab4957799947b841fb1ae3758ed48 : FAILURE
[Build](https://travis-ci.com/flink-ci/
walterddr commented on a change in pull request #9373: [FLINK-13596][ml] Add
two utils for Table transformations
URL: https://github.com/apache/flink/pull/9373#discussion_r342376557
##
File path:
flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/utils/DataSetCon
walterddr commented on a change in pull request #9373: [FLINK-13596][ml] Add
two utils for Table transformations
URL: https://github.com/apache/flink/pull/9373#discussion_r342375237
##
File path:
flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/utils/DataSetCon
walterddr commented on a change in pull request #9373: [FLINK-13596][ml] Add
two utils for Table transformations
URL: https://github.com/apache/flink/pull/9373#discussion_r342376183
##
File path:
flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/utils/DataSetCon
walterddr commented on a change in pull request #9373: [FLINK-13596][ml] Add
two utils for Table transformations
URL: https://github.com/apache/flink/pull/9373#discussion_r342374624
##
File path:
flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/utils/DataSetCon
walterddr commented on a change in pull request #9373: [FLINK-13596][ml] Add
two utils for Table transformations
URL: https://github.com/apache/flink/pull/9373#discussion_r342375974
##
File path:
flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/utils/DataSetCon
openinx commented on issue #10042: [FLINK-11466][e2e] Design the e2e java
framework so that the Kafka streaming tests and Kafka SQL tests can running on
it
URL: https://github.com/apache/flink/pull/10042#issuecomment-549655452
Ping @tillrohrmann @zentol for reviewing ..
--
[
https://issues.apache.org/jira/browse/FLINK-14572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16967225#comment-16967225
]
Zhu Zhu commented on FLINK-14572:
-
>From the root cause, the case fails when trying to g
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
flinkbot edited a comment on issue #10042: [FLINK-11466][e2e] Design the e2e
java framework so that the Kafka streaming tests and Kafka SQL tests can
running on it
URL: https://github.com/apache/flink/pull/10042#issuecomment-547792578
## CI report:
* b523eace793d9168a2816e50891d
[
https://issues.apache.org/jira/browse/FLINK-14591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16967212#comment-16967212
]
Jark Wu commented on FLINK-14591:
-
Hi [~Dillon.], I'm not sure the fixing approach yet.
flinkbot edited a comment on issue #10080: [FLINK-14600] Degenerate the current
AtomicInteger type of verticesFinished to a normal int type
URL: https://github.com/apache/flink/pull/10080#issuecomment-549633254
## CI report:
* d854a07f002bd43cab524acb03e4dbd918869827 : SUCCESS
[
flinkbot edited a comment on issue #10071: [FLINK-14371][runtime, tests] Enable
ClassLoaderITCase/WindowCheckpointingITCase/EventTimeWindowCheckpointingITCase
for NG scheduling
URL: https://github.com/apache/flink/pull/10071#issuecomment-549017258
## CI report:
* 80b38a072f3c5a4
flinkbot edited a comment on issue #10067: [FLINK-14375][runtime] Avoid to
notify scheduler about fake or outdated state update
URL: https://github.com/apache/flink/pull/10067#issuecomment-548812084
## CI report:
* d3341d9f0bff2cb97bd0b5bf507725ae6d670b88 : SUCCESS
[Build](https
flinkbot edited a comment on issue #10060: [FLINK-14546] [flink-json] Support
map type in flink-json
URL: https://github.com/apache/flink/pull/10060#issuecomment-548313242
## CI report:
* c68dc12d24be4ef19efc1ef42246e6018c4f6e8d : SUCCESS
[Build](https://travis-ci.com/flink-ci/f
flinkbot edited a comment on issue #10042: [FLINK-11466][e2e] Design the e2e
java framework so that the Kafka streaming tests and Kafka SQL tests can
running on it
URL: https://github.com/apache/flink/pull/10042#issuecomment-547792578
## CI report:
* b523eace793d9168a2816e50891d
flinkbot edited a comment on issue #10059: [FLINK-14543][table] Support
partition for temporary table
URL: https://github.com/apache/flink/pull/10059#issuecomment-548289939
## CI report:
* 4937b8b139bab4957799947b841fb1ae3758ed48 : FAILURE
[Build](https://travis-ci.com/flink-ci/
[
https://issues.apache.org/jira/browse/FLINK-14591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16967203#comment-16967203
]
Zhanchun Zhang commented on FLINK-14591:
Hi [~zhongwei][~jark], I'm willing to f
1 - 100 of 391 matches
Mail list logo
