GitHub user yew1eb opened a pull request:
https://github.com/apache/flink/pull/4677
[FLINK-7626] Add some checkpoints metric description in docs
I export the metrics to the logfile via
Slf4jReporter(https://issues.apache.org/jira/browse/FLINK-4831), and found that
there are some ch
[
https://issues.apache.org/jira/browse/FLINK-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167430#comment-16167430
]
ASF GitHub Bot commented on FLINK-7378:
---
Github user zhijiangW commented on a diff i
Github user zhijiangW commented on a diff in the pull request:
https://github.com/apache/flink/pull/4485#discussion_r139076168
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/BufferPoolFactoryTest.java
---
@@ -155,6 +156,57 @@ public void testUnifo
[
https://issues.apache.org/jira/browse/FLINK-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167428#comment-16167428
]
ASF GitHub Bot commented on FLINK-7378:
---
Github user zhijiangW commented on a diff i
Github user zhijiangW commented on a diff in the pull request:
https://github.com/apache/flink/pull/4485#discussion_r139075946
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/BufferPoolFactoryTest.java
---
@@ -155,6 +156,57 @@ public void testUnifo
[
https://issues.apache.org/jira/browse/FLINK-7625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167389#comment-16167389
]
ASF GitHub Bot commented on FLINK-7625:
---
GitHub user yew1eb opened a pull request:
GitHub user yew1eb opened a pull request:
https://github.com/apache/flink/pull/4676
[FLINK-7625] Fix typo in metrics part of documents
metric: **Memory.Heap.Used** ==> **Heap.Used**
You can merge this pull request into a Git repository by running:
$ git pull https://github.co
[
https://issues.apache.org/jira/browse/FLINK-7386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167365#comment-16167365
]
ASF GitHub Bot commented on FLINK-7386:
---
Github user zjureel commented on the issue:
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4675
@rmetzger @tzulitai I create this PR and try to fix
[https://issues.apache.org/jira/browse/FLINK-7386(https://issues.apache.org/jira/browse/FLINK-7386).
In the PR I do some things as follows:
[
https://issues.apache.org/jira/browse/FLINK-7386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167357#comment-16167357
]
ASF GitHub Bot commented on FLINK-7386:
---
GitHub user zjureel opened a pull request:
GitHub user zjureel opened a pull request:
https://github.com/apache/flink/pull/4675
[FLINK-7386] FIx Elasticsearch 5 connector is not compatible with
Elasticsearch 5.2+ client
## What is the purpose of the change
Add flink-connector-elasticsearch5.3 to support Elasticsearc
[
https://issues.apache.org/jira/browse/FLINK-7627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167317#comment-16167317
]
ASF GitHub Bot commented on FLINK-7627:
---
GitHub user hequn8128 opened a pull request
GitHub user hequn8128 opened a pull request:
https://github.com/apache/flink/pull/4674
[FLINK-7627] [table] SingleElementIterable should implement with
Serializable
## What is the purpose of the change
*This pull request is a bugfix which implements `SingleElementItera
Hequn Cheng created FLINK-7627:
--
Summary: SingleElementIterable should implement with Serializable
Key: FLINK-7627
URL: https://issues.apache.org/jira/browse/FLINK-7627
Project: Flink
Issue Typ
[
https://issues.apache.org/jira/browse/FLINK-5858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he reassigned FLINK-5858:
-
Assignee: godfrey he
> Support multiple sinks in same execution DAG
> ---
[
https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167242#comment-16167242
]
Dian Fu edited comment on FLINK-7606 at 9/15/17 2:18 AM:
-
I think
[
https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167242#comment-16167242
]
Dian Fu commented on FLINK-7606:
I think this is by design otherwise users could not get t
[
https://issues.apache.org/jira/browse/FLINK-5859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167224#comment-16167224
]
ASF GitHub Bot commented on FLINK-5859:
---
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/4667#discussion_r139049572
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/PartitionableTableSource.scala
---
@@ -0,0 +1,193 @@
+/*
+ * L
[
https://issues.apache.org/jira/browse/FLINK-5859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167219#comment-16167219
]
ASF GitHub Bot commented on FLINK-5859:
---
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/4667#discussion_r139049316
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/PartitionableTableSource.scala
---
@@ -0,0 +1,193 @@
+/*
+ * L
[
https://issues.apache.org/jira/browse/FLINK-5859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167216#comment-16167216
]
ASF GitHub Bot commented on FLINK-5859:
---
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/4667#discussion_r139048604
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/PartitionableTableSource.scala
---
@@ -0,0 +1,193 @@
+/*
+ * L
[
https://issues.apache.org/jira/browse/FLINK-4047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167214#comment-16167214
]
ASF GitHub Bot commented on FLINK-4047:
---
Github user zhangminglei commented on a dif
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/4659#discussion_r139048412
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/functions/KeySelector.java
---
@@ -36,7 +37,7 @@
public interface KeySelector extends
[
https://issues.apache.org/jira/browse/FLINK-5859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167213#comment-16167213
]
ASF GitHub Bot commented on FLINK-5859:
---
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/4667#discussion_r139048337
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/sources/FilterableTableSource.scala
---
@@ -55,4 +55,9 @@ trait FilterableTabl
[
https://issues.apache.org/jira/browse/FLINK-7617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young closed FLINK-7617.
-
Resolution: Fixed
Fix Version/s: 1.3.3
1.4.0
> Remove string format in BitSet to
[
https://issues.apache.org/jira/browse/FLINK-7617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167179#comment-16167179
]
ASF GitHub Bot commented on FLINK-7617:
---
Github user KurtYoung commented on the issu
Github user KurtYoung commented on the issue:
https://github.com/apache/flink/pull/4668
@fhueske sure
---
[
https://issues.apache.org/jira/browse/FLINK-3991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167060#comment-16167060
]
Chetna Chaudhari commented on FLINK-3991:
-
Is it still open? Can I work on it?
>
Github user yestinchen commented on the issue:
https://github.com/apache/flink/pull/4673
Hi @dawidwys ,
I just found this issue in after match feature, which causes
AfterMatchSkipStrategy not work. This may be introduced while merging file
conflicts. I addressed that in this PR an
[
https://issues.apache.org/jira/browse/FLINK-7622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166925#comment-16166925
]
Bowen Li commented on FLINK-7622:
-
[~tzulitai] I think FLINK-7508 indirectly solves this i
[
https://issues.apache.org/jira/browse/FLINK-7508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166783#comment-16166783
]
ASF GitHub Bot commented on FLINK-7508:
---
Github user bowenli86 commented on the issu
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/4656
@tzulitai Thanks, Gordon! I watched your presentation on "managing state of
Flink", and you did a great job explaining all details.
I added an option for PER_REQUEST model since it doesn't
[
https://issues.apache.org/jira/browse/FLINK-7508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166709#comment-16166709
]
ASF GitHub Bot commented on FLINK-7508:
---
Github user bowenli86 commented on a diff i
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4656#discussion_r138965647
--- Diff:
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
---
@@ -171,8 +17
[
https://issues.apache.org/jira/browse/FLINK-7567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166633#comment-16166633
]
ASF GitHub Bot commented on FLINK-7567:
---
Github user mlipkovich commented on the iss
Github user mlipkovich commented on the issue:
https://github.com/apache/flink/pull/4655
The local build works fine. If you mean `mvn verify` by compatibility
plugin it also worked with no issues
---
[
https://issues.apache.org/jira/browse/FLINK-4814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166576#comment-16166576
]
Elias Levy commented on FLINK-4814:
---
Yes please. That would be helpful. I would sugges
Github user Xpray commented on the issue:
https://github.com/apache/flink/pull/4658
@twalthr , I've rewrite the methods, please have a look.
---
[
https://issues.apache.org/jira/browse/FLINK-7589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166527#comment-16166527
]
Steve Loughran commented on FLINK-7589:
---
bq. is there any plan to make Flink use AW
Github user Aitozi commented on the issue:
https://github.com/apache/flink/pull/4665
@aljoscha i agree that the name set to be "numLateElementsDropped", and do
you mean that my result should minus the num of element that go to side output
which is skipped and lateElement?
---
GitHub user yestinchen opened a pull request:
https://github.com/apache/flink/pull/4673
[hotfix] [cep] Fix afterMatchStrategy parameter missing issue
## What is the purpose of the change
Fix afterMatchSkipStrategy parameter missing when calling `nfa.process()`
function
[
https://issues.apache.org/jira/browse/FLINK-7589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166515#comment-16166515
]
Bowen Li commented on FLINK-7589:
-
[~aljoscha] Yes, the job restarted successfully.
Just
Github user Xpray commented on the issue:
https://github.com/apache/flink/pull/4658
what about overriding `leastRestrictiveSqlType` method in
`FlinkTypeFactory`?
---
[
https://issues.apache.org/jira/browse/FLINK-4796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166443#comment-16166443
]
Erik van Oosten commented on FLINK-4796:
I am not sure why this is marked as a dup
Github user Xpray commented on the issue:
https://github.com/apache/flink/pull/4658
Thanks for your advice. I am considering a better way to solve this.
---
[
https://issues.apache.org/jira/browse/FLINK-4814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166428#comment-16166428
]
Aljoscha Krettek commented on FLINK-4814:
-
Yes I think this is still a problem and
[
https://issues.apache.org/jira/browse/FLINK-4047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166401#comment-16166401
]
ASF GitHub Bot commented on FLINK-4047:
---
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/4659#discussion_r138918167
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/functions/KeySelector.java
---
@@ -36,7 +37,7 @@
public interface KeySelector extends Fun
[
https://issues.apache.org/jira/browse/FLINK-4796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-4796.
---
Resolution: Duplicate
> Add new Sink interface with access to more meta data
> ---
[
https://issues.apache.org/jira/browse/FLINK-4796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166394#comment-16166394
]
Aljoscha Krettek commented on FLINK-4796:
-
Ah I see, the workaround is for the NPE
[
https://issues.apache.org/jira/browse/FLINK-4796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166391#comment-16166391
]
Aljoscha Krettek commented on FLINK-4796:
-
Sorry, I didn't get what this workaroun
[
https://issues.apache.org/jira/browse/FLINK-4796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-4796:
---
Assignee: Aljoscha Krettek
> Add new Sink interface with access to more meta data
> -
[
https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166387#comment-16166387
]
Aljoscha Krettek commented on FLINK-2646:
-
I thought about this and the new {{clos
[
https://issues.apache.org/jira/browse/FLINK-7589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166370#comment-16166370
]
Aljoscha Krettek commented on FLINK-7589:
-
Yes, I think we cannot do much except w
[
https://issues.apache.org/jira/browse/FLINK-7617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166369#comment-16166369
]
ASF GitHub Bot commented on FLINK-7617:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/4668
Hi @KurtYoung, do you want to merge this to the `release-1.3` branch as
well?
---
[
https://issues.apache.org/jira/browse/FLINK-7567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166365#comment-16166365
]
ASF GitHub Bot commented on FLINK-7567:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/4655
You can try and run the build locally to have a look at the file generated
by the compatibility plugin. Then we can figure out why it's complaining.
---
Github user ggevay commented on a diff in the pull request:
https://github.com/apache/flink/pull/3511#discussion_r138905728
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/LargeRecordHandler.java
---
@@ -218,7 +221,7 @@ public long addRecord(T record)
Github user ggevay commented on a diff in the pull request:
https://github.com/apache/flink/pull/3511#discussion_r138904204
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerConfiguration.java
---
@@ -115,6 +115,13 @@ public Configuration getCo
[
https://issues.apache.org/jira/browse/FLINK-7617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-7617:
---
Assignee: Jingsong Lee
> Remove string format in BitSet to improve the performance of
[
https://issues.apache.org/jira/browse/FLINK-7607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-7607:
Fix Version/s: 1.4.0
> Web Frontend Hangs with Large Numbers of Tasks
>
[
https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166340#comment-16166340
]
Aljoscha Krettek commented on FLINK-7606:
-
Will NFAs not be cleared when the allow
[
https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-7606:
Summary: CEP operator leaks state (was: Memory leak on
NestedMapsStateTable)
> CEP operato
Github user ggevay commented on a diff in the pull request:
https://github.com/apache/flink/pull/3511#discussion_r138899420
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/LargeRecordHandler.java
---
@@ -218,7 +221,7 @@ public long addRecord(T record)
[
https://issues.apache.org/jira/browse/FLINK-7590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-7590:
Priority: Major (was: Blocker)
> Flink failed to flush and close the file system output str
[
https://issues.apache.org/jira/browse/FLINK-7590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166333#comment-16166333
]
Aljoscha Krettek commented on FLINK-7590:
-
Agreed!
> Flink failed to flush and cl
[
https://issues.apache.org/jira/browse/FLINK-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166323#comment-16166323
]
ASF GitHub Bot commented on FLINK-7378:
---
Github user NicoK commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166322#comment-16166322
]
ASF GitHub Bot commented on FLINK-7378:
---
Github user NicoK commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166324#comment-16166324
]
ASF GitHub Bot commented on FLINK-7378:
---
Github user NicoK commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166328#comment-16166328
]
ASF GitHub Bot commented on FLINK-7378:
---
Github user NicoK commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-7608:
Priority: Blocker (was: Major)
> LatencyGauge change to histogram metric
> ---
[
https://issues.apache.org/jira/browse/FLINK-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166327#comment-16166327
]
ASF GitHub Bot commented on FLINK-7378:
---
Github user NicoK commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166329#comment-16166329
]
ASF GitHub Bot commented on FLINK-7378:
---
Github user NicoK commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166325#comment-16166325
]
ASF GitHub Bot commented on FLINK-7378:
---
Github user NicoK commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166331#comment-16166331
]
ASF GitHub Bot commented on FLINK-7378:
---
Github user NicoK commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166330#comment-16166330
]
ASF GitHub Bot commented on FLINK-7378:
---
Github user NicoK commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166326#comment-16166326
]
ASF GitHub Bot commented on FLINK-7378:
---
Github user NicoK commented on a diff in th
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4485#discussion_r138891582
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPoolTest.java
---
@@ -172,44 +178,117 @@ public void testDestroy
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4485#discussion_r138889161
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPoolTest.java
---
@@ -172,44 +178,117 @@ public void testDestroy
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4485#discussion_r13882
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPoolTest.java
---
@@ -172,44 +178,117 @@ public void testDestroy
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4485#discussion_r138879343
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPool.java
---
@@ -159,23 +159,20 @@ public void recycle(MemorySe
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4485#discussion_r13514
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPoolTest.java
---
@@ -172,44 +178,117 @@ public void testDestroy
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4485#discussion_r138897087
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.java
---
@@ -333,7 +333,7 @@ public void
updateI
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4485#discussion_r138889183
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPoolTest.java
---
@@ -172,44 +178,117 @@ public void testDestroy
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4485#discussion_r138852758
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/BufferPoolFactoryTest.java
---
@@ -155,6 +156,57 @@ public void testUniformDi
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4485#discussion_r13440
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPoolTest.java
---
@@ -172,44 +178,117 @@ public void testDestroy
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4485#discussion_r138853431
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/BufferPoolFactoryTest.java
---
@@ -155,6 +156,57 @@ public void testUniformDi
Hai Zhou created FLINK-7626:
---
Summary: Add some metric description about checkpoints
Key: FLINK-7626
URL: https://issues.apache.org/jira/browse/FLINK-7626
Project: Flink
Issue Type: Bug
C
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/4658#discussion_r138894127
--- Diff:
flink-libraries/flink-table/src/main/java/org/apache/calcite/sql/type/SqlTypeFactoryImpl.java
---
@@ -0,0 +1,575 @@
+/*
+ * Licensed to th
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/4665
These are not actually the places where you can count dropped data. I would
suggest to add this at the very end of `processElement()` where we also check
whether we should side-output late data:
ht
[
https://issues.apache.org/jira/browse/FLINK-6331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-6331.
Resolution: Cannot Reproduce
Could not reproduce the problem. Will close the issue therefore. If thi
[
https://issues.apache.org/jira/browse/FLINK-5205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-5205.
Resolution: Won't Fix
Seems not to be a problem and with the Flip-6 changes obsolete.
> Asynchronou
[
https://issues.apache.org/jira/browse/FLINK-2733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-2733.
Resolution: Not A Problem
> ZooKeeperLeaderElectionTest.testZooKeeperReelection fails
>
[
https://issues.apache.org/jira/browse/FLINK-2733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166301#comment-16166301
]
Till Rohrmann commented on FLINK-2733:
--
I think [~tonycox], you actually did not use
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/4672
Thanks @Xpray. The changes look good, but I think if we would really want
to have the correct behavior, we need to make more changes at different
positions. Could you add some more tests to check ins
[
https://issues.apache.org/jira/browse/FLINK-2253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-2253:
Assignee: (was: Till Rohrmann)
> ALS fails if the data flow is split up and the input i
1 - 100 of 175 matches
Mail list logo
