[jira] [Created] (FLINK-16537) Implement ResultPartition state recovery for unaligned checkpoint

2020-03-10 Thread Zhijiang (Jira)
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

[GitHub] [flink] flinkbot edited a comment on issue #11358: [FLINK-16516][python] Remove Python UDF Codegen Code

2020-03-10 Thread GitBox
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:

[jira] [Updated] (FLINK-16536) Implement InputChannel state recovery for unaligned checkpoint

2020-03-10 Thread Zhijiang (Jira)
[ 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

[jira] [Updated] (FLINK-16536) Implement InputChannel state recovery for unaligned checkpoint

2020-03-10 Thread Zhijiang (Jira)
[ 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

[jira] [Created] (FLINK-16536) Implement InputChannel state recovery for unaligned checkpoint

2020-03-10 Thread Zhijiang (Jira)
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

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager

2020-03-10 Thread GitBox
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:

[GitHub] [flink] flinkbot edited a comment on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-03-10 Thread GitBox
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 *

[jira] [Comment Edited] (FLINK-16477) CorrelateTest.testCorrelatePythonTableFunction test fails

2020-03-10 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17056642#comment-17056642 ] Zhijiang edited comment on FLINK-16477 at 3/11/20, 5:13 AM: Another instance 

[jira] [Commented] (FLINK-16534) Support specify savepoint path when submitting sql job through sql client

2020-03-10 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17056650#comment-17056650 ] Yu Li commented on FLINK-16534: --- The requirement stems from this user-zh ML discussion:

[jira] [Created] (FLINK-16535) BatchTableSink#emitDataSet returns DataSink

2020-03-10 Thread godfrey he (Jira)
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

[jira] [Updated] (FLINK-16533) ExecutionEnvironment supports execution of existing plan

2020-03-10 Thread godfrey he (Jira)
[ 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

[jira] [Updated] (FLINK-16533) ExecutionEnvironment supports executing plan

2020-03-10 Thread godfrey he (Jira)
[ 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

[jira] [Created] (FLINK-16534) Support specify savepoint path when submitting sql job through sql client

2020-03-10 Thread Kurt Young (Jira)
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

[jira] [Updated] (FLINK-16533) ExecutionEnvironment supports executing plan

2020-03-10 Thread godfrey he (Jira)
[ 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

[jira] [Updated] (FLINK-16533) ExecutionEnvironment supports executing existing plan

2020-03-10 Thread godfrey he (Jira)
[ 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

[jira] [Created] (FLINK-16533) ExecutionEnvironment supports executing plan

2020-03-10 Thread godfrey he (Jira)
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:

[jira] [Commented] (FLINK-16477) CorrelateTest.testCorrelatePythonTableFunction test fails

2020-03-10 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17056642#comment-17056642 ] Zhijiang commented on FLINK-16477: -- Another instance 

[GitHub] [flink] xintongsong commented on a change in pull request #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager

2020-03-10 Thread GitBox
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:

[GitHub] [flink] xintongsong commented on a change in pull request #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager

2020-03-10 Thread GitBox
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:

[GitHub] [flink] xintongsong commented on a change in pull request #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager

2020-03-10 Thread GitBox
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:

[GitHub] [flink] xintongsong commented on a change in pull request #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager

2020-03-10 Thread GitBox
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:

[jira] [Closed] (FLINK-16512) Add API to persist channel state

2020-03-10 Thread Zhijiang (Jira)
[ 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

[GitHub] [flink] flinkbot edited a comment on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-03-10 Thread GitBox
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 *

[GitHub] [flink] zhijiangW merged pull request #11354: [FLINK-16512][task] Unaligned checkpoints: API for persistence

2020-03-10 Thread GitBox
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

[jira] [Updated] (FLINK-16512) Add API to persist channel state

2020-03-10 Thread ASF GitHub Bot (Jira)
[ 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 >

[GitHub] [flink] xintongsong commented on a change in pull request #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager

2020-03-10 Thread GitBox
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:

[GitHub] [flink] walterddr commented on a change in pull request #11189: [FLINK-16236][yarn][hotfix] fix Yarn secure test not loading correct context factory

2020-03-10 Thread GitBox
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:

[GitHub] [flink] flinkbot edited a comment on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-03-10 Thread GitBox
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 *

[jira] [Assigned] (FLINK-16530) Add documentation about "GROUPING SETS" and "CUBE" support in streaming mode

2020-03-10 Thread Jark Wu (Jira)
[ 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 >

[GitHub] [flink] walterddr commented on a change in pull request #7702: [FLINK-11088][Security][YARN] Allow YARN to discover pre-installed keytab files

2020-03-10 Thread GitBox
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:

[GitHub] [flink] walterddr commented on a change in pull request #7702: [FLINK-11088][Security][YARN] Allow YARN to discover pre-installed keytab files

2020-03-10 Thread GitBox
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:

[GitHub] [flink] walterddr commented on a change in pull request #7702: [FLINK-11088][Security][YARN] Allow YARN to discover pre-installed keytab files

2020-03-10 Thread GitBox
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:

[GitHub] [flink] walterddr commented on a change in pull request #7702: [FLINK-11088][Security][YARN] Allow YARN to discover pre-installed keytab files

2020-03-10 Thread GitBox
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:

[GitHub] [flink] walterddr commented on a change in pull request #7702: [FLINK-11088][Security][YARN] Allow YARN to discover pre-installed keytab files

2020-03-10 Thread GitBox
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:

[GitHub] [flink] walterddr commented on a change in pull request #7702: [FLINK-11088][Security][YARN] Allow YARN to discover pre-installed keytab files

2020-03-10 Thread GitBox
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:

[GitHub] [flink] walterddr commented on a change in pull request #7702: [FLINK-11088][Security][YARN] Allow YARN to discover pre-installed keytab files

2020-03-10 Thread GitBox
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:

[GitHub] [flink] flinkbot edited a comment on issue #11358: [FLINK-16516][python] Remove Python UDF Codegen Code

2020-03-10 Thread GitBox
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:

[GitHub] [flink] flinkbot edited a comment on issue #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-03-10 Thread GitBox
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 *

[jira] [Updated] (FLINK-16532) Cannot insert white space characters as partition value for Hive table

2020-03-10 Thread Rui Li (Jira)
[ 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

[jira] [Created] (FLINK-16532) Cannot insert white space characters as partition value for Hive table

2020-03-10 Thread Rui Li (Jira)
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

[jira] [Closed] (FLINK-16523) The improvement for local state of rocksdb backend.

2020-03-10 Thread luojiangyu (Jira)
[ 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. >

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager

2020-03-10 Thread GitBox
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:

[GitHub] [flink] walterddr commented on a change in pull request #11344: [FLINK-16250][python][ml] Add interfaces for PipelineStage and Pipeline

2020-03-10 Thread GitBox
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:

[GitHub] [flink] walterddr commented on a change in pull request #11344: [FLINK-16250][python][ml] Add interfaces for PipelineStage and Pipeline

2020-03-10 Thread GitBox
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 @@

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager

2020-03-10 Thread GitBox
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:

[GitHub] [flink] walterddr commented on a change in pull request #11344: [FLINK-16250][python][ml] Add interfaces for PipelineStage and Pipeline

2020-03-10 Thread GitBox
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 @@

[GitHub] [flink] godfreyhe commented on issue #11296: [FLINK-16363] [table] Correct the execution behavior of TableEnvironment and StreamTableEnvironment

2020-03-10 Thread GitBox
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 ?

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager

2020-03-10 Thread GitBox
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:

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager

2020-03-10 Thread GitBox
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:

[GitHub] [flink-statefun] tzulitai commented on issue #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs

2020-03-10 Thread GitBox
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.

[GitHub] [flink] jinglining commented on a change in pull request #11250: [FLINK-16302][rest]add log list and read log by name for taskmanager

2020-03-10 Thread GitBox
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:

[jira] [Created] (FLINK-16531) Add full integration tests for "GROUPING SETS" for streaming mode

2020-03-10 Thread Jark Wu (Jira)
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

[jira] [Updated] (FLINK-16530) Add documentation about "GROUPING SETS" and "CUBE" support in streaming mode

2020-03-10 Thread Jark Wu (Jira)
[ 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

[jira] [Updated] (FLINK-16530) Add documentation about "GROUPING SETS" and "CUBE" support in streaming mode

2020-03-10 Thread Jark Wu (Jira)
[ 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

[jira] [Created] (FLINK-16530) Add documentation about "GROUPING SETS" and "CUBE" support in streaming mode

2020-03-10 Thread Jark Wu (Jira)
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

[jira] [Commented] (FLINK-16526) Escape character doesn't work for computed column

2020-03-10 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17056608#comment-17056608 ] Danny Chen commented on FLINK-16526: Thanks, [~liuyufei], you should try {code:sql} `timestamp`

[jira] [Created] (FLINK-16529) Add ignore_parse_errors() method to Json format in python API

2020-03-10 Thread Jark Wu (Jira)
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

[jira] [Updated] (FLINK-16529) Add ignore_parse_errors() method to Json format in python API

2020-03-10 Thread Jark Wu (Jira)
[ 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 >

[jira] [Resolved] (FLINK-15396) Support to ignore parse errors for JSON format

2020-03-10 Thread Jark Wu (Jira)
[ 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):

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-03-10 Thread GitBox
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:

[GitHub] [flink] flinkbot edited a comment on issue #11358: [FLINK-16516][python] Remove Python UDF Codegen Code

2020-03-10 Thread GitBox
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:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-03-10 Thread GitBox
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:

[GitHub] [flink-statefun] tzulitai edited a comment on issue #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs

2020-03-10 Thread GitBox
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:

[GitHub] [flink-statefun] tzulitai edited a comment on issue #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs

2020-03-10 Thread GitBox
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:

[GitHub] [flink] wuchong closed pull request #11119: [FLINK-15396][json] Support to ignore parse errors for JSON format

2020-03-10 Thread GitBox
wuchong closed pull request #9: [FLINK-15396][json] Support to ignore parse errors for JSON format URL: https://github.com/apache/flink/pull/9 This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink-statefun] tzulitai commented on issue #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs

2020-03-10 Thread GitBox
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-597414511 One last thing:

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs

2020-03-10 Thread GitBox
tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs URL: https://github.com/apache/flink-statefun/pull/54#discussion_r390706590 ## File path: statefun-docs/docs/concepts/index.rst ## @@ -0,0 +1,97

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs

2020-03-10 Thread GitBox
tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs URL: https://github.com/apache/flink-statefun/pull/54#discussion_r390711708 ## File path: statefun-docs/docs/concepts/logical.rst ## @@ -0,0

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs

2020-03-10 Thread GitBox
tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs URL: https://github.com/apache/flink-statefun/pull/54#discussion_r390713139 ## File path: statefun-docs/docs/getting_started/walkthrough.rst ##

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs

2020-03-10 Thread GitBox
tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs URL: https://github.com/apache/flink-statefun/pull/54#discussion_r390712156 ## File path: statefun-docs/docs/concepts/logical.rst ## @@ -0,0

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs

2020-03-10 Thread GitBox
tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs URL: https://github.com/apache/flink-statefun/pull/54#discussion_r390705594 ## File path: statefun-docs/docs/concepts/index.rst ## @@ -0,0 +1,97

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs

2020-03-10 Thread GitBox
tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs URL: https://github.com/apache/flink-statefun/pull/54#discussion_r390710405 ## File path: statefun-docs/docs/concepts/logical.rst ## @@ -0,0

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs

2020-03-10 Thread GitBox
tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs URL: https://github.com/apache/flink-statefun/pull/54#discussion_r390714422 ## File path: statefun-docs/docs/sdk/modules.rst ## @@ -0,0 +1,96 @@

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs

2020-03-10 Thread GitBox
tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs URL: https://github.com/apache/flink-statefun/pull/54#discussion_r390707590 ## File path: statefun-docs/docs/concepts/index.rst ## @@ -0,0 +1,97

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs

2020-03-10 Thread GitBox
tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs URL: https://github.com/apache/flink-statefun/pull/54#discussion_r390704803 ## File path: statefun-docs/docs/concepts/index.rst ## @@ -0,0 +1,97

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs

2020-03-10 Thread GitBox
tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs URL: https://github.com/apache/flink-statefun/pull/54#discussion_r390709762 ## File path: statefun-docs/docs/concepts/logical.rst ## @@ -0,0

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs

2020-03-10 Thread GitBox
tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs URL: https://github.com/apache/flink-statefun/pull/54#discussion_r390709148 ## File path: statefun-docs/docs/concepts/index.rst ## @@ -0,0 +1,97

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs

2020-03-10 Thread GitBox
tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs URL: https://github.com/apache/flink-statefun/pull/54#discussion_r390706518 ## File path: statefun-docs/docs/concepts/index.rst ## @@ -0,0 +1,97

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs

2020-03-10 Thread GitBox
tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs URL: https://github.com/apache/flink-statefun/pull/54#discussion_r390703680 ## File path: statefun-docs/docs/concepts/index.rst ## @@ -0,0 +1,97

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs

2020-03-10 Thread GitBox
tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs URL: https://github.com/apache/flink-statefun/pull/54#discussion_r390710336 ## File path: statefun-docs/docs/concepts/logical.rst ## @@ -0,0

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs

2020-03-10 Thread GitBox
tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs URL: https://github.com/apache/flink-statefun/pull/54#discussion_r390709575 ## File path: statefun-docs/docs/concepts/index.rst ## @@ -0,0 +1,97

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs

2020-03-10 Thread GitBox
tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs URL: https://github.com/apache/flink-statefun/pull/54#discussion_r390712287 ## File path: statefun-docs/docs/concepts/logical.rst ## @@ -0,0

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs

2020-03-10 Thread GitBox
tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs URL: https://github.com/apache/flink-statefun/pull/54#discussion_r390710157 ## File path: statefun-docs/docs/concepts/logical.rst ## @@ -0,0

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs

2020-03-10 Thread GitBox
tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs URL: https://github.com/apache/flink-statefun/pull/54#discussion_r390705435 ## File path: statefun-docs/docs/concepts/index.rst ## @@ -0,0 +1,97

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs

2020-03-10 Thread GitBox
tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs URL: https://github.com/apache/flink-statefun/pull/54#discussion_r390708228 ## File path: statefun-docs/docs/concepts/logical.rst ## @@ -0,0

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs

2020-03-10 Thread GitBox
tzulitai commented on a change in pull request #54: [FLINK-16515][docs] Refactor statefun documentation for multi-language SDKs URL: https://github.com/apache/flink-statefun/pull/54#discussion_r390706263 ## File path: statefun-docs/docs/concepts/index.rst ## @@ -0,0 +1,97

[GitHub] [flink] flinkbot edited a comment on issue #11358: [FLINK-16516][python] Remove Python UDF Codegen Code

2020-03-10 Thread GitBox
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:

[GitHub] [flink] jiasheng55 commented on a change in pull request #11322: [FLINK-16376][yarn] Use consistent method to get Yarn application dir…

2020-03-10 Thread GitBox
jiasheng55 commented on a change in pull request #11322: [FLINK-16376][yarn] Use consistent method to get Yarn application dir… URL: https://github.com/apache/flink/pull/11322#discussion_r390714696 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager

2020-03-10 Thread GitBox
flinkbot edited a comment on issue #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager URL: https://github.com/apache/flink/pull/11353#issuecomment-596455079 ## CI report: *

[jira] [Commented] (FLINK-16528) Support Limit push down for streaming sources

2020-03-10 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17056593#comment-17056593 ] Jingsong Lee commented on FLINK-16528: -- +1, it is useful, should not be TOP N, should be pushed

[jira] [Updated] (FLINK-16528) Support Limit push down for streaming sources

2020-03-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16528: Labels: usability (was: ) > Support Limit push down for streaming sources >

[jira] [Updated] (FLINK-16528) Support Limit push down for streaming sources

2020-03-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16528: Description: Currently, a limit query {{SELECT * FROM kafka LIMIT 10}} will be translated into TopN

[jira] [Updated] (FLINK-16528) Support Limit push down for streaming sources

2020-03-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16528: Description: Currently, a limit query {{SELECT * FROM kafka LIMIT 10}} will be translated into TopN

[jira] [Created] (FLINK-16528) Support Limit push down for streaming sources

2020-03-10 Thread Jark Wu (Jira)
Jark Wu created FLINK-16528: --- Summary: Support Limit push down for streaming sources Key: FLINK-16528 URL: https://issues.apache.org/jira/browse/FLINK-16528 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-16528) Support Limit push down for streaming sources

2020-03-10 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16528: Description: Currently, a limit query {{SELECT * FROM kafka LIMIT 10}} will be translated into TopN

[jira] [Commented] (FLINK-16526) Escape character doesn't work for computed column

2020-03-10 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17056587#comment-17056587 ] Kurt Young commented on FLINK-16526: cc [~danny0405] > Escape character doesn't work for computed

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-03-10 Thread GitBox
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_r390707610 ## File path:

[jira] [Commented] (FLINK-16470) Network failure causes Checkpoint Coordinator to flood disk with exceptions

2020-03-10 Thread Jason Kania (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17056583#comment-17056583 ] Jason Kania commented on FLINK-16470: - [~gjy], the restart strategy was just the default and had no

[jira] [Updated] (FLINK-16455) Introduce flink-sql-connector-hive modules to provide hive uber jars

2020-03-10 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-16455: - Issue Type: New Feature (was: Bug) > Introduce flink-sql-connector-hive modules to provide

[jira] [Resolved] (FLINK-16455) Introduce flink-sql-connector-hive modules to provide hive uber jars

2020-03-10 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee resolved FLINK-16455. -- Resolution: Fixed master: bd18b8715466bfe49d8b31019075f8081a618875 > Introduce

  1   2   3   4   5   6   >