[
https://issues.apache.org/jira/browse/FLINK-10845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xueyu reassigned FLINK-10845:
-
Assignee: xueyu
> Support DISTINCT aggregates for batch
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-10847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-10847:
---
Assignee: Hequn Cheng
> Add support for IS NOT DISTINCT FROM in code generator
> --
[
https://issues.apache.org/jira/browse/FLINK-10846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xueyu reassigned FLINK-10846:
-
Assignee: xueyu
> Add support for IS DISTINCT FROM in code generator
>
[
https://issues.apache.org/jira/browse/FLINK-10844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681734#comment-16681734
]
Stefan Richter edited comment on FLINK-10844 at 11/9/18 5:28 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-10844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681734#comment-16681734
]
Stefan Richter commented on FLINK-10844:
I don't think that it is an issue with
[
https://issues.apache.org/jira/browse/FLINK-10482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681680#comment-16681680
]
Andrey Zagrebin commented on FLINK-10482:
-
[~JBiason]
do you still have the ful
[
https://issues.apache.org/jira/browse/FLINK-10847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-10847:
-
Issue Type: Sub-task (was: New Feature)
Parent: FLINK-6810
> Add support for IS NOT DIS
Timo Walther created FLINK-10847:
Summary: Add support for IS NOT DISTINCT FROM in code generator
Key: FLINK-10847
URL: https://issues.apache.org/jira/browse/FLINK-10847
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-10846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-10846:
-
Issue Type: Sub-task (was: New Feature)
Parent: FLINK-6810
> Add support for IS DISTINC
Timo Walther created FLINK-10846:
Summary: Add support for IS DISTINCT FROM in code generator
Key: FLINK-10846
URL: https://issues.apache.org/jira/browse/FLINK-10846
Project: Flink
Issue Type
Timo Walther created FLINK-10845:
Summary: Support DISTINCT aggregates for batch
Key: FLINK-10845
URL: https://issues.apache.org/jira/browse/FLINK-10845
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-10736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681562#comment-16681562
]
ASF GitHub Bot commented on FLINK-10736:
azagrebin opened a new pull request #70
[
https://issues.apache.org/jira/browse/FLINK-10736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10736:
---
Labels: pull-request-available test-stability (was: test-stability)
> Shaded Hadoop S3A end
azagrebin opened a new pull request #7077: [FLINK-10736][E2E tests] Use already
uploaded to s3 file in shaded s3 e2e tests
URL: https://github.com/apache/flink/pull/7077
## What is the purpose of the change
Remove s3 put/delete from s3 shaded e2e tests and use already uploaded,
neve
[
https://issues.apache.org/jira/browse/FLINK-10844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681533#comment-16681533
]
Daniel Harper commented on FLINK-10844:
---
Note I can see this code was changed for
[
https://issues.apache.org/jira/browse/FLINK-7155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681556#comment-16681556
]
ASF GitHub Bot commented on FLINK-7155:
---
zentol commented on a change in pull reque
zentol commented on a change in pull request #6976: [FLINK-7155][metrics] Add
new metrics reporter to InfluxDB
URL: https://github.com/apache/flink/pull/6976#discussion_r232280371
##
File path:
flink-metrics/flink-metrics-influxdb/src/main/java/org/apache/flink/metrics/influxdb/Met
[
https://issues.apache.org/jira/browse/FLINK-7155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681550#comment-16681550
]
ASF GitHub Bot commented on FLINK-7155:
---
zentol commented on a change in pull reque
zentol commented on a change in pull request #6976: [FLINK-7155][metrics] Add
new metrics reporter to InfluxDB
URL: https://github.com/apache/flink/pull/6976#discussion_r232279530
##
File path:
flink-metrics/flink-metrics-influxdb/src/test/java/org/apache/flink/metrics/influxdb/Met
Daniel Harper created FLINK-10844:
-
Summary: ArrayIndexOutOfBoundsException during checkpoint (Flink
1.5.2)
Key: FLINK-10844
URL: https://issues.apache.org/jira/browse/FLINK-10844
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-10626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681513#comment-16681513
]
ASF GitHub Bot commented on FLINK-10626:
pnowojski commented on a change in pull
[
https://issues.apache.org/jira/browse/FLINK-10626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681512#comment-16681512
]
ASF GitHub Bot commented on FLINK-10626:
pnowojski commented on a change in pull
[
https://issues.apache.org/jira/browse/FLINK-10626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681514#comment-16681514
]
ASF GitHub Bot commented on FLINK-10626:
pnowojski commented on a change in pull
pnowojski commented on a change in pull request #7065: [FLINK-10626] [docs]
[table] Add documentation for event-time temporal table joins
URL: https://github.com/apache/flink/pull/7065#discussion_r232268635
##
File path: docs/dev/table/streaming/joins.md
##
@@ -189,14 +189
pnowojski commented on a change in pull request #7065: [FLINK-10626] [docs]
[table] Add documentation for event-time temporal table joins
URL: https://github.com/apache/flink/pull/7065#discussion_r232267090
##
File path: docs/dev/table/streaming/joins.md
##
@@ -189,14 +189
pnowojski commented on a change in pull request #7065: [FLINK-10626] [docs]
[table] Add documentation for event-time temporal table joins
URL: https://github.com/apache/flink/pull/7065#discussion_r232268772
##
File path: docs/dev/table/streaming/joins.md
##
@@ -189,14 +189
[
https://issues.apache.org/jira/browse/FLINK-10828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681505#comment-16681505
]
Till Rohrmann commented on FLINK-10828:
---
I was referring to
{{org.apache.flink.te
[
https://issues.apache.org/jira/browse/FLINK-10674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681497#comment-16681497
]
ASF GitHub Bot commented on FLINK-10674:
wenhuitang opened a new pull request #7
wenhuitang opened a new pull request #7076: [Patch]:Fix
[FLINK-10674]DistinctAccumulator.remove lead to NPE.
URL: https://github.com/apache/flink/pull/7076
## What is the purpose of the change
This pull request fixes the problem reported by FLINK-10674
DistinctAccumulator.remove lea
[
https://issues.apache.org/jira/browse/FLINK-10835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-10835.
--
Resolution: Fixed
Fix Version/s: 1.8.0
merged commit 091cff3 into apache:master
> Remo
[
https://issues.apache.org/jira/browse/FLINK-10835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681490#comment-16681490
]
ASF GitHub Bot commented on FLINK-10835:
pnowojski closed pull request #7069: [F
pnowojski closed pull request #7069: [FLINK-10835][network] Remove duplicated
round-robin ChannelSelector implementation
URL: https://github.com/apache/flink/pull/7069
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the s
[
https://issues.apache.org/jira/browse/FLINK-10764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681488#comment-16681488
]
ASF GitHub Bot commented on FLINK-10764:
GJL opened a new pull request #7075: [F
[
https://issues.apache.org/jira/browse/FLINK-10764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10764:
---
Labels: pull-request-available (was: )
> Add S3 entropy injection end-to-end/IT test
>
GJL opened a new pull request #7075: [FLINK-10764][tests] Add ITCase for
checkpoint path entropy injection.
URL: https://github.com/apache/flink/pull/7075
Add a test that verifies that checkpoint data on the file system has
additional
entropy added to its path.
Remove code duplic
[
https://issues.apache.org/jira/browse/FLINK-10628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681477#comment-16681477
]
ASF GitHub Bot commented on FLINK-10628:
azagrebin commented on issue #6967: [FL
[
https://issues.apache.org/jira/browse/FLINK-10481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz reassigned FLINK-10481:
Assignee: Dawid Wysakowicz
> Wordcount end-to-end test in docker env unstable
> -
[
https://issues.apache.org/jira/browse/FLINK-10842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10842:
---
Labels: pull-request-available (was: )
> Waiting loops are broken in e2e/common.sh
> --
[
https://issues.apache.org/jira/browse/FLINK-7155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681483#comment-16681483
]
ASF GitHub Bot commented on FLINK-7155:
---
1u0 commented on a change in pull request
[
https://issues.apache.org/jira/browse/FLINK-10820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681482#comment-16681482
]
ASF GitHub Bot commented on FLINK-10820:
pnowojski commented on a change in pull
[
https://issues.apache.org/jira/browse/FLINK-10827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681480#comment-16681480
]
ASF GitHub Bot commented on FLINK-10827:
zentol commented on a change in pull re
1u0 commented on a change in pull request #6976: [FLINK-7155][metrics] Add new
metrics reporter to InfluxDB
URL: https://github.com/apache/flink/pull/6976#discussion_r232263625
##
File path:
flink-metrics/flink-metrics-influxdb/src/main/java/org/apache/flink/metrics/influxdb/Metric
[
https://issues.apache.org/jira/browse/FLINK-10628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681479#comment-16681479
]
ASF GitHub Bot commented on FLINK-10628:
azagrebin edited a comment on issue #69
azagrebin edited a comment on issue #6967: [FLINK-10628][E2E][SSL] Enable
mutual REST SSL auth in e2e tests
URL: https://github.com/apache/flink/pull/6967#issuecomment-437369228
I reverted the loop changes and factored out them into another PR #7073 for
new issue [FLINK-10842](https://issu
dawidwys opened a new pull request #7074: [FLINK-10481][e2e] Added retry logic
for building docker image
URL: https://github.com/apache/flink/pull/7074
Added retry logic around building docker job image.
This is an automated
zentol commented on a change in pull request #7061: [FLINK-10827][tests] Add
test for duplicate() to SerializerTestBase
URL: https://github.com/apache/flink/pull/7061#discussion_r232263454
##
File path:
flink-core/src/test/java/org/apache/flink/api/common/typeutils/SerializerTestBa
pnowojski commented on a change in pull request #7051: [FLINK-10820][network]
Simplify the RebalancePartitioner implementation
URL: https://github.com/apache/flink/pull/7051#discussion_r232263469
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/pa
[
https://issues.apache.org/jira/browse/FLINK-10481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681478#comment-16681478
]
ASF GitHub Bot commented on FLINK-10481:
dawidwys opened a new pull request #707
azagrebin commented on issue #6967: [FLINK-10628][E2E][SSL] Enable mutual REST
SSL auth in e2e tests
URL: https://github.com/apache/flink/pull/6967#issuecomment-437369228
I reverted the loop changes and factored out them into another PR #7073 for
new issue FLINK-10842.
---
[
https://issues.apache.org/jira/browse/FLINK-10481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10481:
---
Labels: pull-request-available test-stability (was: test-stability)
> Wordcount end-to-end
[
https://issues.apache.org/jira/browse/FLINK-10819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681469#comment-16681469
]
sunjincheng commented on FLINK-10819:
-
Thanks [~till.rohrmann]， I am sorry that I di
[
https://issues.apache.org/jira/browse/FLINK-10674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681456#comment-16681456
]
ASF GitHub Bot commented on FLINK-10674:
ambition119 commented on issue #7067: [
azagrebin commented on issue #7073: [FLINK-10842][E2E tests] fix broken waiting
loops in common.sh
URL: https://github.com/apache/flink/pull/7073#issuecomment-437367164
cc @zentol
This is an automated message from the Apache
[
https://issues.apache.org/jira/browse/FLINK-10842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681462#comment-16681462
]
ASF GitHub Bot commented on FLINK-10842:
azagrebin opened a new pull request #70
[
https://issues.apache.org/jira/browse/FLINK-10842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrey Zagrebin updated FLINK-10842:
Affects Version/s: 1.7.0
> Waiting loops are broken in e2e/common.sh
> ---
Timo Walther created FLINK-10843:
Summary: Make Kafka version definition more flexible for new Kafka
table factory
Key: FLINK-10843
URL: https://issues.apache.org/jira/browse/FLINK-10843
Project: Flin
[
https://issues.apache.org/jira/browse/FLINK-10842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681463#comment-16681463
]
ASF GitHub Bot commented on FLINK-10842:
azagrebin commented on issue #7073: [FL
[
https://issues.apache.org/jira/browse/FLINK-10771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-10771.
---
Resolution: Fixed
Fix Version/s: 1.7.0
Fixed via fbfa2460ce25aaa11eb0a011015af335602d
azagrebin opened a new pull request #7073: [FLINK-10842][E2E tests] fix broken
waiting loops in common.sh
URL: https://github.com/apache/flink/pull/7073
## What is the purpose of the change
There are 3 loops in flink-end-to-end-tests/test-scripts/common.sh where the
script waits for
ambition119 commented on issue #7067: [FLINK-10674] [table]
DistinctAccumulator.remove occur NPE
URL: https://github.com/apache/flink/pull/7067#issuecomment-437366592
sorry, Complex Event Processing (CEP) SQL Realization this commit I can't
remove
-
[
https://issues.apache.org/jira/browse/FLINK-6046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681453#comment-16681453
]
ASF GitHub Bot commented on FLINK-6046:
---
TisonKun commented on issue #7050: [hotfix
[
https://issues.apache.org/jira/browse/FLINK-10662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681454#comment-16681454
]
Piotr Nowojski commented on FLINK-10662:
Yes, back in the past I was also thinki
TisonKun commented on issue #7050: [hotfix] Follow up FLINK-6046 to clean
unused variable
URL: https://github.com/apache/flink/pull/7050#issuecomment-437366246
Thank @zhijiangW and @tillrohrmann for reviews!
To @zhijiangW sorry for response too late to catch the discussion. I copy
t
[
https://issues.apache.org/jira/browse/FLINK-10843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-10843:
-
Affects Version/s: 1.7.0
> Make Kafka version definition more flexible for new Kafka table facto
[
https://issues.apache.org/jira/browse/FLINK-10771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681448#comment-16681448
]
ASF GitHub Bot commented on FLINK-10771:
asfgit closed pull request #7054: [FLIN
asfgit closed pull request #7054: [FLINK-10771] Replace hard code of job graph
file path with config option for FileJobGraphRetriever
URL: https://github.com/apache/flink/pull/7054
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed be
[
https://issues.apache.org/jira/browse/FLINK-10842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrey Zagrebin updated FLINK-10842:
Fix Version/s: 1.7.0
> Waiting loops are broken in e2e/common.sh
> ---
[
https://issues.apache.org/jira/browse/FLINK-10842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrey Zagrebin updated FLINK-10842:
Component/s: E2E Tests
> Waiting loops are broken in e2e/common.sh
> -
Andrey Zagrebin created FLINK-10842:
---
Summary: Waiting loops are broken in e2e/common.sh
Key: FLINK-10842
URL: https://issues.apache.org/jira/browse/FLINK-10842
Project: Flink
Issue Type: B
[
https://issues.apache.org/jira/browse/FLINK-10624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681446#comment-16681446
]
ASF GitHub Bot commented on FLINK-10624:
twalthr commented on a change in pull r
[
https://issues.apache.org/jira/browse/FLINK-10827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681445#comment-16681445
]
ASF GitHub Bot commented on FLINK-10827:
StefanRRichter commented on a change in
twalthr commented on a change in pull request #6927: [FLINK-10624] Extend SQL
client end-to-end to test new KafkaTableSink
URL: https://github.com/apache/flink/pull/6927#discussion_r232257714
##
File path: flink-end-to-end-tests/flink-sql-client-test-kafka-0.10/pom.xml
##
StefanRRichter commented on a change in pull request #7061:
[FLINK-10827][tests] Add test for duplicate() to SerializerTestBase
URL: https://github.com/apache/flink/pull/7061#discussion_r232249327
##
File path:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/Po
[
https://issues.apache.org/jira/browse/FLINK-7155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681441#comment-16681441
]
ASF GitHub Bot commented on FLINK-7155:
---
1u0 commented on a change in pull request
[
https://issues.apache.org/jira/browse/FLINK-7155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681439#comment-16681439
]
ASF GitHub Bot commented on FLINK-7155:
---
1u0 commented on a change in pull request
1u0 commented on a change in pull request #6976: [FLINK-7155][metrics] Add new
metrics reporter to InfluxDB
URL: https://github.com/apache/flink/pull/6976#discussion_r232255912
##
File path:
flink-metrics/flink-metrics-influxdb/src/test/java/org/apache/flink/metrics/influxdb/Measur
1u0 commented on a change in pull request #6976: [FLINK-7155][metrics] Add new
metrics reporter to InfluxDB
URL: https://github.com/apache/flink/pull/6976#discussion_r232256095
##
File path:
flink-metrics/flink-metrics-influxdb/src/test/java/org/apache/flink/metrics/influxdb/Measur
Pawel Bartoszek created FLINK-10841:
---
Summary: Reduce the number of ListObjects calls when checkpointing
to S3
Key: FLINK-10841
URL: https://issues.apache.org/jira/browse/FLINK-10841
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681433#comment-16681433
]
ASF GitHub Bot commented on FLINK-7155:
---
1u0 commented on a change in pull request
tillrohrmann closed pull request #7050: [hotfix] Follow up FLINK-6046 to clean
unused variable
URL: https://github.com/apache/flink/pull/7050
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As thi
1u0 commented on a change in pull request #6976: [FLINK-7155][metrics] Add new
metrics reporter to InfluxDB
URL: https://github.com/apache/flink/pull/6976#discussion_r232254767
##
File path:
flink-metrics/flink-metrics-influxdb/src/test/java/org/apache/flink/metrics/influxdb/Metric
[
https://issues.apache.org/jira/browse/FLINK-6046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681430#comment-16681430
]
ASF GitHub Bot commented on FLINK-6046:
---
tillrohrmann closed pull request #7050: [h
[
https://issues.apache.org/jira/browse/FLINK-10828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-10828:
--
Fix Version/s: 1.8.0
> Enforce that all TypeSerializers are tested through SerializerTestBase
[
https://issues.apache.org/jira/browse/FLINK-10840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681421#comment-16681421
]
Till Rohrmann commented on FLINK-10840:
---
You pass in the {{Collection}} stored in
[
https://issues.apache.org/jira/browse/FLINK-10674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681419#comment-16681419
]
ASF GitHub Bot commented on FLINK-10674:
ambition119 removed a comment on issue
ambition119 removed a comment on issue #7067: [FLINK-10674] [table]
DistinctAccumulator.remove occur NPE
URL: https://github.com/apache/flink/pull/7067#issuecomment-437321281
Complex Event Processing (CEP) SQL Realization is a new feature. Use
statement :
```sql
SELECT [ ALL | DIST
[
https://issues.apache.org/jira/browse/FLINK-10838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-10838:
-
Description:
Currently we have many tests that in order to test for example `at-least-on
[
https://issues.apache.org/jira/browse/FLINK-10827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681417#comment-16681417
]
ASF GitHub Bot commented on FLINK-10827:
StefanRRichter commented on a change in
StefanRRichter commented on a change in pull request #7061:
[FLINK-10827][tests] Add test for duplicate() to SerializerTestBase
URL: https://github.com/apache/flink/pull/7061#discussion_r232249327
##
File path:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/Po
[
https://issues.apache.org/jira/browse/FLINK-10827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681415#comment-16681415
]
ASF GitHub Bot commented on FLINK-10827:
StefanRRichter commented on a change in
StefanRRichter commented on a change in pull request #7061:
[FLINK-10827][tests] Add test for duplicate() to SerializerTestBase
URL: https://github.com/apache/flink/pull/7061#discussion_r232249327
##
File path:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/Po
[
https://issues.apache.org/jira/browse/FLINK-10821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681409#comment-16681409
]
ASF GitHub Bot commented on FLINK-10821:
igalshilman opened a new pull request #
[
https://issues.apache.org/jira/browse/FLINK-10821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10821:
---
Labels: pull-request-available (was: )
> Resuming Externalized Checkpoint E2E test does not
igalshilman opened a new pull request #7072: [FLINK-10821] E2E now uses
externalized checkpoint
URL: https://github.com/apache/flink/pull/7072
## What is the purpose of the change
This PR fixes the `test_resume_externalized_checkpoints.sh` script,
by providing the path to the exte
[
https://issues.apache.org/jira/browse/FLINK-10251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681407#comment-16681407
]
ASF GitHub Bot commented on FLINK-10251:
tillrohrmann commented on issue #6876:
tillrohrmann commented on issue #6876: [FLINK-10251] Handle oversized response
messages in AkkaRpcActor
URL: https://github.com/apache/flink/pull/6876#issuecomment-437353852
Thanks for the reminder @yanghua. I'm still busy with the 1.7 release. Once
it is out, I'll take a look at this PR.
[
https://issues.apache.org/jira/browse/FLINK-10840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681398#comment-16681398
]
vinoyang commented on FLINK-10840:
--
yes.Isn't it?
> BucketingSink incorrectly clears t
[
https://issues.apache.org/jira/browse/FLINK-10827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681397#comment-16681397
]
ASF GitHub Bot commented on FLINK-10827:
zentol commented on a change in pull re
zentol commented on a change in pull request #7061: [FLINK-10827][tests] Add
test for duplicate() to SerializerTestBase
URL: https://github.com/apache/flink/pull/7061#discussion_r232240467
##
File path:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/PojoSerial
[
https://issues.apache.org/jira/browse/FLINK-10840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681395#comment-16681395
]
Chesnay Schepler commented on FLINK-10840:
--
[~yanghua] are you asking whether {
1 - 100 of 224 matches
Mail list logo
