[jira] [Updated] (FLINK-17498) MapCancelingITCase.testMapCancelling fails with timeout

[ https://issues.apache.org/jira/browse/FLINK-17498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17498: - Labels: test-stability (was: ) > MapCancelingITCase.testMapCancelling fails w

[jira] [Updated] (FLINK-17487) Do not delete old checkpoints when stop the job.

[ https://issues.apache.org/jira/browse/FLINK-17487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17487: - Component/s: Client / Job Submission > Do not delete old checkpoints when stop the

[jira] [Assigned] (FLINK-16521) Remove unused FileUtils#isClassFile

[ https://issues.apache.org/jira/browse/FLINK-16521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-16521: Assignee: Guru Prasad > Remove unused FileUtils#isClassF

[jira] [Commented] (FLINK-16521) Remove unused FileUtils#isClassFile

[ https://issues.apache.org/jira/browse/FLINK-16521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17098748#comment-17098748 ] Aljoscha Krettek commented on FLINK-16521: -- [~guruprasad146], please go a

[jira] [Updated] (FLINK-16521) Remove unused FileUtils#isClassFile

[ https://issues.apache.org/jira/browse/FLINK-16521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-16521: - Fix Version/s: (was: 1.10.2) > Remove unused FileUtils#isClassF

[jira] [Commented] (FLINK-17453) KyroSerializer throws IndexOutOfBoundsException type java.util.PriorityQueue

[ https://issues.apache.org/jira/browse/FLINK-17453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17096456#comment-17096456 ] Aljoscha Krettek commented on FLINK-17453: -- And what's the type

[jira] [Commented] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17096447#comment-17096447 ] Aljoscha Krettek commented on FLINK-17469: -- I'm definitely open

[jira] [Updated] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17469: - Component/s: (was: API / Core) API / DataStream

[jira] [Updated] (FLINK-14964) Support configure remote flink jar

[ https://issues.apache.org/jira/browse/FLINK-14964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-14964: - Component/s: Client / Job Submission > Support configure remote flink

[jira] [Updated] (FLINK-17412) Make the FLINK_YARN_FILES value configurable

[ https://issues.apache.org/jira/browse/FLINK-17412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17412: - Component/s: Client / Job Submission > Make the FLINK_YARN_FILES value configura

[jira] [Updated] (FLINK-13938) Use pre-uploaded libs to accelerate flink submission

[ https://issues.apache.org/jira/browse/FLINK-13938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-13938: - Component/s: Client / Job Submission > Use pre-uploaded libs to accelerate fl

[jira] [Updated] (FLINK-17472) StreamExecutionEnvironment and ExecutionEnvironment in Yarn mode

[ https://issues.apache.org/jira/browse/FLINK-17472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17472: - Docs Text: (was: There may be many details about this new feature that we have to pay

[jira] [Commented] (FLINK-17453) KyroSerializer throws IndexOutOfBoundsException type java.util.PriorityQueue

[ https://issues.apache.org/jira/browse/FLINK-17453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17095487#comment-17095487 ] Aljoscha Krettek commented on FLINK-17453: -- What's stor

[jira] [Commented] (FLINK-17443) Flink's ZK in HA mode setup is unable to start up if any of the zk hosts are unreachable

[ https://issues.apache.org/jira/browse/FLINK-17443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17095386#comment-17095386 ] Aljoscha Krettek commented on FLINK-17443: -- cc [~trohrmann] or [~chesnay]:

[jira] [Commented] (FLINK-17447) Flink CEPOperator StateException

[ https://issues.apache.org/jira/browse/FLINK-17447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17095384#comment-17095384 ] Aljoscha Krettek commented on FLINK-17447: -- Did you try and reproduce

[jira] [Updated] (FLINK-17443) Flink's ZK in HA mode setup is unable to start up if any of the zk hosts are unreachable

[ https://issues.apache.org/jira/browse/FLINK-17443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17443: - Component/s: Runtime / Coordination > Flink's ZK in HA mode setup is unable to

[jira] [Commented] (FLINK-17444) StreamingFileSink Azure HadoopRecoverableWriter class missing.

[ https://issues.apache.org/jira/browse/FLINK-17444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17095308#comment-17095308 ] Aljoscha Krettek commented on FLINK-17444: -- It seems the fix would then b

[jira] [Commented] (FLINK-17453) KyroSerializer throws IndexOutOfBoundsException type java.util.PriorityQueue

[ https://issues.apache.org/jira/browse/FLINK-17453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17095305#comment-17095305 ] Aljoscha Krettek commented on FLINK-17453: -- Is your program u

[jira] [Updated] (FLINK-16144) Add client.timeout setting and use that for CLI operations

[ https://issues.apache.org/jira/browse/FLINK-16144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-16144: - Labels: starter (was: ) > Add client.timeout setting and use that for CLI operati

[jira] [Assigned] (FLINK-16144) Add client.timeout setting and use that for CLI operations

[ https://issues.apache.org/jira/browse/FLINK-16144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-16144: Assignee: (was: Khaireddine Rezgui) > Add client.timeout setting and

[jira] [Closed] (FLINK-17074) Deprecate DataStream.keyBy() that use tuple/expression keys

[ https://issues.apache.org/jira/browse/FLINK-17074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17074. Resolution: Done master: 4f106c50194886cb6e98b993785481192485479c

[jira] [Commented] (FLINK-17376) Remove deprecated state access methods

[ https://issues.apache.org/jira/browse/FLINK-17376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17094257#comment-17094257 ] Aljoscha Krettek commented on FLINK-17376: -- assigned [~manish.c.gh

[jira] [Assigned] (FLINK-17403) Fix invalid classpath in BashJavaUtilsITCase

[ https://issues.apache.org/jira/browse/FLINK-17403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-17403: Assignee: Paul Lin > Fix invalid classpath in BashJavaUtilsITC

[jira] [Commented] (FLINK-17403) Fix invalid classpath in BashJavaUtilsITCase

[ https://issues.apache.org/jira/browse/FLINK-17403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17094247#comment-17094247 ] Aljoscha Krettek commented on FLINK-17403: -- Done! 🍵 > Fix invalid cl

[jira] [Assigned] (FLINK-15670) Provide a Kafka Source/Sink pair that aligns Kafka's Partitions and Flink's KeyGroups

[ https://issues.apache.org/jira/browse/FLINK-15670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-15670: Assignee: Yuan Mei > Provide a Kafka Source/Sink pair that aligns Kafk

[jira] [Assigned] (FLINK-17415) Fold API-agnostic documentation into DataStream documentation (chinese)

[ https://issues.apache.org/jira/browse/FLINK-17415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-17415: Assignee: (was: Aljoscha Krettek) > Fold API-agnostic documentation i

[jira] [Updated] (FLINK-17415) Fold API-agnostic documentation into DataStream documentation (chinese)

[ https://issues.apache.org/jira/browse/FLINK-17415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17415: - Component/s: (was: API / DataStream) chinese-translation > F

[jira] [Commented] (FLINK-17415) Fold API-agnostic documentation into DataStream documentation (chinese)

[ https://issues.apache.org/jira/browse/FLINK-17415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17093428#comment-17093428 ] Aljoscha Krettek commented on FLINK-17415: -- The translator should re-trace

[jira] [Created] (FLINK-17415) Fold API-agnostic documentation into DataStream documentation (chinese)

Aljoscha Krettek created FLINK-17415: Summary: Fold API-agnostic documentation into DataStream documentation (chinese) Key: FLINK-17415 URL: https://issues.apache.org/jira/browse/FLINK-17415

[jira] [Closed] (FLINK-17009) Fold API-agnostic documentation into DataStream documentation

[ https://issues.apache.org/jira/browse/FLINK-17009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17009. Fix Version/s: 1.11.0 Resolution: Fixed master

[jira] [Updated] (FLINK-17326) flink sql gateway should support persist meta information such as SessionContext in order to recover

[ https://issues.apache.org/jira/browse/FLINK-17326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17326: - Component/s: (was: Client / Job Submission) Table SQL / Client

[jira] [Closed] (FLINK-1919) Add HCatOutputFormat for Tuple data types

[ https://issues.apache.org/jira/browse/FLINK-1919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-1919. --- Resolution: Abandoned > Add HCatOutputFormat for Tuple data ty

[jira] [Closed] (FLINK-2032) Migrate integration tests from temp output files to collect()

[ https://issues.apache.org/jira/browse/FLINK-2032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-2032. --- Resolution: Fixed > Migrate integration tests from temp output files to coll

[jira] [Closed] (FLINK-9553) Migrate integration tests for DataSinkITCase

[ https://issues.apache.org/jira/browse/FLINK-9553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-9553. --- Resolution: Abandoned We don't do major work on the DataSet API anymore. >

[jira] [Updated] (FLINK-9553) Migrate integration tests for DataSinkITCase

[ https://issues.apache.org/jira/browse/FLINK-9553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-9553: Component/s: Tests > Migrate integration tests for DataSinkITC

[jira] [Updated] (FLINK-2032) Migrate integration tests from temp output files to collect()

[ https://issues.apache.org/jira/browse/FLINK-2032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-2032: Component/s: API / DataSet > Migrate integration tests from temp output files to coll

[jira] [Closed] (FLINK-2077) Rework Path class and add extend support for Windows paths

[ https://issues.apache.org/jira/browse/FLINK-2077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-2077. --- Resolution: Abandoned Closing this since the code base has moved on quite a bit. > Rew

[jira] [Closed] (FLINK-10619) config MemoryStateBackend default value

[ https://issues.apache.org/jira/browse/FLINK-10619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-10619. Resolution: Abandoned Closing since this doesn't seem to be an issue. >

[jira] [Closed] (FLINK-5087) Additional steps needed for the Java quickstart guide

[ https://issues.apache.org/jira/browse/FLINK-5087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-5087. --- Resolution: Abandoned Closing this since no-one seems to have complained about this since a

[jira] [Assigned] (FLINK-17376) Remove deprecated state access methods

[ https://issues.apache.org/jira/browse/FLINK-17376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-17376: Assignee: Manish Ghildiyal > Remove deprecated state access meth

[jira] [Commented] (FLINK-17403) Fix invalid classpath in BashJavaUtilsITCase

[ https://issues.apache.org/jira/browse/FLINK-17403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17093236#comment-17093236 ] Aljoscha Krettek commented on FLINK-17403: -- [~xintongsong] Could you pl

[jira] [Commented] (FLINK-17394) Add RemoteEnvironment and RemoteStreamEnvironment in Python

[ https://issues.apache.org/jira/browse/FLINK-17394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17093232#comment-17093232 ] Aljoscha Krettek commented on FLINK-17394: -- I think this is not necessary

[jira] [Closed] (FLINK-17389) LocalExecutorITCase.testBatchQueryCancel asserts error

[ https://issues.apache.org/jira/browse/FLINK-17389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17389. Fix Version/s: (was: 1.11.0) Resolution: Invalid The test doesn't

[jira] [Commented] (FLINK-15669) SQL client can't cancel flink job

[ https://issues.apache.org/jira/browse/FLINK-15669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17093212#comment-17093212 ] Aljoscha Krettek commented on FLINK-15669: -- Thanks for the fast resp

[jira] [Closed] (FLINK-17359) Entropy key is not resolved if flink-s3-fs-hadoop is added as a plugin

[ https://issues.apache.org/jira/browse/FLINK-17359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17359. Fix Version/s: 1.10.2 1.11.0 Resolution: Fixed release-1.10

[jira] [Updated] (FLINK-16198) FileUtilsTest fails on Mac OS

[ https://issues.apache.org/jira/browse/FLINK-16198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-16198: - Labels: starter (was: ) > FileUtilsTest fails on Mac

[jira] [Updated] (FLINK-17376) Remove deprecated state access methods

[ https://issues.apache.org/jira/browse/FLINK-17376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17376: - Labels: starter (was: ) > Remove deprecated state access meth

[jira] [Updated] (FLINK-17376) Remove deprecated state access methods

[ https://issues.apache.org/jira/browse/FLINK-17376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17376: - Priority: Critical (was: Blocker) > Remove deprecated state access meth

[jira] [Closed] (FLINK-1890) Add note to docs that ReadFields annotations are currently not evaluated

[ https://issues.apache.org/jira/browse/FLINK-1890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-1890. --- Resolution: Abandoned I'm closing this as "Abandoned", since there is no mo

[jira] [Updated] (FLINK-17074) Deprecate DataStream.keyBy() that use tuple/expression keys

[ https://issues.apache.org/jira/browse/FLINK-17074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17074: - Component/s: API / Scala > Deprecate DataStream.keyBy() that use tuple/expression k

[jira] [Commented] (FLINK-17338) LocalExecutorITCase.testBatchQueryCancel test timeout

[ https://issues.apache.org/jira/browse/FLINK-17338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17092588#comment-17092588 ] Aljoscha Krettek commented on FLINK-17338: -- I reverted the broken t

[jira] [Closed] (FLINK-17338) LocalExecutorITCase.testBatchQueryCancel test timeout

[ https://issues.apache.org/jira/browse/FLINK-17338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17338. Resolution: Fixed > LocalExecutorITCase.testBatchQueryCancel test time

[jira] [Reopened] (FLINK-15669) SQL client can't cancel flink job

[ https://issues.apache.org/jira/browse/FLINK-15669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-15669: -- I partially reverted these changes: Only the tests are reverted because the fix is still

[jira] [Commented] (FLINK-17338) LocalExecutorITCase.testBatchQueryCancel test timeout

[ https://issues.apache.org/jira/browse/FLINK-17338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17092570#comment-17092570 ] Aljoscha Krettek commented on FLINK-17338: -- [~liyu] It's a differ

[jira] [Updated] (FLINK-16661) Introduce the YarnApplicationClusterEntrypoint

[ https://issues.apache.org/jira/browse/FLINK-16661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-16661: - Component/s: Client / Job Submission > Introduce the YarnApplicationClusterEntrypo

[jira] [Updated] (FLINK-16656) Introduce DispatcherBootstrap to initialise Dispatcher

[ https://issues.apache.org/jira/browse/FLINK-16656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-16656: - Component/s: Client / Job Submission > Introduce DispatcherBootstrap to initial

[jira] [Updated] (FLINK-16657) Wire the EmbeddedExecutor to the Web Submission logic.

[ https://issues.apache.org/jira/browse/FLINK-16657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-16657: - Component/s: Client / Job Submission > Wire the EmbeddedExecutor to the Web Submiss

[jira] [Updated] (FLINK-16654) Implement Application Mode according to FLIP-85

[ https://issues.apache.org/jira/browse/FLINK-16654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-16654: - Component/s: Client / Job Submission > Implement Application Mode according to FLIP

[jira] [Updated] (FLINK-16658) Wire the EmbeddedExecutor to the StandaloneJobClusterEntryPoint.

[ https://issues.apache.org/jira/browse/FLINK-16658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-16658: - Component/s: Client / Job Submission > Wire the EmbeddedExecutor to

[jira] [Updated] (FLINK-16655) Introduce the EmbeddedExecutor for executing the main() on the Dispatcher

[ https://issues.apache.org/jira/browse/FLINK-16655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-16655: - Component/s: Client / Job Submission > Introduce the EmbeddedExecutor for executing

[jira] [Updated] (FLINK-16660) Introduce the ApplicationDispatcherBootstrap

[ https://issues.apache.org/jira/browse/FLINK-16660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-16660: - Component/s: Client / Job Submission > Introduce the ApplicationDispatcherBootst

[jira] [Assigned] (FLINK-17359) Entropy key is not resolved if flink-s3-fs-hadoop is added as a plugin

[ https://issues.apache.org/jira/browse/FLINK-17359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-17359: Assignee: Prem Santosh > Entropy key is not resolved if flink-s3-fs-hadoop

[jira] [Updated] (FLINK-17359) Entropy key is not resolved if flink-s3-fs-hadoop is added as a plugin

[ https://issues.apache.org/jira/browse/FLINK-17359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17359: - Component/s: FileSystems > Entropy key is not resolved if flink-s3-fs-hadoop is ad

[jira] [Updated] (FLINK-17348) Expose metric group to ascendingTimestampExtractor

[ https://issues.apache.org/jira/browse/FLINK-17348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17348: - Component/s: API / DataStream > Expose metric group to ascendingTimestampExtrac

[jira] [Assigned] (FLINK-17058) Adding TimeoutTrigger support nested triggers

[ https://issues.apache.org/jira/browse/FLINK-17058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-17058: Assignee: Roey Shem Tov > Adding TimeoutTrigger support nested trigg

[jira] [Commented] (FLINK-17058) Adding TimeoutTrigger support nested triggers

[ https://issues.apache.org/jira/browse/FLINK-17058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17091329#comment-17091329 ] Aljoscha Krettek commented on FLINK-17058: -- For going on, could you add a

[jira] [Commented] (FLINK-17349) Reduce runtime of LocalExecutorITCase

[ https://issues.apache.org/jira/browse/FLINK-17349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17090581#comment-17090581 ] Aljoscha Krettek commented on FLINK-17349: -- See also my earlier commen

[jira] [Commented] (FLINK-17058) Adding TimeoutTrigger support nested triggers

[ https://issues.apache.org/jira/browse/FLINK-17058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17090583#comment-17090583 ] Aljoscha Krettek commented on FLINK-17058: -- Sorry for the late reply, I

[jira] [Created] (FLINK-17349) Reduce runtime of LocalExecutorITCase

Aljoscha Krettek created FLINK-17349: Summary: Reduce runtime of LocalExecutorITCase Key: FLINK-17349 URL: https://issues.apache.org/jira/browse/FLINK-17349 Project: Flink Issue Type

[jira] [Closed] (FLINK-17338) LocalExecutorITCase.testBatchQueryCancel test timeout

[ https://issues.apache.org/jira/browse/FLINK-17338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17338. Resolution: Fixed master: 008e0afb3c62c059dcdf2c58a43cdd2e2d283512 Fixed by increasing

[jira] [Commented] (FLINK-17338) LocalExecutorITCase.testBatchQueryCancel test timeout

[ https://issues.apache.org/jira/browse/FLINK-17338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17090557#comment-17090557 ] Aljoscha Krettek commented on FLINK-17338: -- I increased the test time

[jira] [Assigned] (FLINK-17338) LocalExecutorITCase.testBatchQueryCancel test timeout

[ https://issues.apache.org/jira/browse/FLINK-17338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-17338: Assignee: Aljoscha Krettek > LocalExecutorITCase.testBatchQueryCancel t

[jira] [Commented] (FLINK-17327) Kafka unavailability could cause Flink TM shutdown

[ https://issues.apache.org/jira/browse/FLINK-17327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17090378#comment-17090378 ] Aljoscha Krettek commented on FLINK-17327: -- Isn't this the expected

[jira] [Updated] (FLINK-17327) Kafka unavailability could cause Flink TM shutdown

[ https://issues.apache.org/jira/browse/FLINK-17327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17327: - Component/s: Connectors / Kafka > Kafka unavailability could cause Flink TM shutd

[jira] [Commented] (FLINK-17338) LocalExecutorITCase.testBatchQueryCancel test timeout

[ https://issues.apache.org/jira/browse/FLINK-17338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17090377#comment-17090377 ] Aljoscha Krettek commented on FLINK-17338: -- This test has always been

[jira] [Updated] (FLINK-17338) LocalExecutorITCase.testBatchQueryCancel test timeout

[ https://issues.apache.org/jira/browse/FLINK-17338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17338: - Component/s: Table SQL / Planner Table SQL / Legacy Planner

[jira] [Assigned] (FLINK-17324) Move the image we use to generate the docker official-images changes into flink-docker

[ https://issues.apache.org/jira/browse/FLINK-17324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-17324: Assignee: Ismaël Mejía > Move the image we use to generate the docker offic

[jira] [Closed] (FLINK-15669) SQL client can't cancel flink job

[ https://issues.apache.org/jira/browse/FLINK-15669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-15669. Resolution: Fixed master: 0650e4b6b6a9725c3a9589a110b202478a68f90c release-1.10

[jira] [Updated] (FLINK-17310) Test blink planner failed to generate JobGraph when the checkpoint mode enable

[ https://issues.apache.org/jira/browse/FLINK-17310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17310: - Component/s: Table SQL / Planner > Test blink planner failed to generate JobGraph w

[jira] [Commented] (FLINK-17268) SourceReaderTestBase.testAddSplitToExistingFetcher deadlocks on Travis

[ https://issues.apache.org/jira/browse/FLINK-17268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17088488#comment-17088488 ] Aljoscha Krettek commented on FLINK-17268: -- cc [~

[jira] [Closed] (FLINK-17249) Bump universal Kafka connector to Kafka 2.2.2

[ https://issues.apache.org/jira/browse/FLINK-17249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17249. Fix Version/s: 1.11.0 Resolution: Fixed master

[jira] [Assigned] (FLINK-17249) Bump universal Kafka connector to Kafka 2.2.2

[ https://issues.apache.org/jira/browse/FLINK-17249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-17249: Assignee: Ismael Juma > Bump universal Kafka connector to Kafka 2.

[jira] [Closed] (FLINK-17229) Add a flink-sql-client-sdk module

[ https://issues.apache.org/jira/browse/FLINK-17229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-17229. Resolution: Not A Problem Closing this for now, I think the Table API is the SQL client

[jira] [Commented] (FLINK-17279) Use gradle build scans for training exercises

[ https://issues.apache.org/jira/browse/FLINK-17279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17087954#comment-17087954 ] Aljoscha Krettek commented on FLINK-17279: -- Is "Training Exercises&q

[jira] [Updated] (FLINK-17279) Use gradle build scans for training exercises

[ https://issues.apache.org/jira/browse/FLINK-17279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17279: - Summary: Use gradle build scans for training exercises (was: Use gradle build scans

[jira] [Commented] (FLINK-17278) Add Travis to the training exercises

[ https://issues.apache.org/jira/browse/FLINK-17278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17087886#comment-17087886 ] Aljoscha Krettek commented on FLINK-17278: -- Aren't we currently migra

[jira] [Commented] (FLINK-17264) taskmanager.sh could not work on Mac

[ https://issues.apache.org/jira/browse/FLINK-17264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17087756#comment-17087756 ] Aljoscha Krettek commented on FLINK-17264: -- The script uses string compar

[jira] [Updated] (FLINK-17264) taskmanager.sh could not work on Mac

[ https://issues.apache.org/jira/browse/FLINK-17264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17264: - Priority: Blocker (was: Major) > taskmanager.sh could not work on

[jira] [Closed] (FLINK-16308) SQL connector download links are broken

[ https://issues.apache.org/jira/browse/FLINK-16308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-16308. Resolution: Fixed > SQL connector download links are bro

[jira] [Commented] (FLINK-16308) SQL connector download links are broken

[ https://issues.apache.org/jira/browse/FLINK-16308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085636#comment-17085636 ] Aljoscha Krettek commented on FLINK-16308: -- release

[jira] [Updated] (FLINK-16308) SQL connector download links are broken

[ https://issues.apache.org/jira/browse/FLINK-16308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-16308: - Fix Version/s: 1.11.0 1.10.1 1.9.3 >

[jira] [Updated] (FLINK-16308) SQL connector download links are broken

[ https://issues.apache.org/jira/browse/FLINK-16308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-16308: - Priority: Critical (was: Major) > SQL connector download links are bro

[jira] [Created] (FLINK-17217) Download links for central.maven.org in doc don't work

Aljoscha Krettek created FLINK-17217: Summary: Download links for central.maven.org in doc don't work Key: FLINK-17217 URL: https://issues.apache.org/jira/browse/FLINK-17217 Project:

[jira] [Updated] (FLINK-17213) Surefire configuration should override locale

[ https://issues.apache.org/jira/browse/FLINK-17213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17213: - Issue Type: Improvement (was: Test) > Surefire configuration should override loc

[jira] [Updated] (FLINK-17213) Surefire configuration should override locale

[ https://issues.apache.org/jira/browse/FLINK-17213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17213: - Component/s: Tests > Surefire configuration should override loc

[jira] [Assigned] (FLINK-17213) Surefire configuration should override locale

[ https://issues.apache.org/jira/browse/FLINK-17213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-17213: Assignee: Etienne Chauchot > Surefire configuration should override loc

[jira] [Commented] (FLINK-17197) ContinuousFileReaderOperator might shade the real exception when processing records

[ https://issues.apache.org/jira/browse/FLINK-17197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085595#comment-17085595 ] Aljoscha Krettek commented on FLINK-17197: -- [~roman_khachatryan

[jira] [Updated] (FLINK-17195) Worker threads for source function have wrong ClassLoader

[ https://issues.apache.org/jira/browse/FLINK-17195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17195: - Component/s: (was: Runtime / State Backends) > Worker threads for source funct

[jira] [Updated] (FLINK-17197) ContinuousFileReaderOperator might shade the real exception when processing records

[ https://issues.apache.org/jira/browse/FLINK-17197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-17197: - Component/s: Runtime / Task > ContinuousFileReaderOperator might shade the r

[jira] [Updated] (FLINK-16057) Performance regression in ContinuousFileReaderOperator

[ https://issues.apache.org/jira/browse/FLINK-16057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-16057: - Component/s: Runtime / Task > Performance regression in ContinuousFileReaderOpera

<    4   5   6   7   8   9   10   11   12   13   >