[jira] [Commented] (FLINK-10766) Add a link to flink-china.org in Flink website

[ https://issues.apache.org/jira/browse/FLINK-10766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16684644#comment-16684644 ] ASF GitHub Bot commented on FLINK-10766: wuchong closed pull request #134: [FLINK-10766] Add a

[GitHub] maqingxiang opened a new pull request #7083: [hotfix][flink-runtime] modify maxAttempts when find a unique file name for the spilling channel

maqingxiang opened a new pull request #7083: [hotfix][flink-runtime] modify maxAttempts when find a unique file name for the spilling channel URL: https://github.com/apache/flink/pull/7083 This is an automated message from

[GitHub] hequn8128 commented on a change in pull request #7079: [FLINK-10845][table] Support multiple different DISTINCT aggregates for batch

hequn8128 commented on a change in pull request #7079: [FLINK-10845][table] Support multiple different DISTINCT aggregates for batch URL: https://github.com/apache/flink/pull/7079#discussion_r232887060 ## File path:

[GitHub] hequn8128 commented on a change in pull request #7079: [FLINK-10845][table] Support multiple different DISTINCT aggregates for batch

hequn8128 commented on a change in pull request #7079: [FLINK-10845][table] Support multiple different DISTINCT aggregates for batch URL: https://github.com/apache/flink/pull/7079#discussion_r232887066 ## File path:

[jira] [Commented] (FLINK-9555) Support table api in scala shell

[ https://issues.apache.org/jira/browse/FLINK-9555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16684704#comment-16684704 ] sunjincheng commented on FLINK-9555: Thanks for report this issue Jeff Zhang ！ +1 to make TableApi

[jira] [Commented] (FLINK-10845) Support DISTINCT aggregates for batch

[ https://issues.apache.org/jira/browse/FLINK-10845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16684676#comment-16684676 ] ASF GitHub Bot commented on FLINK-10845: hequn8128 commented on a change in pull request #7079:

[jira] [Commented] (FLINK-10845) Support DISTINCT aggregates for batch

[ https://issues.apache.org/jira/browse/FLINK-10845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16684675#comment-16684675 ] ASF GitHub Bot commented on FLINK-10845: hequn8128 commented on a change in pull request #7079:

[jira] [Closed] (FLINK-10851) sqlUpdate support complex insert grammar

[ https://issues.apache.org/jira/browse/FLINK-10851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] frank wang closed FLINK-10851. -- Resolution: Resolved > sqlUpdate support complex insert grammar >

[jira] [Commented] (FLINK-10851) sqlUpdate support complex insert grammar

[ https://issues.apache.org/jira/browse/FLINK-10851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16684717#comment-16684717 ] frank wang commented on FLINK-10851: OK，it can work，thx > sqlUpdate support complex insert grammar

[GitHub] hequn8128 commented on a change in pull request #7079: [FLINK-10845][table] Support multiple different DISTINCT aggregates for batch

hequn8128 commented on a change in pull request #7079: [FLINK-10845][table] Support multiple different DISTINCT aggregates for batch URL: https://github.com/apache/flink/pull/7079#discussion_r232887066 ## File path:

[jira] [Commented] (FLINK-10845) Support DISTINCT aggregates for batch

[ https://issues.apache.org/jira/browse/FLINK-10845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16684693#comment-16684693 ] ASF GitHub Bot commented on FLINK-10845: hequn8128 commented on a change in pull request #7079:

[jira] [Assigned] (FLINK-10855) CheckpointCoordinator does not delete checkpoint directory of late/failed checkpoints

[ https://issues.apache.org/jira/browse/FLINK-10855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-10855: Assignee: vinoyang > CheckpointCoordinator does not delete checkpoint directory of late/failed

[jira] [Commented] (FLINK-8997) Add sliding window aggregation to the job

[ https://issues.apache.org/jira/browse/FLINK-8997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683414#comment-16683414 ] ASF GitHub Bot commented on FLINK-8997: --- kl0u commented on a change in pull request #7039:

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

[jira] [Commented] (FLINK-8997) Add sliding window aggregation to the job

[ https://issues.apache.org/jira/browse/FLINK-8997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683418#comment-16683418 ] ASF GitHub Bot commented on FLINK-8997: --- kl0u commented on a change in pull request #7039:

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

[jira] [Commented] (FLINK-8997) Add sliding window aggregation to the job

[ https://issues.apache.org/jira/browse/FLINK-8997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683419#comment-16683419 ] ASF GitHub Bot commented on FLINK-8997: --- kl0u commented on a change in pull request #7039:

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

[jira] [Commented] (FLINK-8997) Add sliding window aggregation to the job

[ https://issues.apache.org/jira/browse/FLINK-8997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683416#comment-16683416 ] ASF GitHub Bot commented on FLINK-8997: --- kl0u commented on a change in pull request #7039:

[jira] [Commented] (FLINK-8997) Add sliding window aggregation to the job

[ https://issues.apache.org/jira/browse/FLINK-8997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683417#comment-16683417 ] ASF GitHub Bot commented on FLINK-8997: --- kl0u commented on a change in pull request #7039:

[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_r232570726 ## 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_r232570322 ## 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_r232570916 ## File path:

[jira] [Commented] (FLINK-8997) Add sliding window aggregation to the job

[ https://issues.apache.org/jira/browse/FLINK-8997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683415#comment-16683415 ] ASF GitHub Bot commented on FLINK-8997: --- kl0u commented on a change in pull request #7039:

[jira] [Commented] (FLINK-10826) Heavy deployment end-to-end test produces no output on Travis

[ https://issues.apache.org/jira/browse/FLINK-10826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683431#comment-16683431 ] ASF GitHub Bot commented on FLINK-10826: twalthr commented on issue #7066: [FLINK-10826][test]

[jira] [Commented] (FLINK-10736) Shaded Hadoop S3A end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-10736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683457#comment-16683457 ] Andrey Zagrebin commented on FLINK-10736: - I uploaded the words file as public s3 object in

[jira] [Commented] (FLINK-10809) Using DataStreamUtils.reinterpretAsKeyedStream produces corrupted keyed state after restore

[ https://issues.apache.org/jira/browse/FLINK-10809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683474#comment-16683474 ] ASF GitHub Bot commented on FLINK-10809: StefanRRichter commented on a change in pull request

[GitHub] yiduwangkai opened a new pull request #7080: flink sqlUpdate support complex insert

yiduwangkai opened a new pull request #7080: flink sqlUpdate support complex insert URL: https://github.com/apache/flink/pull/7080 my code is `tableEnv.sqlUpdate("insert into kafka.sdkafka.product_4 select filedName1, filedName2 from kafka.sdkafka.order_4");` but flink give me

[GitHub] StefanRRichter commented on a change in pull request #7048: [FLINK-10809][state] Include keyed state that is not from head operat…

StefanRRichter commented on a change in pull request #7048: [FLINK-10809][state] Include keyed state that is not from head operat… URL: https://github.com/apache/flink/pull/7048#discussion_r232590240 ## File path:

[jira] [Created] (FLINK-10851) sqlUpdate support complex insert grammar

frank wang created FLINK-10851: -- Summary: sqlUpdate support complex insert grammar Key: FLINK-10851 URL: https://issues.apache.org/jira/browse/FLINK-10851 Project: Flink Issue Type: Bug

[GitHub] StefanRRichter commented on a change in pull request #7061: [FLINK-10827][tests] Add test for duplicate() to SerializerTestBase

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

[GitHub] asfgit closed pull request #7066: [FLINK-10826][test] Decrease deployment size of heavy deplyment e2e t…

asfgit closed pull request #7066: [FLINK-10826][test] Decrease deployment size of heavy deplyment e2e t… URL: https://github.com/apache/flink/pull/7066 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

[jira] [Commented] (FLINK-10634) End-to-end test: Metrics accessible via REST API

[ https://issues.apache.org/jira/browse/FLINK-10634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683485#comment-16683485 ] ASF GitHub Bot commented on FLINK-10634: kl0u commented on a change in pull request #7056:

[jira] [Commented] (FLINK-10634) End-to-end test: Metrics accessible via REST API

[ https://issues.apache.org/jira/browse/FLINK-10634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683484#comment-16683484 ] ASF GitHub Bot commented on FLINK-10634: kl0u commented on a change in pull request #7056:

[jira] [Commented] (FLINK-10634) End-to-end test: Metrics accessible via REST API

[ https://issues.apache.org/jira/browse/FLINK-10634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683488#comment-16683488 ] ASF GitHub Bot commented on FLINK-10634: kl0u commented on a change in pull request #7056:

[jira] [Commented] (FLINK-10634) End-to-end test: Metrics accessible via REST API

[ https://issues.apache.org/jira/browse/FLINK-10634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683483#comment-16683483 ] ASF GitHub Bot commented on FLINK-10634: kl0u commented on a change in pull request #7056:

[GitHub] aljoscha commented on issue #7058: [FLINK-10817] Upgrade presto dependency to support path-style access

aljoscha commented on issue #7058: [FLINK-10817] Upgrade presto dependency to support path-style access URL: https://github.com/apache/flink/pull/7058#issuecomment-437829882 I bumped the version in all places and also added an exclude for the new `io.airlift.log-manager` dependency`.

[jira] [Commented] (FLINK-10457) Support SequenceFile for StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-10457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683393#comment-16683393 ] ASF GitHub Bot commented on FLINK-10457: kl0u commented on issue #6774: [FLINK-10457] Support

[GitHub] twalthr commented on issue #7065: [FLINK-10626] [docs] [table] Add documentation for event-time temporal table joins

twalthr commented on issue #7065: [FLINK-10626] [docs] [table] Add documentation for event-time temporal table joins URL: https://github.com/apache/flink/pull/7065#issuecomment-437795049 Thanks @pnowojski. I will address your comments and merge this.

[GitHub] kl0u commented on issue #6774: [FLINK-10457] Support SequenceFile for StreamingFileSink

kl0u commented on issue #6774: [FLINK-10457] Support SequenceFile for StreamingFileSink URL: https://github.com/apache/flink/pull/6774#issuecomment-437795189 Hi @jihyun ! Currently we are busy with testing the release candidate for Flink-1.7. Unfortunately, this PR will have to wait until

[GitHub] igalshilman commented on a change in pull request #7072: [FLINK-10821] Fix resume from externalized checkpoints E2E Test

igalshilman commented on a change in pull request #7072: [FLINK-10821] Fix resume from externalized checkpoints E2E Test URL: https://github.com/apache/flink/pull/7072#discussion_r232572095 ## File path: flink-end-to-end-tests/test-scripts/test_resume_externalized_checkpoints.sh

[GitHub] kl0u commented on a change in pull request #7056: [FLINK-10634][metrics][rest] Add metrics availability e2e test

kl0u commented on a change in pull request #7056: [FLINK-10634][metrics][rest] Add metrics availability e2e test URL: https://github.com/apache/flink/pull/7056#discussion_r232591854 ## File path:

[GitHub] kl0u commented on a change in pull request #7056: [FLINK-10634][metrics][rest] Add metrics availability e2e test

kl0u commented on a change in pull request #7056: [FLINK-10634][metrics][rest] Add metrics availability e2e test URL: https://github.com/apache/flink/pull/7056#discussion_r232591615 ## File path:

[jira] [Commented] (FLINK-10634) End-to-end test: Metrics accessible via REST API

[ https://issues.apache.org/jira/browse/FLINK-10634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683486#comment-16683486 ] ASF GitHub Bot commented on FLINK-10634: kl0u commented on a change in pull request #7056:

[GitHub] kl0u commented on a change in pull request #7056: [FLINK-10634][metrics][rest] Add metrics availability e2e test

kl0u commented on a change in pull request #7056: [FLINK-10634][metrics][rest] Add metrics availability e2e test URL: https://github.com/apache/flink/pull/7056#discussion_r232591919 ## File path:

[GitHub] kl0u commented on a change in pull request #7056: [FLINK-10634][metrics][rest] Add metrics availability e2e test

kl0u commented on a change in pull request #7056: [FLINK-10634][metrics][rest] Add metrics availability e2e test URL: https://github.com/apache/flink/pull/7056#discussion_r232592152 ## File path:

[GitHub] kl0u commented on a change in pull request #7056: [FLINK-10634][metrics][rest] Add metrics availability e2e test

kl0u commented on a change in pull request #7056: [FLINK-10634][metrics][rest] Add metrics availability e2e test URL: https://github.com/apache/flink/pull/7056#discussion_r232591615 ## File path:

[GitHub] art4ul commented on issue #6608: [FLINK-10203]Support truncate method for old Hadoop versions in HadoopRecoverableFsDataOutputStream

art4ul commented on issue #6608: [FLINK-10203]Support truncate method for old Hadoop versions in HadoopRecoverableFsDataOutputStream URL: https://github.com/apache/flink/pull/6608#issuecomment-437836407 Hi @kl0u , maybe could you share your ticket regarding the implementation of logic to

[jira] [Resolved] (FLINK-10626) Add documentation for event-time temporal table joins

[ https://issues.apache.org/jira/browse/FLINK-10626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-10626. -- Resolution: Fixed Fixed in master: 17a6e7a2be756883f9109ba04febe1f6743944a3 Fixed in 1.7:

[GitHub] twalthr commented on a change in pull request #7045: [hotfix] Update nightly master cron jobs

twalthr commented on a change in pull request #7045: [hotfix] Update nightly master cron jobs URL: https://github.com/apache/flink/pull/7045#discussion_r232570011 ## File path: splits/split_misc.sh ## @@ -43,12 +43,16 @@ echo "Flink distribution directory: $FLINK_DIR"

[jira] [Commented] (FLINK-10826) Heavy deployment end-to-end test produces no output on Travis

[ https://issues.apache.org/jira/browse/FLINK-10826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683460#comment-16683460 ] ASF GitHub Bot commented on FLINK-10826: asfgit closed pull request #7066: [FLINK-10826][test]

[jira] [Commented] (FLINK-10817) Upgrade presto dependency to support path-style access

[ https://issues.apache.org/jira/browse/FLINK-10817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683525#comment-16683525 ] ASF GitHub Bot commented on FLINK-10817: aljoscha commented on issue #7058: [FLINK-10817]

[jira] [Commented] (FLINK-10203) Support truncate method for old Hadoop versions in HadoopRecoverableFsDataOutputStream

[ https://issues.apache.org/jira/browse/FLINK-10203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683556#comment-16683556 ] ASF GitHub Bot commented on FLINK-10203: art4ul commented on issue #6608: [FLINK-10203]Support

[jira] [Commented] (FLINK-10626) Add documentation for event-time temporal table joins

[ https://issues.apache.org/jira/browse/FLINK-10626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683392#comment-16683392 ] ASF GitHub Bot commented on FLINK-10626: twalthr commented on issue #7065: [FLINK-10626] [docs]

[jira] [Assigned] (FLINK-10419) ClassNotFoundException while deserializing user exceptions from checkpointing

[ https://issues.apache.org/jira/browse/FLINK-10419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-10419: Assignee: Dawid Wysakowicz > ClassNotFoundException while deserializing user

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

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

[jira] [Commented] (FLINK-10634) End-to-end test: Metrics accessible via REST API

[ https://issues.apache.org/jira/browse/FLINK-10634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683491#comment-16683491 ] ASF GitHub Bot commented on FLINK-10634: kl0u commented on issue #7056:

[jira] [Assigned] (FLINK-10736) Shaded Hadoop S3A end-to-end test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-10736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-10736: Assignee: Andrey Zagrebin > Shaded Hadoop S3A end-to-end test failed on Travis >

[jira] [Commented] (FLINK-10626) Add documentation for event-time temporal table joins

[ https://issues.apache.org/jira/browse/FLINK-10626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683400#comment-16683400 ] ASF GitHub Bot commented on FLINK-10626: asfgit closed pull request #7065: [FLINK-10626] [docs]

[jira] [Commented] (FLINK-10821) Resuming Externalized Checkpoint E2E test does not resume from Externalized Checkpoint

[ https://issues.apache.org/jira/browse/FLINK-10821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683423#comment-16683423 ] ASF GitHub Bot commented on FLINK-10821: igalshilman commented on a change in pull request

[GitHub] igalshilman commented on a change in pull request #7072: [FLINK-10821] Fix resume from externalized checkpoints E2E Test

igalshilman commented on a change in pull request #7072: [FLINK-10821] Fix resume from externalized checkpoints E2E Test URL: https://github.com/apache/flink/pull/7072#discussion_r232572095 ## File path: flink-end-to-end-tests/test-scripts/test_resume_externalized_checkpoints.sh

[jira] [Commented] (FLINK-10821) Resuming Externalized Checkpoint E2E test does not resume from Externalized Checkpoint

[ https://issues.apache.org/jira/browse/FLINK-10821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683426#comment-16683426 ] ASF GitHub Bot commented on FLINK-10821: igalshilman commented on a change in pull request

[GitHub] twalthr commented on issue #7066: [FLINK-10826][test] Decrease deployment size of heavy deplyment e2e t…

twalthr commented on issue #7066: [FLINK-10826][test] Decrease deployment size of heavy deplyment e2e t… URL: https://github.com/apache/flink/pull/7066#issuecomment-437803788 Thanks @StefanRRichter I will address @zentol comments and merge this to unblock #7045.

[jira] [Created] (FLINK-10850) Job may hang on FAILING state if taskmanager updateTaskExecutionState failed

ouyangzhe created FLINK-10850: - Summary: Job may hang on FAILING state if taskmanager updateTaskExecutionState failed Key: FLINK-10850 URL: https://issues.apache.org/jira/browse/FLINK-10850 Project:

[GitHub] asfgit closed pull request #7065: [FLINK-10626] [docs] [table] Add documentation for event-time temporal table joins

asfgit closed pull request #7065: [FLINK-10626] [docs] [table] Add documentation for event-time temporal table joins URL: https://github.com/apache/flink/pull/7065 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake

[jira] [Commented] (FLINK-10827) Add test for duplicate() to SerializerTestBase

[ https://issues.apache.org/jira/browse/FLINK-10827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683428#comment-16683428 ] ASF GitHub Bot commented on FLINK-10827: StefanRRichter commented on a change in pull request

[jira] [Commented] (FLINK-8997) Add sliding window aggregation to the job

[ https://issues.apache.org/jira/browse/FLINK-8997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683463#comment-16683463 ] ASF GitHub Bot commented on FLINK-8997: --- dawidwys commented on a change in pull request #7039:

[jira] [Resolved] (FLINK-10826) Heavy deployment end-to-end test produces no output on Travis

[ https://issues.apache.org/jira/browse/FLINK-10826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-10826. -- Resolution: Fixed Fix Version/s: 1.7.0 Fixed in master:

[GitHub] kl0u commented on issue #7056: [FLINK-10634][metrics][rest] Add metrics availability e2e test

kl0u commented on issue #7056: [FLINK-10634][metrics][rest] Add metrics availability e2e test URL: https://github.com/apache/flink/pull/7056#issuecomment-437821227 BTW the Travis build you link to has failed. This is an

[jira] [Created] (FLINK-10852) Decremented number of unfinished producers below 0. This is most likely a bug in the execution state/intermediate result partition management

ouyangzhe created FLINK-10852: - Summary: Decremented number of unfinished producers below 0. This is most likely a bug in the execution state/intermediate result partition management Key: FLINK-10852 URL:

[jira] [Commented] (FLINK-10674) DistinctAccumulator.remove lead to NPE

[ https://issues.apache.org/jira/browse/FLINK-10674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16684785#comment-16684785 ] ASF GitHub Bot commented on FLINK-10674: wenhuitang closed pull request #7076: [FLINK-10674]

[GitHub] wenhuitang closed pull request #7076: [FLINK-10674] [table] Fix DistinctAccumulator.remove lead to NPE.

wenhuitang closed pull request #7076: [FLINK-10674] [table] Fix DistinctAccumulator.remove lead to NPE. URL: https://github.com/apache/flink/pull/7076 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] wenhuitang opened a new pull request #7076: [FLINK-10674] [table] Fix DistinctAccumulator.remove lead to NPE.

wenhuitang opened a new pull request #7076: [FLINK-10674] [table] Fix 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

[jira] [Created] (FLINK-10857) Conflict between JMX and Prometheus Metrics reporter

Truong Duc Kien created FLINK-10857: --- Summary: Conflict between JMX and Prometheus Metrics reporter Key: FLINK-10857 URL: https://issues.apache.org/jira/browse/FLINK-10857 Project: Flink

[jira] [Updated] (FLINK-10857) Conflict between JMX and Prometheus Metrics reporter

[ https://issues.apache.org/jira/browse/FLINK-10857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Truong Duc Kien updated FLINK-10857: Description: When registering both JMX and Prometheus metrics reporter, the Prometheus

[jira] [Comment Edited] (FLINK-10818) RestartStrategies.fixedDelayRestart Occur NoResourceAvailableException: Not enough free slots available to run the job.

[ https://issues.apache.org/jira/browse/FLINK-10818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16684814#comment-16684814 ] ambition edited comment on FLINK-10818 at 11/13/18 7:37 AM: logs file :

[jira] [Comment Edited] (FLINK-10818) RestartStrategies.fixedDelayRestart Occur NoResourceAvailableException: Not enough free slots available to run the job.

[ https://issues.apache.org/jira/browse/FLINK-10818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16684814#comment-16684814 ] ambition edited comment on FLINK-10818 at 11/13/18 7:36 AM:

[jira] [Commented] (FLINK-10818) RestartStrategies.fixedDelayRestart Occur NoResourceAvailableException: Not enough free slots available to run the job.

[ https://issues.apache.org/jira/browse/FLINK-10818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16684814#comment-16684814 ] ambition commented on FLINK-10818: -- [^jobmanager.log][^taskmanager.log] >

[GitHub] zhijiangW commented on a change in pull request #7051: [FLINK-10820][network] Simplify the RebalancePartitioner implementation

zhijiangW commented on a change in pull request #7051: [FLINK-10820][network] Simplify the RebalancePartitioner implementation URL: https://github.com/apache/flink/pull/7051#discussion_r232926075 ## File path:

[jira] [Commented] (FLINK-10820) Simplify the RebalancePartitioner implementation

[ https://issues.apache.org/jira/browse/FLINK-10820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16684825#comment-16684825 ] ASF GitHub Bot commented on FLINK-10820: zhijiangW commented on a change in pull request #7051:

***UNCHECKED*** [jira] [Commented] (FLINK-10674) DistinctAccumulator.remove lead to NPE

[ https://issues.apache.org/jira/browse/FLINK-10674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16684786#comment-16684786 ] ASF GitHub Bot commented on FLINK-10674: wenhuitang opened a new pull request #7076:

***UNCHECKED*** [jira] [Updated] (FLINK-10818) RestartStrategies.fixedDelayRestart Occur NoResourceAvailableException: Not enough free slots available to run the job.

[ https://issues.apache.org/jira/browse/FLINK-10818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ambition updated FLINK-10818: - Attachment: jobmanager.log > RestartStrategies.fixedDelayRestart Occur NoResourceAvailableException:

[jira] [Updated] (FLINK-10818) RestartStrategies.fixedDelayRestart Occur NoResourceAvailableException: Not enough free slots available to run the job.

[ https://issues.apache.org/jira/browse/FLINK-10818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ambition updated FLINK-10818: - Attachment: taskmanager.log > RestartStrategies.fixedDelayRestart Occur NoResourceAvailableException:

[jira] [Commented] (FLINK-10827) Add test for duplicate() to SerializerTestBase

[ https://issues.apache.org/jira/browse/FLINK-10827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683604#comment-16683604 ] ASF GitHub Bot commented on FLINK-10827: StefanRRichter commented on a change in pull request

[GitHub] StefanRRichter commented on a change in pull request #7061: [FLINK-10827][tests] Add test for duplicate() to SerializerTestBase

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

[GitHub] twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause

twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause URL: https://github.com/apache/flink/pull/7070#discussion_r232617404 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -0,0 +1,654 @@ +--- +title:

[GitHub] twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause

twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause URL: https://github.com/apache/flink/pull/7070#discussion_r232601742 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -0,0 +1,654 @@ +--- +title:

[GitHub] twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause

twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause URL: https://github.com/apache/flink/pull/7070#discussion_r232619371 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -0,0 +1,654 @@ +--- +title:

[GitHub] twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause

twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause URL: https://github.com/apache/flink/pull/7070#discussion_r232595246 ## File path: docs/dev/table/sql.md ## @@ -756,6 +796,51 @@ Group windows are defined in the

[GitHub] twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause

twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause URL: https://github.com/apache/flink/pull/7070#discussion_r232604261 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -0,0 +1,654 @@ +--- +title:

[GitHub] twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause

twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause URL: https://github.com/apache/flink/pull/7070#discussion_r232593513 ## File path: docs/dev/table/sql.md ## @@ -756,6 +796,51 @@ Group windows are defined in the

[GitHub] twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause

twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause URL: https://github.com/apache/flink/pull/7070#discussion_r232600187 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -0,0 +1,654 @@ +--- +title:

[GitHub] twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause

twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause URL: https://github.com/apache/flink/pull/7070#discussion_r232603954 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -0,0 +1,654 @@ +--- +title:

[GitHub] twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause

twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause URL: https://github.com/apache/flink/pull/7070#discussion_r232597810 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -0,0 +1,654 @@ +--- +title:

[GitHub] twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause

twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause URL: https://github.com/apache/flink/pull/7070#discussion_r232598253 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -0,0 +1,654 @@ +--- +title:

[GitHub] twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause

twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause URL: https://github.com/apache/flink/pull/7070#discussion_r232596586 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -0,0 +1,654 @@ +--- +title:

[GitHub] twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause

twalthr commented on a change in pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause URL: https://github.com/apache/flink/pull/7070#discussion_r232601307 ## File path: docs/dev/table/streaming/match_recognize.md ## @@ -0,0 +1,654 @@ +--- +title:

[jira] [Commented] (FLINK-10731) Support AVG on Date fields

[ https://issues.apache.org/jira/browse/FLINK-10731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683607#comment-16683607 ] Flavio Pompermaier commented on FLINK-10731: Fine for me [~twalthr] > Support AVG on Date

[jira] [Commented] (FLINK-9311) PubSub connector

[ https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683691#comment-16683691 ] ASF GitHub Bot commented on FLINK-9311: --- nielsbasjes commented on a change in pull request #6594:

[jira] [Commented] (FLINK-9311) PubSub connector

[ https://issues.apache.org/jira/browse/FLINK-9311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16683693#comment-16683693 ] ASF GitHub Bot commented on FLINK-9311: --- nielsbasjes commented on a change in pull request #6594:

  1   2   3   >