[jira] [Assigned] (FLINK-35509) Slack community invite link has expired

[ https://issues.apache.org/jira/browse/FLINK-35509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi reassigned FLINK-35509: --- Assignee: Santwana Verma > Slack community invite link has expired > --

[jira] [Created] (FLINK-35509) Slack community invite link has expired

Ufuk Celebi created FLINK-35509: --- Summary: Slack community invite link has expired Key: FLINK-35509 URL: https://issues.apache.org/jira/browse/FLINK-35509 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-35481) Add HISTOGRAM function in SQL & Table API

Ufuk Celebi created FLINK-35481: --- Summary: Add HISTOGRAM function in SQL & Table API Key: FLINK-35481 URL: https://issues.apache.org/jira/browse/FLINK-35481 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-35480) Add FIELD function in SQL & Table API

Ufuk Celebi created FLINK-35480: --- Summary: Add FIELD function in SQL & Table API Key: FLINK-35480 URL: https://issues.apache.org/jira/browse/FLINK-35480 Project: Flink Issue Type: Improvement

[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 Ka

[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 Compo

[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 dr

[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: Tec

[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 Issue

[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&focusedCommentId=17294788#comment-17294788 ] Ufuk Celebi commented on FLINK-21351: - [~roman_khachatryan] The ticket includes fixV

[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&focusedCommentId=17262719#comment-17262719 ] Ufuk Celebi commented on FLINK-10841: - [~uberspot] Presto's S3 FileSystem seems to o

[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&focusedCommentId=17222800#comment-17222800 ] Ufuk Celebi commented on FLINK-18192: - [~trohrmann] Thanks for the ping. If the upgr

[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&focusedCommentId=17202044#comment-17202044 ] Ufuk Celebi commented on FLINK-18828: - [~trohrmann] [~fly_in_gis] Just noticed that

[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&focusedCommentId=17186623#comment-17186623 ] Ufuk Celebi commented on FLINK-18828: - Thanks for the summary, Till. I think that's

[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&focusedCommentId=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&focusedCommentId=17186532#comment-17186532 ] Ufuk Celebi commented on FLINK-18828: - [~fly_in_gis] Thanks for the pointers. The Fl

[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&focusedCommentId=17186327#comment-17186327 ] Ufuk Celebi commented on FLINK-18828: - [~fly_in_gis] I think it makes sense to keep

[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&focusedCommentId=17166902#comment-17166902 ] Ufuk Celebi commented on FLINK-18695: - I agree with Stephan that it should not have

[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&focusedCommentId=17101541#comment-17101541 ] Ufuk Celebi commented on FLINK-17500: - [~zhuzh] Good points. I would agree to keep t

[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&focusedCommentId=17098866#comment-17098866 ] Ufuk Celebi commented on FLINK-17500: - # Yes, that makes sense. (y) # I just skimme

[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&focusedCommentId=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&focusedCommentId=17059342#comment-17059342 ] Ufuk Celebi commented on FLINK-16499: - [~fly_in_gis] For proper Hadoop setups, the e

[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&focusedCommentId=17033449#comment-17033449 ] Ufuk Celebi edited comment on FLINK-14812 at 2/10/20 9:07 AM:

[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&focusedCommentId=17033449#comment-17033449 ] Ufuk Celebi commented on FLINK-14812: - [~elanv] I'm reopening again, because the ini

[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  f26d

[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] [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&focusedCommentId=17027376#comment-17027376 ] Ufuk Celebi commented on FLINK-15829: - The repository has been created in https://gi

[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 apa

[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] [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 Typ

[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&focusedCommentId=16978315#comment-16978315 ] Ufuk Celebi edited comment on FLINK-14812 at 11/20/19 11:08 AM: --

[jira] [Commented] (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&focusedCommentId=16978315#comment-16978315 ] Ufuk Celebi commented on FLINK-14812: - [~elanv] I think your work around with adding

[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 wr

[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) > getLatestChe

[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 > getLatestCheckpoint(true

[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 wr

[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 wro

[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 wr

[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 wr

[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 retu

[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&focusedCommentId=16900096#comment-16900096 ] Ufuk Celebi commented on FLINK-13566: - I see that having a good default checkpointin

[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&focusedCommentId=16861856#comment-16861856 ] Ufuk Celebi edited comment on FLINK-12813 at 6/12/19 8:11 AM:

[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&focusedCommentId=16861856#comment-16861856 ] Ufuk Celebi commented on FLINK-12813: - Makes sense. Since a user was also confused b

[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: Bug

[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) > SynchronousCheckpointITCase.taskCachedThreadPoolAllowsForSynchronou

[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 standalone

[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&focusedCommentId=16805723#comment-16805723 ] Ufuk Celebi commented on FLINK-8093: Yes I agree with [~NicoK]. We need to dynamicall

[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 Comp

[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&focusedCommentId=16795743#comment-16795743 ] Ufuk Celebi commented on FLINK-11953: - [~srichter] [Presto's plugin system|https://

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

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

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

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

[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&focusedCommentId=16786143#comment-16786143 ] Ufuk Celebi commented on FLINK-11847: - {{README.md}} refers to [https://github.com/

[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. Therefore,

[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 clas

[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 ClassPa

[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 > > > Key

[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&focusedCommentId=16781394#comment-16781394 ] Ufuk Celebi commented on FLINK-4387: I think as [~yunta] says, this should have been

[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 T

[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&focusedCommentId=16778922#comment-16778922 ] Ufuk Celebi commented on FLINK-1275: [~yanghua] It has been a long time since I creat

[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 Comp

[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 StandaloneJobCl

[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 submission

[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 Class

[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&focusedCommentId=16763366#comment-16763366 ] Ufuk Celebi commented on FLINK-11533: - [~yanghua] I assigned myself. Sorry for the c

[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&focusedCommentId=16763365#comment-16763365 ] Ufuk Celebi commented on FLINK-11534: - [~yanghua] I assigned myself. Sorry for the c

[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 standalo

[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 manu

[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 StandaloneJobClusterEntryPoin

[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&focusedCommentId=16762483#comment-16762483 ] Ufuk Celebi commented on FLINK-11537: - Is this related to/a duplicate of https://is

[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&focusedCommentId=16761683#comment-16761683 ] Ufuk Celebi commented on FLINK-11534: - [~till.rohrmann] Yes. This would work. Thanks

[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&focusedCommentId=16760788#comment-16760788 ] Ufuk Celebi commented on FLINK-11525: - [~f.pompermaier] I believe that ticket is ort

[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 ma

[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 mu

[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&focusedCommentId=16748241#comment-16748241 ] Ufuk Celebi commented on FLINK-11402: - Similar issue for RocksDB (FLINK-5408) > Use

  1   2   3   4   5   6   7   8   9   10   >