[jira] [Created] (FLINK-11377) AbstractYarnClusterDescriptor's validClusterSpecification is not final application resources from yarn if cli -yn -ys not effect

shengjk1 created FLINK-11377: Summary: AbstractYarnClusterDescriptor's validClusterSpecification is not final application resources from yarn if cli -yn -ys not effect Key: FLINK-11377 URL: https://issues.apache.o

[jira] [Created] (FLINK-11376) flink cli -yn -ys is not effect if (yn * ys)

shengjk1 created FLINK-11376: Summary: flink cli -yn -ys is not effect if (yn * ys)https://issues.apache.org/jira/browse/FLINK-11376 Project: Flink Issue Type: Bug Affects Versions: 1.7.1 Environment: java: jdk1.

[jira] [Created] (FLINK-11375) Concurrent modification to slot pool due to SlotSharingManager releaseSlot directly

shuai.xu created FLINK-11375: Summary: Concurrent modification to slot pool due to SlotSharingManager releaseSlot directly Key: FLINK-11375 URL: https://issues.apache.org/jira/browse/FLINK-11375 Project:

[jira] [Created] (FLINK-11374) Faiover add time range filter

lining created FLINK-11374: -- Summary: Faiover add time range filter Key: FLINK-11374 URL: https://issues.apache.org/jira/browse/FLINK-11374 Project: Flink Issue Type: Improvement Component

Re: 1.7.0 build failure, could not get required dependency from maven central.

You can try with the newest maven. I met a similar problem but solved by updating to a new version maven -- Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/

[jira] [Created] (FLINK-11373) CliFrontend cuts off reason for error messages

Maximilian Michels created FLINK-11373: -- Summary: CliFrontend cuts off reason for error messages Key: FLINK-11373 URL: https://issues.apache.org/jira/browse/FLINK-11373 Project: Flink Is

[jira] [Created] (FLINK-11372) Incorrect delegation of compatibility checks to new snapshots in CollectionSerializerConfigSnapshot

Tzu-Li (Gordon) Tai created FLINK-11372: --- Summary: Incorrect delegation of compatibility checks to new snapshots in CollectionSerializerConfigSnapshot Key: FLINK-11372 URL: https://issues.apache.org/jira/bro

[jira] [Created] (FLINK-11371) Close the AvroParquetReader after use

Fokko Driesprong created FLINK-11371: Summary: Close the AvroParquetReader after use Key: FLINK-11371 URL: https://issues.apache.org/jira/browse/FLINK-11371 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-11370) Check and port ZooKeeperLeaderElectionITCase to new code base if necessary

Till Rohrmann created FLINK-11370: - Summary: Check and port ZooKeeperLeaderElectionITCase to new code base if necessary Key: FLINK-11370 URL: https://issues.apache.org/jira/browse/FLINK-11370 Project:

[jira] [Created] (FLINK-11368) Check and port TaskManagerStartupTest to new code base if necessary

Till Rohrmann created FLINK-11368: - Summary: Check and port TaskManagerStartupTest to new code base if necessary Key: FLINK-11368 URL: https://issues.apache.org/jira/browse/FLINK-11368 Project: Flink

[jira] [Created] (FLINK-11369) Check and port ZooKeeperHAJobManagerTest to new code base if necessary

Till Rohrmann created FLINK-11369: - Summary: Check and port ZooKeeperHAJobManagerTest to new code base if necessary Key: FLINK-11369 URL: https://issues.apache.org/jira/browse/FLINK-11369 Project: Fli

[jira] [Created] (FLINK-11366) Check and port TaskManagerMetricsTest to new code base if necessary

Till Rohrmann created FLINK-11366: - Summary: Check and port TaskManagerMetricsTest to new code base if necessary Key: FLINK-11366 URL: https://issues.apache.org/jira/browse/FLINK-11366 Project: Flink

[jira] [Created] (FLINK-11367) Check and port TaskManagerProcessReapingTestBase to new code base if necessary

Till Rohrmann created FLINK-11367: - Summary: Check and port TaskManagerProcessReapingTestBase to new code base if necessary Key: FLINK-11367 URL: https://issues.apache.org/jira/browse/FLINK-11367 Proj

[jira] [Created] (FLINK-11364) Check and port TaskManagerFailsITCase to new code base if necessary

Till Rohrmann created FLINK-11364: - Summary: Check and port TaskManagerFailsITCase to new code base if necessary Key: FLINK-11364 URL: https://issues.apache.org/jira/browse/FLINK-11364 Project: Flink

[jira] [Created] (FLINK-11365) Check and port TaskManagerFailureRecoveryITCase to new code base if necessary

Till Rohrmann created FLINK-11365: - Summary: Check and port TaskManagerFailureRecoveryITCase to new code base if necessary Key: FLINK-11365 URL: https://issues.apache.org/jira/browse/FLINK-11365 Proje

[jira] [Created] (FLINK-11363) Check and remove TaskManagerConfigurationTest

Till Rohrmann created FLINK-11363: - Summary: Check and remove TaskManagerConfigurationTest Key: FLINK-11363 URL: https://issues.apache.org/jira/browse/FLINK-11363 Project: Flink Issue Type: S

[jira] [Created] (FLINK-11362) Check and port TaskManagerComponentsStartupShutdownTest to new code base if necessary

Till Rohrmann created FLINK-11362: - Summary: Check and port TaskManagerComponentsStartupShutdownTest to new code base if necessary Key: FLINK-11362 URL: https://issues.apache.org/jira/browse/FLINK-11362

[jira] [Created] (FLINK-11360) Check and remove LocalFlinkMiniClusterITCase

Till Rohrmann created FLINK-11360: - Summary: Check and remove LocalFlinkMiniClusterITCase Key: FLINK-11360 URL: https://issues.apache.org/jira/browse/FLINK-11360 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-11361) Check and port RecoveryITCase to new code base if necessary

Till Rohrmann created FLINK-11361: - Summary: Check and port RecoveryITCase to new code base if necessary Key: FLINK-11361 URL: https://issues.apache.org/jira/browse/FLINK-11361 Project: Flink

[jira] [Created] (FLINK-11358) Check and port LeaderChangeStateCleanupTest to new code base if necessary

Till Rohrmann created FLINK-11358: - Summary: Check and port LeaderChangeStateCleanupTest to new code base if necessary Key: FLINK-11358 URL: https://issues.apache.org/jira/browse/FLINK-11358 Project:

[jira] [Created] (FLINK-11359) Check and port LegacyAvroExternalJarProgramITCase to new code base if necessary

Till Rohrmann created FLINK-11359: - Summary: Check and port LegacyAvroExternalJarProgramITCase to new code base if necessary Key: FLINK-11359 URL: https://issues.apache.org/jira/browse/FLINK-11359 Pro

[jira] [Created] (FLINK-11357) Check and port LeaderChangeJobRecoveryTest to new code base if necessary

Till Rohrmann created FLINK-11357: - Summary: Check and port LeaderChangeJobRecoveryTest to new code base if necessary Key: FLINK-11357 URL: https://issues.apache.org/jira/browse/FLINK-11357 Project: F

[jira] [Created] (FLINK-11356) Check and port JobManagerStartupTest to new code base if necessary

Till Rohrmann created FLINK-11356: - Summary: Check and port JobManagerStartupTest to new code base if necessary Key: FLINK-11356 URL: https://issues.apache.org/jira/browse/FLINK-11356 Project: Flink

[jira] [Created] (FLINK-11355) Check and port JobManagerProcessReapingTest if necessary to new code base

Till Rohrmann created FLINK-11355: - Summary: Check and port JobManagerProcessReapingTest if necessary to new code base Key: FLINK-11355 URL: https://issues.apache.org/jira/browse/FLINK-11355 Project:

[jira] [Created] (FLINK-11354) Check and port JobManagerHARecoveryTest if necessary to new code base

Till Rohrmann created FLINK-11354: - Summary: Check and port JobManagerHARecoveryTest if necessary to new code base Key: FLINK-11354 URL: https://issues.apache.org/jira/browse/FLINK-11354 Project: Flin

[jira] [Created] (FLINK-11353) Check & port JobManagerHAJobGraphRecoveryITCase if necessary to new code base

Till Rohrmann created FLINK-11353: - Summary: Check & port JobManagerHAJobGraphRecoveryITCase if necessary to new code base Key: FLINK-11353 URL: https://issues.apache.org/jira/browse/FLINK-11353 Proje

[jira] [Created] (FLINK-11352) Check and port JobManagerHACheckpointRecoveryITCase to new code base if necessary

Till Rohrmann created FLINK-11352: - Summary: Check and port JobManagerHACheckpointRecoveryITCase to new code base if necessary Key: FLINK-11352 URL: https://issues.apache.org/jira/browse/FLINK-11352 P

[jira] [Created] (FLINK-11351) Port JobManagerCleanupITCase to new code base

Till Rohrmann created FLINK-11351: - Summary: Port JobManagerCleanupITCase to new code base Key: FLINK-11351 URL: https://issues.apache.org/jira/browse/FLINK-11351 Project: Flink Issue Type: S

[jira] [Created] (FLINK-11350) Remove JobClientActorRecoveryITCase

Till Rohrmann created FLINK-11350: - Summary: Remove JobClientActorRecoveryITCase Key: FLINK-11350 URL: https://issues.apache.org/jira/browse/FLINK-11350 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-11349) Port CoordinatorShutdownTest to new code base

Till Rohrmann created FLINK-11349: - Summary: Port CoordinatorShutdownTest to new code base Key: FLINK-11349 URL: https://issues.apache.org/jira/browse/FLINK-11349 Project: Flink Issue Type: S

[jira] [Created] (FLINK-11348) Port YARNSessionCapacitySchedulerITCase to new code base

Till Rohrmann created FLINK-11348: - Summary: Port YARNSessionCapacitySchedulerITCase to new code base Key: FLINK-11348 URL: https://issues.apache.org/jira/browse/FLINK-11348 Project: Flink Is

[jira] [Created] (FLINK-11347) Optimize the ParquetAvroWriters factory

Fokko Driesprong created FLINK-11347: Summary: Optimize the ParquetAvroWriters factory Key: FLINK-11347 URL: https://issues.apache.org/jira/browse/FLINK-11347 Project: Flink Issue Type: I

[jira] [Created] (FLINK-11346) Could not enable basic authentication with elastic search connector

kannan created FLINK-11346: -- Summary: Could not enable basic authentication with elastic search connector Key: FLINK-11346 URL: https://issues.apache.org/jira/browse/FLINK-11346 Project: Flink Issu

Re: [NOTICE] Mandatory migration of git repositories to gitbox.apache.org

The repositories have been dropped. On 16.01.2019 14:12, Stephan Ewen wrote: +1 to drop those repos On Wed, Jan 16, 2019 at 12:08 PM Ufuk Celebi > wrote: Thanks Chesnay. +1 to drop since we are not using them (flink-libraries is empty and incubator-flink r

Re: [NOTICE] Mandatory migration of git repositories to gitbox.apache.org

+1 to drop those repos On Wed, Jan 16, 2019 at 12:08 PM Ufuk Celebi wrote: > Thanks Chesnay. > > +1 to drop since we are not using them (flink-libraries is empty and > incubator-flink redirects to flink in GitHub). > > – Ufuk > > On Wed, Jan 16, 2019 at 10:38 AM Chesnay Schepler > wrote: > > >

Data not getting passed between operators

Hi I have a Flink 1.7 with Kafka 0.11 and ES 6.5 setup. I can see the Flink Kafka Consumer consuming messages, but these are not passed on to the next level, that is the elasticsearch sink. Unable to find any logs relevant to this. Logs about my kafka consumers 2019-01-16 17:28:05,860 DEBUG org

Re: [NOTICE] Mandatory migration of git repositories to gitbox.apache.org

Thanks Chesnay. +1 to drop since we are not using them (flink-libraries is empty and incubator-flink redirects to flink in GitHub). – Ufuk On Wed, Jan 16, 2019 at 10:38 AM Chesnay Schepler wrote: > > I've filed https://issues.apache.org/jira/browse/INFRA-17666. > > On 16.01.2019 10:32, Tzu-Li (

Re: [DISCUSS] Support Interactive Programming in Flink Table API

Hey Becket, +1 From my side Piotrek > On 14 Jan 2019, at 14:43, Becket Qin wrote: > > Hi Seth, > > Thanks for the feedback. Re-caching makes sense to me. Piotr and I had some > offline discussion and we generally reached consensus on the following API: > > { > /** >* Cache this table to

[jira] [Created] (FLINK-11345) BucketingSinkFaultToleranceITCase failed on Travis

Chesnay Schepler created FLINK-11345: Summary: BucketingSinkFaultToleranceITCase failed on Travis Key: FLINK-11345 URL: https://issues.apache.org/jira/browse/FLINK-11345 Project: Flink Is

Re: [NOTICE] Mandatory migration of git repositories to gitbox.apache.org

I've filed https://issues.apache.org/jira/browse/INFRA-17666. On 16.01.2019 10:32, Tzu-Li (Gordon) Tai wrote: Makes sense if we haven't been using them. +1 to drop. On Thu, Jan 3, 2019 at 2:45 PM Aljoscha Krettek > wrote: Sounds good. > On 3. Jan 2019, at

Re: [NOTICE] Mandatory migration of git repositories to gitbox.apache.org

Makes sense if we haven't been using them. +1 to drop. On Thu, Jan 3, 2019 at 2:45 PM Aljoscha Krettek wrote: > Sounds good. > > > On 3. Jan 2019, at 14:27, Chesnay Schepler wrote: > > > > Since neither of these repositories are in use (flink-libraries is > empty, and incubator-flink is 3+ year

Re: 1.7.0 build failure, could not get required dependency from maven central.

The hadoop uber jar is not deployed to maven. You have to build it locally if you want to build flink-dist yourself. On 14.01.2019 15:22, jiaxl wrote: Below is maven build error: [ERROR] Failed to execute goal on project flink-dist_2.11: Could not resolve dependencies for project org.apache.fl

[jira] [Created] (FLINK-11344) Show All Execution Attempt Information on Flink Web Dashboard

BoWang created FLINK-11344: -- Summary: Show All Execution Attempt Information on Flink Web Dashboard Key: FLINK-11344 URL: https://issues.apache.org/jira/browse/FLINK-11344 Project: Flink Issue Type