[
https://issues.apache.org/jira/browse/FLINK-16227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17056698#comment-17056698
]
Zhijiang commented on FLINK-16227:
--
Another instance
[https://dev.azure.com/rmetzger/5
flinkbot edited a comment on issue #11369: [FLINK-16205][sql] Support
JSON_OBJECTAGG for blink planner
URL: https://github.com/apache/flink/pull/11369#issuecomment-597138709
## CI report:
* 213a1bfefe610c5cacfec61828b2d9a6bb76833b Travis:
[PENDING](https://travis-ci.com/flink-ci
flinkbot edited a comment on issue #11317: [FLINK-16433][table-api]
TableEnvironmentImpl doesn't clear…
URL: https://github.com/apache/flink/pull/11317#issuecomment-595145709
## CI report:
* 9c6d3fcae177e05bba552a967d0cf75587412693 Travis:
[CANCELED](https://travis-ci.com/flink-
flinkbot edited a comment on issue #10687: [FLINK-15364] Introduce streaming
task using heap backend e2e tests for Mesos
URL: https://github.com/apache/flink/pull/10687#issuecomment-568881372
## CI report:
* d7a4237329fccbd820c01c7688df5a5822409d42 Travis:
[SUCCESS](https://trav
lirui-apache commented on issue #11317: [FLINK-16433][table-api]
TableEnvironmentImpl doesn't clear…
URL: https://github.com/apache/flink/pull/11317#issuecomment-597468940
Thanks @godfreyhe and @JingsongLi for your review. PR updated accordingly.
---
[
https://issues.apache.org/jira/browse/FLINK-14807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17056695#comment-17056695
]
Caizhi Weng commented on FLINK-14807:
-
Hi dear Flink community.
After a long offlin
becketqin commented on a change in pull request #11344:
[FLINK-16250][python][ml] Add interfaces for PipelineStage and Pipeline
URL: https://github.com/apache/flink/pull/11344#discussion_r390733535
##
File path: flink-python/pyflink/ml/tests/test_pipeline_it_case.py
##
@@
becketqin commented on a change in pull request #11344:
[FLINK-16250][python][ml] Add interfaces for PipelineStage and Pipeline
URL: https://github.com/apache/flink/pull/11344#discussion_r390732188
##
File path: flink-python/pyflink/ml/api/base.py
##
@@ -0,0 +1,275 @@
+###
KarmaGYZ commented on issue #10687: [FLINK-15364] Introduce streaming task
using heap backend e2e tests for Mesos
URL: https://github.com/apache/flink/pull/10687#issuecomment-597461571
@GJL Would you like to take a look?
This
[
https://issues.apache.org/jira/browse/FLINK-1640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17056678#comment-17056678
]
Rui Li commented on FLINK-1640:
---
Hi [~fhueske], I noticed in this PR we trim trailing white
flinkbot edited a comment on issue #11369: [FLINK-16205][sql] Support
JSON_OBJECTAGG for blink planner
URL: https://github.com/apache/flink/pull/11369#issuecomment-597138709
## CI report:
* 213a1bfefe610c5cacfec61828b2d9a6bb76833b Travis:
[PENDING](https://travis-ci.com/flink-ci
Zhijiang created FLINK-16537:
Summary: Implement ResultPartition state recovery for unaligned
checkpoint
Key: FLINK-16537
URL: https://issues.apache.org/jira/browse/FLINK-16537
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-16536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-16536:
-
Description:
During recovery process for unaligned checkpoint, the input channel state
should also be r
flinkbot edited a comment on issue #11358: [FLINK-16516][python] Remove Python
UDF Codegen Code
URL: https://github.com/apache/flink/pull/11358#issuecomment-596885127
## CI report:
* beba9d15aaf629de9e09aa8885cdcc844a96ad30 Travis:
[SUCCESS](https://travis-ci.com/github/flink-ci
[
https://issues.apache.org/jira/browse/FLINK-16536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-16536:
-
Description:
During recovery process for unaligned checkpoint, the input channel state
should also be r
Zhijiang created FLINK-16536:
Summary: Implement InputChannel state recovery for unaligned
checkpoint
Key: FLINK-16536
URL: https://issues.apache.org/jira/browse/FLINK-16536
Project: Flink
Issue
KarmaGYZ commented on a change in pull request #11353: [FLINK-16438][yarn] Make
YarnResourceManager starts workers using WorkerResourceSpec requested by
SlotManager
URL: https://github.com/apache/flink/pull/11353#discussion_r390751400
##
File path:
flink-yarn/src/test/java/org/apa
flinkbot edited a comment on issue #7368: [FLINK-10742][network] Let Netty use
Flink's buffers directly in credit-based mode
URL: https://github.com/apache/flink/pull/7368#issuecomment-567435407
## CI report:
* 4d17b4de75015fade25228f8fa6668f0cf0d9dca UNKNOWN
* ce48c4289d1f953
[
https://issues.apache.org/jira/browse/FLINK-16477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17056642#comment-17056642
]
Zhijiang edited comment on FLINK-16477 at 3/11/20, 5:13 AM:
[
https://issues.apache.org/jira/browse/FLINK-16534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17056650#comment-17056650
]
Yu Li commented on FLINK-16534:
---
The requirement stems from this user-zh ML discussion:
h
godfrey he created FLINK-16535:
--
Summary: BatchTableSink#emitDataSet returns DataSink
Key: FLINK-16535
URL: https://issues.apache.org/jira/browse/FLINK-16535
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-16533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-16533:
---
Summary: ExecutionEnvironment supports execution of existing plan (was:
ExecutionEnvironment suppor
[
https://issues.apache.org/jira/browse/FLINK-16533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-16533:
---
Description:
Currently, {{ExecutionEnvironment}} only supports executing the plan generated
by self
Kurt Young created FLINK-16534:
--
Summary: Support specify savepoint path when submitting sql job
through sql client
Key: FLINK-16534
URL: https://issues.apache.org/jira/browse/FLINK-16534
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-16533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-16533:
---
Summary: ExecutionEnvironment supports executing plan (was:
ExecutionEnvironment supports executing
[
https://issues.apache.org/jira/browse/FLINK-16533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-16533:
---
Summary: ExecutionEnvironment supports executing existing plan (was:
ExecutionEnvironment supports
godfrey he created FLINK-16533:
--
Summary: ExecutionEnvironment supports executing plan
Key: FLINK-16533
URL: https://issues.apache.org/jira/browse/FLINK-16533
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-16477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17056642#comment-17056642
]
Zhijiang commented on FLINK-16477:
--
Another instance [https://api.travis-ci.org/v3/job/
xintongsong commented on a change in pull request #11353: [FLINK-16438][yarn]
Make YarnResourceManager starts workers using WorkerResourceSpec requested by
SlotManager
URL: https://github.com/apache/flink/pull/11353#discussion_r390742962
##
File path:
flink-yarn/src/test/java/org/
xintongsong commented on a change in pull request #11353: [FLINK-16438][yarn]
Make YarnResourceManager starts workers using WorkerResourceSpec requested by
SlotManager
URL: https://github.com/apache/flink/pull/11353#discussion_r390741693
##
File path:
flink-yarn/src/main/java/org/
xintongsong commented on a change in pull request #11353: [FLINK-16438][yarn]
Make YarnResourceManager starts workers using WorkerResourceSpec requested by
SlotManager
URL: https://github.com/apache/flink/pull/11353#discussion_r390740551
##
File path:
flink-yarn/src/main/java/org/
xintongsong commented on a change in pull request #11353: [FLINK-16438][yarn]
Make YarnResourceManager starts workers using WorkerResourceSpec requested by
SlotManager
URL: https://github.com/apache/flink/pull/11353#discussion_r390740551
##
File path:
flink-yarn/src/main/java/org/
[
https://issues.apache.org/jira/browse/FLINK-16512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang closed FLINK-16512.
Resolution: Fixed
Merged in master: 1ad361b787ad2929b334a72e7f5be944f4fe27af
> Add API to persist channel
flinkbot edited a comment on issue #7368: [FLINK-10742][network] Let Netty use
Flink's buffers directly in credit-based mode
URL: https://github.com/apache/flink/pull/7368#issuecomment-567435407
## CI report:
* 4d17b4de75015fade25228f8fa6668f0cf0d9dca UNKNOWN
* ce48c4289d1f953
zhijiangW merged pull request #11354: [FLINK-16512][task] Unaligned
checkpoints: API for persistence
URL: https://github.com/apache/flink/pull/11354
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-16512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-16512:
---
Labels: pull-request-available (was: )
> Add API to persist channel state
> ---
xintongsong commented on a change in pull request #11353: [FLINK-16438][yarn]
Make YarnResourceManager starts workers using WorkerResourceSpec requested by
SlotManager
URL: https://github.com/apache/flink/pull/11353#discussion_r390738660
##
File path:
flink-yarn/src/test/java/org/
walterddr commented on a change in pull request #11189:
[FLINK-16236][yarn][hotfix] fix Yarn secure test not loading correct context
factory
URL: https://github.com/apache/flink/pull/11189#discussion_r390735933
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/sec
flinkbot edited a comment on issue #7368: [FLINK-10742][network] Let Netty use
Flink's buffers directly in credit-based mode
URL: https://github.com/apache/flink/pull/7368#issuecomment-567435407
## CI report:
* 4d17b4de75015fade25228f8fa6668f0cf0d9dca UNKNOWN
* ce48c4289d1f953
[
https://issues.apache.org/jira/browse/FLINK-16530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-16530:
---
Assignee: Jark Wu
> Add documentation about "GROUPING SETS" and "CUBE" support in streaming mode
>
walterddr commented on a change in pull request #7702:
[FLINK-11088][Security][YARN] Allow YARN to discover pre-installed keytab files
URL: https://github.com/apache/flink/pull/7702#discussion_r390733239
##
File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnConfigKeys.jav
walterddr commented on a change in pull request #7702:
[FLINK-11088][Security][YARN] Allow YARN to discover pre-installed keytab files
URL: https://github.com/apache/flink/pull/7702#discussion_r390733239
##
File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnConfigKeys.jav
walterddr commented on a change in pull request #7702:
[FLINK-11088][Security][YARN] Allow YARN to discover pre-installed keytab files
URL: https://github.com/apache/flink/pull/7702#discussion_r39071
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescri
walterddr commented on a change in pull request #7702:
[FLINK-11088][Security][YARN] Allow YARN to discover pre-installed keytab files
URL: https://github.com/apache/flink/pull/7702#discussion_r390733381
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescri
walterddr commented on a change in pull request #7702:
[FLINK-11088][Security][YARN] Allow YARN to discover pre-installed keytab files
URL: https://github.com/apache/flink/pull/7702#discussion_r390732821
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/entrypoint/YarnEn
walterddr commented on a change in pull request #7702:
[FLINK-11088][Security][YARN] Allow YARN to discover pre-installed keytab files
URL: https://github.com/apache/flink/pull/7702#discussion_r390733373
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescri
walterddr commented on a change in pull request #7702:
[FLINK-11088][Security][YARN] Allow YARN to discover pre-installed keytab files
URL: https://github.com/apache/flink/pull/7702#discussion_r390733239
##
File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnConfigKeys.jav
flinkbot edited a comment on issue #11358: [FLINK-16516][python] Remove Python
UDF Codegen Code
URL: https://github.com/apache/flink/pull/11358#issuecomment-596885127
## CI report:
* beba9d15aaf629de9e09aa8885cdcc844a96ad30 Travis:
[SUCCESS](https://travis-ci.com/github/flink-ci
[
https://issues.apache.org/jira/browse/FLINK-16532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Li updated FLINK-16532:
---
Description:
The following test fails:
{code}
create table dest (x int) partitioned by (p string);
insert in
flinkbot edited a comment on issue #7368: [FLINK-10742][network] Let Netty use
Flink's buffers directly in credit-based mode
URL: https://github.com/apache/flink/pull/7368#issuecomment-567435407
## CI report:
* 4d17b4de75015fade25228f8fa6668f0cf0d9dca UNKNOWN
* ce48c4289d1f953
Rui Li created FLINK-16532:
--
Summary: Cannot insert white space characters as partition value
for Hive table
Key: FLINK-16532
URL: https://issues.apache.org/jira/browse/FLINK-16532
Project: Flink
I
[
https://issues.apache.org/jira/browse/FLINK-16523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luojiangyu closed FLINK-16523.
--
Resolution: Fixed
> The improvement for local state of rocksdb backend.
>
walterddr commented on a change in pull request #11344:
[FLINK-16250][python][ml] Add interfaces for PipelineStage and Pipeline
URL: https://github.com/apache/flink/pull/11344#discussion_r390727205
##
File path:
flink-ml-parent/flink-ml-lib/src/test/java/org/apache/flink/ml/pipelin
walterddr commented on a change in pull request #11344:
[FLINK-16250][python][ml] Add interfaces for PipelineStage and Pipeline
URL: https://github.com/apache/flink/pull/11344#discussion_r390729953
##
File path: flink-python/pyflink/ml/api/base.py
##
@@ -0,0 +1,275 @@
+###
KarmaGYZ commented on a change in pull request #11353: [FLINK-16438][yarn] Make
YarnResourceManager starts workers using WorkerResourceSpec requested by
SlotManager
URL: https://github.com/apache/flink/pull/11353#discussion_r390730646
##
File path:
flink-yarn/src/test/java/org/apa
godfreyhe commented on issue #11296: [FLINK-16363] [table] Correct the
execution behavior of TableEnvironment and StreamTableEnvironment
URL: https://github.com/apache/flink/pull/11296#issuecomment-597429594
@hequn8128 @dianfu could you help review the python test change part ?
---
KarmaGYZ commented on a change in pull request #11353: [FLINK-16438][yarn] Make
YarnResourceManager starts workers using WorkerResourceSpec requested by
SlotManager
URL: https://github.com/apache/flink/pull/11353#discussion_r390711414
##
File path:
flink-yarn/src/test/java/org/apa
KarmaGYZ commented on a change in pull request #11353: [FLINK-16438][yarn] Make
YarnResourceManager starts workers using WorkerResourceSpec requested by
SlotManager
URL: https://github.com/apache/flink/pull/11353#discussion_r390722307
##
File path:
flink-yarn/src/main/java/org/apa
KarmaGYZ commented on a change in pull request #11353: [FLINK-16438][yarn] Make
YarnResourceManager starts workers using WorkerResourceSpec requested by
SlotManager
URL: https://github.com/apache/flink/pull/11353#discussion_r390715114
##
File path:
flink-yarn/src/main/java/org/apa
walterddr commented on a change in pull request #11344:
[FLINK-16250][python][ml] Add interfaces for PipelineStage and Pipeline
URL: https://github.com/apache/flink/pull/11344#discussion_r390727653
##
File path: flink-python/pyflink/ml/api/base.py
##
@@ -0,0 +1,275 @@
+###
tzulitai commented on issue #54: [FLINK-16515][docs] Refactor statefun
documentation for multi-language SDKs
URL: https://github.com/apache/flink-statefun/pull/54#issuecomment-597429233
> I've also noticed that the ingresses/egress structures are not here, maybe
@tzulitai can help here.
jinglining commented on a change in pull request #11250: [FLINK-16302][rest]add
log list and read log by name for taskmanager
URL: https://github.com/apache/flink/pull/11250#discussion_r390286564
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskEx
Jark Wu created FLINK-16531:
---
Summary: Add full integration tests for "GROUPING SETS" for
streaming mode
Key: FLINK-16531
URL: https://issues.apache.org/jira/browse/FLINK-16531
Project: Flink
Issu
[
https://issues.apache.org/jira/browse/FLINK-16530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-16530:
Description:
"GROUPING SETS" and "CUBE" are already supported in streaming mode in blink
planner, but we
[
https://issues.apache.org/jira/browse/FLINK-16530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-16530:
Description:
"GROUPING SETS" and "CUBE" are already supported in streaming mode, but we
missed to add tha
Jark Wu created FLINK-16530:
---
Summary: Add documentation about "GROUPING SETS" and "CUBE"
support in streaming mode
Key: FLINK-16530
URL: https://issues.apache.org/jira/browse/FLINK-16530
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-16526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17056608#comment-17056608
]
Danny Chen commented on FLINK-16526:
Thanks, [~liuyufei], you should try
{code:sql}
Jark Wu created FLINK-16529:
---
Summary: Add ignore_parse_errors() method to Json format in python
API
Key: FLINK-16529
URL: https://issues.apache.org/jira/browse/FLINK-16529
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-16529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-16529:
Component/s: Table SQL / Ecosystem
> Add ignore_parse_errors() method to Json format in python API
> -
[
https://issues.apache.org/jira/browse/FLINK-15396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu resolved FLINK-15396.
-
Fix Version/s: 1.11.0
Resolution: Fixed
Resolved in master (1.11.0): 87ebe5533d3cd675b416146189ab
gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network]
Let Netty use Flink's buffers directly in credit-based mode
URL: https://github.com/apache/flink/pull/7368#discussion_r390719053
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/io/netw
flinkbot edited a comment on issue #11358: [FLINK-16516][python] Remove Python
UDF Codegen Code
URL: https://github.com/apache/flink/pull/11358#issuecomment-596885127
## CI report:
* cf3f3aac4aa052f71bd4954fd55b48c84350edf6 Travis:
[SUCCESS](https://travis-ci.com/flink-ci/flink/
gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network]
Let Netty use Flink's buffers directly in credit-based mode
URL: https://github.com/apache/flink/pull/7368#discussion_r390717265
##
File path:
flink-end-to-end-tests/test-scripts/test_taskmanager_direct_
tzulitai edited a comment on issue #54: [FLINK-16515][docs] Refactor statefun
documentation for multi-language SDKs
URL: https://github.com/apache/flink-statefun/pull/54#issuecomment-597414511
One last thing:
