[GitHub] [flink] leesf commented on issue #7862: [FLINK-11779] CLI ignores -m parameter if high-availability is ZOOKEEPER

leesf commented on issue #7862: [FLINK-11779] CLI ignores -m parameter if high-availability is ZOOKEEPER URL: https://github.com/apache/flink/pull/7862#issuecomment-480462684 @flinkbot cc @zentol @GJL , could you please review this PR when you have time. Thanks ---

[jira] [Updated] (FLINK-12119) Add OWASP Dependency Check to Flink Build

[ https://issues.apache.org/jira/browse/FLINK-12119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-12119: - Description: In order to obtain some visibility on the current known security vulnerabi

[jira] [Created] (FLINK-12119) Add OWASP Dependency Check to Flink Build

Konstantin Knauf created FLINK-12119: Summary: Add OWASP Dependency Check to Flink Build Key: FLINK-12119 URL: https://issues.apache.org/jira/browse/FLINK-12119 Project: Flink Issue Type:

[jira] [Commented] (FLINK-8801) S3's eventual consistent read-after-write may fail yarn deployment of resources to S3

[ https://issues.apache.org/jira/browse/FLINK-8801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16811267#comment-16811267 ] Yan Yan commented on FLINK-8801: Hi [~NicoK], I have the same concern. I was using the o

[jira] [Commented] (FLINK-12104) Flink Kafka fails with Incompatible KafkaProducer version / NoSuchFieldException sequenceNumbers

[ https://issues.apache.org/jira/browse/FLINK-12104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16811250#comment-16811250 ] Tim commented on FLINK-12104: - I can confirm that this fix works. > Flink Kafka fails with

[jira] [Resolved] (FLINK-12104) Flink Kafka fails with Incompatible KafkaProducer version / NoSuchFieldException sequenceNumbers

[ https://issues.apache.org/jira/browse/FLINK-12104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tim resolved FLINK-12104. - Resolution: Fixed > Flink Kafka fails with Incompatible KafkaProducer version / > NoSuchFieldException sequence

[jira] [Updated] (FLINK-12115) Add support in Flink to persist state in Azure's blob store

[ https://issues.apache.org/jira/browse/FLINK-12115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12115: --- Labels: pull-request-available (was: ) > Add support in Flink to persist state in Azure's b

[GitHub] [flink] flinkbot commented on issue #8117: [FLINK-12115] [filesystems]: Add support for AzureFS

flinkbot commented on issue #8117: [FLINK-12115] [filesystems]: Add support for AzureFS URL: https://github.com/apache/flink/pull/8117#issuecomment-480408700 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull reque

[GitHub] [flink] piyushnarang opened a new pull request #8117: [FLINK-12115] [filesystems]: Add support for AzureFS

piyushnarang opened a new pull request #8117: [FLINK-12115] [filesystems]: Add support for AzureFS URL: https://github.com/apache/flink/pull/8117 ## What is the purpose of the change Add support for the Azure blob store as one of the supported flink-filesystems. ## B

[jira] [Commented] (FLINK-10950) RocksDB backend does not work on Windows due to path issue

[ https://issues.apache.org/jira/browse/FLINK-10950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16811191#comment-16811191 ] Michał Jedynak commented on FLINK-10950: Duplicate of [10918|https://issues.apac

[jira] [Commented] (FLINK-8033) Build Flink with JDK 9

[ https://issues.apache.org/jira/browse/FLINK-8033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16811156#comment-16811156 ] Chesnay Schepler commented on FLINK-8033: - because you still have to solve most o

[jira] [Commented] (FLINK-8033) Build Flink with JDK 9

[ https://issues.apache.org/jira/browse/FLINK-8033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16811075#comment-16811075 ] David Anderson commented on FLINK-8033: --- [~Zentol] I'm no longer hearing any intere

[GitHub] [flink] flinkbot commented on issue #8116: [FLINK-11920][scala] Reuse java classpath

flinkbot commented on issue #8116: [FLINK-11920][scala] Reuse java classpath URL: https://github.com/apache/flink/pull/8116#issuecomment-480324226 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will

[jira] [Updated] (FLINK-11920) EnumValueSerializerUpgradeTest fails on Java 9

[ https://issues.apache.org/jira/browse/FLINK-11920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11920: --- Labels: pull-request-available (was: ) > EnumValueSerializerUpgradeTest fails on Java 9 > -

[GitHub] [flink] zentol opened a new pull request #8116: [FLINK-11920][scala] Reuse java classpath

zentol opened a new pull request #8116: [FLINK-11920][scala] Reuse java classpath URL: https://github.com/apache/flink/pull/8116 Simplifies the `EnumValueSerializerUpgradeTest` by setting `usejavacp` instead of manually re-creating the classpath. With this the test passes on Java 9.

[jira] [Updated] (FLINK-12099) Elasticsearch(1)SinkITCase fails on Java 9

[ https://issues.apache.org/jira/browse/FLINK-12099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12099: --- Labels: pull-request-available (was: ) > Elasticsearch(1)SinkITCase fails on Java 9 > -

[GitHub] [flink] flinkbot commented on issue #8115: [FLINK-12099][travis] Remove Elasticsearch1 exclusion

flinkbot commented on issue #8115: [FLINK-12099][travis] Remove Elasticsearch1 exclusion URL: https://github.com/apache/flink/pull/8115#issuecomment-480321914 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull requ

[GitHub] [flink] zentol opened a new pull request #8115: [FLINK-12099][travis] Remove Elasticsearch1 exclusion

zentol opened a new pull request #8115: [FLINK-12099][travis] Remove Elasticsearch1 exclusion URL: https://github.com/apache/flink/pull/8115 ES1 simply doesn't support Java 9 so the tests are disabled in that case. This is an

[GitHub] [flink] aloyszhang commented on issue #8075: [FLINK-12043][core] Process unreadble NPE without any hint

aloyszhang commented on issue #8075: [FLINK-12043][core] Process unreadble NPE without any hint URL: https://github.com/apache/flink/pull/8075#issuecomment-480316447 @zento If you think this is not needed, you can close this pr. --

[GitHub] [flink] aloyszhang commented on issue #8054: [hotfix][docs] fix description error of checkpoint directory

aloyszhang commented on issue #8054: [hotfix][docs] fix description error of checkpoint directory URL: https://github.com/apache/flink/pull/8054#issuecomment-480316073 @zentol please review this pr when it's convenience This

[jira] [Comment Edited] (FLINK-11974) Introduce StreamOperatorSubstitutor to help table perform the whole Operator CodeGen

[ https://issues.apache.org/jira/browse/FLINK-11974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16810900#comment-16810900 ] Piotr Nowojski edited comment on FLINK-11974 at 4/5/19 2:50 PM: --

[jira] [Comment Edited] (FLINK-11974) Introduce StreamOperatorSubstitutor to help table perform the whole Operator CodeGen

[ https://issues.apache.org/jira/browse/FLINK-11974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16810900#comment-16810900 ] Piotr Nowojski edited comment on FLINK-11974 at 4/5/19 2:47 PM: --

[jira] [Commented] (FLINK-11974) Introduce StreamOperatorSubstitutor to help table perform the whole Operator CodeGen

[ https://issues.apache.org/jira/browse/FLINK-11974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16810900#comment-16810900 ] Piotr Nowojski commented on FLINK-11974: Can we take a step back here? Maybe I'm

[jira] [Updated] (FLINK-12116) Args autocast will cause exception for plan transformation in TableAPI

[ https://issues.apache.org/jira/browse/FLINK-12116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-12116: Description: In tableAPI, the automatic typecast for arguments may break their initial structures

[jira] [Closed] (FLINK-12050) BlockingShutdownTest fails on Java 9

[ https://issues.apache.org/jira/browse/FLINK-12050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-12050. Resolution: Fixed Fix Version/s: 1.9.0 master: 8d05e91945c6c8d83f9924c00890ccf350f1

[jira] [Updated] (FLINK-12050) BlockingShutdownTest fails on Java 9

[ https://issues.apache.org/jira/browse/FLINK-12050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12050: - Issue Type: Sub-task (was: Bug) Parent: FLINK-8033 > BlockingShutdownTest fails

[GitHub] [flink] zentol merged pull request #8083: [FLINK-12050][Tests] BlockingShutdownTest fails on Java 9

zentol merged pull request #8083: [FLINK-12050][Tests] BlockingShutdownTest fails on Java 9 URL: https://github.com/apache/flink/pull/8083 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] leesf commented on a change in pull request #8083: [FLINK-12050][Tests] BlockingShutdownTest fails on Java 9

leesf commented on a change in pull request #8083: [FLINK-12050][Tests] BlockingShutdownTest fails on Java 9 URL: https://github.com/apache/flink/pull/8083#discussion_r272576789 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/testutils/TestJvmProcess.java ##

[jira] [Assigned] (FLINK-12099) Elasticsearch(1)SinkITCase fails on Java 9

[ https://issues.apache.org/jira/browse/FLINK-12099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-12099: Assignee: Chesnay Schepler > Elasticsearch(1)SinkITCase fails on Java 9 > ---

[jira] [Assigned] (FLINK-11920) EnumValueSerializerUpgradeTest fails on Java 9

[ https://issues.apache.org/jira/browse/FLINK-11920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-11920: Assignee: Chesnay Schepler > EnumValueSerializerUpgradeTest fails on Java 9 > ---

[GitHub] [flink] sunjincheng121 commented on issue #7196: [FLINK-10974] [table] Add support for flatMap to table API

sunjincheng121 commented on issue #7196: [FLINK-10974] [table] Add support for flatMap to table API URL: https://github.com/apache/flink/pull/7196#issuecomment-480256259 Hi @dianfu please rebase the code, thanks! This is an

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

[ https://issues.apache.org/jira/browse/FLINK-10973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-10973. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in master: 656bd9caf62355b3936831c9ef6f0f026326f

[GitHub] [flink] asfgit closed pull request #7167: [FLINK-10973] [table] Add support for map to table API

asfgit closed pull request #7167: [FLINK-10973] [table] Add support for map to table API URL: https://github.com/apache/flink/pull/7167 This is an automated message from the Apache Git Service. To respond to the message, ple

[jira] [Updated] (FLINK-11920) EnumValueSerializerUpgradeTest fails on Java 9

[ https://issues.apache.org/jira/browse/FLINK-11920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11920: - Description: The \{{EnumValueSerializerUpgradeTest}} fails on Java 9 since it relies on

[jira] [Updated] (FLINK-12015) TaskManagerRunnerTest is unstable

[ https://issues.apache.org/jira/browse/FLINK-12015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12015: - Fix Version/s: (was: 1.8.1) (was: 1.9.0) 1.

[jira] [Updated] (FLINK-12001) Test AvroExternalJarProgramITCase, get `JAR file does not exist` Error.

[ https://issues.apache.org/jira/browse/FLINK-12001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12001: - Fix Version/s: (was: 1.8.1) (was: 1.9.0) 1.

[jira] [Comment Edited] (FLINK-12012) BroadcastStateITCase does not use Test Environments

[ https://issues.apache.org/jira/browse/FLINK-12012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16801556#comment-16801556 ] Chesnay Schepler edited comment on FLINK-12012 at 4/5/19 12:01 PM: ---

[jira] [Updated] (FLINK-12012) BroadcastStateITCase does not use Test Environments

[ https://issues.apache.org/jira/browse/FLINK-12012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12012: - Fix Version/s: (was: 1.8.1) (was: 1.9.0) 1.

[jira] [Updated] (FLINK-9007) End-to-end test: Kinesis connector

[ https://issues.apache.org/jira/browse/FLINK-9007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9007: Fix Version/s: (was: 1.8.1) (was: 1.9.0) 1.8.0

[jira] [Updated] (FLINK-11887) Latency metrics drift apart

[ https://issues.apache.org/jira/browse/FLINK-11887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11887: - Fix Version/s: (was: 1.8.1) (was: 1.9.0) 1.

[jira] [Updated] (FLINK-11786) Merge cron branches into respective release branches

[ https://issues.apache.org/jira/browse/FLINK-11786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11786: - Fix Version/s: (was: 1.8.1) (was: 1.9.0) 1.

[jira] [Updated] (FLINK-12006) ZooKeeperHaServicesTest.testSimpleCloseAndCleanupAllData is unstable

[ https://issues.apache.org/jira/browse/FLINK-12006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12006: - Fix Version/s: (was: 1.8.1) (was: 1.9.0) 1.

[jira] [Updated] (FLINK-12021) Let ResultConjunctFuture return future results in same order as futures

[ https://issues.apache.org/jira/browse/FLINK-12021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12021: - Fix Version/s: (was: 1.8.1) (was: 1.9.0) 1.

[jira] [Updated] (FLINK-12051) TaskExecutorTest.testFilterOutDuplicateJobMasterRegistrations() does not wait for TaskExecutor to be started

[ https://issues.apache.org/jira/browse/FLINK-12051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12051: - Fix Version/s: (was: 1.8.1) 1.8.0 > TaskExecutorTest.testFilterOu

[jira] [Updated] (FLINK-11826) Kafka09ITCase.testRateLimitedConsumer fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-11826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11826: - Fix Version/s: (was: 1.9.0) 1.8.0 > Kafka09ITCase.testRateLimited

[jira] [Commented] (FLINK-11826) Kafka09ITCase.testRateLimitedConsumer fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-11826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16810733#comment-16810733 ] Chesnay Schepler commented on FLINK-11826: -- 1.8: e42fa0e057eecb8b773e7d57d01fb5

[jira] [Updated] (FLINK-11826) Kafka09ITCase.testRateLimitedConsumer fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-11826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-11826: - Affects Version/s: (was: 1.9.0) 1.8.0 > Kafka09ITCase.testRat

[jira] [Updated] (FLINK-12100) Kafka 0.10/0.11 tests fail on Java 9

[ https://issues.apache.org/jira/browse/FLINK-12100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12100: --- Labels: pull-request-available (was: ) > Kafka 0.10/0.11 tests fail on Java 9 > ---

[GitHub] [flink] flinkbot commented on issue #8114: [FLINK-12100][kafka] Add jaxb-api dependency on Java 9

flinkbot commented on issue #8114: [FLINK-12100][kafka] Add jaxb-api dependency on Java 9 URL: https://github.com/apache/flink/pull/8114#issuecomment-480238839 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull req

[GitHub] [flink] zentol opened a new pull request #8114: [FLINK-12100][kafka] Add jaxb-api dependency on Java 9

zentol opened a new pull request #8114: [FLINK-12100][kafka] Add jaxb-api dependency on Java 9 URL: https://github.com/apache/flink/pull/8114 ## What is the purpose of the change Adds `jaxb-api` to the kafka 0.10/0.11 dependencies during tests. These are required by jetty and are no

[jira] [Created] (FLINK-12118) Documentation in left navigation is not in step with its content

Yu Haidong created FLINK-12118: -- Summary: Documentation in left navigation is not in step with its content Key: FLINK-12118 URL: https://issues.apache.org/jira/browse/FLINK-12118 Project: Flink

[jira] [Created] (FLINK-12117) CassandraConnectorITCase fails on Java 9

Chesnay Schepler created FLINK-12117: Summary: CassandraConnectorITCase fails on Java 9 Key: FLINK-12117 URL: https://issues.apache.org/jira/browse/FLINK-12117 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-12065) E2E tests fail due to illegal-access warning on Java 9

[ https://issues.apache.org/jira/browse/FLINK-12065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-12065: Assignee: Chesnay Schepler > E2E tests fail due to illegal-access warning on Java

[GitHub] [flink] zentol commented on issue #7780: [FLINK-11593][tests] Check & port TaskManagerTest to new code base

zentol commented on issue #7780: [FLINK-11593][tests] Check & port TaskManagerTest to new code base URL: https://github.com/apache/flink/pull/7780#issuecomment-480229781 Changelog for the `JobSubmissionEnvironment` refactoring: ``` - inline prepareEnvironment into constructor - ini

[GitHub] [flink] azagrebin commented on issue #7835: [FLINK-11750][network] Replace IntermediateResultPartitionID with ResultPartitionID in ResultPartitionDeploymentDescriptor

azagrebin commented on issue #7835: [FLINK-11750][network] Replace IntermediateResultPartitionID with ResultPartitionID in ResultPartitionDeploymentDescriptor URL: https://github.com/apache/flink/pull/7835#issuecomment-480211309 @zhijiangW , thinking about [result partition lifecycle](htt

[GitHub] [flink] azagrebin edited a comment on issue #7835: [FLINK-11750][network] Replace IntermediateResultPartitionID with ResultPartitionID in ResultPartitionDeploymentDescriptor

azagrebin edited a comment on issue #7835: [FLINK-11750][network] Replace IntermediateResultPartitionID with ResultPartitionID in ResultPartitionDeploymentDescriptor URL: https://github.com/apache/flink/pull/7835#issuecomment-480211309 @zhijiangW , thinking about [result partition lif

[GitHub] [flink] zentol commented on a change in pull request #8083: [FLINK-12050][Tests] BlockingShutdownTest fails on Java 9

zentol commented on a change in pull request #8083: [FLINK-12050][Tests] BlockingShutdownTest fails on Java 9 URL: https://github.com/apache/flink/pull/8083#discussion_r272490263 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/testutils/TestJvmProcess.java #

[jira] [Closed] (FLINK-12112) AbstractTaskManagerProcessFailureRecoveryTest process output logging does not work properly

[ https://issues.apache.org/jira/browse/FLINK-12112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-12112. Resolution: Fixed master: bf62427cc13cdb427172d22d427d3563694fcbc4 1.8: 46934b39cbe2de7d60

[GitHub] [flink] zentol merged pull request #8113: [FLINK-12112][tests] Properly print process output

zentol merged pull request #8113: [FLINK-12112][tests] Properly print process output URL: https://github.com/apache/flink/pull/8113 This is an automated message from the Apache Git Service. To respond to the message, please