[
https://issues.apache.org/jira/browse/FLINK-4840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15584669#comment-15584669
]
Chesnay Schepler commented on FLINK-4840:
-
That's a good point about the capacity.
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/2653
Because SQL doesn't have standard user-defined table function, we introduce
MS SQL Server's `CROSS/OUTER APPLY` to support UDTF , see
https://technet.microsoft.com/en-us/library/ms175156(v=sql.105).a
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15584635#comment-15584635
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user wuchong commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15584576#comment-15584576
]
zhuhaifeng commented on FLINK-4840:
---
I agree with you, I will modify this jira and add t
[
https://issues.apache.org/jira/browse/FLINK-4840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15584570#comment-15584570
]
zhuhaifeng commented on FLINK-4840:
---
The TPS is numRecordsInPerSecond, is it will be add
[
https://issues.apache.org/jira/browse/FLINK-4723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15584364#comment-15584364
]
Tzu-Li (Gordon) Tai edited comment on FLINK-4723 at 10/18/16 3:58 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-4723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15584364#comment-15584364
]
Tzu-Li (Gordon) Tai commented on FLINK-4723:
[~rmetzger] Should this fix go in
[
https://issues.apache.org/jira/browse/FLINK-4723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-4723.
Resolution: Fixed
> Unify behaviour of committed offsets to Kafka / ZK for Kafka 0.8
[
https://issues.apache.org/jira/browse/FLINK-4723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15584361#comment-15584361
]
Tzu-Li (Gordon) Tai commented on FLINK-4723:
Resolved for master via
http://g
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2585
Rebasing to include f46ca39 with the IT tests de-commented. Will merge when
Travis turns green.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHu
[
https://issues.apache.org/jira/browse/FLINK-4727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15584340#comment-15584340
]
ASF GitHub Bot commented on FLINK-4727:
---
Github user tzulitai commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-4723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15584332#comment-15584332
]
ASF GitHub Bot commented on FLINK-4723:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2580
---
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
Github user skrishnappa commented on the issue:
https://github.com/apache/flink/pull/2518
Thanks @mxm for following this up. Cheers
---
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 featur
[
https://issues.apache.org/jira/browse/FLINK-3931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15584329#comment-15584329
]
ASF GitHub Bot commented on FLINK-3931:
---
Github user skrishnappa commented on the is
[
https://issues.apache.org/jira/browse/FLINK-4723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15584323#comment-15584323
]
ASF GitHub Bot commented on FLINK-4723:
---
Github user tzulitai commented on the issue
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2580
Merging this to master now ...
---
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
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15584306#comment-15584306
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user wuchong commented on the issue:
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/2653
Hi @twalthr @fhueske , it will be great if you can review this.
---
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-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15584302#comment-15584302
]
ASF GitHub Bot commented on FLINK-4469:
---
GitHub user wuchong opened a pull request:
GitHub user wuchong opened a pull request:
https://github.com/apache/flink/pull/2653
[FLINK-4469] [table] Add support for user defined table function in Table
API & SQL
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list
[
https://issues.apache.org/jira/browse/FLINK-4315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15584198#comment-15584198
]
Evgeny Kincharov commented on FLINK-4315:
-
I have pushed new version of PR. Could
[
https://issues.apache.org/jira/browse/FLINK-4849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4849:
--
Description:
{code}
String trustStorePassword = sslConfig.getString(
ConfigConstants.SECURITY_SSL_
[
https://issues.apache.org/jira/browse/FLINK-4849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4849:
--
Comment: was deleted
(was: Dup of FLINK-4848)
> trustStorePassword should be checked against null in
> SSLUtil
[
https://issues.apache.org/jira/browse/FLINK-4849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu reopened FLINK-4849:
---
> trustStorePassword should be checked against null in
> SSLUtils#createSSLClientContext
> --
[
https://issues.apache.org/jira/browse/FLINK-4849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4849:
--
Summary: trustStorePassword should be checked against null in
SSLUtils#createSSLClientContext (was: keystoreFil
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582974#comment-15582974
]
Philipp von dem Bussche commented on FLINK-2821:
Thanks [~mxm], I am not g
Ted Yu created FLINK-4849:
-
Summary: keystoreFilePath should be checked against null in
SSLUtils#createSSLServerContext
Key: FLINK-4849
URL: https://issues.apache.org/jira/browse/FLINK-4849
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582930#comment-15582930
]
Ted Yu commented on FLINK-4848:
---
There is similar issue with trustStoreFilePath
> keystoreF
[
https://issues.apache.org/jira/browse/FLINK-4849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu resolved FLINK-4849.
---
Resolution: Duplicate
Dup of FLINK-4848
> keystoreFilePath should be checked against null in
> SSLUtils#crea
Ted Yu created FLINK-4848:
-
Summary: keystoreFilePath should be checked against null in
SSLUtils#createSSLServerContext
Key: FLINK-4848
URL: https://issues.apache.org/jira/browse/FLINK-4848
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582860#comment-15582860
]
ASF GitHub Bot commented on FLINK-4510:
---
Github user uce commented on the issue:
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2453
Thanks for the contribution. I'm going to merge this with slight
modifications. We don't need the introduced checks with the current master as
there is a check whether periodic checkpoints are activated.
[
https://issues.apache.org/jira/browse/FLINK-4174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vishnu viswanath reassigned FLINK-4174:
---
Assignee: vishnu viswanath
> Enhance Window Evictor
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-4844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582779#comment-15582779
]
ASF GitHub Bot commented on FLINK-4844:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582782#comment-15582782
]
ASF GitHub Bot commented on FLINK-4844:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582774#comment-15582774
]
ASF GitHub Bot commented on FLINK-4844:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582784#comment-15582784
]
ASF GitHub Bot commented on FLINK-4844:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582776#comment-15582776
]
ASF GitHub Bot commented on FLINK-4844:
---
Github user aljoscha commented on a diff in
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2648#discussion_r83680393
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorTest.java
---
@@ -2132,24 +2132,36 @@ public void
testRestor
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2648#discussion_r83685681
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/util/OneInputStreamOperatorTestHarness.java
---
@@ -199,30 +228,56 @@ public Environ
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2648#discussion_r83673478
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/SnapshotInProgressSubtaskState.java
---
@@ -0,0 +1,81 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-4844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582792#comment-15582792
]
ASF GitHub Bot commented on FLINK-4844:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582777#comment-15582777
]
ASF GitHub Bot commented on FLINK-4844:
---
Github user aljoscha commented on a diff in
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2648#discussion_r83682543
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
---
@@ -238,11 +294,51 @@ public void disp
[
https://issues.apache.org/jira/browse/FLINK-4844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582791#comment-15582791
]
ASF GitHub Bot commented on FLINK-4844:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582786#comment-15582786
]
ASF GitHub Bot commented on FLINK-4844:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582796#comment-15582796
]
ASF GitHub Bot commented on FLINK-4844:
---
Github user aljoscha commented on a diff in
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2648#discussion_r83673691
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/SubtaskState.java
---
@@ -34,10 +37,14 @@
private static final long
[
https://issues.apache.org/jira/browse/FLINK-4844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582794#comment-15582794
]
ASF GitHub Bot commented on FLINK-4844:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582793#comment-15582793
]
ASF GitHub Bot commented on FLINK-4844:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582787#comment-15582787
]
ASF GitHub Bot commented on FLINK-4844:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582785#comment-15582785
]
ASF GitHub Bot commented on FLINK-4844:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582788#comment-15582788
]
ASF GitHub Bot commented on FLINK-4844:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582789#comment-15582789
]
ASF GitHub Bot commented on FLINK-4844:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582795#comment-15582795
]
ASF GitHub Bot commented on FLINK-4844:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582775#comment-15582775
]
ASF GitHub Bot commented on FLINK-4844:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582780#comment-15582780
]
ASF GitHub Bot commented on FLINK-4844:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582778#comment-15582778
]
ASF GitHub Bot commented on FLINK-4844:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582781#comment-15582781
]
ASF GitHub Bot commented on FLINK-4844:
---
Github user aljoscha commented on a diff in
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2648#discussion_r83683321
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorStateHandles.java
---
@@ -0,0 +1,105 @@
+/*
+ * Licens
[
https://issues.apache.org/jira/browse/FLINK-4844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582783#comment-15582783
]
ASF GitHub Bot commented on FLINK-4844:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582790#comment-15582790
]
ASF GitHub Bot commented on FLINK-4844:
---
Github user aljoscha commented on a diff in
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2648#discussion_r83680077
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/util/NonClosingStreamDecorator.java
---
@@ -0,0 +1,76 @@
+/*
+ * Licensed to the Apac
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2648#discussion_r83676027
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/AbstractPartitionedCheckpointOutputStream.java
---
@@ -0,0 +1,79 @@
+/*
+ * Lic
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2648#discussion_r83662569
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java
---
@@
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2648#discussion_r83677603
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/DefaultOperatorStateBackend.java
---
@@ -132,7 +133,7 @@ public DefaultOperatorStateBac
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2648#discussion_r83679164
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyGroupsList.java
---
@@ -0,0 +1,28 @@
+/*
+ * Licensed to the Apache Software
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2648#discussion_r83661373
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerBase.java
---
@@
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2648#discussion_r83661983
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java
---
@@
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2648#discussion_r83679673
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/StateSnapshotContextSynchronousImpl.java
---
@@ -0,0 +1,117 @@
+/*
+ * Licensed
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2648#discussion_r83666257
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/state/OperatorStateStore.java
---
@@ -18,14 +18,18 @@
package org.apache.flink.api
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2648#discussion_r83678862
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ManagedSnapshotContext.java
---
@@ -0,0 +1,41 @@
+/*
+ * Licensed to the Apache
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2648#discussion_r83678698
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ManagedInitializationContext.java
---
@@ -0,0 +1,53 @@
+/*
+ * Licensed to the
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2648#discussion_r83676729
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ClosableRegistry.java
---
@@ -25,6 +25,13 @@
import java.util.HashSet;
import
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2648#discussion_r83669355
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
---
@@ -804,199 +792,15 @@ public boolean restoreLatest
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2648#discussion_r83664806
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/functions/RuntimeContext.java
---
@@ -48,7 +43,7 @@
* {@link AbstractRichFunction#getRu
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2648#discussion_r83674157
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskStateHandles.java
---
@@ -0,0 +1,172 @@
+/*
+ * Licensed to the Apache Soft
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2648#discussion_r83670574
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/OperatorStateHandle.java
---
@@ -38,8 +38,8 @@
private final StreamStateHandle
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2648#discussion_r83663696
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582735#comment-15582735
]
ASF GitHub Bot commented on FLINK-4715:
---
GitHub user uce opened a pull request:
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/2652
[FLINK-4715] Fail TaskManager with fatal error if task cancellation is stuck
- Splits the cancellation up into two threads:
* The `TaskCanceler` calls `cancel` on the invokable and `interrupt` on
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2211
Ah, thanks for pointing out the dependency on #2094. I wasn't aware of
that.
Will try to push that PR further than :-).
---
If your project is set up for it, you can reply to this email and hav
[
https://issues.apache.org/jira/browse/FLINK-3599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582606#comment-15582606
]
ASF GitHub Bot commented on FLINK-3599:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582605#comment-15582605
]
Maximilian Michels commented on FLINK-2821:
---
Thanks for testing [~philipp.bussch
[
https://issues.apache.org/jira/browse/FLINK-3599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582596#comment-15582596
]
ASF GitHub Bot commented on FLINK-3599:
---
Github user Xazax-hun commented on the issu
Github user Xazax-hun commented on the issue:
https://github.com/apache/flink/pull/2211
Hi!
This patch depends on the following pull request:
https://github.com/apache/flink/pull/2094
Once it is landed I will remove the [WIP] tag. I did not remove it yet
because I did not want
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2651
[FLINK-4847] Let RpcEndpoint.start/shutDown throw exceptions
Allowing the RpcEndpoint.start/shutDown to throw exceptions will help to
let rpc endpoints
to quickly fail without having to use
[
https://issues.apache.org/jira/browse/FLINK-4847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582405#comment-15582405
]
ASF GitHub Bot commented on FLINK-4847:
---
GitHub user tillrohrmann opened a pull requ
Till Rohrmann created FLINK-4847:
Summary: Let RpcEndpoint.start/shutDown throw exceptions
Key: FLINK-4847
URL: https://issues.apache.org/jira/browse/FLINK-4847
Project: Flink
Issue Type: Sub
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2498
Yes, I merge this later today.
---
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 wishe
[
https://issues.apache.org/jira/browse/FLINK-4619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582373#comment-15582373
]
ASF GitHub Bot commented on FLINK-4619:
---
Github user uce commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-4847:
Assignee: Till Rohrmann
> Let RpcEndpoint.start/shutDown throw exceptions
> ---
[
https://issues.apache.org/jira/browse/FLINK-4839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582341#comment-15582341
]
ASF GitHub Bot commented on FLINK-4839:
---
Github user KurtYoung closed the pull reque
Github user KurtYoung commented on the issue:
https://github.com/apache/flink/pull/2647
Thanks for you reviewing @tillrohrmann , closing it now.
---
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 hav
[
https://issues.apache.org/jira/browse/FLINK-4839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582342#comment-15582342
]
ASF GitHub Bot commented on FLINK-4839:
---
Github user KurtYoung commented on the issu
Github user KurtYoung closed the pull request at:
https://github.com/apache/flink/pull/2647
---
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 e
[
https://issues.apache.org/jira/browse/FLINK-4840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582332#comment-15582332
]
Stephan Ewen commented on FLINK-4840:
-
To me, throughput and latency could be in the I
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2646
Thanks for the update, looks good!
+1 to merge this
---
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 n
[
https://issues.apache.org/jira/browse/FLINK-4843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582323#comment-15582323
]
ASF GitHub Bot commented on FLINK-4843:
---
Github user StephanEwen commented on the is
1 - 100 of 209 matches
Mail list logo
