[jira] [Commented] (FLINK-10772) create_binary_release.sh is broken

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674814#comment-16674814 ] ASF GitHub Bot commented on FLINK-10772: tillrohrmann commented on issue #7016:

[jira] [Created] (FLINK-10778) Update TypeSerializerSnapshotMigrationTestBase and subclasses for 1.7

2018-11-05 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-10778: --- Summary: Update TypeSerializerSnapshotMigrationTestBase and subclasses for 1.7 Key: FLINK-10778 URL: https://issues.apache.org/jira/browse/FLINK-10778

[jira] [Created] (FLINK-10783) Update WindowOperatorMigrationTest for 1.7

2018-11-05 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-10783: --- Summary: Update WindowOperatorMigrationTest for 1.7 Key: FLINK-10783 URL: https://issues.apache.org/jira/browse/FLINK-10783 Project: Flink

[GitHub] StefanRRichter commented on issue #6994: [FLINK-10720][tests] Add deployment end-to-end stress test with many …

2018-11-05 Thread GitBox
StefanRRichter commented on issue #6994: [FLINK-10720][tests] Add deployment end-to-end stress test with many … URL: https://github.com/apache/flink/pull/6994#issuecomment-435797556 @tillrohrmann I addressed all your comments except the one with the open question from my last comment.

[jira] [Commented] (FLINK-10490) OperatorSnapshotUtil should probably use SavepointV2Serializer

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674854#comment-16674854 ] ASF GitHub Bot commented on FLINK-10490: asfgit closed pull request #6910: [FLINK-10490][tests]

[GitHub] asfgit closed pull request #6910: [FLINK-10490][tests] OperatorSnapshotUtil should use SavepointV2Seria…

2018-11-05 Thread GitBox
asfgit closed pull request #6910: [FLINK-10490][tests] OperatorSnapshotUtil should use SavepointV2Seria… URL: https://github.com/apache/flink/pull/6910 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] [Updated] (FLINK-10490) OperatorSnapshotUtil should probably use SavepointV2Serializer

2018-11-05 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-10490: --- Fix Version/s: 1.8.0 1.7.0 > OperatorSnapshotUtil should probably use

[jira] [Commented] (FLINK-10368) 'Kerberized YARN on Docker test' instable

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674876#comment-16674876 ] ASF GitHub Bot commented on FLINK-10368: aljoscha commented on issue #6965: [FLINK-10368][e2e]

[jira] [Commented] (FLINK-10368) 'Kerberized YARN on Docker test' instable

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674877#comment-16674877 ] ASF GitHub Bot commented on FLINK-10368: aljoscha edited a comment on issue #6965:

[jira] [Created] (FLINK-10775) Quarantined address [akka.tcp://flink@flink-jobmanager:6123] is still unreachable or has not been restarted. Keeping it quarantined.

2018-11-05 Thread ChuanHaiTan (JIRA)
ChuanHaiTan created FLINK-10775: --- Summary: Quarantined address [akka.tcp://flink@flink-jobmanager:6123] is still unreachable or has not been restarted. Keeping it quarantined. Key: FLINK-10775 URL:

[jira] [Commented] (FLINK-6944) Introduce DefaultTypeSerializerConfigSnapshot as a base implementation for serializer compatibility checks

2018-11-05 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674806#comment-16674806 ] Tzu-Li (Gordon) Tai commented on FLINK-6944: [~till.rohrmann] For the latest reworked design,

[jira] [Closed] (FLINK-6944) Introduce DefaultTypeSerializerConfigSnapshot as a base implementation for serializer compatibility checks

2018-11-05 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-6944. -- Resolution: Won't Fix > Introduce DefaultTypeSerializerConfigSnapshot as a base

[jira] [Created] (FLINK-10779) Update Java / Scala StatefulJobSavepointMigrationITCase for 1.7

2018-11-05 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-10779: --- Summary: Update Java / Scala StatefulJobSavepointMigrationITCase for 1.7 Key: FLINK-10779 URL: https://issues.apache.org/jira/browse/FLINK-10779

[jira] [Created] (FLINK-10788) Update ContinuousFileProcessingMigrationTest for 1.7

2018-11-05 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-10788: --- Summary: Update ContinuousFileProcessingMigrationTest for 1.7 Key: FLINK-10788 URL: https://issues.apache.org/jira/browse/FLINK-10788 Project: Flink

[GitHub] StefanRRichter commented on issue #6910: [FLINK-10490][tests] OperatorSnapshotUtil should use SavepointV2Seria…

2018-11-05 Thread GitBox
StefanRRichter commented on issue #6910: [FLINK-10490][tests] OperatorSnapshotUtil should use SavepointV2Seria… URL: https://github.com/apache/flink/pull/6910#issuecomment-435802436 Thanks for the reviews @zentol @dawidwys. Merging this.

[GitHub] yanghua commented on a change in pull request #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors

2018-11-05 Thread GitBox
yanghua commented on a change in pull request #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors URL: https://github.com/apache/flink/pull/6924#discussion_r230673105 ## File path:

[jira] [Closed] (FLINK-10632) Run general purpose test job with failures in per-job mode

2018-11-05 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-10632. Resolution: Fixed > Run general purpose test job with failures in per-job mode >

[jira] [Commented] (FLINK-10368) 'Kerberized YARN on Docker test' instable

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674862#comment-16674862 ] ASF GitHub Bot commented on FLINK-10368: dawidwys edited a comment on issue #6965:

[GitHub] dawidwys edited a comment on issue #6965: [FLINK-10368][e2e] Hardened kerberized yarn e2e test

2018-11-05 Thread GitBox
dawidwys edited a comment on issue #6965: [FLINK-10368][e2e] Hardened kerberized yarn e2e test URL: https://github.com/apache/flink/pull/6965#issuecomment-435802842 @tillrohrmann @aljoscha I've updated the test. Could you have the final look?

[jira] [Created] (FLINK-10790) Refactor all the StreamPartitioner implementations into runtime module

2018-11-05 Thread zhijiang (JIRA)
zhijiang created FLINK-10790: Summary: Refactor all the StreamPartitioner implementations into runtime module Key: FLINK-10790 URL: https://issues.apache.org/jira/browse/FLINK-10790 Project: Flink

[GitHub] tzulitai commented on issue #7019: [BP-1.7][FLINK-10773] Harden resume externalized checkpoint end-to-end test

2018-11-05 Thread GitBox
tzulitai commented on issue #7019: [BP-1.7][FLINK-10773] Harden resume externalized checkpoint end-to-end test URL: https://github.com/apache/flink/pull/7019#issuecomment-435788341 +1, LGTM. This is an automated message from

[jira] [Updated] (FLINK-10775) Quarantined address [akka.tcp://flink@flink-jobmanager:6123] is still unreachable or has not been restarted. Keeping it quarantined.

2018-11-05 Thread ChuanHaiTan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ChuanHaiTan updated FLINK-10775: Labels: k8s+docker usability (was: usability) > Quarantined address

[jira] [Commented] (FLINK-10773) Resume externalized checkpoint end-to-end test fails

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674794#comment-16674794 ] ASF GitHub Bot commented on FLINK-10773: tzulitai commented on issue #7018: [FLINK-10773] Harden

[GitHub] tzulitai commented on issue #7018: [FLINK-10773] Harden resume externalized checkpoint end-to-end test

2018-11-05 Thread GitBox
tzulitai commented on issue #7018: [FLINK-10773] Harden resume externalized checkpoint end-to-end test URL: https://github.com/apache/flink/pull/7018#issuecomment-435788373 +1, LGTM. This is an automated message from the

[jira] [Created] (FLINK-10777) Update TypeSerializerSnapshotMigrationITCase for Flink 1.7

2018-11-05 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-10777: --- Summary: Update TypeSerializerSnapshotMigrationITCase for Flink 1.7 Key: FLINK-10777 URL: https://issues.apache.org/jira/browse/FLINK-10777 Project:

[GitHub] tillrohrmann commented on issue #7016: [FLINK-10772][release] Fix create_binary_release.sh

2018-11-05 Thread GitBox
tillrohrmann commented on issue #7016: [FLINK-10772][release] Fix create_binary_release.sh URL: https://github.com/apache/flink/pull/7016#issuecomment-435794892 Thanks for the review @zentol. I think it works for the `1.6.x` release because we introduced the dependency on

[jira] [Closed] (FLINK-10732) force-shading 1.5.5 maven artifact was not released

2018-11-05 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-10732. Resolution: Fixed Maven artifact was deployed.

[jira] [Created] (FLINK-10780) Update Java / Scala StatefulJobWBroadcastStateMigrationITCase for 1.7

2018-11-05 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-10780: --- Summary: Update Java / Scala StatefulJobWBroadcastStateMigrationITCase for 1.7 Key: FLINK-10780 URL: https://issues.apache.org/jira/browse/FLINK-10780

[jira] [Commented] (FLINK-10720) Add stress deployment end-to-end test

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674828#comment-16674828 ] ASF GitHub Bot commented on FLINK-10720: StefanRRichter commented on issue #6994:

[jira] [Created] (FLINK-10784) Update FlinkKafkaConsumerBaseMigrationTest for 1.7

2018-11-05 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-10784: --- Summary: Update FlinkKafkaConsumerBaseMigrationTest for 1.7 Key: FLINK-10784 URL: https://issues.apache.org/jira/browse/FLINK-10784 Project: Flink

[jira] [Created] (FLINK-10785) Update FlinkKinesisConsumerMigrationTest for 1.7

2018-11-05 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-10785: --- Summary: Update FlinkKinesisConsumerMigrationTest for 1.7 Key: FLINK-10785 URL: https://issues.apache.org/jira/browse/FLINK-10785 Project: Flink

[GitHub] StefanRRichter commented on issue #6910: [FLINK-10490][tests] OperatorSnapshotUtil should use SavepointV2Seria…

2018-11-05 Thread GitBox
StefanRRichter commented on issue #6910: [FLINK-10490][tests] OperatorSnapshotUtil should use SavepointV2Seria… URL: https://github.com/apache/flink/pull/6910#issuecomment-435798177 @zentol @dawidwys Can somebody give a  or request changes? Thanks!

[jira] [Closed] (FLINK-10191) WindowCheckpointingITCase.testAggregatingSlidingProcessingTimeWindow

2018-11-05 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-10191. Resolution: Cannot Reproduce >

[jira] [Closed] (FLINK-10490) OperatorSnapshotUtil should probably use SavepointV2Serializer

2018-11-05 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-10490. -- Resolution: Fixed Release Note: Snapshots created with OperatorSnapshotUtil before this

[jira] [Assigned] (FLINK-10784) Update FlinkKafkaConsumerBaseMigrationTest for 1.7

2018-11-05 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-10784: Assignee: vinoyang > Update FlinkKafkaConsumerBaseMigrationTest for 1.7 >

[jira] [Created] (FLINK-10776) Update migration tests for Flink 1.7

2018-11-05 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-10776: --- Summary: Update migration tests for Flink 1.7 Key: FLINK-10776 URL: https://issues.apache.org/jira/browse/FLINK-10776 Project: Flink Issue

[jira] [Updated] (FLINK-10776) Update migration tests for Flink 1.7

2018-11-05 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-10776: Component/s: Tests > Update migration tests for Flink 1.7 >

[jira] [Updated] (FLINK-10776) Update migration tests for Flink 1.7

2018-11-05 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-10776: Description: Now that the feature branch is cut for Flink 1.7, we should now

[jira] [Created] (FLINK-10781) Update BucketingSinkMigrationTest for Flink 1.7

2018-11-05 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-10781: --- Summary: Update BucketingSinkMigrationTest for Flink 1.7 Key: FLINK-10781 URL: https://issues.apache.org/jira/browse/FLINK-10781 Project: Flink

[jira] [Commented] (FLINK-10490) OperatorSnapshotUtil should probably use SavepointV2Serializer

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674830#comment-16674830 ] ASF GitHub Bot commented on FLINK-10490: StefanRRichter commented on issue #6910:

[jira] [Created] (FLINK-10786) Update CEPMigrationTest for 1.7

2018-11-05 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-10786: --- Summary: Update CEPMigrationTest for 1.7 Key: FLINK-10786 URL: https://issues.apache.org/jira/browse/FLINK-10786 Project: Flink Issue Type:

[GitHub] dawidwys commented on issue #6965: [FLINK-10368][e2e] Hardened kerberized yarn e2e test

2018-11-05 Thread GitBox
dawidwys commented on issue #6965: [FLINK-10368][e2e] Hardened kerberized yarn e2e test URL: https://github.com/apache/flink/pull/6965#issuecomment-435802842 @tillrohrmann @aljoscha I've updated the test. Could you have final look?

[jira] [Commented] (FLINK-10368) 'Kerberized YARN on Docker test' instable

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674849#comment-16674849 ] ASF GitHub Bot commented on FLINK-10368: dawidwys commented on issue #6965: [FLINK-10368][e2e]

[jira] [Commented] (FLINK-10490) OperatorSnapshotUtil should probably use SavepointV2Serializer

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674847#comment-16674847 ] ASF GitHub Bot commented on FLINK-10490: StefanRRichter commented on issue #6910:

[jira] [Commented] (FLINK-10600) Provide End-to-end test cases for modern Kafka connectors

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674845#comment-16674845 ] ASF GitHub Bot commented on FLINK-10600: yanghua commented on a change in pull request #6924:

[GitHub] yanghua commented on issue #6927: [FLINK-10624] Extend SQL client end-to-end to test new KafkaTableSink

2018-11-05 Thread GitBox
yanghua commented on issue #6927: [FLINK-10624] Extend SQL client end-to-end to test new KafkaTableSink URL: https://github.com/apache/flink/pull/6927#issuecomment-435803131 This PR was blocked by FLINK-10600 and FLINK-10704. cc @pnowojski @twalthr and @tillrohrmann

[jira] [Commented] (FLINK-10624) Extend SQL client end-to-end to test new KafkaTableSink

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674851#comment-16674851 ] ASF GitHub Bot commented on FLINK-10624: yanghua commented on issue #6927: [FLINK-10624] Extend

[jira] [Created] (FLINK-10791) Provide end-to-end test for Kafka 0.11 connector

2018-11-05 Thread vinoyang (JIRA)
vinoyang created FLINK-10791: Summary: Provide end-to-end test for Kafka 0.11 connector Key: FLINK-10791 URL: https://issues.apache.org/jira/browse/FLINK-10791 Project: Flink Issue Type: Test

[jira] [Created] (FLINK-10782) Update AbstractKeyedOperatorRestoreTestBase for 1.7

2018-11-05 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-10782: --- Summary: Update AbstractKeyedOperatorRestoreTestBase for 1.7 Key: FLINK-10782 URL: https://issues.apache.org/jira/browse/FLINK-10782 Project: Flink

[jira] [Created] (FLINK-10787) Update AbstractNonKeyedOperatorRestoreTestBase for 1.7

2018-11-05 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-10787: --- Summary: Update AbstractNonKeyedOperatorRestoreTestBase for 1.7 Key: FLINK-10787 URL: https://issues.apache.org/jira/browse/FLINK-10787 Project: Flink

[GitHub] yanghua commented on issue #6963: [FLINK-10704] Fix sql client end to end test failure

2018-11-05 Thread GitBox
yanghua commented on issue #6963: [FLINK-10704] Fix sql client end to end test failure URL: https://github.com/apache/flink/pull/6963#issuecomment-435801869 @pnowojski @twalthr I refer to other end-to-end tests and skip the check.

[jira] [Commented] (FLINK-10704) Fix sql client end to end test failure

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674843#comment-16674843 ] ASF GitHub Bot commented on FLINK-10704: yanghua commented on issue #6963: [FLINK-10704] Fix sql

[jira] [Created] (FLINK-10789) Some new serializer snapshots added after 1.6 are not implementing the new TypeSerializerSnapshot interface

2018-11-05 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-10789: --- Summary: Some new serializer snapshots added after 1.6 are not implementing the new TypeSerializerSnapshot interface Key: FLINK-10789 URL:

[jira] [Commented] (FLINK-10191) WindowCheckpointingITCase.testAggregatingSlidingProcessingTimeWindow

2018-11-05 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674850#comment-16674850 ] Dawid Wysakowicz commented on FLINK-10191: -- Couldn't reproduce this failure. I don't see any

[jira] [Commented] (FLINK-10729) Create a Hive connector for Hive data access in Flink

2018-11-05 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674863#comment-16674863 ] Fabian Hueske commented on FLINK-10729: --- Sure, I'd be happy to have a look at the design document

[GitHub] aljoscha commented on issue #6965: [FLINK-10368][e2e] Hardened kerberized yarn e2e test

2018-11-05 Thread GitBox
aljoscha commented on issue #6965: [FLINK-10368][e2e] Hardened kerberized yarn e2e test URL: https://github.com/apache/flink/pull/6965#issuecomment-435811883 I think this looks good to merge now. : This is an automated

[jira] [Commented] (FLINK-10732) force-shading 1.5.5 maven artifact was not released

2018-11-05 Thread Maximilian Michels (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674878#comment-16674878 ] Maximilian Michels commented on FLINK-10732: Thanks! > force-shading 1.5.5 maven artifact

[GitHub] aljoscha edited a comment on issue #6965: [FLINK-10368][e2e] Hardened kerberized yarn e2e test

2018-11-05 Thread GitBox
aljoscha edited a comment on issue #6965: [FLINK-10368][e2e] Hardened kerberized yarn e2e test URL: https://github.com/apache/flink/pull/6965#issuecomment-435811883 I think this looks good to merge now.  This is an

[jira] [Commented] (FLINK-10790) Refactor all the StreamPartitioner implementations into runtime module

2018-11-05 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674875#comment-16674875 ] zhijiang commented on FLINK-10790: -- [~pnowojski], do you think it makes sense for unifying the

[jira] [Created] (FLINK-10792) Extend SQL client end-to-end to test KafkaTableSink for kafka 0.11 connector

2018-11-05 Thread vinoyang (JIRA)
vinoyang created FLINK-10792: Summary: Extend SQL client end-to-end to test KafkaTableSink for kafka 0.11 connector Key: FLINK-10792 URL: https://issues.apache.org/jira/browse/FLINK-10792 Project: Flink

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

2018-11-05 Thread GitBox
yanghua commented on issue #6850: [FLINK-10252] Handle oversized metric messges URL: https://github.com/apache/flink/pull/6850#issuecomment-435814056 @zentol This is an automated message from the Apache Git Service. To

[jira] [Commented] (FLINK-10570) State grows unbounded when "within" constraint not applied

2018-11-05 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674913#comment-16674913 ] Dawid Wysakowicz commented on FLINK-10570: -- Unfortunately it didn't make it into the 1.6.2

[jira] [Created] (FLINK-10793) Change visibility of TtlValue and TtlSerializer to public for external tools

2018-11-05 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-10793: -- Summary: Change visibility of TtlValue and TtlSerializer to public for external tools Key: FLINK-10793 URL: https://issues.apache.org/jira/browse/FLINK-10793

[jira] [Assigned] (FLINK-10793) Change visibility of TtlValue and TtlSerializer to public for external tools

2018-11-05 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-10793: -- Assignee: Stefan Richter > Change visibility of TtlValue and TtlSerializer to public

[jira] [Commented] (FLINK-10773) Resume externalized checkpoint end-to-end test fails

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16675000#comment-16675000 ] ASF GitHub Bot commented on FLINK-10773: tillrohrmann closed pull request #7018: [FLINK-10773]

[jira] [Closed] (FLINK-10772) create_binary_release.sh is broken

2018-11-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-10772. - Resolution: Fixed Fixed via master:

[GitHub] tillrohrmann closed pull request #7018: [FLINK-10773] Harden resume externalized checkpoint end-to-end test

2018-11-05 Thread GitBox
tillrohrmann closed pull request #7018: [FLINK-10773] Harden resume externalized checkpoint end-to-end test URL: https://github.com/apache/flink/pull/7018 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-10773) Resume externalized checkpoint end-to-end test fails

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674999#comment-16674999 ] ASF GitHub Bot commented on FLINK-10773: tillrohrmann commented on issue #7018: [FLINK-10773]

[GitHub] tillrohrmann commented on issue #7018: [FLINK-10773] Harden resume externalized checkpoint end-to-end test

2018-11-05 Thread GitBox
tillrohrmann commented on issue #7018: [FLINK-10773] Harden resume externalized checkpoint end-to-end test URL: https://github.com/apache/flink/pull/7018#issuecomment-435842909 Thanks for the review @tzulitai. Merging this PR.

[jira] [Commented] (FLINK-10793) Change visibility of TtlValue and TtlSerializer to public for external tools

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16675034#comment-16675034 ] ASF GitHub Bot commented on FLINK-10793: gyfora commented on issue #7021: [FLINK-10793][ttl]

[GitHub] gyfora commented on issue #7021: [FLINK-10793][ttl] Change visibility of TtlValue and TtlSerializer to…

2018-11-05 Thread GitBox
gyfora commented on issue #7021: [FLINK-10793][ttl] Change visibility of TtlValue and TtlSerializer to… URL: https://github.com/apache/flink/pull/7021#issuecomment-435852171 Looks good Stefan! Thanks a lot for fixing this so quickly :)

[jira] [Updated] (FLINK-10794) Do not create checkpointStorage when checkpoint is disabled

2018-11-05 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu updated FLINK-10794: - Description: In `StreamTask#invoke` will create CheckpointStore by

[jira] [Updated] (FLINK-10794) Do not create checkpointStorage when checkpoint is disabled

2018-11-05 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu updated FLINK-10794: - Description: In `StreamTask#invoke` will create CheckpointStore by

[jira] [Commented] (FLINK-10368) 'Kerberized YARN on Docker test' instable

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674907#comment-16674907 ] ASF GitHub Bot commented on FLINK-10368: dawidwys closed pull request #6965: [FLINK-10368][e2e]

[GitHub] dawidwys closed pull request #6965: [FLINK-10368][e2e] Hardened kerberized yarn e2e test

2018-11-05 Thread GitBox
dawidwys closed pull request #6965: [FLINK-10368][e2e] Hardened kerberized yarn e2e test URL: https://github.com/apache/flink/pull/6965 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

[jira] [Commented] (FLINK-10793) Change visibility of TtlValue and TtlSerializer to public for external tools

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674941#comment-16674941 ] ASF GitHub Bot commented on FLINK-10793: StefanRRichter commented on issue #7021:

[jira] [Commented] (FLINK-10790) Refactor all the StreamPartitioner implementations into runtime module

2018-11-05 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674971#comment-16674971 ] Piotr Nowojski commented on FLINK-10790: Is there some difference between batch and streaming in

[jira] [Commented] (FLINK-10720) Add stress deployment end-to-end test

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674987#comment-16674987 ] ASF GitHub Bot commented on FLINK-10720: tillrohrmann commented on issue #6994:

[jira] [Commented] (FLINK-10769) port InMemoryExternalCatalog to java

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674993#comment-16674993 ] ASF GitHub Bot commented on FLINK-10769: fhueske commented on issue #7012: [FLINK-10769][Table &

[GitHub] tillrohrmann closed pull request #7016: [FLINK-10772][release] Fix create_binary_release.sh

2018-11-05 Thread GitBox
tillrohrmann closed pull request #7016: [FLINK-10772][release] Fix create_binary_release.sh URL: https://github.com/apache/flink/pull/7016 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-10694) ZooKeeperHaServices Cleanup

2018-11-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674996#comment-16674996 ] Till Rohrmann commented on FLINK-10694: --- Yes it is necessary. However, I think it is not as easy

[jira] [Commented] (FLINK-10772) create_binary_release.sh is broken

2018-11-05 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674997#comment-16674997 ] ASF GitHub Bot commented on FLINK-10772: tillrohrmann closed pull request #7016:

[jira] [Updated] (FLINK-10772) create_binary_release.sh is broken

2018-11-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10772: -- Affects Version/s: 1.7.0 > create_binary_release.sh is broken >

[jira] [Updated] (FLINK-10772) create_binary_release.sh is broken

2018-11-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10772: -- Affects Version/s: (was: 1.6.2) (was: 1.7.0) >

[jira] [Updated] (FLINK-10772) create_binary_release.sh is broken

2018-11-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10772: -- Fix Version/s: (was: 1.7.0) > create_binary_release.sh is broken >

[GitHub] tillrohrmann closed pull request #7017: [BP-1.7][FLINK-10772][release] Fix create_binary_release.sh

2018-11-05 Thread GitBox
tillrohrmann closed pull request #7017: [BP-1.7][FLINK-10772][release] Fix create_binary_release.sh URL: https://github.com/apache/flink/pull/7017 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:

[jira] [Reopened] (FLINK-10773) Resume externalized checkpoint end-to-end test fails

2018-11-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reopened FLINK-10773: --- > Resume externalized checkpoint end-to-end test fails >

[jira] [Commented] (FLINK-10776) Update migration tests for Flink 1.7

2018-11-05 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16675029#comment-16675029 ] vinoyang commented on FLINK-10776: -- [~tzulitai] Do we need to create a separate issue to update the

[jira] [Updated] (FLINK-10794) Do not create checkpointStorage when checkpoint is disabled

2018-11-05 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu updated FLINK-10794: - Description: In `StreamTask#invoke` will create CheckpointStore by

[jira] [Closed] (FLINK-10368) 'Kerberized YARN on Docker test' instable

2018-11-05 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-10368. Resolution: Fixed > 'Kerberized YARN on Docker test' instable >

[jira] [Commented] (FLINK-10368) 'Kerberized YARN on Docker test' instable

2018-11-05 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674912#comment-16674912 ] Dawid Wysakowicz commented on FLINK-10368: -- Fixed in master via:

[jira] [Updated] (FLINK-10671) rest monitoring api Savepoint status call fails if akka.ask.timeout < checkpoint duration

2018-11-05 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-10671: - Description: Hi,   There seems to be a problem with REST monitoring API:

[jira] [Reopened] (FLINK-10490) OperatorSnapshotUtil should probably use SavepointV2Serializer

2018-11-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reopened FLINK-10490: --- > OperatorSnapshotUtil should probably use SavepointV2Serializer >

[GitHub] tillrohrmann commented on issue #6994: [FLINK-10720][tests] Add deployment end-to-end stress test with many …

2018-11-05 Thread GitBox
tillrohrmann commented on issue #6994: [FLINK-10720][tests] Add deployment end-to-end stress test with many … URL: https://github.com/apache/flink/pull/6994#issuecomment-435839464 Maybe it's best to say that we set the attempt number to a low value (something like 3 or so) in order to

[GitHub] tillrohrmann closed pull request #7019: [BP-1.7][FLINK-10773] Harden resume externalized checkpoint end-to-end test

2018-11-05 Thread GitBox
tillrohrmann closed pull request #7019: [BP-1.7][FLINK-10773] Harden resume externalized checkpoint end-to-end test URL: https://github.com/apache/flink/pull/7019 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake

[GitHub] tillrohrmann opened a new pull request #7022: [BP-1.7][FLINK-10773] Harden resume externalized checkpoint end-to-end test

2018-11-05 Thread GitBox
tillrohrmann opened a new pull request #7022: [BP-1.7][FLINK-10773] Harden resume externalized checkpoint end-to-end test URL: https://github.com/apache/flink/pull/7022 Backport of #7018 for `release-1.7`. This is an

[GitHub] tillrohrmann closed pull request #7022: [BP-1.7][FLINK-10773] Harden resume externalized checkpoint end-to-end test

2018-11-05 Thread GitBox
tillrohrmann closed pull request #7022: [BP-1.7][FLINK-10773] Harden resume externalized checkpoint end-to-end test URL: https://github.com/apache/flink/pull/7022 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] [Closed] (FLINK-10773) Resume externalized checkpoint end-to-end test fails

2018-11-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-10773. - Resolution: Fixed Fixed via master:

[jira] [Closed] (FLINK-10773) Resume externalized checkpoint end-to-end test fails

2018-11-05 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-10773. - Resolution: Fixed Fix Version/s: (was: 1.7.0) > Resume externalized checkpoint

[jira] [Commented] (FLINK-10771) Replace hard code of job graph file path with config option for FileJobGraphRetriever

2018-11-05 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16675004#comment-16675004 ] vinoyang commented on FLINK-10771: -- [~till.rohrmann] What do you think of this issue? At present,

  1   2   3   4   >