Github user KurtYoung commented on the issue:
https://github.com/apache/flink/pull/2550
For "cluster-id" thing, actually there is some similar functionality in
current Flink, configed by "high-availability.zookeeper.path.namespace". It
will work with another config "high-availability.
[
https://issues.apache.org/jira/browse/FLINK-4657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15528274#comment-15528274
]
ASF GitHub Bot commented on FLINK-4657:
---
Github user KurtYoung commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-4657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15528245#comment-15528245
]
ASF GitHub Bot commented on FLINK-4657:
---
Github user KurtYoung commented on a diff i
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/2550#discussion_r80837572
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -467,6 +487,128 @@ public void registerAtResourceManager(fin
[
https://issues.apache.org/jira/browse/FLINK-4670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15528226#comment-15528226
]
ASF GitHub Bot commented on FLINK-4670:
---
Github user beyond1920 closed the pull requ
Github user beyond1920 closed the pull request at:
https://github.com/apache/flink/pull/2543
---
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 is
[
https://issues.apache.org/jira/browse/FLINK-4606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15528211#comment-15528211
]
ASF GitHub Bot commented on FLINK-4606:
---
Github user beyond1920 commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-4679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-4679:
--
Assignee: Jark Wu
> Add TumbleRow row-windows for streaming tables
> --
Github user beyond1920 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2540#discussion_r80836325
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
---
@@ -324,6 +337,158 @@ public void handleError(fina
[
https://issues.apache.org/jira/browse/FLINK-4657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15528198#comment-15528198
]
ASF GitHub Bot commented on FLINK-4657:
---
Github user KurtYoung commented on a diff i
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/2550#discussion_r80835773
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -467,6 +487,128 @@ public void registerAtResourceManager(fin
[
https://issues.apache.org/jira/browse/FLINK-4657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15528193#comment-15528193
]
ASF GitHub Bot commented on FLINK-4657:
---
Github user KurtYoung commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-4657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15528189#comment-15528189
]
ASF GitHub Bot commented on FLINK-4657:
---
Github user KurtYoung commented on a diff i
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/2550#discussion_r80835559
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -467,6 +487,128 @@ public void registerAtResourceManager(fin
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/2550#discussion_r80835462
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -467,6 +487,128 @@ public void registerAtResourceManager(fin
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/2550#discussion_r80834516
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -467,6 +487,128 @@ public void registerAtResourceManager(fin
[
https://issues.apache.org/jira/browse/FLINK-4657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15528167#comment-15528167
]
ASF GitHub Bot commented on FLINK-4657:
---
Github user KurtYoung commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-4068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15528157#comment-15528157
]
ASF GitHub Bot commented on FLINK-4068:
---
GitHub user wuchong opened a pull request:
GitHub user wuchong opened a pull request:
https://github.com/apache/flink/pull/2560
[FLINK-4068] [table] Move constant computations out of code-generated
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into considerat
[
https://issues.apache.org/jira/browse/FLINK-4450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15528031#comment-15528031
]
ASF GitHub Bot commented on FLINK-4450:
---
Github user liuyuzhong commented on the iss
Github user liuyuzhong commented on the issue:
https://github.com/apache/flink/pull/2439
Jenkins run successful, but CI fail.
![image](https://cloud.githubusercontent.com/assets/12843176/18897594/2c9e40e2-855e-11e6-8d3c-0397b33d5d8f.png)
---
If your project is set up for it
[
https://issues.apache.org/jira/browse/FLINK-4646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ivan Mushketyk reassigned FLINK-4646:
-
Assignee: Ivan Mushketyk
> Add BipartiteGraph class
>
>
>
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2430#discussion_r80784331
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSinkTestBase.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15527303#comment-15527303
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2430#discussion_r80783113
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSinkTestBase.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15527304#comment-15527304
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2430#discussion_r80783750
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSinkTestBase.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15527305#comment-15527305
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user fhueske commented on a diff in
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/2559
[FLINK-4702] [kafka connector] Commit offets to Kafka asynchronously
The offset commit calls to Kafka may occasionally take very long. In that
case, the notifyCheckpointComplete() method blocks
[
https://issues.apache.org/jira/browse/FLINK-4702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15527146#comment-15527146
]
ASF GitHub Bot commented on FLINK-4702:
---
GitHub user StephanEwen opened a pull reque
Stephan Ewen created FLINK-4702:
---
Summary: Kafka consumer must commit offsets asynchronously
Key: FLINK-4702
URL: https://issues.apache.org/jira/browse/FLINK-4702
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-4675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15527122#comment-15527122
]
Stephan Ewen commented on FLINK-4675:
-
It would be okay to break it now (from what we
[
https://issues.apache.org/jira/browse/FLINK-4699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15527013#comment-15527013
]
Fabian Hueske commented on FLINK-4699:
--
There is a pull request to convert the KafkaJ
[
https://issues.apache.org/jira/browse/FLINK-4657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15526962#comment-15526962
]
ASF GitHub Bot commented on FLINK-4657:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2550
Can we try and unify the structure / paths under which all this information
is stored in ZooKeeper?
```
/flink
+/cluster_id_1/resource_manager_lock
||
Ted Yu created FLINK-4701:
-
Summary: Unprotected access to cancelables in StreamTask
Key: FLINK-4701
URL: https://issues.apache.org/jira/browse/FLINK-4701
Project: Flink
Issue Type: Bug
R
[
https://issues.apache.org/jira/browse/FLINK-4543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4543.
---
> Race Deadlock in SpilledSubpartitionViewTest
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-4543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4543.
-
Resolution: Fixed
Fixed via 90902914ac4b11f9554b67ad49e0d697a0d02f93
> Race Deadlock in SpilledSu
[
https://issues.apache.org/jira/browse/FLINK-4543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15526905#comment-15526905
]
ASF GitHub Bot commented on FLINK-4543:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2444
---
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 is enab
[
https://issues.apache.org/jira/browse/FLINK-4560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4560.
---
> enforcer java version as 1.7
>
>
> Key: FLINK-4560
>
[
https://issues.apache.org/jira/browse/FLINK-4560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4560.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed via b928935b8c5be02b23dd2cb87144ae1ea001278c
[
https://issues.apache.org/jira/browse/FLINK-4560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15526904#comment-15526904
]
ASF GitHub Bot commented on FLINK-4560:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2458
---
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 is enab
[
https://issues.apache.org/jira/browse/FLINK-4695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15526820#comment-15526820
]
ASF GitHub Bot commented on FLINK-4695:
---
Github user asfgit closed the pull request
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/2510
Sounds good @StephanEwen . Thank you.
---
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
ena
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2555
---
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 is enab
[
https://issues.apache.org/jira/browse/FLINK-4695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4695.
Resolution: Fixed
Added via f1b5b35f595e7ae53001a4c46edbf0c9b78ee376
> Separate configuration parsi
[
https://issues.apache.org/jira/browse/FLINK-4695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15526805#comment-15526805
]
ASF GitHub Bot commented on FLINK-4695:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2555
Thanks for the review @StephanEwen. Build passed locally. Will merge the 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 yo
[
https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15526787#comment-15526787
]
ASF GitHub Bot commented on FLINK-3322:
---
Github user ramkrish86 commented on the iss
[
https://issues.apache.org/jira/browse/FLINK-4657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15526751#comment-15526751
]
ASF GitHub Bot commented on FLINK-4657:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-4657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15526750#comment-15526750
]
ASF GitHub Bot commented on FLINK-4657:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-4657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15526753#comment-15526753
]
ASF GitHub Bot commented on FLINK-4657:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-4657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15526754#comment-15526754
]
ASF GitHub Bot commented on FLINK-4657:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-4657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15526752#comment-15526752
]
ASF GitHub Bot commented on FLINK-4657:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-4657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15526749#comment-15526749
]
ASF GitHub Bot commented on FLINK-4657:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2550#discussion_r80734121
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -467,6 +487,128 @@ public void registerAtResourceManager(f
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2550#discussion_r80733402
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -467,6 +487,128 @@ public void registerAtResourceManager(f
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2550#discussion_r80740850
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -467,6 +487,128 @@ public void registerAtResourceManager(f
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2550#discussion_r80740727
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -467,6 +487,128 @@ public void registerAtResourceManager(f
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2550#discussion_r80733924
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -467,6 +487,128 @@ public void registerAtResourceManager(f
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2550#discussion_r80742192
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -467,6 +487,128 @@ public void registerAtResourceManager(f
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2552
---
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 is enab
[
https://issues.apache.org/jira/browse/FLINK-4690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-4690.
--
Resolution: Fixed
Added via 84672c22f8088a70caf35b54d74eee458bf600dd
> Replace SlotAllocationFu
[
https://issues.apache.org/jira/browse/FLINK-4361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15526671#comment-15526671
]
Till Rohrmann commented on FLINK-4361:
--
Added to the master via f8138f4b74332ecb4ef0d
[
https://issues.apache.org/jira/browse/FLINK-4361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15526669#comment-15526669
]
ASF GitHub Bot commented on FLINK-4361:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15526668#comment-15526668
]
ASF GitHub Bot commented on FLINK-4690:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2554
---
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 is enab
[
https://issues.apache.org/jira/browse/FLINK-4690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1552#comment-1552
]
ASF GitHub Bot commented on FLINK-4690:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2552
I've merged it into the master branch. You can close the 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 project does
[
https://issues.apache.org/jira/browse/FLINK-4669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15526621#comment-15526621
]
ASF GitHub Bot commented on FLINK-4669:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2541#discussion_r80730795
--- Diff:
flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/StreamExecutionEnvironment.scala
---
@@ -124,7 +125,7 @@ class Stream
[
https://issues.apache.org/jira/browse/FLINK-4583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-4583.
-
Resolution: Duplicate
> NullPointerException in CliFrontend
> ---
>
>
Kostas Kloudas created FLINK-4700:
-
Summary: Harden the TimeProvider test
Key: FLINK-4700
URL: https://issues.apache.org/jira/browse/FLINK-4700
Project: Flink
Issue Type: Bug
Compon
[
https://issues.apache.org/jira/browse/FLINK-4677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15526575#comment-15526575
]
ASF GitHub Bot commented on FLINK-4677:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2548
Do we have a standard way for user programs to print usage and exit without
triggering this message? This is certainly preferable to the
`NullPointerException`.
---
If your project is set up for
Timo Walther created FLINK-4699:
---
Summary: Convert Kafka TableSource/TableSink tests to unit tests
Key: FLINK-4699
URL: https://issues.apache.org/jira/browse/FLINK-4699
Project: Flink
Issue Typ
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2548
Looks good to me, +1 to merge
---
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 an
[
https://issues.apache.org/jira/browse/FLINK-4677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15526523#comment-15526523
]
ASF GitHub Bot commented on FLINK-4677:
---
Github user StephanEwen commented on the is
Stephan Ewen created FLINK-4698:
---
Summary: Visualize additional checkpoint information
Key: FLINK-4698
URL: https://issues.apache.org/jira/browse/FLINK-4698
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-4685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4685.
---
> Gather operator checkpoint durations data sizes from the runtime
> -
[
https://issues.apache.org/jira/browse/FLINK-4696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4696.
---
> Limit the number of Akka Dispatcher Threads in LocalMiniCluster
> --
[
https://issues.apache.org/jira/browse/FLINK-4685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4685.
-
Resolution: Implemented
Implemented in b1642e32c2f69c60c2b212260c3479feb66a9165
> Gather operator
Stephan Ewen created FLINK-4697:
---
Summary: Gather more detailed checkpoint stats in
CheckpointStatsTracker
Key: FLINK-4697
URL: https://issues.apache.org/jira/browse/FLINK-4697
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4696.
-
Resolution: Fixed
Fixed via 6ea9284d29ec79576f073441a5de681019720ab0
> Limit the number of Akka D
[
https://issues.apache.org/jira/browse/FLINK-4630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15526424#comment-15526424
]
shijinkui commented on FLINK-4630:
--
Some business system such as risk online management.
[
https://issues.apache.org/jira/browse/FLINK-3734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15526303#comment-15526303
]
ASF GitHub Bot commented on FLINK-3734:
---
Github user lw-lin commented on a diff in t
Github user lw-lin commented on a diff in the pull request:
https://github.com/apache/flink/pull/2557#discussion_r80704455
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
---
@@ -568,8 +568,8 @@ public void
setInitialState(Cha
[
https://issues.apache.org/jira/browse/FLINK-3734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15526278#comment-15526278
]
ASF GitHub Bot commented on FLINK-3734:
---
GitHub user lw-lin opened a pull request:
GitHub user lw-lin opened a pull request:
https://github.com/apache/flink/pull/2557
[FLINK-3734] Close stream state handles after state restorations
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
GitHub user lw-lin opened a pull request:
https://github.com/apache/flink/pull/2556
[FLINK-4573] Fix potential resource leak due to unclosed RandomAccessâ¦
â¦File in TaskManagerLogHandler
--
Thanks for contributing to Apache Flink. Before you open your pull reques
[
https://issues.apache.org/jira/browse/FLINK-4573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15526276#comment-15526276
]
ASF GitHub Bot commented on FLINK-4573:
---
GitHub user lw-lin opened a pull request:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2544
Manually merged in 95e9004e36fffae755eab7aa3d5d0d5e8bfb7113
---
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 no
Github user StephanEwen closed the pull request at:
https://github.com/apache/flink/pull/2544
---
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 is
[
https://issues.apache.org/jira/browse/FLINK-4218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15526247#comment-15526247
]
ASF GitHub Bot commented on FLINK-4218:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-4554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15526259#comment-15526259
]
Timo Walther commented on FLINK-4554:
-
[~kirill-morozov-epam] thanks for your interest
[
https://issues.apache.org/jira/browse/FLINK-4218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15526248#comment-15526248
]
ASF GitHub Bot commented on FLINK-4218:
---
Github user StephanEwen closed the pull req
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2555
True, the benefit of this is only marginal in the current master. It is
actually part of the `TaskManager` services start up logic in Flip-6. In this
branch, the services will be generated by pr
[
https://issues.apache.org/jira/browse/FLINK-4695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15526182#comment-15526182
]
ASF GitHub Bot commented on FLINK-4695:
---
Github user tillrohrmann commented on the i
1 - 100 of 161 matches
Mail list logo