[jira] [Updated] (FLINK-11087) Broadcast state migration Incompatibility from 1.5.3 to 1.7.0

[ https://issues.apache.org/jira/browse/FLINK-11087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11087: Fix Version/s: 1.7.1 1.6.3 > Broadcast state migration

[jira] [Commented] (FLINK-11087) Broadcast state migration Incompatibility from 1.5.3 to 1.7.0

[ https://issues.apache.org/jira/browse/FLINK-11087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711637#comment-16711637 ] Chesnay Schepler commented on FLINK-11087: -- [~tzulitai] Can you amend the migration matrix in

[jira] [Comment Edited] (FLINK-11087) Broadcast state migration Incompatibility from 1.5.3 to 1.7.0

[ https://issues.apache.org/jira/browse/FLINK-11087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711635#comment-16711635 ] Tzu-Li (Gordon) Tai edited comment on FLINK-11087 at 12/6/18 4:06 PM:

[jira] [Commented] (FLINK-11087) Broadcast state migration Incompatibility from 1.5.3 to 1.7.0

[ https://issues.apache.org/jira/browse/FLINK-11087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711635#comment-16711635 ] Tzu-Li (Gordon) Tai commented on FLINK-11087: - Confirmed, this is indeed a bug, and the

[jira] [Commented] (FLINK-11048) Ability to programmatically execute streaming pipeline with savepoint restore

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

[GitHub] zentol commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore

zentol commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore URL: https://github.com/apache/flink/pull/7249#discussion_r239509248 ## File path:

[jira] [Assigned] (FLINK-11087) Broadcast state migration Incompatibility from 1.5.3 to 1.7.0

[ https://issues.apache.org/jira/browse/FLINK-11087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-11087: --- Assignee: Tzu-Li (Gordon) Tai > Broadcast state migration Incompatibility

[jira] [Commented] (FLINK-9740) Support group windows over intervals of months

[ https://issues.apache.org/jira/browse/FLINK-9740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711618#comment-16711618 ] Timo Walther commented on FLINK-9740: - I cannot see it in the JIRA yet but in any case: In general we

[jira] [Commented] (FLINK-11048) Ability to programmatically execute streaming pipeline with savepoint restore

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

[jira] [Commented] (FLINK-10945) Avoid resource deadlocks for finite stream jobs when resources are limited

[ https://issues.apache.org/jira/browse/FLINK-10945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711599#comment-16711599 ] ASF GitHub Bot commented on FLINK-10945: zhuzhurk closed pull request #7252: [FLINK-10945] Add

[GitHub] mxm commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore

mxm commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore URL: https://github.com/apache/flink/pull/7249#discussion_r239501341 ## File path:

[jira] [Commented] (FLINK-10945) Avoid resource deadlocks for finite stream jobs when resources are limited

[ https://issues.apache.org/jira/browse/FLINK-10945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711598#comment-16711598 ] ASF GitHub Bot commented on FLINK-10945: zhuzhurk commented on issue #7252: [FLINK-10945] Add an

[GitHub] zhuzhurk closed pull request #7252: [FLINK-10945] Add an InputDependencyConstraint to avoid resource dead…

zhuzhurk closed pull request #7252: [FLINK-10945] Add an InputDependencyConstraint to avoid resource dead… URL: https://github.com/apache/flink/pull/7252 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] zhuzhurk commented on issue #7252: [FLINK-10945] Add an InputDependencyConstraint to avoid resource dead…

zhuzhurk commented on issue #7252: [FLINK-10945] Add an InputDependencyConstraint to avoid resource dead… URL: https://github.com/apache/flink/pull/7252#issuecomment-444913214 > Please open the PR against the master branch. Thanks Zentol for pointing out the fault. The new PR is

[jira] [Commented] (FLINK-11048) Ability to programmatically execute streaming pipeline with savepoint restore

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

[jira] [Commented] (FLINK-10945) Avoid resource deadlocks for finite stream jobs when resources are limited

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

[GitHub] zentol commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore

zentol commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore URL: https://github.com/apache/flink/pull/7249#discussion_r239497531 ## File path:

[GitHub] zhuzhurk opened a new pull request #7255: [FLINK-10945] Use InputDependencyConstraint to avoid resource dead…

zhuzhurk opened a new pull request #7255: [FLINK-10945] Use InputDependencyConstraint to avoid resource dead… URL: https://github.com/apache/flink/pull/7255 …locks in LAZY_FROM_SOURCES scheduling when resources are limited ## What is the purpose of the change This PR add a

[jira] [Commented] (FLINK-10887) Add source watermark tracking to the JobMaster

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

[GitHub] jgrier edited a comment on issue #7099: [FLINK-10887] [jobmaster] Add source watermark tracking to the JobMaster

jgrier edited a comment on issue #7099: [FLINK-10887] [jobmaster] Add source watermark tracking to the JobMaster URL: https://github.com/apache/flink/pull/7099#issuecomment-444907282 @aljoscha @tweise Can you guys comment on the above generic aggregator proposal? I'd like to keep this

[jira] [Commented] (FLINK-10887) Add source watermark tracking to the JobMaster

[ https://issues.apache.org/jira/browse/FLINK-10887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711578#comment-16711578 ] ASF GitHub Bot commented on FLINK-10887: jgrier commented on issue #7099: [FLINK-10887]

[GitHub] jgrier commented on issue #7099: [FLINK-10887] [jobmaster] Add source watermark tracking to the JobMaster

jgrier commented on issue #7099: [FLINK-10887] [jobmaster] Add source watermark tracking to the JobMaster URL: https://github.com/apache/flink/pull/7099#issuecomment-444907282 @aljoscha @tweise Can you guys comment on the above proposal? I'd like to keep this moving forward.

[jira] [Updated] (FLINK-9740) Support group windows over intervals of months

[ https://issues.apache.org/jira/browse/FLINK-9740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuqianjin updated FLINK-9740: - Attachment: (was: About [FLINK-9740] Support group windows over intervals of months.pdf) > Support

[jira] [Issue Comment Deleted] (FLINK-9740) Support group windows over intervals of months

[ https://issues.apache.org/jira/browse/FLINK-9740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuqianjin updated FLINK-9740: - Comment: was deleted (was: hi [~twalthr] The attachment has been submitted) > Support group windows

[jira] [Commented] (FLINK-11087) Broadcast state migration Incompatibility from 1.5.3 to 1.7.0

[ https://issues.apache.org/jira/browse/FLINK-11087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711511#comment-16711511 ] Tzu-Li (Gordon) Tai commented on FLINK-11087: - I'm currently modifying the

[jira] [Comment Edited] (FLINK-11087) Broadcast state migration Incompatibility from 1.5.3 to 1.7.0

[ https://issues.apache.org/jira/browse/FLINK-11087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711511#comment-16711511 ] Tzu-Li (Gordon) Tai edited comment on FLINK-11087 at 12/6/18 2:35 PM:

[jira] [Commented] (FLINK-11049) Unable to execute partial DAG

[ https://issues.apache.org/jira/browse/FLINK-11049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711508#comment-16711508 ] Till Rohrmann commented on FLINK-11049: --- Hi [~zjffdu], the Flink works is that all branches of the

[jira] [Commented] (FLINK-11087) Broadcast state migration Incompatibility from 1.5.3 to 1.7.0

[ https://issues.apache.org/jira/browse/FLINK-11087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711495#comment-16711495 ] Tzu-Li (Gordon) Tai commented on FLINK-11087: - I checked the key / value serializer

[jira] [Commented] (FLINK-9920) BucketingSinkFaultToleranceITCase fails on travis

[ https://issues.apache.org/jira/browse/FLINK-9920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711492#comment-16711492 ] Dawid Wysakowicz commented on FLINK-9920: - Another instance:

[jira] [Commented] (FLINK-11086) flink-hadoop-compatibility tests fail for 3.x hadoop versions

[ https://issues.apache.org/jira/browse/FLINK-11086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711431#comment-16711431 ] Chesnay Schepler commented on FLINK-11086: -- We haven't looked into hadoop3 support yet. >

[jira] [Assigned] (FLINK-10593) Add support for ALL ROWS PER MATCH

[ https://issues.apache.org/jira/browse/FLINK-10593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xueyu reassigned FLINK-10593: - Assignee: xueyu > Add support for ALL ROWS PER MATCH > -- > >

[jira] [Commented] (FLINK-10945) Avoid resource deadlocks for finite stream jobs when resources are limited

[ https://issues.apache.org/jira/browse/FLINK-10945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711471#comment-16711471 ] ASF GitHub Bot commented on FLINK-10945: zentol commented on issue #7252: [FLINK-10945] Add an

[jira] [Commented] (FLINK-11087) Broadcast state migration Incompatibility from 1.5.3 to 1.7.0

[ https://issues.apache.org/jira/browse/FLINK-11087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711469#comment-16711469 ] Edward Rojas commented on FLINK-11087: -- I just tried out, 1.5.3 to 1.6.2. I get a different error,

[GitHub] zentol commented on issue #7252: [FLINK-10945] Add an InputDependencyConstraint to avoid resource dead…

zentol commented on issue #7252: [FLINK-10945] Add an InputDependencyConstraint to avoid resource dead… URL: https://github.com/apache/flink/pull/7252#issuecomment-444876798 Please open the PR against the master branch. This

[jira] [Commented] (FLINK-10252) Handle oversized metric messges

[ https://issues.apache.org/jira/browse/FLINK-10252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711468#comment-16711468 ] ASF GitHub Bot commented on FLINK-10252: zentol commented on issue #6850: [FLINK-10252] Handle

[GitHub] zentol commented on issue #6850: [FLINK-10252] Handle oversized metric messges

zentol commented on issue #6850: [FLINK-10252] Handle oversized metric messges URL: https://github.com/apache/flink/pull/6850#issuecomment-444876607 Will merge this today or tomorrow depending on how much time I need for cleaning up various smaller things.

[jira] [Commented] (FLINK-11048) Ability to programmatically execute streaming pipeline with savepoint restore

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

[GitHub] maqingxiang opened a new pull request #7254: [hotfix][tableApi] fix tEnv in tableApi docs

maqingxiang opened a new pull request #7254: [hotfix][tableApi] fix tEnv in tableApi docs URL: https://github.com/apache/flink/pull/7254 This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-11048) Ability to programmatically execute streaming pipeline with savepoint restore

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

[jira] [Commented] (FLINK-11048) Ability to programmatically execute streaming pipeline with savepoint restore

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

[GitHub] mxm commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore

mxm commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore URL: https://github.com/apache/flink/pull/7249#discussion_r239451409 ## File path:

[jira] [Commented] (FLINK-11048) Ability to programmatically execute streaming pipeline with savepoint restore

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

[jira] [Commented] (FLINK-11048) Ability to programmatically execute streaming pipeline with savepoint restore

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

[GitHub] mxm commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore

mxm commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore URL: https://github.com/apache/flink/pull/7249#discussion_r239452431 ## File path:

[GitHub] mxm commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore

mxm commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore URL: https://github.com/apache/flink/pull/7249#discussion_r239451179 ## File path:

[GitHub] mxm commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore

mxm commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore URL: https://github.com/apache/flink/pull/7249#discussion_r239453780 ## File path:

[GitHub] mxm commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore

mxm commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore URL: https://github.com/apache/flink/pull/7249#discussion_r239451677 ## File path:

[jira] [Commented] (FLINK-9740) Support group windows over intervals of months

[ https://issues.apache.org/jira/browse/FLINK-9740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711442#comment-16711442 ] xuqianjin commented on FLINK-9740: -- hi [~twalthr] The attachment has been submitted > Support group

[jira] [Commented] (FLINK-9740) Support group windows over intervals of months

[ https://issues.apache.org/jira/browse/FLINK-9740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711440#comment-16711440 ] xuqianjin commented on FLINK-9740: -- @ > Support group windows over intervals of months >

[jira] [Issue Comment Deleted] (FLINK-9740) Support group windows over intervals of months

[ https://issues.apache.org/jira/browse/FLINK-9740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuqianjin updated FLINK-9740: - Comment: was deleted (was: @) > Support group windows over intervals of months >

[jira] [Updated] (FLINK-9740) Support group windows over intervals of months

[ https://issues.apache.org/jira/browse/FLINK-9740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuqianjin updated FLINK-9740: - Attachment: About [FLINK-9740] Support group windows over intervals of months.pdf > Support group

[jira] [Commented] (FLINK-11087) Broadcast state migration Incompatibility from 1.5.3 to 1.7.0

[ https://issues.apache.org/jira/browse/FLINK-11087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711437#comment-16711437 ] Chesnay Schepler commented on FLINK-11087: -- Have you tried migration from 1.5 to 1.6 to 1.7? >

[jira] [Commented] (FLINK-11085) NoClassDefFoundError in presto-s3 filesystem

[ https://issues.apache.org/jira/browse/FLINK-11085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711433#comment-16711433 ] Chesnay Schepler commented on FLINK-11085: -- [~StephanEwen] What's your take on this? >

[jira] [Created] (FLINK-11087) Broadcast state migration Incompatibility from 1.5.3 to 1.7.0

Edward Rojas created FLINK-11087: Summary: Broadcast state migration Incompatibility from 1.5.3 to 1.7.0 Key: FLINK-11087 URL: https://issues.apache.org/jira/browse/FLINK-11087 Project: Flink

[jira] [Created] (FLINK-11086) flink-hadoop-compatibility tests fail for 3.x hadoop versions

Sebastian Klemke created FLINK-11086: Summary: flink-hadoop-compatibility tests fail for 3.x hadoop versions Key: FLINK-11086 URL: https://issues.apache.org/jira/browse/FLINK-11086 Project: Flink

[jira] [Updated] (FLINK-11085) NoClassDefFoundError in presto-s3 filesystem

[ https://issues.apache.org/jira/browse/FLINK-11085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11085: - Summary: NoClassDefFoundError in presto-s3 filesystem (was: flink-s3-fs-presto) >

[jira] [Created] (FLINK-11085) flink-s3-fs-presto

Chesnay Schepler created FLINK-11085: Summary: flink-s3-fs-presto Key: FLINK-11085 URL: https://issues.apache.org/jira/browse/FLINK-11085 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-10832) StreamExecutionEnvironment.execute() does not return when all sources end

[ https://issues.apache.org/jira/browse/FLINK-10832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711387#comment-16711387 ] Chesnay Schepler commented on FLINK-10832: -- The project you attached works for me locally in

[jira] [Commented] (FLINK-7208) Refactor build-in agg(MaxWithRetractAccumulator and MinWithRetractAccumulator) using the DataView

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

[GitHub] dianfu commented on a change in pull request #7201: [FLINK-7208] [table] Optimize Min/MaxWithRetractAggFunction with DataView

dianfu commented on a change in pull request #7201: [FLINK-7208] [table] Optimize Min/MaxWithRetractAggFunction with DataView URL: https://github.com/apache/flink/pull/7201#discussion_r239438568 ## File path:

[jira] [Commented] (FLINK-11074) Improve the harness test to make it possible test with state backend

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

[jira] [Updated] (FLINK-11074) Improve the harness test to make it possible test with state backend

[ https://issues.apache.org/jira/browse/FLINK-11074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11074: --- Labels: pull-request-available (was: ) > Improve the harness test to make it possible test

[GitHub] dianfu opened a new pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction

dianfu opened a new pull request #7253: [FLINK-11074] [table][tests] Enable harness tests with RocksdbStateBackend and add harness tests for CollectAggFunction URL: https://github.com/apache/flink/pull/7253 ## What is the purpose of the change *This pull request enables the harness

[jira] [Commented] (FLINK-10945) Avoid resource deadlocks for finite stream jobs when resources are limited

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

[jira] [Updated] (FLINK-11026) Rework creation of sql-client connector/format jars

[ https://issues.apache.org/jira/browse/FLINK-11026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11026: --- Labels: pull-request-available (was: ) > Rework creation of sql-client connector/format

[GitHub] zhuzhurk opened a new pull request #7252: [FLINK-10945] Add an InputDependencyConstraint to avoid resource dead…

zhuzhurk opened a new pull request #7252: [FLINK-10945] Add an InputDependencyConstraint to avoid resource dead… URL: https://github.com/apache/flink/pull/7252 …locks for finite stream jobs when resources are limited ## What is the purpose of the change This PR add a job

[jira] [Commented] (FLINK-11026) Rework creation of sql-client connector/format jars

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

[GitHub] zentol opened a new pull request #7251: [FLINK-11026][ES6] Rework creation of fat sql-client jars

zentol opened a new pull request #7251: [FLINK-11026][ES6] Rework creation of fat sql-client jars URL: https://github.com/apache/flink/pull/7251 Based on #7247. ## What is the purpose of the change This PR is a PoC for reworking the packaging of jars specific to the

[jira] [Comment Edited] (FLINK-10333) Rethink ZooKeeper based stores (SubmittedJobGraph, MesosWorker, CompletedCheckpoints)

[ https://issues.apache.org/jira/browse/FLINK-10333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16710963#comment-16710963 ] TisonKun edited comment on FLINK-10333 at 12/6/18 11:49 AM: Hi

[jira] [Updated] (FLINK-10945) Avoid resource deadlocks for finite stream jobs when resources are limited

[ https://issues.apache.org/jira/browse/FLINK-10945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10945: --- Labels: pull-request-available (was: ) > Avoid resource deadlocks for finite stream jobs

[jira] [Commented] (FLINK-10945) Avoid resource deadlocks for finite stream jobs when resources are limited

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

[jira] [Commented] (FLINK-10945) Avoid resource deadlocks for finite stream jobs when resources are limited

[ https://issues.apache.org/jira/browse/FLINK-10945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711340#comment-16711340 ] ASF GitHub Bot commented on FLINK-10945: zhuzhurk closed pull request #7250: [FLINK-10945] Add

[GitHub] zhuzhurk closed pull request #7250: [FLINK-10945] Add an InputDependencyConstraint to avoid resource dead…

zhuzhurk closed pull request #7250: [FLINK-10945] Add an InputDependencyConstraint to avoid resource dead… URL: https://github.com/apache/flink/pull/7250 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] zhuzhurk opened a new pull request #7250: [FLINK-10945] Add an InputDependencyConstraint to avoid resource dead…

zhuzhurk opened a new pull request #7250: [FLINK-10945] Add an InputDependencyConstraint to avoid resource dead… URL: https://github.com/apache/flink/pull/7250 …locks for finite stream jobs when resources are limited ## What is the purpose of the change *(For example:

[jira] [Commented] (FLINK-10964) sql-client throws exception when paging through finished batch query

[ https://issues.apache.org/jira/browse/FLINK-10964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711334#comment-16711334 ] vinoyang commented on FLINK-10964: -- [~twalthr]  Thank you for providing more information. I personally

[jira] [Commented] (FLINK-11011) Elasticsearch 6 sink end-to-end test unstable

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

[jira] [Assigned] (FLINK-10482) java.lang.IllegalArgumentException: Negative number of in progress checkpoints

[ https://issues.apache.org/jira/browse/FLINK-10482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-10482: - Assignee: Andrey Zagrebin > java.lang.IllegalArgumentException: Negative number of in

[jira] [Updated] (FLINK-10482) java.lang.IllegalArgumentException: Negative number of in progress checkpoints

[ https://issues.apache.org/jira/browse/FLINK-10482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10482: -- Fix Version/s: 1.7.1 1.6.3 > java.lang.IllegalArgumentException: Negative

[jira] [Resolved] (FLINK-11011) Elasticsearch 6 sink end-to-end test unstable

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

[jira] [Commented] (FLINK-11011) Elasticsearch 6 sink end-to-end test unstable

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

[jira] [Commented] (FLINK-11011) Elasticsearch 6 sink end-to-end test unstable

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

[GitHub] tillrohrmann closed pull request #7216: [FLINK-11011][E2E][JM] Log error messages about null CheckpointCoordinator only if job is running

tillrohrmann closed pull request #7216: [FLINK-11011][E2E][JM] Log error messages about null CheckpointCoordinator only if job is running URL: https://github.com/apache/flink/pull/7216 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is

[GitHub] tillrohrmann closed pull request #7224: [FLINK-11011][E2E][JM] Log error messages about null CheckpointCoordinator only if job is running

tillrohrmann closed pull request #7224: [FLINK-11011][E2E][JM] Log error messages about null CheckpointCoordinator only if job is running URL: https://github.com/apache/flink/pull/7224 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is

[GitHub] tillrohrmann closed pull request #7223: [FLINK-11011][E2E][JM] Log error messages about null CheckpointCoordinator only if job is running

tillrohrmann closed pull request #7223: [FLINK-11011][E2E][JM] Log error messages about null CheckpointCoordinator only if job is running URL: https://github.com/apache/flink/pull/7223 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is

[jira] [Commented] (FLINK-11011) Elasticsearch 6 sink end-to-end test unstable

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

[GitHub] tillrohrmann closed pull request #7222: [FLINK-11011][E2E][JM] Log error messages about null CheckpointCoordinator only if job is running

tillrohrmann closed pull request #7222: [FLINK-11011][E2E][JM] Log error messages about null CheckpointCoordinator only if job is running URL: https://github.com/apache/flink/pull/7222 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is

[jira] [Closed] (FLINK-10997) Avro-confluent-registry does not bundle any dependency

[ https://issues.apache.org/jira/browse/FLINK-10997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-10997. Resolution: Fixed Fix Version/s: 1.7.1 1.8.0

[jira] [Commented] (FLINK-11048) Ability to programmatically execute streaming pipeline with savepoint restore

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

[jira] [Commented] (FLINK-10997) Avro-confluent-registry does not bundle any dependency

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

[GitHub] zentol closed pull request #7170: [FLINK-10997][formats] Bundle kafka-scheme-registry-client

zentol closed pull request #7170: [FLINK-10997][formats] Bundle kafka-scheme-registry-client URL: https://github.com/apache/flink/pull/7170 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

[jira] [Commented] (FLINK-11048) Ability to programmatically execute streaming pipeline with savepoint restore

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

[GitHub] zentol commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore

zentol commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore URL: https://github.com/apache/flink/pull/7249#discussion_r239406325 ## File path:

[jira] [Commented] (FLINK-10973) Add Map operator to Table API

[ https://issues.apache.org/jira/browse/FLINK-10973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711263#comment-16711263 ] ASF GitHub Bot commented on FLINK-10973: twalthr commented on issue #7167: [FLINK-10973] [table]

[GitHub] zentol commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore

zentol commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore URL: https://github.com/apache/flink/pull/7249#discussion_r239406192 ## File path:

[GitHub] twalthr commented on issue #7167: [FLINK-10973] [table] Add support for map to table API

twalthr commented on issue #7167: [FLINK-10973] [table] Add support for map to table API URL: https://github.com/apache/flink/pull/7167#issuecomment-444829802 Thanks for the reminder @dianfu. I will try to add my feedback until tomorrow.

[jira] [Commented] (FLINK-11048) Ability to programmatically execute streaming pipeline with savepoint restore

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

[GitHub] zentol commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore

zentol commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore URL: https://github.com/apache/flink/pull/7249#discussion_r239405800 ## File path:

[GitHub] dawidwys closed pull request #7212: [hotfix][docs] Fix invalid link in schema_evolution doc

dawidwys closed pull request #7212: [hotfix][docs] Fix invalid link in schema_evolution doc URL: https://github.com/apache/flink/pull/7212 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

[jira] [Updated] (FLINK-11036) Streaming classloader end-to-end test does not work on source releases

[ https://issues.apache.org/jira/browse/FLINK-11036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11036: -- Labels: test-stability (was: ) > Streaming classloader end-to-end test does not work on

[jira] [Commented] (FLINK-10964) sql-client throws exception when paging through finished batch query

[ https://issues.apache.org/jira/browse/FLINK-10964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16711232#comment-16711232 ] Timo Walther commented on FLINK-10964: -- I can give more information here. The issue is rather a

<    1   2   3   >