[jira] [Closed] (FLINK-10529) Add flink-s3-fs-base to the connectors in the travis stage file.

[ https://issues.apache.org/jira/browse/FLINK-10529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-10529. -- Resolution: Fixed Merged on master with 86f88f71253c8fc916de0dae1c0621072b0321c0. > Add

[GitHub] StefanRRichter commented on issue #6825: [hotfix] Fix typo in WindowedStream.

StefanRRichter commented on issue #6825: [hotfix] Fix typo in WindowedStream. URL: https://github.com/apache/flink/pull/6825#issuecomment-429019467 LGTM  This is an automated message from the Apache Git Service. To respond

[GitHub] asfgit closed pull request #6825: [hotfix] Fix typo in WindowedStream.

asfgit closed pull request #6825: [hotfix] Fix typo in WindowedStream. URL: https://github.com/apache/flink/pull/6825 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] tillrohrmann opened a new pull request #6827: [FLINK-10530][tests] Harden ProcessFailureCancelingITCase and AbstractTaskManagerProcessFailureRecovery

tillrohrmann opened a new pull request #6827: [FLINK-10530][tests] Harden ProcessFailureCancelingITCase and AbstractTaskManagerProcessFailureRecovery URL: https://github.com/apache/flink/pull/6827 ## What is the purpose of the change The problem is that the Dispatcher actor is

[jira] [Updated] (FLINK-10530) ProcessFailureCancelingITCase.testCancelingOnProcessFailure failed on Travis.

[ https://issues.apache.org/jira/browse/FLINK-10530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10530: --- Labels: pull-request-available test-stability (was: test-stability) >

[jira] [Commented] (FLINK-10530) ProcessFailureCancelingITCase.testCancelingOnProcessFailure failed on Travis.

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

[jira] [Resolved] (FLINK-10426) Port TaskTest to new code base

[ https://issues.apache.org/jira/browse/FLINK-10426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-10426. --- Resolution: Fixed Fixed via c1c56b6f1d185b689cdaa661eb02afd6876b3ffd

[GitHub] asfgit closed pull request #6778: [FLINK-10426] [tests] Port TaskTest to new code base

asfgit closed pull request #6778: [FLINK-10426] [tests] Port TaskTest to new code base URL: https://github.com/apache/flink/pull/6778 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

[jira] [Commented] (FLINK-10426) Port TaskTest to new code base

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

[GitHub] tillrohrmann commented on issue #6810: [FLINK-9788] Fix ExecutionGraph inconsistency for global failures when restarting

tillrohrmann commented on issue #6810: [FLINK-9788] Fix ExecutionGraph inconsistency for global failures when restarting URL: https://github.com/apache/flink/pull/6810#issuecomment-428987592 Thanks for the review @ifndef-SleePy and @StefanRRichter. Merging this PR.

[jira] [Commented] (FLINK-9788) ExecutionGraph Inconsistency prevents Job from recovering

[ https://issues.apache.org/jira/browse/FLINK-9788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16646547#comment-16646547 ] ASF GitHub Bot commented on FLINK-9788: --- tillrohrmann commented on issue #6810: [FLINK-9788] Fix

[GitHub] tillrohrmann closed pull request #6810: [FLINK-9788] Fix ExecutionGraph inconsistency for global failures when restarting

tillrohrmann closed pull request #6810: [FLINK-9788] Fix ExecutionGraph inconsistency for global failures when restarting URL: https://github.com/apache/flink/pull/6810 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the

[jira] [Commented] (FLINK-9788) ExecutionGraph Inconsistency prevents Job from recovering

[ https://issues.apache.org/jira/browse/FLINK-9788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16646551#comment-16646551 ] ASF GitHub Bot commented on FLINK-9788: --- tillrohrmann closed pull request #6810: [FLINK-9788] Fix

[GitHub] tillrohrmann closed pull request #6811: [BP-1.6][FLINK-9788] Fix ExecutionGraph inconsistency for global failures when restarting

tillrohrmann closed pull request #6811: [BP-1.6][FLINK-9788] Fix ExecutionGraph inconsistency for global failures when restarting URL: https://github.com/apache/flink/pull/6811 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below

[GitHub] tillrohrmann closed pull request #6812: [BP-1.5][FLINK-9788] Fix ExecutionGraph inconsistency for global failures when restarting

tillrohrmann closed pull request #6812: [BP-1.5][FLINK-9788] Fix ExecutionGraph inconsistency for global failures when restarting URL: https://github.com/apache/flink/pull/6812 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below

[jira] [Resolved] (FLINK-9788) ExecutionGraph Inconsistency prevents Job from recovering

[ https://issues.apache.org/jira/browse/FLINK-9788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-9788. -- Resolution: Fixed Fixed via 1.7.0:

[jira] [Commented] (FLINK-9592) Notify on moving file into pending/ final state

[ https://issues.apache.org/jira/browse/FLINK-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16646693#comment-16646693 ] Kostas Kloudas commented on FLINK-9592: --- Hi [~kent2171]. Sorry for not posting the design doc

[GitHub] azagrebin commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector

azagrebin commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector URL: https://github.com/apache/flink/pull/6782#discussion_r224473345 ## File path: docs/dev/connectors/cassandra.md ## @@ -72,10

[GitHub] azagrebin commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector

azagrebin commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector URL: https://github.com/apache/flink/pull/6782#discussion_r224484466 ## File path:

[GitHub] azagrebin commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector

azagrebin commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector URL: https://github.com/apache/flink/pull/6782#discussion_r224486164 ## File path:

[GitHub] azagrebin commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector

azagrebin commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector URL: https://github.com/apache/flink/pull/6782#discussion_r224475996 ## File path:

[GitHub] azagrebin commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector

azagrebin commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector URL: https://github.com/apache/flink/pull/6782#discussion_r224486540 ## File path:

[GitHub] azagrebin commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector

azagrebin commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector URL: https://github.com/apache/flink/pull/6782#discussion_r224487663 ## File path:

[GitHub] azagrebin commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector

azagrebin commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector URL: https://github.com/apache/flink/pull/6782#discussion_r224485975 ## File path:

[GitHub] azagrebin commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector

azagrebin commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector URL: https://github.com/apache/flink/pull/6782#discussion_r224475206 ## File path:

[GitHub] azagrebin commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector

azagrebin commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector URL: https://github.com/apache/flink/pull/6782#discussion_r224486780 ## File path:

[GitHub] azagrebin commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector

azagrebin commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector URL: https://github.com/apache/flink/pull/6782#discussion_r224481690 ## File path:

[GitHub] azagrebin commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector

azagrebin commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector URL: https://github.com/apache/flink/pull/6782#discussion_r224477067 ## File path:

[GitHub] azagrebin commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector

azagrebin commented on a change in pull request #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector URL: https://github.com/apache/flink/pull/6782#discussion_r224484698 ## File path:

[jira] [Commented] (FLINK-9083) Add async backpressure support to Cassandra Connector

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

[jira] [Commented] (FLINK-9083) Add async backpressure support to Cassandra Connector

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

[jira] [Commented] (FLINK-9083) Add async backpressure support to Cassandra Connector

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

[jira] [Commented] (FLINK-9083) Add async backpressure support to Cassandra Connector

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

[jira] [Commented] (FLINK-9083) Add async backpressure support to Cassandra Connector

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

[jira] [Commented] (FLINK-9083) Add async backpressure support to Cassandra Connector

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

[jira] [Commented] (FLINK-9083) Add async backpressure support to Cassandra Connector

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

[jira] [Commented] (FLINK-9083) Add async backpressure support to Cassandra Connector

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

[jira] [Commented] (FLINK-9083) Add async backpressure support to Cassandra Connector

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

[jira] [Commented] (FLINK-9083) Add async backpressure support to Cassandra Connector

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

[jira] [Commented] (FLINK-9083) Add async backpressure support to Cassandra Connector

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

[jira] [Commented] (FLINK-9083) Add async backpressure support to Cassandra Connector

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

[jira] [Commented] (FLINK-6625) Flink removes HA job data when reaching JobStatus.FAILED

[ https://issues.apache.org/jira/browse/FLINK-6625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16646645#comment-16646645 ] Ufuk Celebi commented on FLINK-6625: {quote}Can't a failed checkpoint (unable to commit something,

[jira] [Closed] (FLINK-9752) Add an S3 RecoverableWriter

[ https://issues.apache.org/jira/browse/FLINK-9752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-9752. - Resolution: Fixed Merged on master with 88ea996dda16e340488a2d9f7516bf8337edefdd. > Add an S3

[jira] [Commented] (FLINK-10423) Forward RocksDB native metrics to Flink metrics reporter

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

[jira] [Commented] (FLINK-10423) Forward RocksDB native metrics to Flink metrics reporter

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

[jira] [Commented] (FLINK-10423) Forward RocksDB native metrics to Flink metrics reporter

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

[jira] [Commented] (FLINK-10423) Forward RocksDB native metrics to Flink metrics reporter

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

[jira] [Commented] (FLINK-9715) Support versioned joins with event time

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

[jira] [Created] (FLINK-10531) State TTL RocksDb backend end-to-end test end-to-end test failed on Travis

Till Rohrmann created FLINK-10531: - Summary: State TTL RocksDb backend end-to-end test end-to-end test failed on Travis Key: FLINK-10531 URL: https://issues.apache.org/jira/browse/FLINK-10531

[GitHub] hequn8128 commented on a change in pull request #6776: [FLINK-9715][table] Support temporal join with event time

hequn8128 commented on a change in pull request #6776: [FLINK-9715][table] Support temporal join with event time URL: https://github.com/apache/flink/pull/6776#discussion_r224492754 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #6814: [FLINK-10423][rocksdb][metrics] rocksdb native metrics monitor

StefanRRichter commented on a change in pull request #6814: [FLINK-10423][rocksdb][metrics] rocksdb native metrics monitor URL: https://github.com/apache/flink/pull/6814#discussion_r224534588 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #6814: [FLINK-10423][rocksdb][metrics] rocksdb native metrics monitor

StefanRRichter commented on a change in pull request #6814: [FLINK-10423][rocksdb][metrics] rocksdb native metrics monitor URL: https://github.com/apache/flink/pull/6814#discussion_r224531500 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #6814: [FLINK-10423][rocksdb][metrics] rocksdb native metrics monitor

StefanRRichter commented on a change in pull request #6814: [FLINK-10423][rocksdb][metrics] rocksdb native metrics monitor URL: https://github.com/apache/flink/pull/6814#discussion_r224529147 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #6814: [FLINK-10423][rocksdb][metrics] rocksdb native metrics monitor

StefanRRichter commented on a change in pull request #6814: [FLINK-10423][rocksdb][metrics] rocksdb native metrics monitor URL: https://github.com/apache/flink/pull/6814#discussion_r224536940 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #6814: [FLINK-10423][rocksdb][metrics] rocksdb native metrics monitor

StefanRRichter commented on a change in pull request #6814: [FLINK-10423][rocksdb][metrics] rocksdb native metrics monitor URL: https://github.com/apache/flink/pull/6814#discussion_r224533004 ## File path:

[jira] [Commented] (FLINK-10423) Forward RocksDB native metrics to Flink metrics reporter

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

[jira] [Commented] (FLINK-8424) [Cassandra Connector] Update Cassandra version to last one

[ https://issues.apache.org/jira/browse/FLINK-8424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16647005#comment-16647005 ] ASF GitHub Bot commented on FLINK-8424: --- bmeriaux commented on issue #6715: [FLINK-8424] update

[GitHub] bmeriaux commented on issue #6715: [FLINK-8424] update cassandra and driver version to latest

bmeriaux commented on issue #6715: [FLINK-8424] update cassandra and driver version to latest URL: https://github.com/apache/flink/pull/6715#issuecomment-429109568 ok thanks for info on the policy of versioning, so will this be merged into master ?

[jira] [Closed] (FLINK-10494) Rename 'JobManager' to 'JobMaster' for some classes in JobMaster folder

[ https://issues.apache.org/jira/browse/FLINK-10494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JIN SUN closed FLINK-10494. --- Resolution: Won't Fix closed as suggestion > Rename 'JobManager' to 'JobMaster' for some classes in

[GitHub] isunjin commented on issue #6429: [FLINK-9943] Support TaskManagerMetricQueryServicePaths msg in JobManager Actor

isunjin commented on issue #6429: [FLINK-9943] Support TaskManagerMetricQueryServicePaths msg in JobManager Actor URL: https://github.com/apache/flink/pull/6429#issuecomment-429081228 could you also close the JIRA? @chuanlei

[jira] [Commented] (FLINK-9943) Support TaskManagerMetricQueryServicePaths msg in JobManager Actor

[ https://issues.apache.org/jira/browse/FLINK-9943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16646923#comment-16646923 ] ASF GitHub Bot commented on FLINK-9943: --- isunjin commented on issue #6429: [FLINK-9943] Support

[GitHub] yanyan300300 opened a new pull request #6828: [FLINK-10516] [yarn] fix YarnApplicationMasterRunner fail to initialize FileSystem with correct Flink Configuration during setup

yanyan300300 opened a new pull request #6828: [FLINK-10516] [yarn] fix YarnApplicationMasterRunner fail to initialize FileSystem with correct Flink Configuration during setup URL: https://github.com/apache/flink/pull/6828 ## What is the purpose of the change This pull request makes

[jira] [Updated] (FLINK-10516) YarnApplicationMasterRunner fail to initialize FileSystem with correct Flink Configuration during setup

[ https://issues.apache.org/jira/browse/FLINK-10516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10516: --- Labels: pull-request-available (was: ) > YarnApplicationMasterRunner fail to initialize

[jira] [Commented] (FLINK-10516) YarnApplicationMasterRunner fail to initialize FileSystem with correct Flink Configuration during setup

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

[jira] [Created] (FLINK-10532) Broken links in documentation

Chesnay Schepler created FLINK-10532: Summary: Broken links in documentation Key: FLINK-10532 URL: https://issues.apache.org/jira/browse/FLINK-10532 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-10265) Configure checkpointing behavior for SQL Client

[ https://issues.apache.org/jira/browse/FLINK-10265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16647218#comment-16647218 ] sunjincheng commented on FLINK-10265: - Hi，[~twalthr] [~yanghua] I agree that we should unify the

[jira] [Updated] (FLINK-10367) Avoid recursion stack overflow during releasing SingleInputGate

[ https://issues.apache.org/jira/browse/FLINK-10367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10367: --- Labels: pull-request-available (was: ) > Avoid recursion stack overflow during releasing

[GitHub] zhijiangW opened a new pull request #6829: [FLINK-10367][network] Introduce NotificationResult for BufferListener to solve recursive stack overflow

zhijiangW opened a new pull request #6829: [FLINK-10367][network] Introduce NotificationResult for BufferListener to solve recursive stack overflow URL: https://github.com/apache/flink/pull/6829 ## What is the purpose of the change *In the process of `LocalBufferPool#recycle`, the

[jira] [Commented] (FLINK-10367) Avoid recursion stack overflow during releasing SingleInputGate

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

[jira] [Updated] (FLINK-10533) job parallelism equals task slot number but not use all tasl slot

[ https://issues.apache.org/jira/browse/FLINK-10533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sean.miao updated FLINK-10533: -- Description: i use the table api and do not use the datastream api。   my job has two graph and

[jira] [Commented] (FLINK-10534) Add idle timeout for a flink session cluster

[ https://issues.apache.org/jira/browse/FLINK-10534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16647381#comment-16647381 ] ouyangzhe commented on FLINK-10534: --- Hi~ [~till.rohrmann] , i'd like to contribute, can you give me

[jira] [Commented] (FLINK-10534) Add idle timeout for a flink session cluster

[ https://issues.apache.org/jira/browse/FLINK-10534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16647379#comment-16647379 ] vinoyang commented on FLINK-10534: -- [~yeshan] It seems that you currently have no JIRA contribute

[jira] [Commented] (FLINK-10135) The JobManager doesn't report the cluster-level metrics

[ https://issues.apache.org/jira/browse/FLINK-10135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16647365#comment-16647365 ] ASF GitHub Bot commented on FLINK-10135: yanghua commented on issue #6702: [FLINK-10135] The

[GitHub] yanghua commented on issue #6702: [FLINK-10135] The JobManager does not report the cluster-level metrics

yanghua commented on issue #6702: [FLINK-10135] The JobManager does not report the cluster-level metrics URL: https://github.com/apache/flink/pull/6702#issuecomment-429191342 I saw some errors not related to this PR change, from `flink-s3-fs-hadoop`. cc @tillrohrmann and @zentol

[GitHub] yanghua edited a comment on issue #6702: [FLINK-10135] The JobManager does not report the cluster-level metrics

yanghua edited a comment on issue #6702: [FLINK-10135] The JobManager does not report the cluster-level metrics URL: https://github.com/apache/flink/pull/6702#issuecomment-429191342 I saw some compile errors not related to this PR change which caused Travis failed from

[jira] [Commented] (FLINK-10534) Add idle timeout for a flink session cluster

[ https://issues.apache.org/jira/browse/FLINK-10534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16647373#comment-16647373 ] vinoyang commented on FLINK-10534: -- [~isunjin] agree.  > Add idle timeout for a flink session cluster

[jira] [Commented] (FLINK-10516) YarnApplicationMasterRunner fail to initialize FileSystem with correct Flink Configuration during setup

[ https://issues.apache.org/jira/browse/FLINK-10516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16647196#comment-16647196 ] ASF GitHub Bot commented on FLINK-10516: suez1224 commented on issue #6828: [FLINK-10516] [yarn]

[jira] [Commented] (FLINK-10135) The JobManager doesn't report the cluster-level metrics

[ https://issues.apache.org/jira/browse/FLINK-10135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16647366#comment-16647366 ] ASF GitHub Bot commented on FLINK-10135: yanghua edited a comment on issue #6702: [FLINK-10135]

[jira] [Commented] (FLINK-10534) Add idle timeout for a flink session cluster

[ https://issues.apache.org/jira/browse/FLINK-10534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16647376#comment-16647376 ] ouyangzhe commented on FLINK-10534: --- hi~ [~yanghua] , for this issue, I have a prototype already, can

[jira] [Commented] (FLINK-10508) Port JobManagerITCase to new code base

[ https://issues.apache.org/jira/browse/FLINK-10508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16647375#comment-16647375 ] TisonKun commented on FLINK-10508: -- checklist: JobManagerITCase.The JobManager actor must handle jobs

[GitHub] suez1224 commented on issue #6828: [FLINK-10516] [yarn] fix YarnApplicationMasterRunner fail to initialize FileSystem with correct Flink Configuration during setup

suez1224 commented on issue #6828: [FLINK-10516] [yarn] fix YarnApplicationMasterRunner fail to initialize FileSystem with correct Flink Configuration during setup URL: https://github.com/apache/flink/pull/6828#issuecomment-429158706 Can you write the fix against the current master? Also,

[jira] [Created] (FLINK-10533) job parallelism equals task slot number but not use all tasl slot

sean.miao created FLINK-10533: - Summary: job parallelism equals task slot number but not use all tasl slot Key: FLINK-10533 URL: https://issues.apache.org/jira/browse/FLINK-10533 Project: Flink

[jira] [Commented] (FLINK-10534) Add idle timeout for a flink session cluster

[ https://issues.apache.org/jira/browse/FLINK-10534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16647372#comment-16647372 ] JIN SUN commented on FLINK-10534: - session can have the semantic of expire time. we probably can add a

[jira] [Commented] (FLINK-5465) RocksDB fails with segfault while calling AbstractRocksDBState.clear()

[ https://issues.apache.org/jira/browse/FLINK-5465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16647154#comment-16647154 ] ASF GitHub Bot commented on FLINK-5465: --- zorro786 commented on issue #5058: [FLINK-5465]

[GitHub] zorro786 commented on issue #5058: [FLINK-5465] [streaming] Wait for pending timer threads to finish or …

zorro786 commented on issue #5058: [FLINK-5465] [streaming] Wait for pending timer threads to finish or … URL: https://github.com/apache/flink/pull/5058#issuecomment-429150903 @StefanRRichter It is mentioned in Jira ticket that this affects versions 1.5.0, 1.4.2, 1.6.0. Could you

[jira] [Commented] (FLINK-10516) YarnApplicationMasterRunner fail to initialize FileSystem with correct Flink Configuration during setup

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

[GitHub] suez1224 commented on a change in pull request #6828: [FLINK-10516] [yarn] fix YarnApplicationMasterRunner fail to initialize FileSystem with correct Flink Configuration during setup

suez1224 commented on a change in pull request #6828: [FLINK-10516] [yarn] fix YarnApplicationMasterRunner fail to initialize FileSystem with correct Flink Configuration during setup URL: https://github.com/apache/flink/pull/6828#discussion_r224638155 ## File path:

[jira] [Commented] (FLINK-10516) YarnApplicationMasterRunner fail to initialize FileSystem with correct Flink Configuration during setup

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

[GitHub] yanghua commented on issue #6702: [FLINK-10135] The JobManager does not report the cluster-level metrics

yanghua commented on issue #6702: [FLINK-10135] The JobManager does not report the cluster-level metrics URL: https://github.com/apache/flink/pull/6702#issuecomment-429191782 display here then I will try to trigger Travis rebuild : ``` 17:18:24.891 [ERROR] Failed to execute goal

[jira] [Commented] (FLINK-10135) The JobManager doesn't report the cluster-level metrics

[ https://issues.apache.org/jira/browse/FLINK-10135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16647370#comment-16647370 ] ASF GitHub Bot commented on FLINK-10135: yanghua commented on issue #6702: [FLINK-10135] The

[GitHub] suez1224 commented on a change in pull request #6828: [FLINK-10516] [yarn] fix YarnApplicationMasterRunner fail to initialize FileSystem with correct Flink Configuration during setup

suez1224 commented on a change in pull request #6828: [FLINK-10516] [yarn] fix YarnApplicationMasterRunner fail to initialize FileSystem with correct Flink Configuration during setup URL: https://github.com/apache/flink/pull/6828#discussion_r224639273 ## File path:

[jira] [Created] (FLINK-10534) Add idle timeout for a flink session cluster

ouyangzhe created FLINK-10534: - Summary: Add idle timeout for a flink session cluster Key: FLINK-10534 URL: https://issues.apache.org/jira/browse/FLINK-10534 Project: Flink Issue Type: New

[jira] [Assigned] (FLINK-10534) Add idle timeout for a flink session cluster

[ https://issues.apache.org/jira/browse/FLINK-10534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-10534: Assignee: (was: vinoyang) > Add idle timeout for a flink session cluster >

[jira] [Commented] (FLINK-9544) Downgrade kinesis protocol from CBOR to JSON not possible as required by kinesalite

[ https://issues.apache.org/jira/browse/FLINK-9544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16647280#comment-16647280 ] Diego Carvallo commented on FLINK-9544: --- [~eyushin] That is not working either in v 1.6.0. I tried

[jira] [Commented] (FLINK-10534) Add idle timeout for a flink session cluster

[ https://issues.apache.org/jira/browse/FLINK-10534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16647352#comment-16647352 ] vinoyang commented on FLINK-10534: -- Hi [~yeshan] Thank you for making this suggestion, it seems that it

[jira] [Created] (FLINK-10535) User jar is present in the flink job manager's class path

yinhua.dai created FLINK-10535: -- Summary: User jar is present in the flink job manager's class path Key: FLINK-10535 URL: https://issues.apache.org/jira/browse/FLINK-10535 Project: Flink Issue

[jira] [Assigned] (FLINK-10534) Add idle timeout for a flink session cluster

[ https://issues.apache.org/jira/browse/FLINK-10534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-10534: Assignee: vinoyang > Add idle timeout for a flink session cluster >

[jira] [Commented] (FLINK-10534) Add idle timeout for a flink session cluster

[ https://issues.apache.org/jira/browse/FLINK-10534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16647499#comment-16647499 ] ouyangzhe commented on FLINK-10534: --- [~yanghua]  thanks :) . > Add idle timeout for a flink session

[jira] [Commented] (FLINK-10534) Add idle timeout for a flink session cluster

[ https://issues.apache.org/jira/browse/FLINK-10534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16647462#comment-16647462 ] vinoyang commented on FLINK-10534: -- [~yeshan] I believe he will see and give you permission, don't

[GitHub] TisonKun commented on issue #6778: [FLINK-10426] [tests] Port TaskTest to new code base

TisonKun commented on issue #6778: [FLINK-10426] [tests] Port TaskTest to new code base URL: https://github.com/apache/flink/pull/6778#issuecomment-428834204 After a rebase on #6729 and its followings, I think this pull request is ready to be reviewed. cc @tillrohrmann and @uce .

  1   2   3   >