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
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:
[
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
[
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
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
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:
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
*
[
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
[
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:
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
[
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
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
[
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:
[
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
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:
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:
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:
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:
[
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
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
*
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
[
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:
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:
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
*
[
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:
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:
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:
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:
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:
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:
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:
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:
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
*
[
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
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
[
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.
>
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:
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:
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_r390715114
##
File path:
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 @@
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:
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:
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:
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
[
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
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=17056608#comment-17056608
]
Danny Chen commented on FLINK-16526:
Thanks, [~liuyufei], you should try
{code:sql}
`timestamp`
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
[
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):
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:
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:
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:
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:
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:
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
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:
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
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
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
##
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
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
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
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 @@
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
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
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
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
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
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
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
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
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
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
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
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
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
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:
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:
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:
*
[
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
[
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
>
[
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
[
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
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
[
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
[
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
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:
[
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
[
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
[
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 - 100 of 537 matches
Mail list logo