Stephan Ewen created FLINK-8548:
---
Summary: Add Streaming State Machine Example
Key: FLINK-8548
URL: https://issues.apache.org/jira/browse/FLINK-8548
Project: Flink
Issue Type: Sub-task
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/5401
[FLINK-8548] [examples] Add state machine example
Example: Running a state machine for pattern detection
==
This example illustrat
[
https://issues.apache.org/jira/browse/FLINK-8548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16349946#comment-16349946
]
ASF GitHub Bot commented on FLINK-8548:
---
GitHub user StephanEwen opened a pull reque
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5371
The CI Server reports the following problem below. Apparently the
configurations cause warnings to be printed. Can you have a look at that?
```
Found non-empty .out files:
log4j:W
[
https://issues.apache.org/jira/browse/FLINK-8357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16349948#comment-16349948
]
ASF GitHub Bot commented on FLINK-8357:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16349962#comment-16349962
]
Fabian Hueske commented on FLINK-8545:
--
Yes, you are right. We also need to support a
Stephan Ewen created FLINK-8549:
---
Summary: Move TimerServiceOptions to TaskManagerOptions
Key: FLINK-8549
URL: https://issues.apache.org/jira/browse/FLINK-8549
Project: Flink
Issue Type: Improv
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/5402
[FLINK-8549] [config] Move TimerServiceOptions into TaskManagerOptions
The `TimerServiceOptions` are in the wrong place, which prohibits
generation of config docs. It also cause over-fragmentati
[
https://issues.apache.org/jira/browse/FLINK-8549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16349989#comment-16349989
]
ASF GitHub Bot commented on FLINK-8549:
---
GitHub user StephanEwen opened a pull reque
Hequn Cheng created FLINK-8550:
--
Summary: Iterate over entryset instead of keys
Key: FLINK-8550
URL: https://issues.apache.org/jira/browse/FLINK-8550
Project: Flink
Issue Type: Improvement
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5393#discussion_r165588081
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisShardAssigner.java
---
@@ -0,0 +
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5393#discussion_r165589453
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisShardAssigner.java
---
@@ -0,0 +
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5393#discussion_r165586434
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java
---
@@ -76
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5393#discussion_r165586994
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java
---
@@ -21
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5393#discussion_r165594279
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java
---
@@ -192,6 +198
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5393#discussion_r165588395
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisShardAssigner.java
---
@@ -0,0 +
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5393#discussion_r165588295
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisShardAssigner.java
---
@@ -0,0 +
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5393#discussion_r165587909
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisShardAssigner.java
---
@@ -0,0 +
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5393#discussion_r165589748
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisShardAssigner.java
---
@@ -0,0 +
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5393#discussion_r165591410
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java
---
@@ -192,6 +198
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5393#discussion_r165588489
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisShardAssigner.java
---
@@ -0,0 +
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5393#discussion_r165590401
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisShardAssigner.java
---
@@ -0,0 +
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5393#discussion_r165590209
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisShardAssigner.java
---
@@ -0,0 +
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5393#discussion_r165587359
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java
---
@@ -18
[
https://issues.apache.org/jira/browse/FLINK-8516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350049#comment-16350049
]
ASF GitHub Bot commented on FLINK-8516:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350038#comment-16350038
]
ASF GitHub Bot commented on FLINK-8516:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350039#comment-16350039
]
ASF GitHub Bot commented on FLINK-8516:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350042#comment-16350042
]
ASF GitHub Bot commented on FLINK-8516:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350047#comment-16350047
]
ASF GitHub Bot commented on FLINK-8516:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350044#comment-16350044
]
ASF GitHub Bot commented on FLINK-8516:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350041#comment-16350041
]
ASF GitHub Bot commented on FLINK-8516:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350045#comment-16350045
]
ASF GitHub Bot commented on FLINK-8516:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350050#comment-16350050
]
ASF GitHub Bot commented on FLINK-8516:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350037#comment-16350037
]
ASF GitHub Bot commented on FLINK-8516:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350043#comment-16350043
]
ASF GitHub Bot commented on FLINK-8516:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350040#comment-16350040
]
ASF GitHub Bot commented on FLINK-8516:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350046#comment-16350046
]
ASF GitHub Bot commented on FLINK-8516:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350048#comment-16350048
]
ASF GitHub Bot commented on FLINK-8516:
---
Github user tzulitai commented on a diff in
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5295
I think the changes are good! Thanks for working on this. ð
As a final change before merging, I would annotate the new classes/methods
as `@PublicEvolving`, would you be ok with that? An
[
https://issues.apache.org/jira/browse/FLINK-8543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8543:
Priority: Blocker (was: Major)
> Output Stream closed at org.apache.hadoop.fs.s3a.S3AOutput
[
https://issues.apache.org/jira/browse/FLINK-8543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8543:
Fix Version/s: 1.5.0
> Output Stream closed at org.apache.hadoop.fs.s3a.S3AOutputStream.chec
[
https://issues.apache.org/jira/browse/FLINK-8384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350119#comment-16350119
]
ASF GitHub Bot commented on FLINK-8384:
---
Github user aljoscha commented on the issue
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5402#discussion_r165623427
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java
---
@@ -206,6 +206,14 @@
key("task.cancella
[
https://issues.apache.org/jira/browse/FLINK-8549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350191#comment-16350191
]
ASF GitHub Bot commented on FLINK-8549:
---
Github user zentol commented on a diff in t
Github user dyanarose commented on the issue:
https://github.com/apache/flink/pull/5295
I like long myself, but I think that's only because I'm quite used to
working in milliseconds. As the existing static Session Windows take Time as
the gap, I think it made sense to have the extract
[
https://issues.apache.org/jira/browse/FLINK-8384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350138#comment-16350138
]
ASF GitHub Bot commented on FLINK-8384:
---
Github user dyanarose commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-8472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350146#comment-16350146
]
ASF GitHub Bot commented on FLINK-8472:
---
Github user tzulitai commented on the issue
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5364
Thanks for the reviews, I'll address Chesnay's comment and the merge this
then (to `master` and `release-1.4`).
---
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5402#discussion_r165626728
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java
---
@@ -206,6 +206,14 @@
key("task.can
[
https://issues.apache.org/jira/browse/FLINK-8549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350207#comment-16350207
]
ASF GitHub Bot commented on FLINK-8549:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5402
Thanks for the heads up - nice to know that the generator also supports
different projects now.
I am still leaning towards making this change, because all other shutdown
options are alre
[
https://issues.apache.org/jira/browse/FLINK-8549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350209#comment-16350209
]
ASF GitHub Bot commented on FLINK-8549:
---
Github user StephanEwen commented on the is
Github user uce commented on the issue:
https://github.com/apache/flink/pull/5395
https://issues.apache.org/jira/browse/INFRA-15959
`ruby2.3.1` has been installed on the buildbot. I will check whether the
build works as expected and report back here (probably only by next week
[
https://issues.apache.org/jira/browse/FLINK-8308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350108#comment-16350108
]
ASF GitHub Bot commented on FLINK-8308:
---
Github user uce commented on the issue:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5398
---
GitHub user StefanRRichter opened a pull request:
https://github.com/apache/flink/pull/5403
[WIP] Reschedule failed tasks to previous allocation (if possible).
This PR is a preview for early feedback on scheduler changes that make
allocations sticky under failures for local recovery
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5362#discussion_r165636384
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimeServiceManager.java
---
@@ -52,7 +52,7 @@
p
[
https://issues.apache.org/jira/browse/FLINK-8421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350259#comment-16350259
]
ASF GitHub Bot commented on FLINK-8421:
---
Github user aljoscha commented on a diff in
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5295
I get that logic, but the existing `TimestampAssigner` also returns a
`long` and if we return `Time` we always have to wrap/unwrap that long. What do
you think?
---
[
https://issues.apache.org/jira/browse/FLINK-8384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350278#comment-16350278
]
ASF GitHub Bot commented on FLINK-8384:
---
Github user aljoscha commented on the issue
GitHub user hequn8128 opened a pull request:
https://github.com/apache/flink/pull/5404
[FLINK-8550][table] Iterate over entryset instead of keys
## What is the purpose of the change
Iterate over entrysets instead of keys when we want to get both key and
value. I went o
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5362#discussion_r165646464
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimeServiceManager.java
---
@@ -52,7 +52,7 @@
p
[
https://issues.apache.org/jira/browse/FLINK-8421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350342#comment-16350342
]
ASF GitHub Bot commented on FLINK-8421:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350339#comment-16350339
]
ASF GitHub Bot commented on FLINK-8550:
---
GitHub user hequn8128 opened a pull request
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/5371
Thanks @StephanEwen review. Yea, You correct. DailyRollingFileAppender
doesn't support MaxFileSize, RollingFileAppender does. I will changed the code
to a correct version and wait for the CI en
[
https://issues.apache.org/jira/browse/FLINK-8357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350363#comment-16350363
]
ASF GitHub Bot commented on FLINK-8357:
---
Github user zhangminglei commented on the i
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/5357
In this case, could you please close the PR? (we cannot easily do that)
---
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/5356
I still do not believe that this is a significant improvement, and may even
increase confusion: Now you have two slightly different ways to do almost the
same thing, in one case you need to ta
[
https://issues.apache.org/jira/browse/FLINK-8364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350371#comment-16350371
]
ASF GitHub Bot commented on FLINK-8364:
---
Github user StefanRRichter commented on the
[
https://issues.apache.org/jira/browse/FLINK-8477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350403#comment-16350403
]
aitozi commented on FLINK-8477:
---
[~aljoscha]In production, some application like monitor typ
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/5230
@aljoscha I addressed your comments. Please have a look.
---
[
https://issues.apache.org/jira/browse/FLINK-8345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350425#comment-16350425
]
ASF GitHub Bot commented on FLINK-8345:
---
Github user kl0u commented on the issue:
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5172#discussion_r165663546
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnTaskManagerRunner.java ---
@@ -142,19 +153,10 @@ public static void runYarnTaskManager(String[]
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5172#discussion_r165635517
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnApplicationMasterRunner.java
---
@@ -170,9 +160,10 @@ protected int run(String[] args) {
[
https://issues.apache.org/jira/browse/FLINK-8275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350432#comment-16350432
]
ASF GitHub Bot commented on FLINK-8275:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350430#comment-16350430
]
ASF GitHub Bot commented on FLINK-8275:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350437#comment-16350437
]
aitozi commented on FLINK-6109:
---
OK， i will see the pr later .
> Add "consumer lag" report
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5172
@suez1224 Thanks a lot for the contribution!
I've had a look and the changes LGTM. I did have a comment regarding
injecting a dependency for the runner, which I've added a commit for.
Ca
[
https://issues.apache.org/jira/browse/FLINK-8275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350438#comment-16350438
]
ASF GitHub Bot commented on FLINK-8275:
---
Github user tzulitai commented on the issue
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5172#discussion_r165636080
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnTaskManagerRunner.java ---
@@ -142,19 +153,10 @@ public static void runYarnTaskManager(String[]
[
https://issues.apache.org/jira/browse/FLINK-8275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350431#comment-16350431
]
ASF GitHub Bot commented on FLINK-8275:
---
Github user tzulitai commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-8489:
Affects Version/s: 1.5.0
> Data is not emitted by second ElasticSearch connector
> -
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5397#discussion_r165666773
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TestingTaskExecutorGateway.java
---
@@ -75,6 +76,17 @@ public void
setDisconnectJob
[
https://issues.apache.org/jira/browse/FLINK-7856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350465#comment-16350465
]
ASF GitHub Bot commented on FLINK-7856:
---
Github user GJL commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-8489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-8489.
---
Resolution: Fixed
Fix Version/s: 1.4.1
1.5.0
1.4: dfa050c01adc559a3e
[
https://issues.apache.org/jira/browse/FLINK-6109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350468#comment-16350468
]
aitozi commented on FLINK-6109:
---
[~tzulitai] you mentioned that the calculate of the lag is
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5155
merging.
---
[
https://issues.apache.org/jira/browse/FLINK-4812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350488#comment-16350488
]
ASF GitHub Bot commented on FLINK-4812:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350548#comment-16350548
]
Hequn Cheng commented on FLINK-8545:
Hi, the {{Tuple}} input format is a good choice.
[
https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350548#comment-16350548
]
Hequn Cheng edited comment on FLINK-8545 at 2/2/18 4:08 PM:
Hi
[
https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350548#comment-16350548
]
Hequn Cheng edited comment on FLINK-8545 at 2/2/18 4:09 PM:
Hi
[
https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350548#comment-16350548
]
Hequn Cheng edited comment on FLINK-8545 at 2/2/18 4:01 PM:
Hi
Github user dyanarose commented on the issue:
https://github.com/apache/flink/pull/5295
erf, I see what you mean, as well as the creation of all those Time objects.
---
[
https://issues.apache.org/jira/browse/FLINK-8384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16350872#comment-16350872
]
ASF GitHub Bot commented on FLINK-8384:
---
Github user dyanarose commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-7588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-7588:
--
Labels: performance (was: )
> Document RocksDB tuning for spinning disks
>
[
https://issues.apache.org/jira/browse/FLINK-7525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16351081#comment-16351081
]
Ted Yu commented on FLINK-7525:
---
Looks like activity on FLINK-4319 has stalled.
> Add confi
GitHub user Aitozi opened a pull request:
https://github.com/apache/flink/pull/5405
[FLINK-8477][Window]Add api to support user to skip serval broken window
In production, some application like monitor type , it need the accuarcy
data,but in this scenario: if we start a job at 10:45
[
https://issues.apache.org/jira/browse/FLINK-8477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16351163#comment-16351163
]
ASF GitHub Bot commented on FLINK-8477:
---
GitHub user Aitozi opened a pull request:
Github user Aitozi commented on the issue:
https://github.com/apache/flink/pull/5405
cc @aljoscha please help review this patch.
see the picture above, when user choose
[
https://issues.apache.org/jira/browse/FLINK-8477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16351172#comment-16351172
]
ASF GitHub Bot commented on FLINK-8477:
---
Github user Aitozi commented on the issue:
1 - 100 of 122 matches
Mail list logo
