[jira] [Assigned] (FLINK-10463) Null literal cannot be properly parsed in Java Table API function call

[ https://issues.apache.org/jira/browse/FLINK-10463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-10463: --- Assignee: Hequn Cheng > Null literal cannot be properly parsed in Java Table API function

[jira] [Commented] (FLINK-10205) Batch Job: InputSplit Fault tolerant for DataSourceTask

[ https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657704#comment-16657704 ] ASF GitHub Bot commented on FLINK-10205: TisonKun commented on issue #6684: [FLINK-10205]

[GitHub] TisonKun commented on issue #6684: [FLINK-10205] Batch Job: InputSplit Fault tolerant for DataSource…

TisonKun commented on issue #6684: [FLINK-10205] Batch Job: InputSplit Fault tolerant for DataSource… URL: https://github.com/apache/flink/pull/6684#issuecomment-431546174 FYI there was another [discussion(FLINK-10038)](https://issues.apache.org/jira/browse/FLINK-10038) on

[jira] [Commented] (FLINK-10558) Port YARNHighAvailabilityITCase and YARNSessionCapacitySchedulerITCase to new code base

[ https://issues.apache.org/jira/browse/FLINK-10558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657694#comment-16657694 ] TisonKun commented on FLINK-10558: -- [~till.rohrmann] I'd like to know if the present status excepted.

[jira] [Commented] (FLINK-10461) Speed up download file procedure when restore

[ https://issues.apache.org/jira/browse/FLINK-10461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657653#comment-16657653 ] ASF GitHub Bot commented on FLINK-10461: klion26 commented on issue #6777: [FLINK-10461] [State

[GitHub] klion26 commented on issue #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS

klion26 commented on issue #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS URL: https://github.com/apache/flink/pull/6777#issuecomment-431539541 Hi, @azagrebin , could you please help to review this?

[GitHub] yanghua commented on issue #6816: [FLINK-10527] Cleanup constant isNewMode in YarnTestBase

yanghua commented on issue #6816: [FLINK-10527] Cleanup constant isNewMode in YarnTestBase URL: https://github.com/apache/flink/pull/6816#issuecomment-431537500 failed case : testFlinkKafkaProducer10FailTransactionCoordinatorBeforeNotify, log file :

[jira] [Commented] (FLINK-10527) Cleanup constant isNewMode in YarnTestBase

[ https://issues.apache.org/jira/browse/FLINK-10527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657639#comment-16657639 ] ASF GitHub Bot commented on FLINK-10527: yanghua commented on issue #6816: [FLINK-10527] Cleanup

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

[ https://issues.apache.org/jira/browse/FLINK-10619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657627#comment-16657627 ] yangxiaoshuo commented on FLINK-10619: -- If it is allowed, I would linke to fix it. > config

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

yangxiaoshuo created FLINK-10619: Summary: config MemoryStateBackend default value Key: FLINK-10619 URL: https://issues.apache.org/jira/browse/FLINK-10619 Project: Flink Issue Type:

[jira] [Created] (FLINK-10618) Introduce catalog for Flink tables

Xuefu Zhang created FLINK-10618: --- Summary: Introduce catalog for Flink tables Key: FLINK-10618 URL: https://issues.apache.org/jira/browse/FLINK-10618 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-10617) Restoring job fails because of slot allocation timeout

Elias Levy created FLINK-10617: -- Summary: Restoring job fails because of slot allocation timeout Key: FLINK-10617 URL: https://issues.apache.org/jira/browse/FLINK-10617 Project: Flink Issue

[jira] [Commented] (FLINK-9761) Potential buffer leak in PartitionRequestClientHandler during job failures

[ https://issues.apache.org/jira/browse/FLINK-9761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657306#comment-16657306 ] Till Rohrmann commented on FLINK-9761: -- [~NicoK] could you verify whether this is really a problem?

[jira] [Commented] (FLINK-8418) Kafka08ITCase.testStartFromLatestOffsets() times out on Travis

[ https://issues.apache.org/jira/browse/FLINK-8418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657305#comment-16657305 ] Till Rohrmann commented on FLINK-8418: -- Do you think that we can close this issue because it did not

[jira] [Resolved] (FLINK-8073) Test instability FlinkKafkaProducer011ITCase.testScaleDownBeforeFirstCheckpoint()

[ https://issues.apache.org/jira/browse/FLINK-8073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-8073. -- Resolution: Cannot Reproduce Fix Version/s: (was: 1.5.6)

[jira] [Resolved] (FLINK-8452) BucketingSinkTest.testNonRollingAvroKeyValueWithCompressionWriter instable on Travis

[ https://issues.apache.org/jira/browse/FLINK-8452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-8452. -- Resolution: Cannot Reproduce Fix Version/s: (was: 1.5.6)

[jira] [Resolved] (FLINK-8408) YarnFileStageTestS3ITCase.testRecursiveUploadForYarnS3n unstable on Travis

[ https://issues.apache.org/jira/browse/FLINK-8408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-8408. -- Resolution: Cannot Reproduce Fix Version/s: (was: 1.5.6)

[jira] [Resolved] (FLINK-8779) ClassLoaderITCase.testKMeansJobWithCustomClassLoader fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-8779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-8779. -- Resolution: Cannot Reproduce Fix Version/s: (was: 1.5.6)

[jira] [Resolved] (FLINK-8034) ProcessFailureCancelingITCase.testCancelingOnProcessFailure failing on Travis

[ https://issues.apache.org/jira/browse/FLINK-8034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-8034. -- Resolution: Not A Problem Fix Version/s: (was: 1.5.6) (was:

[jira] [Updated] (FLINK-8779) ClassLoaderITCase.testKMeansJobWithCustomClassLoader fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-8779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8779: - Fix Version/s: (was: 1.7.0) > ClassLoaderITCase.testKMeansJobWithCustomClassLoader fails on

[jira] [Commented] (FLINK-7351) test instability in JobClientActorRecoveryITCase#testJobClientRecovery

[ https://issues.apache.org/jira/browse/FLINK-7351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657237#comment-16657237 ] Till Rohrmann commented on FLINK-7351: -- No longer relevant for 1.7 since we disabled the legacy mode

[jira] [Resolved] (FLINK-9764) Failure in LocalRecoveryRocksDBFullITCase

[ https://issues.apache.org/jira/browse/FLINK-9764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-9764. -- Resolution: Cannot Reproduce So far this issue has never been reported again and could not be

[jira] [Resolved] (FLINK-10614) Update test_batch_allround.sh e2e to new testing infrastructure

[ https://issues.apache.org/jira/browse/FLINK-10614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-10614. --- Resolution: Fixed Fixed via 1.7.0:

[GitHub] tillrohrmann closed pull request #6886: [BP-1.5][FLINK-10614] Let test_batch_allround.sh rely on test-runner-common.sh for clean up

tillrohrmann closed pull request #6886: [BP-1.5][FLINK-10614] Let test_batch_allround.sh rely on test-runner-common.sh for clean up URL: https://github.com/apache/flink/pull/6886 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed

[GitHub] tillrohrmann closed pull request #6885: [BP-1.6][FLINK-10614] Let test_batch_allround.sh rely on test-runner-common.sh for clean up

tillrohrmann closed pull request #6885: [BP-1.6][FLINK-10614] Let test_batch_allround.sh rely on test-runner-common.sh for clean up URL: https://github.com/apache/flink/pull/6885 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed

[jira] [Commented] (FLINK-10614) Update test_batch_allround.sh e2e to new testing infrastructure

[ https://issues.apache.org/jira/browse/FLINK-10614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657215#comment-16657215 ] ASF GitHub Bot commented on FLINK-10614: tillrohrmann closed pull request #6884: [FLINK-10614]

[GitHub] tillrohrmann closed pull request #6884: [FLINK-10614] Let test_batch_allround.sh rely on test-runner-common.sh for clean up

tillrohrmann closed pull request #6884: [FLINK-10614] Let test_batch_allround.sh rely on test-runner-common.sh for clean up URL: https://github.com/apache/flink/pull/6884 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for

[jira] [Assigned] (FLINK-10558) Port YARNHighAvailabilityITCase and YARNSessionCapacitySchedulerITCase to new code base

[ https://issues.apache.org/jira/browse/FLINK-10558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun reassigned FLINK-10558: Assignee: TisonKun > Port YARNHighAvailabilityITCase and YARNSessionCapacitySchedulerITCase to

[jira] [Updated] (FLINK-7351) test instability in JobClientActorRecoveryITCase#testJobClientRecovery

[ https://issues.apache.org/jira/browse/FLINK-7351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7351: - Fix Version/s: (was: 1.7.0) > test instability in

[jira] [Updated] (FLINK-9000) Add automated cluster framework tests

[ https://issues.apache.org/jira/browse/FLINK-9000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9000: - Fix Version/s: (was: 1.7.0) > Add automated cluster framework tests >

[jira] [Updated] (FLINK-9000) Add automated cluster framework tests

[ https://issues.apache.org/jira/browse/FLINK-9000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9000: - Fix Version/s: 1.8.0 > Add automated cluster framework tests >

[jira] [Commented] (FLINK-10527) Cleanup constant isNewMode in YarnTestBase

[ https://issues.apache.org/jira/browse/FLINK-10527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16657026#comment-16657026 ] ASF GitHub Bot commented on FLINK-10527: yanghua commented on issue #6816: [FLINK-10527] Cleanup

[GitHub] yanghua commented on issue #6816: [FLINK-10527] Cleanup constant isNewMode in YarnTestBase

yanghua commented on issue #6816: [FLINK-10527] Cleanup constant isNewMode in YarnTestBase URL: https://github.com/apache/flink/pull/6816#issuecomment-431419776 @tillrohrmann I have updated this PR, just keep the change for class `YARNSessionFIFOITCase `.

[jira] [Assigned] (FLINK-10357) Streaming File Sink end-to-end test failed with mismatch

[ https://issues.apache.org/jira/browse/FLINK-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-10357: Assignee: Gary Yao > Streaming File Sink end-to-end test failed with mismatch >

[jira] [Updated] (FLINK-10616) Jepsen test fails while tearing down Hadoop

[ https://issues.apache.org/jira/browse/FLINK-10616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-10616: - Description: While tearing down Hadoop, the tests sporadically fail with the exception below:

[jira] [Commented] (FLINK-9808) Implement state conversion procedure in state backends

[ https://issues.apache.org/jira/browse/FLINK-9808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16656964#comment-16656964 ] ASF GitHub Bot commented on FLINK-9808: --- StefanRRichter commented on a change in pull request

[jira] [Commented] (FLINK-9808) Implement state conversion procedure in state backends

[ https://issues.apache.org/jira/browse/FLINK-9808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16656953#comment-16656953 ] ASF GitHub Bot commented on FLINK-9808: --- StefanRRichter commented on a change in pull request

[jira] [Commented] (FLINK-9808) Implement state conversion procedure in state backends

[ https://issues.apache.org/jira/browse/FLINK-9808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16656965#comment-16656965 ] ASF GitHub Bot commented on FLINK-9808: --- StefanRRichter commented on a change in pull request

[jira] [Commented] (FLINK-9808) Implement state conversion procedure in state backends

[ https://issues.apache.org/jira/browse/FLINK-9808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16656963#comment-16656963 ] ASF GitHub Bot commented on FLINK-9808: --- StefanRRichter commented on a change in pull request

[jira] [Commented] (FLINK-9808) Implement state conversion procedure in state backends

[ https://issues.apache.org/jira/browse/FLINK-9808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16656962#comment-16656962 ] ASF GitHub Bot commented on FLINK-9808: --- StefanRRichter commented on a change in pull request

[jira] [Commented] (FLINK-9808) Implement state conversion procedure in state backends

[ https://issues.apache.org/jira/browse/FLINK-9808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16656957#comment-16656957 ] ASF GitHub Bot commented on FLINK-9808: --- StefanRRichter commented on a change in pull request

[jira] [Commented] (FLINK-9808) Implement state conversion procedure in state backends

[ https://issues.apache.org/jira/browse/FLINK-9808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16656952#comment-16656952 ] ASF GitHub Bot commented on FLINK-9808: --- StefanRRichter commented on a change in pull request

[jira] [Commented] (FLINK-9808) Implement state conversion procedure in state backends

[ https://issues.apache.org/jira/browse/FLINK-9808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16656958#comment-16656958 ] ASF GitHub Bot commented on FLINK-9808: --- StefanRRichter commented on a change in pull request

[jira] [Commented] (FLINK-9808) Implement state conversion procedure in state backends

[ https://issues.apache.org/jira/browse/FLINK-9808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16656954#comment-16656954 ] ASF GitHub Bot commented on FLINK-9808: --- StefanRRichter commented on a change in pull request

[jira] [Commented] (FLINK-9808) Implement state conversion procedure in state backends

[ https://issues.apache.org/jira/browse/FLINK-9808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16656959#comment-16656959 ] ASF GitHub Bot commented on FLINK-9808: --- StefanRRichter commented on a change in pull request

[jira] [Commented] (FLINK-9808) Implement state conversion procedure in state backends

[ https://issues.apache.org/jira/browse/FLINK-9808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16656955#comment-16656955 ] ASF GitHub Bot commented on FLINK-9808: --- StefanRRichter commented on a change in pull request

[jira] [Commented] (FLINK-9808) Implement state conversion procedure in state backends

[ https://issues.apache.org/jira/browse/FLINK-9808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16656951#comment-16656951 ] ASF GitHub Bot commented on FLINK-9808: --- StefanRRichter commented on a change in pull request

[jira] [Commented] (FLINK-9808) Implement state conversion procedure in state backends

[ https://issues.apache.org/jira/browse/FLINK-9808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16656950#comment-16656950 ] ASF GitHub Bot commented on FLINK-9808: --- StefanRRichter commented on a change in pull request

[jira] [Commented] (FLINK-9808) Implement state conversion procedure in state backends

[ https://issues.apache.org/jira/browse/FLINK-9808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16656960#comment-16656960 ] ASF GitHub Bot commented on FLINK-9808: --- StefanRRichter commented on a change in pull request

[jira] [Commented] (FLINK-9808) Implement state conversion procedure in state backends

[ https://issues.apache.org/jira/browse/FLINK-9808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16656956#comment-16656956 ] ASF GitHub Bot commented on FLINK-9808: --- StefanRRichter commented on a change in pull request

[jira] [Commented] (FLINK-9808) Implement state conversion procedure in state backends

[ https://issues.apache.org/jira/browse/FLINK-9808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16656961#comment-16656961 ] ASF GitHub Bot commented on FLINK-9808: --- StefanRRichter commented on a change in pull request

[GitHub] StefanRRichter commented on a change in pull request #6875: [FLINK-9808] [state backends] Migrate state when necessary in state backends

StefanRRichter commented on a change in pull request #6875: [FLINK-9808] [state backends] Migrate state when necessary in state backends URL: https://github.com/apache/flink/pull/6875#discussion_r226684033 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #6875: [FLINK-9808] [state backends] Migrate state when necessary in state backends

StefanRRichter commented on a change in pull request #6875: [FLINK-9808] [state backends] Migrate state when necessary in state backends URL: https://github.com/apache/flink/pull/6875#discussion_r226687515 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #6875: [FLINK-9808] [state backends] Migrate state when necessary in state backends

StefanRRichter commented on a change in pull request #6875: [FLINK-9808] [state backends] Migrate state when necessary in state backends URL: https://github.com/apache/flink/pull/6875#discussion_r226690598 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #6875: [FLINK-9808] [state backends] Migrate state when necessary in state backends

StefanRRichter commented on a change in pull request #6875: [FLINK-9808] [state backends] Migrate state when necessary in state backends URL: https://github.com/apache/flink/pull/6875#discussion_r226662102 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #6875: [FLINK-9808] [state backends] Migrate state when necessary in state backends

StefanRRichter commented on a change in pull request #6875: [FLINK-9808] [state backends] Migrate state when necessary in state backends URL: https://github.com/apache/flink/pull/6875#discussion_r226686907 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #6875: [FLINK-9808] [state backends] Migrate state when necessary in state backends

StefanRRichter commented on a change in pull request #6875: [FLINK-9808] [state backends] Migrate state when necessary in state backends URL: https://github.com/apache/flink/pull/6875#discussion_r226685552 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #6875: [FLINK-9808] [state backends] Migrate state when necessary in state backends

StefanRRichter commented on a change in pull request #6875: [FLINK-9808] [state backends] Migrate state when necessary in state backends URL: https://github.com/apache/flink/pull/6875#discussion_r226683613 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #6875: [FLINK-9808] [state backends] Migrate state when necessary in state backends

StefanRRichter commented on a change in pull request #6875: [FLINK-9808] [state backends] Migrate state when necessary in state backends URL: https://github.com/apache/flink/pull/6875#discussion_r226669120 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #6875: [FLINK-9808] [state backends] Migrate state when necessary in state backends

StefanRRichter commented on a change in pull request #6875: [FLINK-9808] [state backends] Migrate state when necessary in state backends URL: https://github.com/apache/flink/pull/6875#discussion_r226676987 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #6875: [FLINK-9808] [state backends] Migrate state when necessary in state backends

StefanRRichter commented on a change in pull request #6875: [FLINK-9808] [state backends] Migrate state when necessary in state backends URL: https://github.com/apache/flink/pull/6875#discussion_r226679606 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #6875: [FLINK-9808] [state backends] Migrate state when necessary in state backends

StefanRRichter commented on a change in pull request #6875: [FLINK-9808] [state backends] Migrate state when necessary in state backends URL: https://github.com/apache/flink/pull/6875#discussion_r226688632 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #6875: [FLINK-9808] [state backends] Migrate state when necessary in state backends

StefanRRichter commented on a change in pull request #6875: [FLINK-9808] [state backends] Migrate state when necessary in state backends URL: https://github.com/apache/flink/pull/6875#discussion_r226663119 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #6875: [FLINK-9808] [state backends] Migrate state when necessary in state backends

StefanRRichter commented on a change in pull request #6875: [FLINK-9808] [state backends] Migrate state when necessary in state backends URL: https://github.com/apache/flink/pull/6875#discussion_r226691526 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #6875: [FLINK-9808] [state backends] Migrate state when necessary in state backends

StefanRRichter commented on a change in pull request #6875: [FLINK-9808] [state backends] Migrate state when necessary in state backends URL: https://github.com/apache/flink/pull/6875#discussion_r22394 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #6875: [FLINK-9808] [state backends] Migrate state when necessary in state backends

StefanRRichter commented on a change in pull request #6875: [FLINK-9808] [state backends] Migrate state when necessary in state backends URL: https://github.com/apache/flink/pull/6875#discussion_r226680634 ## File path:

[GitHub] StefanRRichter commented on a change in pull request #6875: [FLINK-9808] [state backends] Migrate state when necessary in state backends

StefanRRichter commented on a change in pull request #6875: [FLINK-9808] [state backends] Migrate state when necessary in state backends URL: https://github.com/apache/flink/pull/6875#discussion_r226689891 ## File path:

[jira] [Created] (FLINK-10616) Jepsen test fails while tearing down Hadoop

Gary Yao created FLINK-10616: Summary: Jepsen test fails while tearing down Hadoop Key: FLINK-10616 URL: https://issues.apache.org/jira/browse/FLINK-10616 Project: Flink Issue Type: Bug

[GitHub] tillrohrmann commented on a change in pull request #6886: [BP-1.5][FLINK-10614] Let test_batch_allround.sh rely on test-runner-common.sh for clean up

tillrohrmann commented on a change in pull request #6886: [BP-1.5][FLINK-10614] Let test_batch_allround.sh rely on test-runner-common.sh for clean up URL: https://github.com/apache/flink/pull/6886#discussion_r226690899 ## File path:

[jira] [Updated] (FLINK-5601) Window operator does not checkpoint watermarks

[ https://issues.apache.org/jira/browse/FLINK-5601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5601: - Affects Version/s: 1.7.0 > Window operator does not checkpoint watermarks >

[jira] [Updated] (FLINK-5601) Window operator does not checkpoint watermarks

[ https://issues.apache.org/jira/browse/FLINK-5601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5601: - Fix Version/s: (was: 1.7.0) 1.8.0 > Window operator does not checkpoint

[jira] [Commented] (FLINK-6856) Eagerly check if serializer config snapshots are deserializable when snapshotting

[ https://issues.apache.org/jira/browse/FLINK-6856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16656930#comment-16656930 ] Till Rohrmann commented on FLINK-6856: -- What's the state of this issue [~tzulitai]? Is it still

[jira] [Resolved] (FLINK-7915) Verify functionality of RollingSinkSecuredITCase

[ https://issues.apache.org/jira/browse/FLINK-7915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-7915. -- Resolution: Won't Do Fix Version/s: (was: 1.5.6) (was: 1.6.3)

[jira] [Updated] (FLINK-8871) Checkpoint cancellation is not propagated to stop checkpointing threads on the task manager

[ https://issues.apache.org/jira/browse/FLINK-8871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8871: - Fix Version/s: (was: 1.7.0) 1.8.0 > Checkpoint cancellation is not

[jira] [Updated] (FLINK-8871) Checkpoint cancellation is not propagated to stop checkpointing threads on the task manager

[ https://issues.apache.org/jira/browse/FLINK-8871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8871: - Affects Version/s: 1.7.0 > Checkpoint cancellation is not propagated to stop checkpointing

[jira] [Updated] (FLINK-9002) Add operators with input type that goes through Avro serialization (with schema/generic)

[ https://issues.apache.org/jira/browse/FLINK-9002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9002: - Fix Version/s: 1.7.0 > Add operators with input type that goes through Avro serialization (with

[jira] [Updated] (FLINK-8997) Add sliding window aggregation to the job

[ https://issues.apache.org/jira/browse/FLINK-8997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8997: - Fix Version/s: 1.7.0 > Add sliding window aggregation to the job >

[jira] [Updated] (FLINK-8998) Add user-defined watermark assigner and timestamp extractor to the test job

[ https://issues.apache.org/jira/browse/FLINK-8998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8998: - Fix Version/s: 1.7.0 > Add user-defined watermark assigner and timestamp extractor to the test

[jira] [Updated] (FLINK-9003) Add operators with input type that goes through custom, stateful serialization

[ https://issues.apache.org/jira/browse/FLINK-9003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9003: - Fix Version/s: 1.7.0 > Add operators with input type that goes through custom, stateful

[jira] [Updated] (FLINK-9001) Add operators with input type that goes through Kryo serialization (registered/generic/custom)

[ https://issues.apache.org/jira/browse/FLINK-9001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9001: - Fix Version/s: 1.7.0 > Add operators with input type that goes through Kryo serialization >

[jira] [Updated] (FLINK-8995) Add a test operator with keyed state that uses custom, stateful serializer

[ https://issues.apache.org/jira/browse/FLINK-8995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8995: - Fix Version/s: 1.7.0 > Add a test operator with keyed state that uses custom, stateful

[jira] [Updated] (FLINK-9410) Replace NMClient with NMClientAsync in YarnResourceManager

[ https://issues.apache.org/jira/browse/FLINK-9410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9410: - Affects Version/s: 1.7.0 > Replace NMClient with NMClientAsync in YarnResourceManager >

[jira] [Assigned] (FLINK-10543) Leverage efficient timer deletion in relational operators

[ https://issues.apache.org/jira/browse/FLINK-10543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-10543: --- Assignee: Hequn Cheng > Leverage efficient timer deletion in relational operators >

[jira] [Updated] (FLINK-9410) Replace NMClient with NMClientAsync in YarnResourceManager

[ https://issues.apache.org/jira/browse/FLINK-9410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9410: - Fix Version/s: (was: 1.7.0) 1.8.0 > Replace NMClient with NMClientAsync

[jira] [Resolved] (FLINK-9587) ContinuousFileMonitoringFunction crashes on short living files

[ https://issues.apache.org/jira/browse/FLINK-9587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-9587. -- Resolution: Not A Problem > ContinuousFileMonitoringFunction crashes on short living files >

[jira] [Commented] (FLINK-9587) ContinuousFileMonitoringFunction crashes on short living files

[ https://issues.apache.org/jira/browse/FLINK-9587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16656921#comment-16656921 ] Till Rohrmann commented on FLINK-9587: -- I think we can close this issue due to inactivity. >

[jira] [Updated] (FLINK-10368) 'Kerberized YARN on Docker test' instable

[ https://issues.apache.org/jira/browse/FLINK-10368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10368: -- Fix Version/s: 1.6.3 1.5.6 > 'Kerberized YARN on Docker test' instable >

[jira] [Commented] (FLINK-10364) Test instability in NonHAQueryableStateFsBackendITCase#testMapState

[ https://issues.apache.org/jira/browse/FLINK-10364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16656917#comment-16656917 ] Till Rohrmann commented on FLINK-10364: --- Ping [~kkl0u] > Test instability in

[jira] [Commented] (FLINK-10491) Deadlock during spilling data in SpillableSubpartition

[ https://issues.apache.org/jira/browse/FLINK-10491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16656916#comment-16656916 ] Till Rohrmann commented on FLINK-10491: --- [~pnowojski] [~zjwang], is this something we want to

[jira] [Updated] (FLINK-10481) Wordcount end-to-end test in docker env unstable

[ https://issues.apache.org/jira/browse/FLINK-10481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10481: -- Fix Version/s: 1.5.6 > Wordcount end-to-end test in docker env unstable >

[jira] [Updated] (FLINK-10481) Wordcount end-to-end test in docker env unstable

[ https://issues.apache.org/jira/browse/FLINK-10481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10481: -- Fix Version/s: 1.6.3 > Wordcount end-to-end test in docker env unstable >

[jira] [Commented] (FLINK-10368) 'Kerberized YARN on Docker test' instable

[ https://issues.apache.org/jira/browse/FLINK-10368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16656901#comment-16656901 ] Till Rohrmann commented on FLINK-10368: --- I encountered another problem: {code}The program finished

[jira] [Commented] (FLINK-10482) java.lang.IllegalArgumentException: Negative number of in progress checkpoints

[ https://issues.apache.org/jira/browse/FLINK-10482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16656892#comment-16656892 ] Gary Yao commented on FLINK-10482: -- While working on FLINK-10309, I discovered FLINK-10615, which can

[jira] [Commented] (FLINK-10601) Make user home dir consistent with Flink default filesystem

[ https://issues.apache.org/jira/browse/FLINK-10601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16656883#comment-16656883 ] ASF GitHub Bot commented on FLINK-10601: link3280 commented on issue #6887: [FLINK-10601] [YARN]

[GitHub] link3280 commented on issue #6887: [FLINK-10601] [YARN] Make user home dir consistent with Flink default filesystem

link3280 commented on issue #6887: [FLINK-10601] [YARN] Make user home dir consistent with Flink default filesystem URL: https://github.com/apache/flink/pull/6887#issuecomment-431389044 I'd like to add some tests, but it seems that it's hard to expose the state of YARN containers in a UT,

[jira] [Commented] (FLINK-10601) Make user home dir consistent with Flink default filesystem

[ https://issues.apache.org/jira/browse/FLINK-10601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16656881#comment-16656881 ] ASF GitHub Bot commented on FLINK-10601: link3280 opened a new pull request #6887: [FLINK-10601]

[GitHub] link3280 opened a new pull request #6887: [FLINK-10601] [YARN] Make user home dir consistent with Flink default filesystem

link3280 opened a new pull request #6887: [FLINK-10601] [YARN] Make user home dir consistent with Flink default filesystem URL: https://github.com/apache/flink/pull/6887 ## What is the purpose of the change Currently, Flink client uses the raw default Hadoop filesystem to upload

[jira] [Resolved] (FLINK-10275) StreamTask support object reuse

[ https://issues.apache.org/jira/browse/FLINK-10275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-10275. --- Resolution: Won't Fix Fix Version/s: (was: 1.7.0) > StreamTask support object

[jira] [Reopened] (FLINK-10275) StreamTask support object reuse

[ https://issues.apache.org/jira/browse/FLINK-10275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reopened FLINK-10275: --- > StreamTask support object reuse > --- > > Key:

[jira] [Commented] (FLINK-10605) Upgrade AvroSerializer snapshot to implement new TypeSerializerSnapshot interface

[ https://issues.apache.org/jira/browse/FLINK-10605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16656874#comment-16656874 ] ASF GitHub Bot commented on FLINK-10605: igalshilman commented on a change in pull request

  1   2   3   4   >