[
https://issues.apache.org/jira/browse/FLINK-9002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16679343#comment-16679343
]
ASF GitHub Bot commented on FLINK-9002:
---
tzulitai commented on a change in pull req
[
https://issues.apache.org/jira/browse/FLINK-10819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16679498#comment-16679498
]
Till Rohrmann commented on FLINK-10819:
---
Thanks for reporting this issue. Could yo
[
https://issues.apache.org/jira/browse/FLINK-10817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10817:
---
Labels: pull-request-available (was: )
> Upgrade presto dependency to support path-style ac
[
https://issues.apache.org/jira/browse/FLINK-10770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-10770.
--
Resolution: Fixed
Fix Version/s: 1.7.0
1.6.3
1.5.6
[
https://issues.apache.org/jira/browse/FLINK-10776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16679526#comment-16679526
]
Till Rohrmann commented on FLINK-10776:
---
This issues seems to be a duplicate of FL
[
https://issues.apache.org/jira/browse/FLINK-10814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16679187#comment-16679187
]
vinoyang commented on FLINK-10814:
--
Hi [~hequn8128] Are you already fixing this issue?
[
https://issues.apache.org/jira/browse/FLINK-10676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16679151#comment-16679151
]
ASF GitHub Bot commented on FLINK-10676:
sunjincheng121 commented on issue #6949
[
https://issues.apache.org/jira/browse/FLINK-10436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16679721#comment-16679721
]
ASF GitHub Bot commented on FLINK-10436:
tillrohrmann commented on issue #6872:
[
https://issues.apache.org/jira/browse/FLINK-6046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16679204#comment-16679204
]
ASF GitHub Bot commented on FLINK-6046:
---
TisonKun opened a new pull request #7050:
[
https://issues.apache.org/jira/browse/FLINK-10361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16679667#comment-16679667
]
ASF GitHub Bot commented on FLINK-10361:
zentol opened a new pull request #7057:
[
https://issues.apache.org/jira/browse/FLINK-10346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16679274#comment-16679274
]
Congxian Qiu edited comment on FLINK-10346 at 11/8/18 3:46 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-10814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-10814:
---
Assignee: Hequn Cheng
> Kafka examples modules need scala suffix
>
[
https://issues.apache.org/jira/browse/FLINK-10817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-10817:
Assignee: Aljoscha Krettek
> Upgrade presto dependency to support path-style acce
[
https://issues.apache.org/jira/browse/FLINK-10819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-10819:
--
Fix Version/s: (was: 1.7.1)
1.7.0
> The instability problem of CI,
> J
[
https://issues.apache.org/jira/browse/FLINK-10820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10820:
---
Labels: pull-request-available (was: )
> Simplify the RebalancePartitioner implementation
>
[
https://issues.apache.org/jira/browse/FLINK-9875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TisonKun closed FLINK-9875.
---
Resolution: Won't Fix
Further discussion about parallelizing the creation of InputSplit goes to
FLINK-10038
[
https://issues.apache.org/jira/browse/FLINK-8997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16679618#comment-16679618
]
ASF GitHub Bot commented on FLINK-8997:
---
kl0u commented on a change in pull request
[
https://issues.apache.org/jira/browse/FLINK-10531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16679597#comment-16679597
]
ASF GitHub Bot commented on FLINK-10531:
StefanRRichter commented on issue #7036
[
https://issues.apache.org/jira/browse/FLINK-8997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16679622#comment-16679622
]
ASF GitHub Bot commented on FLINK-8997:
---
kl0u commented on a change in pull request
[
https://issues.apache.org/jira/browse/FLINK-9001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16679684#comment-16679684
]
ASF GitHub Bot commented on FLINK-9001:
---
twalthr commented on a change in pull requ
[
https://issues.apache.org/jira/browse/FLINK-10700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16679230#comment-16679230
]
ASF GitHub Bot commented on FLINK-10700:
TisonKun commented on issue #6946: [FLI
[
https://issues.apache.org/jira/browse/FLINK-10756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-10756:
--
Priority: Critical (was: Major)
> TaskManagerProcessFailureBatchRecoveryITCase did not finish
[
https://issues.apache.org/jira/browse/FLINK-10814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16679718#comment-16679718
]
ASF GitHub Bot commented on FLINK-10814:
hequn8128 commented on issue #7052: [FL
[
https://issues.apache.org/jira/browse/FLINK-10770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16679528#comment-16679528
]
ASF GitHub Bot commented on FLINK-10770:
asfgit closed pull request #7014: [FLIN
Stefan Richter created FLINK-10828:
--
Summary: Enforce that all TypeSerializers are tested through
SerializerTestBase
Key: FLINK-10828
URL: https://issues.apache.org/jira/browse/FLINK-10828
Project: F
[
https://issues.apache.org/jira/browse/FLINK-10361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-10361.
--
Resolution: Fixed
Fixed in 1.8.0: d946ec5f130c4d3ffaa0e9b8d9abd35ba3224661
Fixed in 1.7.0: e34
[
https://issues.apache.org/jira/browse/FLINK-10676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16679285#comment-16679285
]
ASF GitHub Bot commented on FLINK-10676:
asfgit closed pull request #6949: [FLIN
[
https://issues.apache.org/jira/browse/FLINK-8997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16679623#comment-16679623
]
ASF GitHub Bot commented on FLINK-8997:
---
kl0u commented on a change in pull request
[
https://issues.apache.org/jira/browse/FLINK-10814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16679403#comment-16679403
]
ASF GitHub Bot commented on FLINK-10814:
hequn8128 opened a new pull request #70
[
https://issues.apache.org/jira/browse/FLINK-10361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16679175#comment-16679175
]
Biao Liu commented on FLINK-10361:
--
Hi [~twalthr]
Could you offer more details?
The s
[
https://issues.apache.org/jira/browse/FLINK-10676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16679270#comment-16679270
]
ASF GitHub Bot commented on FLINK-10676:
sunjincheng121 commented on issue #6949
[
https://issues.apache.org/jira/browse/FLINK-10626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10626:
---
Labels: pull-request-available (was: )
> Add documentation for temporal table joins
> -
[
https://issues.apache.org/jira/browse/FLINK-10816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-10816.
--
Resolution: Fixed
Fix Version/s: 1.7.0
1.6.3
Merged in:
master: 997f
[
https://issues.apache.org/jira/browse/FLINK-10361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16679722#comment-16679722
]
ASF GitHub Bot commented on FLINK-10361:
asfgit closed pull request #7057: [FLIN
[
https://issues.apache.org/jira/browse/FLINK-10799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-10799.
---
Resolution: Fixed
Fixed via
https://github.com/apache/flink/commit/a53f97525f8ad1c321574b92
zentol commented on a change in pull request #7058: [FLINK-10817] Upgrade
presto dependency to support path-style access
URL: https://github.com/apache/flink/pull/7058#discussion_r232004611
##
File path: docs/ops/filesystems.md
##
@@ -48,7 +48,7 @@ including any NFS or SAN
[
https://issues.apache.org/jira/browse/FLINK-10626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16679994#comment-16679994
]
ASF GitHub Bot commented on FLINK-10626:
twalthr opened a new pull request #7065
[
https://issues.apache.org/jira/browse/FLINK-10686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16679755#comment-16679755
]
ASF GitHub Bot commented on FLINK-10686:
xueyumusic opened a new pull request #7
[
https://issues.apache.org/jira/browse/FLINK-10825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16679821#comment-16679821
]
ASF GitHub Bot commented on FLINK-10825:
zentol opened a new pull request #7062:
[
https://issues.apache.org/jira/browse/FLINK-10825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10825:
---
Labels: pull-request-available (was: )
> ConnectedComponents test instable on Travis
>
[
https://issues.apache.org/jira/browse/FLINK-10686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10686:
---
Labels: pull-request-available (was: )
> Introduce a flink-table-common module
> --
[
https://issues.apache.org/jira/browse/FLINK-10791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16679767#comment-16679767
]
ASF GitHub Bot commented on FLINK-10791:
pnowojski commented on issue #7038: [FL
[
https://issues.apache.org/jira/browse/FLINK-10791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16679766#comment-16679766
]
ASF GitHub Bot commented on FLINK-10791:
pnowojski closed pull request #7038: [F
[
https://issues.apache.org/jira/browse/FLINK-10251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16679904#comment-16679904
]
ASF GitHub Bot commented on FLINK-10251:
yanghua commented on issue #6876: [FLIN
[
https://issues.apache.org/jira/browse/FLINK-8997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16679817#comment-16679817
]
ASF GitHub Bot commented on FLINK-8997:
---
dawidwys commented on a change in pull req
[
https://issues.apache.org/jira/browse/FLINK-10826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10826:
---
Labels: pull-request-available (was: )
> Heavy deployment end-to-end test produces no outpu
[
https://issues.apache.org/jira/browse/FLINK-10676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16679786#comment-16679786
]
ASF GitHub Bot commented on FLINK-10676:
hequn8128 commented on issue #6949: [FL
[
https://issues.apache.org/jira/browse/FLINK-10826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16680061#comment-16680061
]
Stefan Richter commented on FLINK-10826:
I think we just need to tune this test
[
https://issues.apache.org/jira/browse/FLINK-10826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reassigned FLINK-10826:
--
Assignee: Stefan Richter (was: Hequn Cheng)
> Heavy deployment end-to-end test produ
[
https://issues.apache.org/jira/browse/FLINK-10826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16680068#comment-16680068
]
ASF GitHub Bot commented on FLINK-10826:
StefanRRichter opened a new pull reques
StefanRRichter opened a new pull request #7066: [FLINK-10826][test] Decrease
deployment size of heavy deplyment e2e t…
URL: https://github.com/apache/flink/pull/7066
## What is the purpose of the change
The previous size of the deployment turned out to be too heavy for Travis,
so I
twalthr opened a new pull request #7065: [FLINK-10626] [docs] [table] Add
documentation for event-time temporal table joins
URL: https://github.com/apache/flink/pull/7065
## What is the purpose of the change
Adds documentation for event-time temporal joins.
## Brief change log
twalthr commented on issue #6675: [FLINK-10258] [sql-client] Allow streaming
sources to be present for batch executions
URL: https://github.com/apache/flink/pull/6675#issuecomment-437055333
@yanghua Please don't ping people again and again. You already pinged me 4
times here. Usually, all
pnowojski 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_r231950736
##
File path: flink-end-to-end-tests/test-scripts/test_sql_client_common.sh
##
pnowojski 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_r231951627
##
File path: flink-end-to-end-tests/flink-sql-client-test-kafka-0.10/pom.xml
##
pnowojski 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_r231950479
##
File path: flink-end-to-end-tests/test-scripts/test_sql_client_common.sh
##
kl0u edited a comment on issue #7036: [FLINK-10531][e2e] Fix unstable TTL
end-to-end test.
URL: https://github.com/apache/flink/pull/7036#issuecomment-437051981
Actually, now @StefanRRichter mentioned it, we have the `TtlTimeProvider`
and the `ProcessingTimeService`. Both of them are used
kl0u commented on issue #7036: [FLINK-10531][e2e] Fix unstable TTL end-to-end
test.
URL: https://github.com/apache/flink/pull/7036#issuecomment-437051981
Actually, now @StefanRRichter mentioned it, we have the `TtlTimeProvider`
and the `ProcessingTimeService`. Both of them are used interna
hequn8128 commented on issue #7052: [FLINK-10814][examples] Add scala suffix
for Kafka example module
URL: https://github.com/apache/flink/pull/7052#issuecomment-437047887
@zentol Have updated and rebased to the master. Would be great if you can
take a look.
-
kl0u commented on issue #7036: [FLINK-10531][e2e] Fix unstable TTL end-to-end
test.
URL: https://github.com/apache/flink/pull/7036#issuecomment-437044814
@azagrebin I commented on https://issues.apache.org/jira/browse/FLINK-10830
about my concerns of allowing the user to specify his/her ow
azagrebin edited a comment on issue #7036: [FLINK-10531][e2e] Fix unstable TTL
end-to-end test.
URL: https://github.com/apache/flink/pull/7036#issuecomment-437038969
I agree that configuring custom processing time provider on the API side is
more robust approach for tests. The change might
azagrebin commented on issue #7036: [FLINK-10531][e2e] Fix unstable TTL
end-to-end test.
URL: https://github.com/apache/flink/pull/7036#issuecomment-437038969
I agree that configuring custom processing time provider on the API side is
more robust approach for tests. The change might be a b
yanghua commented on issue #6675: [FLINK-10258] [sql-client] Allow streaming
sources to be present for batch executions
URL: https://github.com/apache/flink/pull/6675#issuecomment-437036158
cc @fhueske @twalthr @pnowojski
Th
yanghua commented on issue #6876: [FLINK-10251] Handle oversized response
messages in AkkaRpcActor
URL: https://github.com/apache/flink/pull/6876#issuecomment-437035419
cc @tillrohrmann
This is an automated message from the
StefanRRichter opened a new pull request #7064: [FLINK-10753] Improve
propagation and logging of snapshot exceptions
URL: https://github.com/apache/flink/pull/7064
## What is the purpose of the change
This PR aims to improve the propagation and logging of exceptions that
happen duri
hequn8128 commented on issue #7052: [FLINK-10814][examples] Add scala suffix
for Kafka example module
URL: https://github.com/apache/flink/pull/7052#issuecomment-437012816
@zentol Thanks for your explanation. I will address your comments and rebase
to the master. PS: I find the `flink-exam
pnowojski commented on a change in pull request #7060: [FLINK-10801][e2e] Retry
verify_result_hash in elastichsearch-common
URL: https://github.com/apache/flink/pull/7060#discussion_r231908066
##
File path: flink-end-to-end-tests/test-scripts/elasticsearch-common.sh
##
@@
twalthr commented on a change in pull request #7060: [FLINK-10801][e2e] Retry
verify_result_hash in elastichsearch-common
URL: https://github.com/apache/flink/pull/7060#discussion_r231904591
##
File path: flink-end-to-end-tests/test-scripts/elasticsearch-common.sh
##
@@ -8
zentol opened a new pull request #7063: [FLINK-10829][tests] Add support for
running jars in FlinkDistribution
URL: https://github.com/apache/flink/pull/7063
## What is the purpose of the change
This PR extends the `FlinkDistribution` to allow running jars. As a first
use-case I've
zentol opened a new pull request #7062: [FLINK-10825][tests] Increase
request-backoff for high-parallelism e2e test
URL: https://github.com/apache/flink/pull/7062
## What is the purpose of the change
This PR stabilizes the high-parallelism iterations e2e test.
When a task star
dawidwys commented on a change in pull request #7039: [FLINK-8997] Added
sliding window aggregation to datastream test job
URL: https://github.com/apache/flink/pull/7039#discussion_r231902404
##
File path:
flink-end-to-end-tests/flink-datastream-allround-test/src/main/java/org/apac
dawidwys commented on issue #7039: [FLINK-8997] Added sliding window
aggregation to datastream test job
URL: https://github.com/apache/flink/pull/7039#issuecomment-437006435
Thanks @kl0u for the review. I've updated the PR. Could you have another
look?
dawidwys commented on a change in pull request #7039: [FLINK-8997] Added
sliding window aggregation to datastream test job
URL: https://github.com/apache/flink/pull/7039#discussion_r231900451
##
File path:
flink-end-to-end-tests/flink-datastream-allround-test/src/main/java/org/apac
zentol commented on issue #7052: [FLINK-10814][examples] Add scala suffix for
Kafka example module
URL: https://github.com/apache/flink/pull/7052#issuecomment-437004573
That doesn't matter; by depending on scala-infected modules they are also
regarded as infected as they (and anyone depend
kl0u commented on a change in pull request #7039: [FLINK-8997] Added sliding
window aggregation to datastream test job
URL: https://github.com/apache/flink/pull/7039#discussion_r231897342
##
File path:
flink-end-to-end-tests/flink-datastream-allround-test/src/main/java/org/apache/f
hequn8128 commented on issue #6949: [FLINK-10676][table] Add 'as' method for
OverWindowWithOrderBy
URL: https://github.com/apache/flink/pull/6949#issuecomment-437000167
Thanks a lot for the review and merging!
This is an auto
StefanRRichter opened a new pull request #7061: [FLINK-10827][tests] Add test
for duplicate() to SerializerTestBase
URL: https://github.com/apache/flink/pull/7061
## What is the purpose of the change
This PR adds a test for proper implementation of `TypeSerializer#duplicate`
to `Ser
dawidwys commented on a change in pull request #7039: [FLINK-8997] Added
sliding window aggregation to datastream test job
URL: https://github.com/apache/flink/pull/7039#discussion_r231888718
##
File path:
flink-end-to-end-tests/flink-datastream-allround-test/src/main/java/org/apac
pnowojski commented on issue #7038: [FLINK-10791] Provide end-to-end test for
Kafka 0.11 connector
URL: https://github.com/apache/flink/pull/7038#issuecomment-436996121
Thanks @yanghua! Merged.
This is an automated message fr
pnowojski closed pull request #7038: [FLINK-10791] Provide end-to-end test for
Kafka 0.11 connector
URL: https://github.com/apache/flink/pull/7038
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:
A
pnowojski opened a new pull request #7060: [FLINK-10801][e2e] Retry
verify_result_hash in elastichsearch-common
URL: https://github.com/apache/flink/pull/7060
Instead of looping the verification until the expected number of results
loop until we get the correct output. This tries to solve
xueyumusic opened a new pull request #7059: [FLINK-10686][table] Port UDFs in
Table API extension points to flink-table-common
URL: https://github.com/apache/flink/pull/7059
## What is the purpose of the change
This PR tries to port UDFs interfaces of TableApi extension points to
fl
kl0u closed pull request #7046: [FLINK-10803] Update the documentation to
include changes to the S3 connector.
URL: https://github.com/apache/flink/pull/7046
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 pro
aljoscha opened a new pull request #7058: [FLINK-10817] Upgrade presto
dependency to support path-style access
URL: https://github.com/apache/flink/pull/7058
## What is the purpose of the change
Update to newer Presto to allow path-style access.
## Brief change log
- Bump
tillrohrmann commented on issue #6872: [FLINK-10436] Add
ConfigOption#withFallbackKeys
URL: https://github.com/apache/flink/pull/6872#issuecomment-436985378
Thanks for the reminder @TisonKun. I'll get back to that once the release is
out, because I'm the release manager.
-
asfgit closed pull request #7057: [FLINK-10361][tests][ES] Properly wait for ES
to start
URL: https://github.com/apache/flink/pull/7057
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 this is a
hequn8128 commented on issue #7052: [FLINK-10814][examples] Add scala suffix
for Kafka example module
URL: https://github.com/apache/flink/pull/7052#issuecomment-436984872
Hi @zentol , thanks a lot for your review.
Should we add scala suffix to a java module? I find both
`flink-exa
zentol commented on a change in pull request #7045: [hotfix] Update nightly
master cron jobs
URL: https://github.com/apache/flink/pull/7045#discussion_r231874926
##
File path: nightly.sh
##
@@ -43,7 +43,7 @@ mkdir -p $ARTIFACTS_DIR || { echo "FAILURE: cannot create
log di
zentol commented on a change in pull request #7045: [hotfix] Update nightly
master cron jobs
URL: https://github.com/apache/flink/pull/7045#discussion_r231874082
##
File path: nightly.sh
##
@@ -43,7 +43,7 @@ mkdir -p $ARTIFACTS_DIR || { echo "FAILURE: cannot create
log di
kl0u commented on issue #7046: [FLINK-10803] Update the documentation to
include changes to the S3 connector.
URL: https://github.com/apache/flink/pull/7046#issuecomment-436982606
Thanks a lot for the comments @zentol and @aljoscha ! I will integrate them
and merge.
--
yanghua commented on issue #7054: [FLINK-10771] Replace hard code of job graph
file path with config option for FileJobGraphRetriever
URL: https://github.com/apache/flink/pull/7054#issuecomment-436980445
cc @tillrohrmann
Thi
aljoscha commented on issue #7046: [FLINK-10803] Update the documentation to
include changes to the S3 connector.
URL: https://github.com/apache/flink/pull/7046#issuecomment-436980403
I think the changes look good modulo the comments @zentol and I had.
twalthr commented on a change in pull request #7042: [FLINK-9001] [e2e] Add
operators with input type that goes through Kryo serialization
URL: https://github.com/apache/flink/pull/7042#discussion_r231868105
##
File path:
flink-end-to-end-tests/flink-datastream-allround-test/src/m
zentol opened a new pull request #7057: [FLINK-10361][tests][ES] Properly wait
for ES to start
URL: https://github.com/apache/flink/pull/7057
## What is the purpose of the change
This PR fixes `elasticsearch-common.sh#wait_elasticsearch_working` not
actually waiting for ES to start
kl0u commented on a change in pull request #7039: [FLINK-8997] Added sliding
window aggregation to datastream test job
URL: https://github.com/apache/flink/pull/7039#discussion_r231847473
##
File path:
flink-end-to-end-tests/flink-datastream-allround-test/src/main/java/org/apache/f
kl0u commented on a change in pull request #7039: [FLINK-8997] Added sliding
window aggregation to datastream test job
URL: https://github.com/apache/flink/pull/7039#discussion_r231845864
##
File path:
flink-end-to-end-tests/flink-datastream-allround-test/src/main/java/org/apache/f
kl0u commented on a change in pull request #7039: [FLINK-8997] Added sliding
window aggregation to datastream test job
URL: https://github.com/apache/flink/pull/7039#discussion_r231851366
##
File path:
flink-end-to-end-tests/flink-datastream-allround-test/src/main/java/org/apache/f
kl0u commented on a change in pull request #7039: [FLINK-8997] Added sliding
window aggregation to datastream test job
URL: https://github.com/apache/flink/pull/7039#discussion_r231846771
##
File path:
flink-end-to-end-tests/flink-datastream-allround-test/src/main/java/org/apache/f
kl0u commented on a change in pull request #7039: [FLINK-8997] Added sliding
window aggregation to datastream test job
URL: https://github.com/apache/flink/pull/7039#discussion_r231851570
##
File path:
flink-end-to-end-tests/flink-datastream-allround-test/src/main/java/org/apache/f
kl0u commented on a change in pull request #7039: [FLINK-8997] Added sliding
window aggregation to datastream test job
URL: https://github.com/apache/flink/pull/7039#discussion_r231850714
##
File path:
flink-end-to-end-tests/flink-datastream-allround-test/src/main/java/org/apache/f
201 - 300 of 319 matches
Mail list logo
