[GitHub] kl0u commented on a change in pull request #7039: [FLINK-8997] Added sliding window aggregation to datastream test job

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_r231851176 ## File path:

[GitHub] kl0u commented on a change in pull request #7039: [FLINK-8997] Added sliding window aggregation to datastream test job

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_r231851692 ## File path:

[GitHub] aljoscha commented on a change in pull request #7046: [FLINK-10803] Update the documentation to include changes to the S3 connector.

aljoscha commented on a change in pull request #7046: [FLINK-10803] Update the documentation to include changes to the S3 connector. URL: https://github.com/apache/flink/pull/7046#discussion_r231851388 ## File path: docs/dev/connectors/streamfile_sink.md ## @@ -24,16

[GitHub] StefanRRichter commented on issue #7036: [FLINK-10531][e2e] Fix unstable TTL end-to-end test.

StefanRRichter commented on issue #7036: [FLINK-10531][e2e] Fix unstable TTL end-to-end test. URL: https://github.com/apache/flink/pull/7036#issuecomment-436954874 I wonder if it would not make more sense to use a monotonous time provider for a single machine, such as `System.nanoTime()`,

[GitHub] zentol opened a new pull request #7056: [FLINK-10634][metrics][rest] Add metrics availability e2e test

zentol opened a new pull request #7056: [FLINK-10634][metrics][rest] Add metrics availability e2e test URL: https://github.com/apache/flink/pull/7056 ## What is the purpose of the change This PR adds an end-to-end test to ensure that JM/TM metrics are available via the REST API.

[GitHub] zentol opened a new pull request #7055: [FLINK-10823] Add missing scala suffixes

zentol opened a new pull request #7055: [FLINK-10823] Add missing scala suffixes URL: https://github.com/apache/flink/pull/7055 This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] asfgit closed pull request #7032: [FLINK-10765][test] Include s3p schema in S3 test

asfgit closed pull request #7032: [FLINK-10765][test] Include s3p schema in S3 test URL: https://github.com/apache/flink/pull/7032 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

[GitHub] StefanRRichter commented on issue #7032: [FLINK-10765][test] Include s3p schema in S3 test

StefanRRichter commented on issue #7032: [FLINK-10765][test] Include s3p schema in S3 test URL: https://github.com/apache/flink/pull/7032#issuecomment-436940643 Thanks @zentol! Merging. This is an automated message from the

[GitHub] asfgit closed pull request #7014: [FLINK-10770] [Table & SQL] Some generated functions are not opened properly.

asfgit closed pull request #7014: [FLINK-10770] [Table & SQL] Some generated functions are not opened properly. URL: https://github.com/apache/flink/pull/7014 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

[GitHub] tillrohrmann closed pull request #7027: [FLINK-10799][yarn] YARN mode JobManager JVM memory args add -XmsXXXm

tillrohrmann closed pull request #7027: [FLINK-10799][yarn] YARN mode JobManager JVM memory args add -XmsXXXm URL: https://github.com/apache/flink/pull/7027 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

[GitHub] asfgit closed pull request #7049: [FLINK-10816][cep] Fix LockableTypeSerializer.duplicate() to consider…

asfgit closed pull request #7049: [FLINK-10816][cep] Fix LockableTypeSerializer.duplicate() to consider… URL: https://github.com/apache/flink/pull/7049 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

[GitHub] StefanRRichter commented on issue #7049: [FLINK-10816][cep] Fix LockableTypeSerializer.duplicate() to consider…

StefanRRichter commented on issue #7049: [FLINK-10816][cep] Fix LockableTypeSerializer.duplicate() to consider… URL: https://github.com/apache/flink/pull/7049#issuecomment-436931807 Thanks for the review @zentol and @dawidwys. Will merge, including the minor changes from my response to

[GitHub] StefanRRichter commented on a change in pull request #7049: [FLINK-10816][cep] Fix LockableTypeSerializer.duplicate() to consider…

StefanRRichter commented on a change in pull request #7049: [FLINK-10816][cep] Fix LockableTypeSerializer.duplicate() to consider… URL: https://github.com/apache/flink/pull/7049#discussion_r231804087 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #7049: [FLINK-10816][cep] Fix LockableTypeSerializer.duplicate() to consider…

StefanRRichter commented on a change in pull request #7049: [FLINK-10816][cep] Fix LockableTypeSerializer.duplicate() to consider… URL: https://github.com/apache/flink/pull/7049#discussion_r231803566 ## File path:

[GitHub] yanghua opened a new pull request #7054: [FLINK-10771] Replace hard code of job graph file path with config option for FileJobGraphRetriever

yanghua opened a new 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 ## What is the purpose of the change *Replace hard code of job graph file path with config

[GitHub] zentol closed pull request #7043: [FLINK-10811][hcatalog] Add scala suffix

zentol closed pull request #7043: [FLINK-10811][hcatalog] Add scala suffix URL: https://github.com/apache/flink/pull/7043 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 foreign pull

[GitHub] yanghua commented on a change in pull request #6927: [FLINK-10624] Extend SQL client end-to-end to test new KafkaTableSink

yanghua 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_r231793883 ## File path: flink-end-to-end-tests/test-scripts/test_sql_client_common.sh ##

[GitHub] tzulitai opened a new pull request #7053: [FLINK-10635] [e2e] Add resume savepoint e2e test for per-job mode

tzulitai opened a new pull request #7053: [FLINK-10635] [e2e] Add resume savepoint e2e test for per-job mode URL: https://github.com/apache/flink/pull/7053 ## What is the purpose of the change This PR adds a new e2e test `test_per_job_cluster_resume_savepoint.sh` which tests taking

[GitHub] hequn8128 opened a new pull request #7052: [FLINK-10814][examples] Add scala suffix for Kafka example module

hequn8128 opened a new pull request #7052: [FLINK-10814][examples] Add scala suffix for Kafka example module URL: https://github.com/apache/flink/pull/7052 ## What is the purpose of the change The kafka examples need Scala suffixes just like flink-examples-batch and

<    1   2   3   4