[
https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17038036#comment-17038036
]
Xintong Song commented on FLINK-15959:
--
Minor:
I would suggest to replace "taskmana
[
https://issues.apache.org/jira/browse/FLINK-16084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-16084:
---
Labels: pull-request-available (was: )
> Translate "Time Attributes" page of "Streaming Con
libenchao opened a new pull request #11102: [FLINK-16084][docs] Translate
/dev/table/streaming/time_attributes.zh.md
URL: https://github.com/apache/flink/pull/11102
## What is the purpose of the change
Translate /dev/table/streaming/time_attributes.zh.md
## Brief chan
flinkbot commented on issue #11102: [FLINK-16084][docs] Translate
/dev/table/streaming/time_attributes.zh.md
URL: https://github.com/apache/flink/pull/11102#issuecomment-586788166
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to
[
https://issues.apache.org/jira/browse/FLINK-16081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17038038#comment-17038038
]
Benchao Li commented on FLINK-16081:
[~jark] I can help translate this one.
> Trans
[
https://issues.apache.org/jira/browse/FLINK-16082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17038040#comment-17038040
]
Benchao Li commented on FLINK-16082:
[~jark] I can help translate this one.
> Trans
hequn8128 commented on a change in pull request #10995: [FLINK-15847][ml]
Include flink-ml-api and flink-ml-lib in opt
URL: https://github.com/apache/flink/pull/10995#discussion_r379951593
##
File path: flink-dist/src/main/assemblies/opt.xml
##
@@ -168,6 +168,14 @@
HuangXingBo opened a new pull request #11103: [hotfix][docs] Regenerate
documentation
URL: https://github.com/apache/flink/pull/11103
## What is the purpose of the change
*Regenerate documentation of k8 configuration*
## Brief change log
- *kubernetes_config_confi
flinkbot commented on issue #11103: [hotfix][docs] Regenerate documentation
URL: https://github.com/apache/flink/pull/11103#issuecomment-586789425
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will
hequn8128 commented on a change in pull request #10995: [FLINK-15847][ml]
Include flink-ml-api and flink-ml-lib in opt
URL: https://github.com/apache/flink/pull/10995#discussion_r379951593
##
File path: flink-dist/src/main/assemblies/opt.xml
##
@@ -168,6 +168,14 @@
hequn8128 commented on a change in pull request #10995: [FLINK-15847][ml]
Include flink-ml-api and flink-ml-lib in opt
URL: https://github.com/apache/flink/pull/10995#discussion_r379951593
##
File path: flink-dist/src/main/assemblies/opt.xml
##
@@ -168,6 +168,14 @@
[
https://issues.apache.org/jira/browse/FLINK-16081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-16081:
---
Assignee: Benchao Li
> Translate "Overview" page of "Table API & SQL" into Chinese
> --
[
https://issues.apache.org/jira/browse/FLINK-16082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-16082:
---
Assignee: Benchao Li
> Translate "Overview" page of "Streaming Concepts" into Chinese
> ---
[
https://issues.apache.org/jira/browse/FLINK-16051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang reassigned FLINK-16051:
Assignee: Jiayi Liao
> Subtask id in Checkpoint UI not consistent with Subtask UI
> -
[
https://issues.apache.org/jira/browse/FLINK-16051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-16051:
-
Issue Type: Improvement (was: Bug)
> Subtask id in Checkpoint UI not consistent with Subtask UI
> -
hequn8128 commented on a change in pull request #11051:
[FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical
Correlate RelNodes which are containers for Python TableFunction
URL: https://github.com/apache/flink/pull/11051#discussion_r379968881
##
File path:
hequn8128 commented on a change in pull request #11051:
[FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical
Correlate RelNodes which are containers for Python TableFunction
URL: https://github.com/apache/flink/pull/11051#discussion_r379968783
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-16051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao updated FLINK-16051:
---
Summary: Subtask ID in Overview-Subtasks should start from 1 (was: Subtask
id in Checkpoint UI not
hequn8128 commented on a change in pull request #11051:
[FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical
Correlate RelNodes which are containers for Python TableFunction
URL: https://github.com/apache/flink/pull/11051#discussion_r379968783
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-16051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayi Liao updated FLINK-16051:
---
Description:
The subtask id in Subtask UI starts from 0 which is not consistent with other
ID in ba
buptljy opened a new pull request #11104: [FLINK-16051] make Overview-Subtasks
ID starts from 1
URL: https://github.com/apache/flink/pull/11104
## What is the purpose of the change
The subtask id in Subtask UI starts from 0 which is not consistent with
other ID in backpressure / che
[
https://issues.apache.org/jira/browse/FLINK-16051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-16051:
---
Labels: pull-request-available (was: )
> Subtask ID in Overview-Subtasks should start from
flinkbot commented on issue #11104: [FLINK-16051] make Overview-Subtasks ID
starts from 1
URL: https://github.com/apache/flink/pull/11104#issuecomment-586800028
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull re
Jark Wu created FLINK-16108:
---
Summary: StreamSQLExample is failed if running in blink planner
Key: FLINK-16108
URL: https://issues.apache.org/jira/browse/FLINK-16108
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17038071#comment-17038071
]
YufeiLiu commented on FLINK-15959:
--
[~xintongsong] Got it, check total Executors less t
[
https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YufeiLiu updated FLINK-15959:
-
Comment: was deleted
(was: [~xintongsong] Got it, check total Executors less than maximum before
startN
[
https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17038072#comment-17038072
]
YufeiLiu commented on FLINK-15959:
--
[~xintongsong]Got it, check total Executors less th
bowenli86 commented on a change in pull request #11093: [FLINK-16055][hive]
Avoid catalog functions when listing Hive built-i…
URL: https://github.com/apache/flink/pull/11093#discussion_r379973331
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/ta
bowenli86 commented on a change in pull request #11093: [FLINK-16055][hive]
Avoid catalog functions when listing Hive built-i…
URL: https://github.com/apache/flink/pull/11093#discussion_r379973331
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/ta
[
https://issues.apache.org/jira/browse/FLINK-16108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-16108:
---
Assignee: Jark Wu
> StreamSQLExample is failed if running in blink planner
> --
Dian Fu created FLINK-16109:
---
Summary: Move the Python scalar operators and table operators to
separate package
Key: FLINK-16109
URL: https://issues.apache.org/jira/browse/FLINK-16109
Project: Flink
hequn8128 commented on a change in pull request #11051:
[FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical
Correlate RelNodes which are containers for Python TableFunction
URL: https://github.com/apache/flink/pull/11051#discussion_r379227379
##
File path:
hequn8128 commented on a change in pull request #11051:
[FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical
Correlate RelNodes which are containers for Python TableFunction
URL: https://github.com/apache/flink/pull/11051#discussion_r379227379
##
File path:
HuangXingBo commented on issue #11051:
[FLINK-15961][table-planner][table-planner-blink] Introduce Python Physical
Correlate RelNodes which are containers for Python TableFunction
URL: https://github.com/apache/flink/pull/11051#issuecomment-586809475
> @HuangXingBo Thanks a lot for the upd
[
https://issues.apache.org/jira/browse/FLINK-16109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-16109:
---
Labels: pull-request-available (was: )
> Move the Python scalar operators and table operato
HuangXingBo opened a new pull request #11105: [FLINK-16109][python] Move the
Python scalar operators and table operators to separate package
URL: https://github.com/apache/flink/pull/11105
## What is the purpose of the change
*This pull request will move the Python scalar operators a
flinkbot commented on issue #11105: [FLINK-16109][python] Move the Python
scalar operators and table operators to separate package
URL: https://github.com/apache/flink/pull/11105#issuecomment-586810362
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I hel
[
https://issues.apache.org/jira/browse/FLINK-6726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17038084#comment-17038084
]
Manas Kale commented on FLINK-6726:
---
Hi, is there any progress on this issue? I have a
[
https://issues.apache.org/jira/browse/FLINK-16058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17038083#comment-17038083
]
Yang Wang commented on FLINK-16058:
---
[~blablabla123] Flink depends the commons-cli wit
[
https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17038086#comment-17038086
]
Xintong Song commented on FLINK-15959:
--
bq. How about put it into ClusterOptions, s
[
https://issues.apache.org/jira/browse/FLINK-15959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17038086#comment-17038086
]
Xintong Song edited comment on FLINK-15959 at 2/17/20 4:18 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-15961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-15961:
---
Assignee: Huang Xingbo
> Introduce Python Physical Correlate RelNodes which are containers
godfrey he created FLINK-16110:
--
Summary: LogicalTypeParser can't parse "TIMESTAMP(3) *ROWTIME*"
and TIMESTAMP(3) *PROCTIME*
Key: FLINK-16110
URL: https://issues.apache.org/jira/browse/FLINK-16110
Projec
[
https://issues.apache.org/jira/browse/FLINK-16110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-16110:
---
Summary: LogicalTypeParser can't parse "TIMESTAMP(3) *ROWTIME*" and
"TIMESTAMP(3) *PROCTIME*" (was:
[
https://issues.apache.org/jira/browse/FLINK-16110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-16110:
---
Description:
{{TIMESTAMP(3) *ROWTIME*}} is the string representation of
{{TimestampType(true, Time
[
https://issues.apache.org/jira/browse/FLINK-16110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-16110:
---
Description:
{{TIMESTAMP(3) *ROWTIME*}} is the string representation of
{{TimestampType(true, Time
dianfu commented on issue #11103: [hotfix][docs] Regenerate documentation
URL: https://github.com/apache/flink/pull/11103#issuecomment-586818230
LGTM.
This is an automated message from the Apache Git Service.
To respond to the
dianfu merged pull request #11103: [hotfix][docs] Regenerate documentation
URL: https://github.com/apache/flink/pull/11103
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
zhijiangW commented 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-586823140
Let's uniform the new class naming and refactor the structure a bit firstly.
- `ZeroCopyNettyMe
zhijiangW 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_r379991124
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/netwo
zhijiangW 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-586823140
Let's uniform the new class naming and refactor the structure a bit firstly.
- `ZeroCopy
zhijiangW 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_r379991763
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/netwo
[
https://issues.apache.org/jira/browse/FLINK-16005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17038101#comment-17038101
]
Zhenqiu Huang commented on FLINK-16005:
---
[~fly_in_gis]
Spark actually support the
zhijiangW 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_r379993355
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/netwo
zhijiangW 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_r379996093
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/netwo
[
https://issues.apache.org/jira/browse/FLINK-16110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17038113#comment-17038113
]
Jark Wu commented on FLINK-16110:
-
{{TIMESTAMP(3) ROWTIME}} is the summary string of Tim
tzulitai opened a new pull request #25: [FLINK-16106] Add PersistedList state
primitive
URL: https://github.com/apache/flink-statefun/pull/25
This PR introduces a `PersistedList` state primitive to Stateful Functions.
- 3491fea: Adds the user-facing SDK classes
- 69e8ce6: Introduc
[
https://issues.apache.org/jira/browse/FLINK-16106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-16106:
---
Labels: pull-request-available (was: )
> Add PersistedList to the SDK
> ---
tzulitai commented on issue #25: [FLINK-16106] Add PersistedList state primitive
URL: https://github.com/apache/flink-statefun/pull/25#issuecomment-586843804
cc @igalshilman
This is an automated message from the Apache Git Se
wuchong commented on a change in pull request #11047: [FLINK-15912][table] Add
Context to TableSourceFactory and TableSinkFactory
URL: https://github.com/apache/flink/pull/11047#discussion_r380001365
##
File path:
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/fli
wuchong commented on a change in pull request #11047: [FLINK-15912][table] Add
Context to TableSourceFactory and TableSinkFactory
URL: https://github.com/apache/flink/pull/11047#discussion_r380009489
##
File path:
flink-table/flink-table-planner/src/test/scala/org/apache/flink/tabl
wuchong commented on a change in pull request #11047: [FLINK-15912][table] Add
Context to TableSourceFactory and TableSinkFactory
URL: https://github.com/apache/flink/pull/11047#discussion_r380004457
##
File path:
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flin
wuchong commented on a change in pull request #11047: [FLINK-15912][table] Add
Context to TableSourceFactory and TableSinkFactory
URL: https://github.com/apache/flink/pull/11047#discussion_r38717
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/
wuchong commented on a change in pull request #11047: [FLINK-15912][table] Add
Context to TableSourceFactory and TableSinkFactory
URL: https://github.com/apache/flink/pull/11047#discussion_r380005079
##
File path:
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flin
wuchong commented on a change in pull request #11047: [FLINK-15912][table] Add
Context to TableSourceFactory and TableSinkFactory
URL: https://github.com/apache/flink/pull/11047#discussion_r379996777
##
File path:
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink
wuchong commented on a change in pull request #11047: [FLINK-15912][table] Add
Context to TableSourceFactory and TableSinkFactory
URL: https://github.com/apache/flink/pull/11047#discussion_r37056
##
File path:
flink-table/flink-table-api-java/src/main/java/org/apache/flink/tabl
shuai-xu commented on issue #11009: [Flink-15873] [cep] fix matches result not
returned when existing earlier partial matches
URL: https://github.com/apache/flink/pull/11009#issuecomment-586844458
@dianfu Thank you very much for review. I didn't see any docs to say that
this is a design. A
wuchong commented on a change in pull request #11047: [FLINK-15912][table] Add
Context to TableSourceFactory and TableSinkFactory
URL: https://github.com/apache/flink/pull/11047#discussion_r380001446
##
File path:
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/fli
wuchong commented on a change in pull request #11047: [FLINK-15912][table] Add
Context to TableSourceFactory and TableSinkFactory
URL: https://github.com/apache/flink/pull/11047#discussion_r38855
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/
wuchong commented on a change in pull request #11047: [FLINK-15912][table] Add
Context to TableSourceFactory and TableSinkFactory
URL: https://github.com/apache/flink/pull/11047#discussion_r380009278
##
File path:
flink-table/flink-table-planner/src/test/scala/org/apache/flink/tabl
shuai-xu commented on a change in pull request #11068: [FLINK-15964] [cep] fix
getting event of previous stage in notFollowedBy may throw exception bug
URL: https://github.com/apache/flink/pull/11068#discussion_r380015480
##
File path:
flink-libraries/flink-cep/src/test/java/org/ap
shuai-xu commented on a change in pull request #11068: [FLINK-15964] [cep] fix
getting event of previous stage in notFollowedBy may throw exception bug
URL: https://github.com/apache/flink/pull/11068#discussion_r380015457
##
File path:
flink-libraries/flink-cep/src/test/java/org/ap
lirui-apache commented on a change in pull request #11093: [FLINK-16055][hive]
Avoid catalog functions when listing Hive built-i…
URL: https://github.com/apache/flink/pull/11093#discussion_r380019248
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink
Xintong Song created FLINK-16111:
Summary: Kubernetes deployment does not respect
"taskmanager.cpu.cores".
Key: FLINK-16111
URL: https://issues.apache.org/jira/browse/FLINK-16111
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-15708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-15708:
---
Labels: pull-request-available (was: )
> Add MigrationVersion.v1_10
> -
yanghua opened a new pull request #11106: [FLINK-15708] Add
MigrationVersion.v1_10
URL: https://github.com/apache/flink/pull/11106
## What is the purpose of the change
*This pull request adds MigrationVersion.v1_10*
## Brief change log
- *Add MigrationVers
[
https://issues.apache.org/jira/browse/FLINK-16111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17038127#comment-17038127
]
Xintong Song commented on FLINK-16111:
--
cc [~fly_in_gis] [~azagrebin]
> Kubernetes
flinkbot commented on issue #11106: [FLINK-15708] Add MigrationVersion.v1_10
URL: https://github.com/apache/flink/pull/11106#issuecomment-586854778
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will
lirui-apache commented on issue #11093: [FLINK-16055][hive] Avoid catalog
functions when listing Hive built-i…
URL: https://github.com/apache/flink/pull/11093#issuecomment-586856518
@bowenli86 PR updated. Please have a look, thanks.
-
Tzu-Li (Gordon) Tai created FLINK-16112:
---
Summary: KafkaDeserializationSchema#isEndOfStream is ill-defined
Key: FLINK-16112
URL: https://issues.apache.org/jira/browse/FLINK-16112
Project: Flink
101 - 180 of 180 matches
Mail list logo
