[jira] [Assigned] (FLINK-35109) Add support for Flink 1.20-SNAPSHOT in Flink Kafka connector and drop support for 1.17 and 1.18

[ https://issues.apache.org/jira/browse/FLINK-35109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-35109: --- Assignee: Fabian Paul (was: Ufuk Celebi) > Add support for Flink 1.20-SNAPSHOT in Flink

[jira] [Resolved] (FLINK-35239) 1.19 docs show outdated warning

[ https://issues.apache.org/jira/browse/FLINK-35239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-35239. - Resolution: Fixed > 1.19 docs show outdated warning > --- > >

[jira] [Created] (FLINK-35239) 1.19 docs show outdated warning

Ufuk Celebi created FLINK-35239: --- Summary: 1.19 docs show outdated warning Key: FLINK-35239 URL: https://issues.apache.org/jira/browse/FLINK-35239 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-35109) Add support for Flink 1.20-SNAPSHOT in Flink Kafka connector and drop support for 1.17 and 1.18

[ https://issues.apache.org/jira/browse/FLINK-35109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-35109: --- Assignee: Ufuk Celebi > Add support for Flink 1.20-SNAPSHOT in Flink Kafka connector and

[jira] [Assigned] (FLINK-35009) Change on getTransitivePredecessors breaks connectors

[ https://issues.apache.org/jira/browse/FLINK-35009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-35009: --- Assignee: Martijn Visser > Change on getTransitivePredecessors breaks connectors >

[jira] [Created] (FLINK-35038) Bump test dependency org.yaml:snakeyaml to 2.2

Ufuk Celebi created FLINK-35038: --- Summary: Bump test dependency org.yaml:snakeyaml to 2.2 Key: FLINK-35038 URL: https://issues.apache.org/jira/browse/FLINK-35038 Project: Flink Issue Type:

[jira] [Created] (FLINK-21928) DuplicateJobSubmissionException after JobManager failover

Ufuk Celebi created FLINK-21928: --- Summary: DuplicateJobSubmissionException after JobManager failover Key: FLINK-21928 URL: https://issues.apache.org/jira/browse/FLINK-21928 Project: Flink

[jira] [Commented] (FLINK-21351) Incremental checkpoint data would be lost once a non-stop savepoint completed

[ https://issues.apache.org/jira/browse/FLINK-21351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17294788#comment-17294788 ] Ufuk Celebi commented on FLINK-21351: - [~roman_khachatryan] The ticket includes fixVersion 1.11.4.

[jira] [Commented] (FLINK-10841) Reduce the number of ListObjects calls when checkpointing to S3

[ https://issues.apache.org/jira/browse/FLINK-10841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17262719#comment-17262719 ] Ufuk Celebi commented on FLINK-10841: - [~uberspot] Presto's S3 FileSystem seems to only use v1

[jira] [Commented] (FLINK-18192) Upgrade to Avro version 1.10.0 from 1.8.2

[ https://issues.apache.org/jira/browse/FLINK-18192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17222800#comment-17222800 ] Ufuk Celebi commented on FLINK-18192: - [~trohrmann] Thanks for the ping. If the upgrade is feasible

[jira] [Commented] (FLINK-18828) Terminate jobmanager process with zero exit code to avoid unexpected restarting by K8s

[ https://issues.apache.org/jira/browse/FLINK-18828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17202044#comment-17202044 ] Ufuk Celebi commented on FLINK-18828: - [~trohrmann] [~fly_in_gis] Just noticed that this ticket has

[jira] [Commented] (FLINK-18828) Terminate jobmanager process with zero exit code to avoid unexpected restarting by K8s

[ https://issues.apache.org/jira/browse/FLINK-18828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186623#comment-17186623 ] Ufuk Celebi commented on FLINK-18828: - Thanks for the summary, Till. I think that's a good way to

[jira] [Comment Edited] (FLINK-18828) Terminate jobmanager process with zero exit code to avoid unexpected restarting by K8s

[ https://issues.apache.org/jira/browse/FLINK-18828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186532#comment-17186532 ] Ufuk Celebi edited comment on FLINK-18828 at 8/28/20, 1:19 PM: ---

[jira] [Commented] (FLINK-18828) Terminate jobmanager process with zero exit code to avoid unexpected restarting by K8s

[ https://issues.apache.org/jira/browse/FLINK-18828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186532#comment-17186532 ] Ufuk Celebi commented on FLINK-18828: - [~fly_in_gis] Thanks for the pointers. The Flink job would

[jira] [Commented] (FLINK-18828) Terminate jobmanager process with zero exit code to avoid unexpected restarting by K8s

[ https://issues.apache.org/jira/browse/FLINK-18828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17186327#comment-17186327 ] Ufuk Celebi commented on FLINK-18828: - [~fly_in_gis] I think it makes sense to keep a non-zero exit

[jira] [Commented] (FLINK-18695) Allow NettyBufferPool to allocate heap buffers

[ https://issues.apache.org/jira/browse/FLINK-18695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17166902#comment-17166902 ] Ufuk Celebi commented on FLINK-18695: - I agree with Stephan that it should not have much of an

[jira] [Commented] (FLINK-17500) Deploy JobGraph from file in StandaloneClusterEntrypoint

[ https://issues.apache.org/jira/browse/FLINK-17500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17101541#comment-17101541 ] Ufuk Celebi commented on FLINK-17500: - [~zhuzh] Good points. I would agree to keep the JobGraph an

[jira] [Commented] (FLINK-17500) Deploy JobGraph from file in StandaloneClusterEntrypoint

[ https://issues.apache.org/jira/browse/FLINK-17500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17098866#comment-17098866 ] Ufuk Celebi commented on FLINK-17500: - # Yes, that makes sense. (y) # I just skimmed the code for

[jira] [Created] (FLINK-17500) Deploy JobGraph form file in StandaloneClusterEntrypoint

Ufuk Celebi created FLINK-17500: --- Summary: Deploy JobGraph form file in StandaloneClusterEntrypoint Key: FLINK-17500 URL: https://issues.apache.org/jira/browse/FLINK-17500 Project: Flink Issue

[jira] [Comment Edited] (FLINK-16499) Flink shaded hadoop could not work when Yarn timeline service is enabled

[ https://issues.apache.org/jira/browse/FLINK-16499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17059342#comment-17059342 ] Ufuk Celebi edited comment on FLINK-16499 at 3/14/20, 1:13 PM: ---

[jira] [Commented] (FLINK-16499) Flink shaded hadoop could not work when Yarn timeline service is enabled

[ https://issues.apache.org/jira/browse/FLINK-16499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17059342#comment-17059342 ] Ufuk Celebi commented on FLINK-16499: - [~fly_in_gis] For proper Hadoop setups, the expected usage it

[jira] [Comment Edited] (FLINK-14812) Add custom libs to Flink classpath with an environment variable.

[ https://issues.apache.org/jira/browse/FLINK-14812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17033449#comment-17033449 ] Ufuk Celebi edited comment on FLINK-14812 at 2/10/20 9:07 AM: -- [~elanv] I'm

[jira] [Reopened] (FLINK-14812) Add custom libs to Flink classpath with an environment variable.

[ https://issues.apache.org/jira/browse/FLINK-14812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reopened FLINK-14812: - > Add custom libs to Flink classpath with an environment variable. >

[jira] [Commented] (FLINK-14812) Add custom libs to Flink classpath with an environment variable.

[ https://issues.apache.org/jira/browse/FLINK-14812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17033449#comment-17033449 ] Ufuk Celebi commented on FLINK-14812: - [~elanv] I'm reopening again, because the initial context of

[jira] [Assigned] (FLINK-15831) Add Docker image publication to release documentation

[ https://issues.apache.org/jira/browse/FLINK-15831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-15831: --- Assignee: Patrick Lucas > Add Docker image publication to release documentation >

[jira] [Closed] (FLINK-15830) Migrate docker-flink/docker-flink to apache/flink-docker

[ https://issues.apache.org/jira/browse/FLINK-15830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-15830. --- Resolution: Fixed apache/flink and docker-flink/docker-flink now have the same histories up to 

[jira] [Commented] (FLINK-15829) Request apache/flink-docker repository

[ https://issues.apache.org/jira/browse/FLINK-15829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17027376#comment-17027376 ] Ufuk Celebi commented on FLINK-15829: - The repository has been created in

[jira] [Resolved] (FLINK-15829) Request apache/flink-docker repository

[ https://issues.apache.org/jira/browse/FLINK-15829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi resolved FLINK-15829. - Resolution: Fixed > Request apache/flink-docker repository >

[jira] [Updated] (FLINK-15830) Migrate docker-flink/docker-flink to apache/flink-docker

[ https://issues.apache.org/jira/browse/FLINK-15830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-15830: Description: * Migrate contents including commit history. * Add note to docker-flink/docker-flink

[jira] [Updated] (FLINK-15830) Migrate docker-flink/docker-flink to apache/flink-docker

[ https://issues.apache.org/jira/browse/FLINK-15830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-15830: Description: Migrate contents including commit history. > Migrate docker-flink/docker-flink to

[jira] [Created] (FLINK-15831) Add Docker image publication to release documentation

Ufuk Celebi created FLINK-15831: --- Summary: Add Docker image publication to release documentation Key: FLINK-15831 URL: https://issues.apache.org/jira/browse/FLINK-15831 Project: Flink Issue

[jira] [Created] (FLINK-15830) Migrate docker-flink/docker-flink to apache/flink-docker

Ufuk Celebi created FLINK-15830: --- Summary: Migrate docker-flink/docker-flink to apache/flink-docker Key: FLINK-15830 URL: https://issues.apache.org/jira/browse/FLINK-15830 Project: Flink Issue

[jira] [Assigned] (FLINK-15829) Request apache/flink-docker repository

[ https://issues.apache.org/jira/browse/FLINK-15829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-15829: --- Assignee: Ufuk Celebi > Request apache/flink-docker repository >

[jira] [Created] (FLINK-15829) Request apache/flink-docker repository

Ufuk Celebi created FLINK-15829: --- Summary: Request apache/flink-docker repository Key: FLINK-15829 URL: https://issues.apache.org/jira/browse/FLINK-15829 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-15828) Integrate docker-flink/docker-flink into Flink release process

Ufuk Celebi created FLINK-15828: --- Summary: Integrate docker-flink/docker-flink into Flink release process Key: FLINK-15828 URL: https://issues.apache.org/jira/browse/FLINK-15828 Project: Flink

[jira] [Comment Edited] (FLINK-14812) Add metric libs to Flink classpath with an environment variable.

[ https://issues.apache.org/jira/browse/FLINK-14812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16978315#comment-16978315 ] Ufuk Celebi edited comment on FLINK-14812 at 11/20/19 11:08 AM: [~elanv] 

[jira] [Assigned] (FLINK-14242) Collapse task names in job graph visualization if too long

[ https://issues.apache.org/jira/browse/FLINK-14242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-14242: --- Assignee: Yadong Xie > Collapse task names in job graph visualization if too long >

[jira] [Updated] (FLINK-14145) getLatestCheckpoint(true) returns wrong checkpoint

[ https://issues.apache.org/jira/browse/FLINK-14145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-14145: Description: The flag to prefer checkpoints for recovery introduced in FLINK-11159 returns the

[jira] [Updated] (FLINK-14145) getLatestCheckpoint(true) returns wrong checkpoint

[ https://issues.apache.org/jira/browse/FLINK-14145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-14145: Attachment: 0001-FLINK-14145-runtime-Add-getLatestCheckpoint-test.patch >

[jira] [Updated] (FLINK-14145) getLatestCheckpoint(true) returns wrong checkpoint

[ https://issues.apache.org/jira/browse/FLINK-14145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-14145: Attachment: (was: 0001-FLINK-14145-runtime-Add-getLatestCheckpoint-test.patch) >

[jira] [Updated] (FLINK-14145) getLatestCheckpoint(true) returns wrong checkpoint

[ https://issues.apache.org/jira/browse/FLINK-14145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-14145: Description: The flag to prefer checkpoints for recovery introduced in FLINK-11159 returns the

[jira] [Updated] (FLINK-14145) getLatestCheckpoint(true) returns wrong checkpoint

[ https://issues.apache.org/jira/browse/FLINK-14145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-14145: Summary: getLatestCheckpoint(true) returns wrong checkpoint (was: getLatestCheckpoint returns

[jira] [Updated] (FLINK-14145) getLatestCheckpoint returns wrong checkpoint

[ https://issues.apache.org/jira/browse/FLINK-14145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-14145: Description: The flag to prefer checkpoints for recovery introduced in FLINK-11159 returns the

[jira] [Updated] (FLINK-14145) getLatestCheckpoint returns wrong checkpoint

[ https://issues.apache.org/jira/browse/FLINK-14145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-14145: Description: The flag to prefer checkpoints for recovery introduced in FLINK-11159 returns the

[jira] [Updated] (FLINK-14145) getLatestCheckpoint returns wrong checkpoint

[ https://issues.apache.org/jira/browse/FLINK-14145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-14145: Attachment: 0001-FLINK-14145-runtime-Add-getLatestCheckpoint-test.patch > getLatestCheckpoint

[jira] [Created] (FLINK-14145) getLatestCheckpoint returns wrong checkpoint

Ufuk Celebi created FLINK-14145: --- Summary: getLatestCheckpoint returns wrong checkpoint Key: FLINK-14145 URL: https://issues.apache.org/jira/browse/FLINK-14145 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-13566) Support checkpoint configuration through flink-conf.yaml

[ https://issues.apache.org/jira/browse/FLINK-13566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16900096#comment-16900096 ] Ufuk Celebi commented on FLINK-13566: - I see that having a good default checkpointing interval for

[jira] [Closed] (FLINK-12813) Add Hadoop profile in building from source docs

[ https://issues.apache.org/jira/browse/FLINK-12813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-12813. --- Resolution: Won't Fix > Add Hadoop profile in building from source docs >

[jira] [Updated] (FLINK-12813) Add Hadoop profile in building from source docs

[ https://issues.apache.org/jira/browse/FLINK-12813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-12813: Issue Type: Improvement (was: Bug) > Add Hadoop profile in building from source docs >

[jira] [Comment Edited] (FLINK-12813) Add Hadoop profile in building from source docs

[ https://issues.apache.org/jira/browse/FLINK-12813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16861856#comment-16861856 ] Ufuk Celebi edited comment on FLINK-12813 at 6/12/19 8:11 AM: -- Makes sense.

[jira] [Commented] (FLINK-12813) Add Hadoop profile in building from source docs

[ https://issues.apache.org/jira/browse/FLINK-12813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16861856#comment-16861856 ] Ufuk Celebi commented on FLINK-12813: - Makes sense. Since a user was also confused by this: What do

[jira] [Created] (FLINK-12813) Add Hadoop profile in building from source docs

Ufuk Celebi created FLINK-12813: --- Summary: Add Hadoop profile in building from source docs Key: FLINK-12813 URL: https://issues.apache.org/jira/browse/FLINK-12813 Project: Flink Issue Type:

[jira] [Updated] (FLINK-12313) SynchronousCheckpointITCase.taskCachedThreadPoolAllowsForSynchronousCheckpoints is unstable

[ https://issues.apache.org/jira/browse/FLINK-12313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-12313: Issue Type: Bug (was: Test) >

[jira] [Created] (FLINK-12313) SynchronousCheckpointITCase.taskCachedThreadPoolAllowsForSynchronousCheckpoints is unstable

Ufuk Celebi created FLINK-12313: --- Summary: SynchronousCheckpointITCase.taskCachedThreadPoolAllowsForSynchronousCheckpoints is unstable Key: FLINK-12313 URL: https://issues.apache.org/jira/browse/FLINK-12313

[jira] [Closed] (FLINK-11534) Don't exit JVM after job termination with standalone job

[ https://issues.apache.org/jira/browse/FLINK-11534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-11534. --- Resolution: Fixed Fix Version/s: 1.9.0 > Don't exit JVM after job termination with

[jira] [Updated] (FLINK-11534) Don't exit JVM after job termination with standalone job

[ https://issues.apache.org/jira/browse/FLINK-11534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-11534: Affects Version/s: 1.8.0 > Don't exit JVM after job termination with standalone job >

[jira] [Commented] (FLINK-8093) flink job fail because of kafka producer create fail of "javax.management.InstanceAlreadyExistsException"

[ https://issues.apache.org/jira/browse/FLINK-8093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16805723#comment-16805723 ] Ufuk Celebi commented on FLINK-8093: Yes I agree with [~NicoK]. We need to dynamically set this per

[jira] [Created] (FLINK-12060) Unify change pom version scripts

Ufuk Celebi created FLINK-12060: --- Summary: Unify change pom version scripts Key: FLINK-12060 URL: https://issues.apache.org/jira/browse/FLINK-12060 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-11953) Introduce Plugin/Loading system and integrate it with FileSystem

[ https://issues.apache.org/jira/browse/FLINK-11953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16795743#comment-16795743 ] Ufuk Celebi commented on FLINK-11953: - [~srichter] [Presto's plugin

[jira] [Commented] (FLINK-11798) Incorrect Kubernetes Documentation

[ https://issues.apache.org/jira/browse/FLINK-11798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16786870#comment-16786870 ] Ufuk Celebi commented on FLINK-11798: - Do you mean the README in {{flink-container/kubernetes}}? >

[jira] [Commented] (FLINK-11798) Incorrect Kubernetes Documentation

[ https://issues.apache.org/jira/browse/FLINK-11798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16786145#comment-16786145 ] Ufuk Celebi commented on FLINK-11798: - [~1u0] Could you take a look at this?  > Incorrect

[jira] [Commented] (FLINK-11847) Docker job-specific image creation instruction make reference to --job-jar parameter that does not actually exist in the script

[ https://issues.apache.org/jira/browse/FLINK-11847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16786143#comment-16786143 ] Ufuk Celebi commented on FLINK-11847: - {{README.md}} refers to

[jira] [Updated] (FLINK-11533) Retrieve job class name from JAR manifest in ClassPathJobGraphRetriever

[ https://issues.apache.org/jira/browse/FLINK-11533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-11533: Release Note: The container entry point will scan the Flink class path for the job jar.

[jira] [Updated] (FLINK-11752) Move flink-python to opt

[ https://issues.apache.org/jira/browse/FLINK-11752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-11752: Release Note: flink-python has been moved from lib to opt and is not available on the default

[jira] [Closed] (FLINK-11533) Retrieve job class name from JAR manifest in ClassPathJobGraphRetriever

[ https://issues.apache.org/jira/browse/FLINK-11533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-11533. --- Resolution: Fixed Fix Version/s: 1.8.0 > Retrieve job class name from JAR manifest in

[jira] [Updated] (FLINK-11752) Move flink-python to opt

[ https://issues.apache.org/jira/browse/FLINK-11752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-11752: Fix Version/s: 1.8.0 > Move flink-python to opt > > >

[jira] [Commented] (FLINK-4387) Instability in KvStateClientTest.testClientServerIntegration()

[ https://issues.apache.org/jira/browse/FLINK-4387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16781394#comment-16781394 ] Ufuk Celebi commented on FLINK-4387: I think as [~yunta] says, this should have been fixed when Netty

[jira] [Closed] (FLINK-1833) Refactor partition availability notification in ExecutionGraph

[ https://issues.apache.org/jira/browse/FLINK-1833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-1833. -- Resolution: Won't Do > Refactor partition availability notification in ExecutionGraph >

[jira] [Updated] (FLINK-11533) Retrieve job class name from JAR manifest in ClassPathJobGraphRetriever

[ https://issues.apache.org/jira/browse/FLINK-11533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-11533: Fix Version/s: 1.9.0 > Retrieve job class name from JAR manifest in ClassPathJobGraphRetriever >

[jira] [Closed] (FLINK-11784) KryoSerializerSnapshotTest occasionally fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-11784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-11784. --- Resolution: Cannot Reproduce > KryoSerializerSnapshotTest occasionally fails on Travis >

[jira] [Updated] (FLINK-11784) KryoSerializerSnapshotTest occasionally fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-11784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-11784: Fix Version/s: (was: 1.8.0) > KryoSerializerSnapshotTest occasionally fails on Travis >

[jira] [Created] (FLINK-11784) KryoSerializerSnapshotTest occasionally fails on Travis

Ufuk Celebi created FLINK-11784: --- Summary: KryoSerializerSnapshotTest occasionally fails on Travis Key: FLINK-11784 URL: https://issues.apache.org/jira/browse/FLINK-11784 Project: Flink Issue

[jira] [Closed] (FLINK-11752) Move flink-python to opt

[ https://issues.apache.org/jira/browse/FLINK-11752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-11752. --- Resolution: Fixed Fix Version/s: 1.9.0 > Move flink-python to opt >

[jira] [Commented] (FLINK-1275) Add support to compress network I/O

[ https://issues.apache.org/jira/browse/FLINK-1275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16778922#comment-16778922 ] Ufuk Celebi commented on FLINK-1275: [~yanghua] It has been a long time since I created this ticket.

[jira] [Created] (FLINK-11752) Move flink-python to opt

Ufuk Celebi created FLINK-11752: --- Summary: Move flink-python to opt Key: FLINK-11752 URL: https://issues.apache.org/jira/browse/FLINK-11752 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-11545) Add option to manually set job ID in StandaloneJobClusterEntryPoint

[ https://issues.apache.org/jira/browse/FLINK-11545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-11545. --- Resolution: Fixed Fix Version/s: 1.8.0 > Add option to manually set job ID in

[jira] [Closed] (FLINK-11544) Add option to manually set job ID for job submissions via REST API

[ https://issues.apache.org/jira/browse/FLINK-11544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-11544. --- Resolution: Fixed Fix Version/s: 1.8.0 > Add option to manually set job ID for job

[jira] [Assigned] (FLINK-11533) Retrieve job class name from JAR manifest in ClassPathJobGraphRetriever

[ https://issues.apache.org/jira/browse/FLINK-11533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-11533: --- Assignee: Ufuk Celebi (was: vinoyang) > Retrieve job class name from JAR manifest in

[jira] [Commented] (FLINK-11533) Retrieve job class name from JAR manifest in ClassPathJobGraphRetriever

[ https://issues.apache.org/jira/browse/FLINK-11533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16763366#comment-16763366 ] Ufuk Celebi commented on FLINK-11533: - [~yanghua] I assigned myself. Sorry for the confusion. As I

[jira] [Commented] (FLINK-11534) Don't exit JVM after job termination with standalone job

[ https://issues.apache.org/jira/browse/FLINK-11534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16763365#comment-16763365 ] Ufuk Celebi commented on FLINK-11534: - [~yanghua] I assigned myself. Sorry for the confusion. As I

[jira] [Assigned] (FLINK-11534) Don't exit JVM after job termination with standalone job

[ https://issues.apache.org/jira/browse/FLINK-11534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-11534: --- Assignee: Ufuk Celebi (was: vinoyang) > Don't exit JVM after job termination with

[jira] [Updated] (FLINK-11544) Add option to manually set job ID for job submissions via REST API

[ https://issues.apache.org/jira/browse/FLINK-11544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-11544: Summary: Add option to manually set job ID for job submissions via REST API (was: Add option

[jira] [Created] (FLINK-11544) Add option manually set job ID for job submissions via REST API

Ufuk Celebi created FLINK-11544: --- Summary: Add option manually set job ID for job submissions via REST API Key: FLINK-11544 URL: https://issues.apache.org/jira/browse/FLINK-11544 Project: Flink

[jira] [Updated] (FLINK-11545) Add option to manually set job ID in StandaloneJobClusterEntryPoint

[ https://issues.apache.org/jira/browse/FLINK-11545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-11545: Priority: Minor (was: Major) > Add option to manually set job ID in

[jira] [Created] (FLINK-11546) Add option to manually set job ID in CLI

Ufuk Celebi created FLINK-11546: --- Summary: Add option to manually set job ID in CLI Key: FLINK-11546 URL: https://issues.apache.org/jira/browse/FLINK-11546 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-11545) Add option to manually set job ID in StandaloneJobClusterEntryPoint

Ufuk Celebi created FLINK-11545: --- Summary: Add option to manually set job ID in StandaloneJobClusterEntryPoint Key: FLINK-11545 URL: https://issues.apache.org/jira/browse/FLINK-11545 Project: Flink

[jira] [Commented] (FLINK-11537) ExecutionGraph does not reach terminal state when JobMaster lost leadership

[ https://issues.apache.org/jira/browse/FLINK-11537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16762483#comment-16762483 ] Ufuk Celebi commented on FLINK-11537: - Is this related to/a duplicate of

[jira] [Commented] (FLINK-11534) Don't exit JVM after job termination with standalone job

[ https://issues.apache.org/jira/browse/FLINK-11534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16761683#comment-16761683 ] Ufuk Celebi commented on FLINK-11534: - [~till.rohrmann] Yes. This would work. Thanks for the

[jira] [Created] (FLINK-11534) Don't exit JVM after job termination with standalone job

Ufuk Celebi created FLINK-11534: --- Summary: Don't exit JVM after job termination with standalone job Key: FLINK-11534 URL: https://issues.apache.org/jira/browse/FLINK-11534 Project: Flink Issue

[jira] [Created] (FLINK-11533) Retrieve job class name from JAR manifest in ClassPathJobGraphRetriever

Ufuk Celebi created FLINK-11533: --- Summary: Retrieve job class name from JAR manifest in ClassPathJobGraphRetriever Key: FLINK-11533 URL: https://issues.apache.org/jira/browse/FLINK-11533 Project: Flink

[jira] [Commented] (FLINK-11525) Add option to manually set job ID

[ https://issues.apache.org/jira/browse/FLINK-11525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16760788#comment-16760788 ] Ufuk Celebi commented on FLINK-11525: - [~f.pompermaier] I believe that ticket is orthogonal to what

[jira] [Updated] (FLINK-11525) Add option to manually set job ID

[ https://issues.apache.org/jira/browse/FLINK-11525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-11525: Description: When submitting Flink jobs programmatically it is desirable to have the option to

[jira] [Created] (FLINK-11525) Add option to manually set job ID

Ufuk Celebi created FLINK-11525: --- Summary: Add option to manually set job ID Key: FLINK-11525 URL: https://issues.apache.org/jira/browse/FLINK-11525 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-11402) User code can fail with an UnsatisfiedLinkError in the presence of multiple classloaders

[ https://issues.apache.org/jira/browse/FLINK-11402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-11402: Component/s: Local Runtime > User code can fail with an UnsatisfiedLinkError in the presence of

[jira] [Commented] (FLINK-11402) User code can fail with an UnsatisfiedLinkError in the presence of multiple classloaders

[ https://issues.apache.org/jira/browse/FLINK-11402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16748241#comment-16748241 ] Ufuk Celebi commented on FLINK-11402: - Similar issue for RocksDB (FLINK-5408) > User code can fail

[jira] [Updated] (FLINK-11402) User code can fail with an UnsatisfiedLinkError in the presence of multiple classloaders

[ https://issues.apache.org/jira/browse/FLINK-11402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-11402: Attachment: hello-snappy.tgz > User code can fail with an UnsatisfiedLinkError in the presence of

[jira] [Updated] (FLINK-11402) User code can fail with an UnsatisfiedLinkError in the presence of multiple classloaders

[ https://issues.apache.org/jira/browse/FLINK-11402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-11402: Attachment: hello-snappy-1.0-SNAPSHOT.jar > User code can fail with an UnsatisfiedLinkError in

[jira] [Created] (FLINK-11402) User code can fail with an UnsatisfiedLinkError in the presence of multiple classloaders

Ufuk Celebi created FLINK-11402: --- Summary: User code can fail with an UnsatisfiedLinkError in the presence of multiple classloaders Key: FLINK-11402 URL: https://issues.apache.org/jira/browse/FLINK-11402

[jira] [Commented] (FLINK-11127) Make metrics query service establish connection to JobManager

[ https://issues.apache.org/jira/browse/FLINK-11127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16720158#comment-16720158 ] Ufuk Celebi commented on FLINK-11127: - [~plucas] Thanks for the update. Regarding connecting by IP:

[jira] [Commented] (FLINK-11127) Make metrics query service establish connection to JobManager

[ https://issues.apache.org/jira/browse/FLINK-11127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16719004#comment-16719004 ] Ufuk Celebi commented on FLINK-11127: - [~spoganshev] Yes, the port configuration is correct. I'm

  1   2   3   4   5   6   7   8   9   10   >