XuPingyong created FLINK-13337:
--
Summary: Do not need to backup and restore streamEnv config in
BatchExecutor
Key: FLINK-13337
URL: https://issues.apache.org/jira/browse/FLINK-13337
Project: Flink
XuPingyong created FLINK-13329:
--
Summary: Set env config for sql jobs
Key: FLINK-13329
URL: https://issues.apache.org/jira/browse/FLINK-13329
Project: Flink
Issue Type: Task
[
https://issues.apache.org/jira/browse/FLINK-13122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
XuPingyong closed FLINK-13122.
--
Resolution: Won't Fix
> Set managed memory to operator resourceSpec in blink table plan
[
https://issues.apache.org/jira/browse/FLINK-13119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
XuPingyong updated FLINK-13119:
---
Component/s: Documentation
> Add blink table config to documentat
XuPingyong created FLINK-13122:
--
Summary: Set managed memory to operator resourceSpec in blink
table planner
Key: FLINK-13122
URL: https://issues.apache.org/jira/browse/FLINK-13122
Project: Flink
XuPingyong created FLINK-13121:
--
Summary: Set batch/streaming properties to StreamGraph in blink
table env
Key: FLINK-13121
URL: https://issues.apache.org/jira/browse/FLINK-13121
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-13121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
XuPingyong updated FLINK-13121:
---
Summary: Set batch/streaming properties to StreamGraph in blink table
planner (was: Set batch
XuPingyong created FLINK-13119:
--
Summary: Add blink table config to documentation
Key: FLINK-13119
URL: https://issues.apache.org/jira/browse/FLINK-13119
Project: Flink
Issue Type: Task
[
https://issues.apache.org/jira/browse/FLINK-13040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
XuPingyong updated FLINK-13040:
---
Description:
_1. improve planner and runtime config of blink_
was:
_1. promote planner
[
https://issues.apache.org/jira/browse/FLINK-13040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
XuPingyong updated FLINK-13040:
---
Summary: improve blink configOptions (was: promote blink configOptions)
> improve bl
[
https://issues.apache.org/jira/browse/FLINK-13040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
XuPingyong updated FLINK-13040:
---
Component/s: (was: Documentation)
Table SQL / API
> promote bl
[
https://issues.apache.org/jira/browse/FLINK-13040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
XuPingyong updated FLINK-13040:
---
Summary: promote blink configOptions (was: promote blink configOptions and
add these config
[
https://issues.apache.org/jira/browse/FLINK-13040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
XuPingyong updated FLINK-13040:
---
Description:
_1. promote planner and runtime config of blink_
was:
_1. promote planner
[
https://issues.apache.org/jira/browse/FLINK-13040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
XuPingyong updated FLINK-13040:
---
Summary: promote blink configOptions and add these config descriptions to
(was: promote blink
[
https://issues.apache.org/jira/browse/FLINK-13040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
XuPingyong updated FLINK-13040:
---
Description:
_1. promote planner and runtime config of blink_
_2. add anotations to indicate
XuPingyong created FLINK-13040:
--
Summary: promote blink configOptions and add these config
descriptions to document
Key: FLINK-13040
URL: https://issues.apache.org/jira/browse/FLINK-13040
Project: Flink
XuPingyong created FLINK-12824:
--
Summary: set parallelism for stream SQL
Key: FLINK-12824
URL: https://issues.apache.org/jira/browse/FLINK-12824
Project: Flink
Issue Type: Task
XuPingyong created FLINK-12816:
--
Summary: set maxParallelism to 1 when DataStreamSource is not
isParallel
Key: FLINK-12816
URL: https://issues.apache.org/jira/browse/FLINK-12816
Project: Flink
XuPingyong created FLINK-12801:
--
Summary: Set parallelism for batch SQL
Key: FLINK-12801
URL: https://issues.apache.org/jira/browse/FLINK-12801
Project: Flink
Issue Type: Task
Github user XuPingyong commented on the issue:
https://github.com/apache/flink/pull/2110
I do not agree with this pr as it always copy StreamRecord to downstream
operator.
StreamMap change the input StreamRecord, so this pr works well. But many
operators do not change/reuse
Github user XuPingyong closed the pull request at:
https://github.com/apache/flink/pull/4525
---
Github user XuPingyong commented on the issue:
https://github.com/apache/flink/pull/4525
Thanks @StephanEwen , so I think `null` values can be returned from
`InputFormat#nextRecord` anytime, even not end.
Can `null` values be passed to `InputFormat#nextRecord
Github user XuPingyong commented on the issue:
https://github.com/apache/flink/pull/4525
Thanks @greghogan , `MergeIterator` is really a special case that it would
be better to pass the returned object to `MutableObjectIterator#next` again.
---
If your project is set up for it, you
Github user XuPingyong commented on the issue:
https://github.com/apache/flink/pull/4525
@greghoganï¼ if the object passed to nextRecord may be reused internally
by the InputFormat, do the similar cases need to be re-considered?
In `DataSourceTask.java
Github user XuPingyong commented on the issue:
https://github.com/apache/flink/pull/4525
Thanks @greghogan.
I think the InputFormat can return anything, may be null or other
immutable objects that cannot be passed to nextRecord.
And I am also not clear why
GitHub user XuPingyong opened a pull request:
https://github.com/apache/flink/pull/4525
[FLINK-7423] Always reuse an instance to get elements from the inputFormat
## What is the purpose of the change
This pull request fix a bug about getting elements from the inputFormat
Github user XuPingyong commented on the issue:
https://github.com/apache/flink/pull/4273
Thanks @tillrohrmann , I have updated this PR according to your advice.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your
Github user XuPingyong commented on a diff in the pull request:
https://github.com/apache/flink/pull/4273#discussion_r131918248
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamGraphExecutor.java
---
@@ -0,0 +1,52
Github user XuPingyong commented on a diff in the pull request:
https://github.com/apache/flink/pull/4273#discussion_r131916494
--- Diff: flink-contrib/flink-connector-wikiedits/pom.xml ---
@@ -37,7 +37,7 @@ under the License
Github user XuPingyong commented on the issue:
https://github.com/apache/flink/pull/4347
Thanks @tillrohrmann !
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled
Github user XuPingyong closed the pull request at:
https://github.com/apache/flink/pull/4347
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
Github user XuPingyong commented on the issue:
https://github.com/apache/flink/pull/4347
@StephanEwen , rpcService of ResourceManager executes with only one single
thread, so there is no conflicts when resourcemanager is in service. When
resourceManager is shutdown by the other
GitHub user XuPingyong opened a pull request:
https://github.com/apache/flink/pull/4347
[FLINK-7201] fix concurrency in JobLeaderIdService when shutdown the â¦
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/XuPingyong/flink
Github user XuPingyong commented on the issue:
https://github.com/apache/flink/pull/4241
Thanks @aljoscha and @StephanEwen, I have updated this PR according to your
advice.
- Rename StreamConfig to StreamTaskConfig.
- Introduce serialisable OperatorConfig and move
Github user XuPingyong commented on the issue:
https://github.com/apache/flink/pull/4273
@tillrohrmann , could you please spend some time on reviewing this PR?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your
GitHub user XuPingyong opened a pull request:
https://github.com/apache/flink/pull/4273
[FLINK-7065] Separate the flink-streaming-java module from flink-clients
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/XuPingyong/flink
GitHub user XuPingyong opened a pull request:
https://github.com/apache/flink/pull/4267
[FLINK-7018][streaming] Refactor streamGraph to make interfaces clear
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/PingyongXu/flink FLINK
37 matches
Mail list logo
