[
https://issues.apache.org/jira/browse/FLINK-7642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16433258#comment-16433258
]
Ted Yu commented on FLINK-7642:
---
SUREFIRE-1439 is in 2.21.0 which is needed for compiling with Java 10
>
[
https://issues.apache.org/jira/browse/FLINK-9152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16432864#comment-16432864
]
ASF GitHub Bot commented on FLINK-9152:
---
Github user kl0u commented on a diff in the pull request:
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5830#discussion_r180541104
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/co/KeyedBroadcastProcessFunction.java
---
@@ -89,11 +89,11 @@
*
[
https://issues.apache.org/jira/browse/FLINK-9152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16432865#comment-16432865
]
ASF GitHub Bot commented on FLINK-9152:
---
Github user kl0u commented on a diff in the pull request:
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5830#discussion_r180538022
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/CoBroadcastWithKeyedOperator.java
---
@@ -33,6 +33,8 @@
import
[
https://issues.apache.org/jira/browse/FLINK-9152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16432863#comment-16432863
]
ASF GitHub Bot commented on FLINK-9152:
---
Github user kl0u commented on a diff in the pull request:
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/5830#discussion_r180541190
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/co/KeyedBroadcastProcessFunction.java
---
@@ -89,11 +89,11 @@
*
[
https://issues.apache.org/jira/browse/FLINK-8205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16432789#comment-16432789
]
Kostas Kloudas commented on FLINK-8205:
---
Hi [~sihuazhou]! I would suggest to start with multi key
[
https://issues.apache.org/jira/browse/FLINK-7917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16432712#comment-16432712
]
Ted Yu commented on FLINK-7917:
---
lgtm
> The return of taskInformationOrBlobKey should be placed inside
[
https://issues.apache.org/jira/browse/FLINK-9088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-9088:
--
Description:
Currently dependency of Nifi is 0.6.1
We should upgrade to 1.6.0
was:
Currently dependency of
[
https://issues.apache.org/jira/browse/FLINK-9008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16432650#comment-16432650
]
ASF GitHub Bot commented on FLINK-9008:
---
Github user zhangminglei commented on the issue:
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/5823
Thank you very much @zentol . I have updated the PR. Not sure whether to
meet the demand 100%. For verify the job was successfully run, I used
Elasticsearch2 as a sink. As well add a
[
https://issues.apache.org/jira/browse/FLINK-9087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-9087:
--
Summary: Change the method signature of RecordWriter#broadcastEvent() from
BufferConsumer to void (was: Return
[
https://issues.apache.org/jira/browse/FLINK-9070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16432548#comment-16432548
]
Sihua Zhou commented on FLINK-9070:
---
Thanks, I will make a PR for this ticket for flink 1.6 once flink
[
https://issues.apache.org/jira/browse/FLINK-9070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou reassigned FLINK-9070:
-
Assignee: Sihua Zhou
> Improve performance of RocksDBMapState.clear()
>
[
https://issues.apache.org/jira/browse/FLINK-9070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-9070:
--
Fix Version/s: 1.6.0
> Improve performance of RocksDBMapState.clear()
>
[
https://issues.apache.org/jira/browse/FLINK-8205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-8205:
--
Fix Version/s: (was: 1.5.0)
1.6.0
> Multi key get
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-9087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16432430#comment-16432430
]
mingleizhang commented on FLINK-9087:
-
It seems that [~triones] does not have permission to perform
[
https://issues.apache.org/jira/browse/FLINK-9087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16432403#comment-16432403
]
ASF GitHub Bot commented on FLINK-9087:
---
Github user zhangminglei commented on the issue:
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/5802
@trionesadam ð
---
[
https://issues.apache.org/jira/browse/FLINK-9087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16432401#comment-16432401
]
ASF GitHub Bot commented on FLINK-9087:
---
Github user trionesadam commented on the issue:
Github user trionesadam commented on the issue:
https://github.com/apache/flink/pull/5802
This PR is ready for having another review. @NicoK , @tedyu , Thank you.
@tedyu , do we need change the description of this jira?
---
[
https://issues.apache.org/jira/browse/FLINK-9087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16432399#comment-16432399
]
Ted Yu commented on FLINK-9087:
---
You can modify the description to match your fix.
Thanks
> Return value
[
https://issues.apache.org/jira/browse/FLINK-9087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16432385#comment-16432385
]
Triones Deng commented on FLINK-9087:
-
This PR is ready for having another review. [~NicoK],
[
https://issues.apache.org/jira/browse/FLINK-6022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16432341#comment-16432341
]
ASF GitHub Bot commented on FLINK-6022:
---
Github user shashank734 commented on the issue:
Github user shashank734 commented on the issue:
https://github.com/apache/flink/pull/4943
@zentol Thanks, I think it's the wrong place to ask But Actually We have
tried to use AvroTypeInfo, But it was unable to restore from the savepoint
(Note we have changed the schema and class
[
https://issues.apache.org/jira/browse/FLINK-9124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16432254#comment-16432254
]
ASF GitHub Bot commented on FLINK-9124:
---
Github user tweise commented on the issue:
Github user tweise commented on the issue:
https://github.com/apache/flink/pull/5803
@aljoscha @tzulitai can you take a look?
---
[
https://issues.apache.org/jira/browse/FLINK-9070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16432213#comment-16432213
]
Truong Duc Kien commented on FLINK-9070:
Sure. Go ahead.
> Improve performance of
[
https://issues.apache.org/jira/browse/FLINK-9153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16432141#comment-16432141
]
ASF GitHub Bot commented on FLINK-9153:
---
Github user yanghua commented on the issue:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5834
cc @tillrohrmann for mode : `new` (flip-6) the `TaskManagerRunner` could
not specify a port range, I suggest we could merge this PR as a hotfix issue
and add it into 1.5 release.
---
[
https://issues.apache.org/jira/browse/FLINK-9153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16432138#comment-16432138
]
ASF GitHub Bot commented on FLINK-9153:
---
GitHub user yanghua opened a pull request:
GitHub user yanghua opened a pull request:
https://github.com/apache/flink/pull/5834
[FLINK-9153] TaskManagerRunner should support rpc port range
## What is the purpose of the change
*This pull request makes `TaskManagerRunner` (FLIP-6) supports rpc port
range*
[
https://issues.apache.org/jira/browse/FLINK-6022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16432133#comment-16432133
]
ASF GitHub Bot commented on FLINK-6022:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4943
@shashank734 The commits are contained in 1.4 already. Have you read
[this](https://github.com/apache/flink/pull/4943#issuecomment-342156083)
comment?
---
Alex Smirnov created FLINK-9155:
---
Summary: Provide message context information in
DeserializationSchema
Key: FLINK-9155
URL: https://issues.apache.org/jira/browse/FLINK-9155
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-6022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16432112#comment-16432112
]
ASF GitHub Bot commented on FLINK-6022:
---
Github user shashank734 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16432113#comment-16432113
]
ASF GitHub Bot commented on FLINK-9154:
---
GitHub user zentol opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/5833
[FLINK-9154][REST][docs] Document WebSubmissionExtension handlers
## What is the purpose of the change
With this PR the handlers defined in the `WebSubmissionExtension` (for
running jars,
Github user shashank734 commented on the issue:
https://github.com/apache/flink/pull/4943
@StephanEwen Are these changes part of 1.5 or 1.4, Do you have any example
how I can use this with states and CEP? Please give me some hint. I have seen
test cases of Input and Output only.
Chesnay Schepler created FLINK-9154:
---
Summary: Include WebSubmissionExtension in REST API docs
Key: FLINK-9154
URL: https://issues.apache.org/jira/browse/FLINK-9154
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-9008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16432035#comment-16432035
]
ASF GitHub Bot commented on FLINK-9008:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5823
1. You should create a project _within the test_. This project must **not**
be based on `https://flink.apache.org/q/quickstart.sh`, is has to be created
with the archetype that is installed locally
[
https://issues.apache.org/jira/browse/FLINK-9137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-9137.
---
Resolution: Won't Fix
> Merge TopSpeedWindowingExampleITCase into StreamingExamplesITCase
>
Github user zentol closed the pull request at:
https://github.com/apache/flink/pull/5816
---
[
https://issues.apache.org/jira/browse/FLINK-9137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16432013#comment-16432013
]
ASF GitHub Bot commented on FLINK-9137:
---
Github user zentol closed the pull request at:
vinoyang created FLINK-9153:
---
Summary: TaskManagerRunner should support rpc port range
Key: FLINK-9153
URL: https://issues.apache.org/jira/browse/FLINK-9153
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-8961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8961:
Issue Type: Sub-task (was: Improvement)
Parent: FLINK-8700
> Port
[
https://issues.apache.org/jira/browse/FLINK-8702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-8702.
---
Resolution: Fixed
> Migrate tests from FlinkMiniCluster to MiniClusterResource
>
[
https://issues.apache.org/jira/browse/FLINK-9151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16431959#comment-16431959
]
ASF GitHub Bot commented on FLINK-9151:
---
GitHub user facboy opened a pull request:
GitHub user facboy opened a pull request:
https://github.com/apache/flink/pull/5832
[FLINK-9151] [Startup Shell Scripts] Export FLINK_CONF_DIR to job manager
and task managers in standalone cluster mode (master)
## What is the purpose of the change
This pull request makes
[
https://issues.apache.org/jira/browse/FLINK-9151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9151:
---
Assignee: (was: vinoyang)
> standalone cluster scripts should pass FLINK_CONF_DIR to job manager
[
https://issues.apache.org/jira/browse/FLINK-9151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16431948#comment-16431948
]
ASF GitHub Bot commented on FLINK-9151:
---
GitHub user facboy opened a pull request:
GitHub user facboy opened a pull request:
https://github.com/apache/flink/pull/5831
[FLINK-9151] [Startup Shell Scripts] Export FLINK_CONF_DIR to job manager
and task managers in standalone cluster mode
## What is the purpose of the change
This pull request makes the
[
https://issues.apache.org/jira/browse/FLINK-9151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Christopher Ng updated FLINK-9151:
--
Component/s: Startup Shell Scripts
> standalone cluster scripts should pass FLINK_CONF_DIR to
[
https://issues.apache.org/jira/browse/FLINK-8205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16431809#comment-16431809
]
Sihua Zhou commented on FLINK-8205:
---
Hi [~kkl0u], I'm preparing to write the design document, there's
56 matches
Mail list logo
