[
https://issues.apache.org/jira/browse/FLINK-5583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855488#comment-15855488
]
Tzu-Li (Gordon) Tai edited comment on FLINK-5583 at 2/7/17 7:57 AM:
[
https://issues.apache.org/jira/browse/FLINK-5702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai reassigned FLINK-5702:
--
Assignee: Tzu-Li (Gordon) Tai
> Kafka Producer docs should warn if using setLog
[
https://issues.apache.org/jira/browse/FLINK-5583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855488#comment-15855488
]
Tzu-Li (Gordon) Tai edited comment on FLINK-5583 at 2/7/17 7:47 AM:
[
https://issues.apache.org/jira/browse/FLINK-5583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855488#comment-15855488
]
Tzu-Li (Gordon) Tai edited comment on FLINK-5583 at 2/7/17 7:47 AM:
[
https://issues.apache.org/jira/browse/FLINK-5583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855488#comment-15855488
]
Tzu-Li (Gordon) Tai commented on FLINK-5583:
The collector can be made thread-
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/3282
[FLINK-5702] [doc] At-least-once configuration info for FlinkKafkaProducer
Adds information about the `setLogFailureOnly` and `setFlushOnCheckpoint`
methods with regards to at-least-once guarantees
[
https://issues.apache.org/jira/browse/FLINK-5702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855483#comment-15855483
]
ASF GitHub Bot commented on FLINK-5702:
---
GitHub user tzulitai opened a pull request:
Tzu-Li (Gordon) Tai created FLINK-5728:
--
Summary: FlinkKafkaProducer should flush on checkpoint by default
Key: FLINK-5728
URL: https://issues.apache.org/jira/browse/FLINK-5728
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855478#comment-15855478
]
Haohui Mai commented on FLINK-5583:
---
The interface looks good to me. It looks like that
[
https://issues.apache.org/jira/browse/FLINK-5583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855466#comment-15855466
]
Tzu-Li (Gordon) Tai commented on FLINK-5583:
Ah, I see what you mean. For your
[
https://issues.apache.org/jira/browse/FLINK-5583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855466#comment-15855466
]
Tzu-Li (Gordon) Tai edited comment on FLINK-5583 at 2/7/17 7:21 AM:
[
https://issues.apache.org/jira/browse/FLINK-5583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855466#comment-15855466
]
Tzu-Li (Gordon) Tai edited comment on FLINK-5583 at 2/7/17 7:20 AM:
[
https://issues.apache.org/jira/browse/FLINK-5583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855466#comment-15855466
]
Tzu-Li (Gordon) Tai edited comment on FLINK-5583 at 2/7/17 7:17 AM:
[
https://issues.apache.org/jira/browse/FLINK-5583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855466#comment-15855466
]
Tzu-Li (Gordon) Tai edited comment on FLINK-5583 at 2/7/17 7:19 AM:
[
https://issues.apache.org/jira/browse/FLINK-5583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855466#comment-15855466
]
Tzu-Li (Gordon) Tai edited comment on FLINK-5583 at 2/7/17 7:18 AM:
[
https://issues.apache.org/jira/browse/FLINK-5583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855424#comment-15855424
]
Haohui Mai commented on FLINK-5583:
---
The pseudo-code looks like the following:
{code}
v
Github user WangTaoTheTonic commented on the issue:
https://github.com/apache/flink/pull/3274
@zentol Thanks for review. I've changed .jade file, but it looks like CI is
not up properly :(
---
If your project is set up for it, you can reply to this email and have your
reply appear on
[
https://issues.apache.org/jira/browse/FLINK-5723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855412#comment-15855412
]
ASF GitHub Bot commented on FLINK-5723:
---
Github user WangTaoTheTonic commented on th
GitHub user KurtYoung opened a pull request:
https://github.com/apache/flink/pull/3281
[FLINK-5727] [table] Unify some API of batch and stream TableEnvironment
This PR contains 3 changes:
1. move `sql` to base class
2. unify `scan` and `ingest` to `scan`, and move to bas
[
https://issues.apache.org/jira/browse/FLINK-5727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855407#comment-15855407
]
ASF GitHub Bot commented on FLINK-5727:
---
GitHub user KurtYoung opened a pull request
Github user docete commented on the issue:
https://github.com/apache/flink/pull/3111
Agree. If we have more than one distinct agg with groupings, do the
partition first and reuse the subsets would improve the performance.
Could we merge this PR first and create another JIRA to tra
[
https://issues.apache.org/jira/browse/FLINK-3475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855397#comment-15855397
]
ASF GitHub Bot commented on FLINK-3475:
---
Github user docete commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855383#comment-15855383
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user ramkrish86 commented on the iss
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/3149
@fhueske - A gentle reminder !!!
---
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
Kurt Young created FLINK-5727:
-
Summary: Unify some API of batch and stream TableEnvironment
Key: FLINK-5727
URL: https://issues.apache.org/jira/browse/FLINK-5727
Project: Flink
Issue Type: Impro
[
https://issues.apache.org/jira/browse/FLINK-5702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855325#comment-15855325
]
Tzu-Li (Gordon) Tai commented on FLINK-5702:
[~StephanEwen] Good point about c
[
https://issues.apache.org/jira/browse/FLINK-5704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855319#comment-15855319
]
Tzu-Li (Gordon) Tai commented on FLINK-5704:
FLINK-3679 and FLINK-5583 would p
[
https://issues.apache.org/jira/browse/FLINK-5583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855313#comment-15855313
]
Tzu-Li (Gordon) Tai commented on FLINK-5583:
Regarding breaking user code when
[
https://issues.apache.org/jira/browse/FLINK-5726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tao Meng updated FLINK-5726:
Summary: Add the RocketMQ plugin for the Apache Flink (was: Add the
RocketMQ plugin for the Apache Spark)
[
https://issues.apache.org/jira/browse/FLINK-5726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Longda Feng updated FLINK-5726:
---
External issue ID: ROCKETMQ-82
> Add the RocketMQ plugin for the Apache Spark
> --
Longda Feng created FLINK-5726:
--
Summary: Add the RocketMQ plugin for the Apache Spark
Key: FLINK-5726
URL: https://issues.apache.org/jira/browse/FLINK-5726
Project: Flink
Issue Type: Task
[
https://issues.apache.org/jira/browse/FLINK-5583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855251#comment-15855251
]
Tzu-Li (Gordon) Tai commented on FLINK-5583:
Hi [~wheat9],
I'm not quite sure
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855241#comment-15855241
]
ASF GitHub Bot commented on FLINK-4354:
---
Github user wangzhijiang999 commented on th
Github user wangzhijiang999 commented on the issue:
https://github.com/apache/flink/pull/2770
@tillrohrmann , thank you for review!
Actually this PR is out-of-date based on flip-6, and my following
modifications do not update this PR. This PR should be re-submitted based on
m
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855222#comment-15855222
]
ASF GitHub Bot commented on FLINK-4354:
---
Github user wangzhijiang999 commented on a
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855218#comment-15855218
]
ASF GitHub Bot commented on FLINK-4354:
---
Github user wangzhijiang999 commented on a
Github user wangzhijiang999 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2770#discussion_r99737255
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java
---
@@ -99,6 +101,13 @@ public TaskManagerRunner(
Github user wangzhijiang999 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2770#discussion_r99737204
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
---
@@ -1099,4 +1121,23 @@ public void run() {
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855217#comment-15855217
]
ASF GitHub Bot commented on FLINK-4354:
---
Github user wangzhijiang999 commented on a
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855216#comment-15855216
]
ASF GitHub Bot commented on FLINK-4354:
---
Github user wangzhijiang999 commented on a
Github user wangzhijiang999 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2770#discussion_r99737151
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManagerGateway.java
---
@@ -122,4 +122,11 @@ void notifySlotAv
Github user wangzhijiang999 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2770#discussion_r99737093
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
---
@@ -137,6 +140,7 @@ public ResourceManager(
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855212#comment-15855212
]
ASF GitHub Bot commented on FLINK-4354:
---
Github user wangzhijiang999 commented on a
Github user wangzhijiang999 commented on a diff in the pull request:
https://github.com/apache/flink/pull/2770#discussion_r99736682
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
---
@@ -340,7 +344,8 @@ public RegistrationRespon
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855209#comment-15855209
]
ASF GitHub Bot commented on FLINK-4364:
---
Github user wangzhijiang999 commented on a
Github user wangzhijiang999 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3151#discussion_r99736386
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
---
@@ -126,6 +129,9 @@
/** The metric registry
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855207#comment-15855207
]
ASF GitHub Bot commented on FLINK-4364:
---
Github user wangzhijiang999 commented on th
Github user wangzhijiang999 commented on the issue:
https://github.com/apache/flink/pull/3151
@tillrohrmann . Thank you for detail review and comments!
This PR just submit the heartbeat logic in TM side, because there is
already a jira of JM heartbeat side.
For my imp
Github user liuyuzhong7 commented on the issue:
https://github.com/apache/flink/pull/3138
@StephanEwen What should to to with this pull request?
---
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 ha
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855194#comment-15855194
]
ASF GitHub Bot commented on FLINK-4364:
---
Github user wangzhijiang999 commented on a
Github user wangzhijiang999 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3151#discussion_r99734627
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
---
@@ -741,6 +763,18 @@ private void establishJobManag
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855179#comment-15855179
]
ASF GitHub Bot commented on FLINK-4364:
---
Github user wangzhijiang999 commented on a
Github user wangzhijiang999 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3151#discussion_r99733319
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java
---
@@ -112,6 +114,13 @@ public TaskManagerRunner(
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855171#comment-15855171
]
ASF GitHub Bot commented on FLINK-4364:
---
Github user wangzhijiang999 commented on a
Github user wangzhijiang999 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3151#discussion_r99732610
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
---
@@ -1058,6 +1092,30 @@ public void handleError(Thro
Github user wangzhijiang999 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3151#discussion_r99732047
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
---
@@ -1058,6 +1092,30 @@ public void handleError(Thro
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855166#comment-15855166
]
ASF GitHub Bot commented on FLINK-4364:
---
Github user wangzhijiang999 commented on a
[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855154#comment-15855154
]
ASF GitHub Bot commented on FLINK-4364:
---
Github user wangzhijiang999 commented on a
Github user wangzhijiang999 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3151#discussion_r99731288
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMasterGateway.java
---
@@ -218,4 +218,12 @@ void failSlot(final ResourceI
[
https://issues.apache.org/jira/browse/FLINK-5725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-5725:
---
Component/s: Table API & SQL
> Support JOIN between two streams in the SQL API
> -
[
https://issues.apache.org/jira/browse/FLINK-5583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854944#comment-15854944
]
Haohui Mai commented on FLINK-5583:
---
In general (1) sounds good to me. Taking a closer l
[
https://issues.apache.org/jira/browse/FLINK-5624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854864#comment-15854864
]
ASF GitHub Bot commented on FLINK-5624:
---
Github user haohui commented on the issue:
Github user haohui commented on the issue:
https://github.com/apache/flink/pull/3252
Updated the PR to recognize the `GROUP BY` clause instead of the `OVER`
clause.
---
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
Haohui Mai created FLINK-5725:
-
Summary: Support JOIN between two streams in the SQL API
Key: FLINK-5725
URL: https://issues.apache.org/jira/browse/FLINK-5725
Project: Flink
Issue Type: New Featu
[
https://issues.apache.org/jira/browse/FLINK-5624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854818#comment-15854818
]
Haohui Mai commented on FLINK-5624:
---
Thanks for the explanation.
I took a closer look a
[
https://issues.apache.org/jira/browse/FLINK-5718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854677#comment-15854677
]
ASF GitHub Bot commented on FLINK-5718:
---
Github user greghogan commented on a diff i
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/3276#discussion_r99674991
--- Diff: docs/setup/config.md ---
@@ -86,7 +86,7 @@ The default fraction for managed memory can be adjusted
using the `taskmanager.m
- `taskmana
GitHub user Fokko opened a pull request:
https://github.com/apache/flink/pull/3280
[Flink-5724] Error in documentation zipping elements
Because the Scala tab is defined twice, it is not possible to open
the Python tab.
Please look at the documentation page itself:
h
[
https://issues.apache.org/jira/browse/FLINK-3163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-3163:
--
Fix Version/s: 1.3.0
> Configure Flink for NUMA systems
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-2908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-2908:
--
Fix Version/s: 1.3.0
> Web interface redraw web plan when browser resized
>
Fokko Driesprong created FLINK-5724:
---
Summary: Error in the 'Zipping Elements' docs
Key: FLINK-5724
URL: https://issues.apache.org/jira/browse/FLINK-5724
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-2883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-2883.
-
Resolution: Implemented
1.2: 37d6f8196f12714491c95adb73319bb36e7a0d34
master: 11ebf484280314231d146dcfb0b9
[
https://issues.apache.org/jira/browse/FLINK-5680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-5680.
-
Resolution: Implemented
1.2: 57cd0713183b4a2a2463736f672e1cd74cd913d6
master: 327ff060a7b64862aa6a33b6c8b0
[
https://issues.apache.org/jira/browse/FLINK-5680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854636#comment-15854636
]
ASF GitHub Bot commented on FLINK-5680:
---
Github user greghogan closed the pull reque
[
https://issues.apache.org/jira/browse/FLINK-2883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854637#comment-15854637
]
ASF GitHub Bot commented on FLINK-2883:
---
Github user greghogan closed the pull reque
Github user greghogan closed the pull request at:
https://github.com/apache/flink/pull/3256
---
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
Github user greghogan closed the pull request at:
https://github.com/apache/flink/pull/3247
---
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-5723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854572#comment-15854572
]
ASF GitHub Bot commented on FLINK-5723:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3274
you have to modify the corresponding jade files; modifications to the html
files will be overridden the next time someone builds the web-ui.
---
If your project is set up for it, you can reply to thi
[
https://issues.apache.org/jira/browse/FLINK-5376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-5376:
--
Description:
The following are two examples where ordered stream element queue is mentioned:
{code}
LOG.
[
https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15822346#comment-15822346
]
Ted Yu edited comment on FLINK-5486 at 2/6/17 6:20 PM:
---
Lock on Stat
[
https://issues.apache.org/jira/browse/FLINK-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-5488:
--
Description:
Here is one example:
{code}
if(jobManagerMemoryMb > maxRes.getMemory() ) {
failSessionDur
[
https://issues.apache.org/jira/browse/FLINK-3163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854437#comment-15854437
]
ASF GitHub Bot commented on FLINK-3163:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/3249
@StephanEwen from the discussion of FLINK-3163 I also had the idea of
`taskmanager.compute.fraction` where the number of slots would be a multiple of
the number of cores / vcores. Since Flink proce
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3279
---
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-5618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854417#comment-15854417
]
ASF GitHub Bot commented on FLINK-5618:
---
Github user asfgit closed the pull request
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/3278
@tillrohrmann
Yes, in the condition that you described, then at-least-once doesn't hold.
I said _might_ mainly considering there is chance that for every checkpoint
barrier, the previous events
[
https://issues.apache.org/jira/browse/FLINK-5701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854409#comment-15854409
]
ASF GitHub Bot commented on FLINK-5701:
---
Github user tzulitai commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-5564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854402#comment-15854402
]
Fabian Hueske edited comment on FLINK-5564 at 2/6/17 5:19 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-5564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854402#comment-15854402
]
Fabian Hueske commented on FLINK-5564:
--
Hi [~Shaoxuan Wang], I think it should be pos
[
https://issues.apache.org/jira/browse/FLINK-5575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854396#comment-15854396
]
ASF GitHub Bot commented on FLINK-5575:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3242
---
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-5575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-5575.
--
Resolution: Fixed
Fix Version/s: 1.2.0
1.1.5
1.3.0
Github user uce commented on the issue:
https://github.com/apache/flink/pull/3240
Could you please close this PR manually? Bot closing only works for the
master branch.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
[
https://issues.apache.org/jira/browse/FLINK-5575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854384#comment-15854384
]
ASF GitHub Bot commented on FLINK-5575:
---
Github user uce commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854383#comment-15854383
]
ASF GitHub Bot commented on FLINK-5575:
---
Github user uce commented on the issue:
Github user uce commented on the issue:
https://github.com/apache/flink/pull/3239
Could you please close this PR manually? Bot closing only works for the
master branch.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
[
https://issues.apache.org/jira/browse/FLINK-5575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854382#comment-15854382
]
ASF GitHub Bot commented on FLINK-5575:
---
Github user uce commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854385#comment-15854385
]
ASF GitHub Bot commented on FLINK-5575:
---
Github user uce commented on the issue:
Github user uce commented on the issue:
https://github.com/apache/flink/pull/3241
Could you please close this PR manually? Bot closing only works for the
master branch.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If
1 - 100 of 323 matches
Mail list logo
