[GitHub] [flink] tillrohrmann commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

tillrohrmann commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#discussion_r401737501 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

tillrohrmann commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#discussion_r403030485 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

tillrohrmann commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#discussion_r401726831 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

tillrohrmann commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#discussion_r403062228 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

tillrohrmann commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#discussion_r401731886 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

tillrohrmann commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#discussion_r403063198 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

tillrohrmann commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#discussion_r403046204 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

tillrohrmann commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#discussion_r403051769 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

tillrohrmann commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#discussion_r403035761 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

tillrohrmann commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#discussion_r403055120 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

tillrohrmann commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#discussion_r403028625 ## File path:

[GitHub] [flink] rkhachatryan commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints

rkhachatryan commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints URL: https://github.com/apache/flink/pull/11515#discussion_r403067210 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

tillrohrmann commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#discussion_r401738574 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

tillrohrmann commented on a change in pull request #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#discussion_r403039671 ## File path:

[GitHub] [flink] rkhachatryan commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints

rkhachatryan commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints URL: https://github.com/apache/flink/pull/11515#discussion_r403064635 ## File path:

[GitHub] [flink] azagrebin commented on issue #11629: [FLINK-14267][connectors/filesystem]Introduce BaseRow Encoder in csv for filesystem table sink.

azagrebin commented on issue #11629: [FLINK-14267][connectors/filesystem]Introduce BaseRow Encoder in csv for filesystem table sink. URL: https://github.com/apache/flink/pull/11629#issuecomment-608485810 @leonardBang no worries, I also created this kind of PR couple of times :)

[GitHub] [flink] leonardBang commented on issue #11629: [FLINK-14267][connectors/filesystem]Introduce BaseRow Encoder in csv for filesystem table sink.

leonardBang commented on issue #11629: [FLINK-14267][connectors/filesystem]Introduce BaseRow Encoder in csv for filesystem table sink. URL: https://github.com/apache/flink/pull/11629#issuecomment-608478125 @azagrebin thanks for update the PR link ^_^

[GitHub] [flink] flinkbot edited a comment on issue #11629: [FLINK-14267][connectors/filesystem]Introduce BaseRow Encoder in csv for filesystem table sink.

flinkbot edited a comment on issue #11629: [FLINK-14267][connectors/filesystem]Introduce BaseRow Encoder in csv for filesystem table sink. URL: https://github.com/apache/flink/pull/11629#issuecomment-608466138 ## CI report: * 5a3f35f15271416d41248df519aa8d3ac1bbe5ea Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11628: [FLINK-14504][rest] Add Cluster DataSet REST API

flinkbot edited a comment on issue #11628: [FLINK-14504][rest] Add Cluster DataSet REST API URL: https://github.com/apache/flink/pull/11628#issuecomment-608370153 ## CI report: * 44066c510cd12ae93baf839652b1bb2b43cc8cab Travis:

[jira] [Updated] (FLINK-16267) Flink uses more memory than taskmanager.memory.process.size in Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-16267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-16267: --- Labels: (was: pull-request-available) > Flink uses more memory than

[GitHub] [flink] flinkbot edited a comment on issue #11460: [FLINK-16655][FLINK-16657] Introduce embedded executor and use it for Web Submission

flinkbot edited a comment on issue #11460: [FLINK-16655][FLINK-16657] Introduce embedded executor and use it for Web Submission URL: https://github.com/apache/flink/pull/11460#issuecomment-601593052 ## CI report: * 349f5d7bfd68016ba3595a17ff3a1533969581fb UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous

flinkbot edited a comment on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous URL: https://github.com/apache/flink/pull/11427#issuecomment-599949839 ## CI report: * e5e11418358bf450d1cca543916bbd7d695375b1 UNKNOWN *

[GitHub] [flink] rkhachatryan commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints

rkhachatryan commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints URL: https://github.com/apache/flink/pull/11515#discussion_r403053686 ## File path:

[GitHub] [flink] kl0u commented on a change in pull request #11460: [FLINK-16655][FLINK-16657] Introduce embedded executor and use it for Web Submission

kl0u commented on a change in pull request #11460: [FLINK-16655][FLINK-16657] Introduce embedded executor and use it for Web Submission URL: https://github.com/apache/flink/pull/11460#discussion_r403050214 ## File path:

[GitHub] [flink] flinkbot commented on issue #11629: [FLINK-16267][connectors/filesystem]Introduce BaseRow Encoder in csv for filesystem table sink.

flinkbot commented on issue #11629: [FLINK-16267][connectors/filesystem]Introduce BaseRow Encoder in csv for filesystem table sink. URL: https://github.com/apache/flink/pull/11629#issuecomment-608466138 ## CI report: * 5a3f35f15271416d41248df519aa8d3ac1bbe5ea UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #11626: [FLINK-16961] Bump Netty 4.X to 4.1.44

flinkbot edited a comment on issue #11626: [FLINK-16961] Bump Netty 4.X to 4.1.44 URL: https://github.com/apache/flink/pull/11626#issuecomment-608322234 ## CI report: * 10cea4c8ba6756ac31de11a5a6728a5dfc41d9c4 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous

flinkbot edited a comment on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous URL: https://github.com/apache/flink/pull/11427#issuecomment-599949839 ## CI report: * e5e11418358bf450d1cca543916bbd7d695375b1 UNKNOWN *

[GitHub] [flink] pnowojski commented on a change in pull request #11564: [FLINK-16864][metrics] Add IdleTime metric for task.

pnowojski commented on a change in pull request #11564: [FLINK-16864][metrics] Add IdleTime metric for task. URL: https://github.com/apache/flink/pull/11564#discussion_r403045117 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

flinkbot edited a comment on issue #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#issuecomment-603776093 ## CI report: * dee2b337e5e72d8f7b1f5098b74f2958d000fb3c UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11627: [FLINK-16770][e2e] Make the checkpoint resuming e2e case pass by increasing the…

flinkbot edited a comment on issue #11627: [FLINK-16770][e2e] Make the checkpoint resuming e2e case pass by increasing the… URL: https://github.com/apache/flink/pull/11627#issuecomment-608340311 ## CI report: * 59717320f953e6c4d3cfefe64c830fafee4d2c40 Travis:

[jira] [Updated] (FLINK-16572) CheckPubSubEmulatorTest is flaky on Azure

[ https://issues.apache.org/jira/browse/FLINK-16572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-16572: --- Priority: Critical (was: Major) > CheckPubSubEmulatorTest is flaky on Azure >

[jira] [Updated] (FLINK-16572) CheckPubSubEmulatorTest is flaky on Azure

[ https://issues.apache.org/jira/browse/FLINK-16572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-16572: --- Fix Version/s: 1.11.0 > CheckPubSubEmulatorTest is flaky on Azure >

[jira] [Commented] (FLINK-16572) CheckPubSubEmulatorTest is flaky on Azure

[ https://issues.apache.org/jira/browse/FLINK-16572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074623#comment-17074623 ] Piotr Nowojski commented on FLINK-16572: Another instance:

[jira] [Created] (FLINK-16975) Add docs for FileSystem connector and hive connector

Leonard Xu created FLINK-16975: -- Summary: Add docs for FileSystem connector and hive connector Key: FLINK-16975 URL: https://issues.apache.org/jira/browse/FLINK-16975 Project: Flink Issue Type:

[GitHub] [flink] pnowojski commented on a change in pull request #11564: [FLINK-16864][metrics] Add IdleTime metric for task.

pnowojski commented on a change in pull request #11564: [FLINK-16864][metrics] Add IdleTime metric for task. URL: https://github.com/apache/flink/pull/11564#discussion_r403043161 ## File path:

[GitHub] [flink] flinkbot commented on issue #11629: [FLINK-16267][connectors/filesystem]Introduce BaseRow Encoder in csv for filesystem table sink.

flinkbot commented on issue #11629: [FLINK-16267][connectors/filesystem]Introduce BaseRow Encoder in csv for filesystem table sink. URL: https://github.com/apache/flink/pull/11629#issuecomment-608462074 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[GitHub] [flink] pnowojski commented on a change in pull request #11564: [FLINK-16864][metrics] Add IdleTime metric for task.

pnowojski commented on a change in pull request #11564: [FLINK-16864][metrics] Add IdleTime metric for task. URL: https://github.com/apache/flink/pull/11564#discussion_r403039657 ## File path: docs/monitoring/metrics.zh.md ## @@ -1440,6 +1440,11 @@ Certain RocksDB native

[GitHub] [flink] leonardBang opened a new pull request #11629: [FLINK-16267][connectors/filesystem]Introduce BaseRow Encoder in csv for filesystem table sink.

leonardBang opened a new pull request #11629: [FLINK-16267][connectors/filesystem]Introduce BaseRow Encoder in csv for filesystem table sink. URL: https://github.com/apache/flink/pull/11629 ## What is the purpose of the change *This pull request introduce BaseRow Csv

[jira] [Updated] (FLINK-16267) Flink uses more memory than taskmanager.memory.process.size in Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-16267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16267: --- Labels: pull-request-available (was: ) > Flink uses more memory than

[GitHub] [flink] flinkbot edited a comment on issue #11618: [FLINK-6258] Deprecate ListCheckpointed interface

flinkbot edited a comment on issue #11618: [FLINK-6258] Deprecate ListCheckpointed interface URL: https://github.com/apache/flink/pull/11618#issuecomment-607784858 ## CI report: * 361c7e90eaf27f69132c054b20cf0e1a24313fff UNKNOWN * 2436722de48565c6abe63c1ed6a72e986edbc6cb

[jira] [Commented] (FLINK-16907) did not react to cancelling signal for 30 seconds, but is stuck in method:

[ https://issues.apache.org/jira/browse/FLINK-16907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074610#comment-17074610 ] Piotr Nowojski commented on FLINK-16907: [~xinyitong] unfortunately logs are not giving any more

[jira] [Updated] (FLINK-16973) Various builds failing with "Corrupted STDOUT by directly writing"

[ https://issues.apache.org/jira/browse/FLINK-16973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-16973: --- Labels: test-stability (was: ) > Various builds failing with "Corrupted STDOUT by directly

[jira] [Updated] (FLINK-16974) Azure build failed with OutOfMemoryError: unable to create new native thread

[ https://issues.apache.org/jira/browse/FLINK-16974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-16974: --- Labels: test-stability (was: ) > Azure build failed with OutOfMemoryError: unable to

[jira] [Created] (FLINK-16974) Azure build failed with OutOfMemoryError: unable to create new native thread

Piotr Nowojski created FLINK-16974: -- Summary: Azure build failed with OutOfMemoryError: unable to create new native thread Key: FLINK-16974 URL: https://issues.apache.org/jira/browse/FLINK-16974

[jira] [Commented] (FLINK-16973) Various builds failing with "Corrupted STDOUT by directly writing"

[ https://issues.apache.org/jira/browse/FLINK-16973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074600#comment-17074600 ] Piotr Nowojski commented on FLINK-16973: Another instance (core)

[jira] [Created] (FLINK-16973) Various builds failing with "Corrupted STDOUT by directly writing"

Piotr Nowojski created FLINK-16973: -- Summary: Various builds failing with "Corrupted STDOUT by directly writing" Key: FLINK-16973 URL: https://issues.apache.org/jira/browse/FLINK-16973 Project:

[GitHub] [flink] flinkbot edited a comment on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous

flinkbot edited a comment on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous URL: https://github.com/apache/flink/pull/11427#issuecomment-599949839 ## CI report: * e5e11418358bf450d1cca543916bbd7d695375b1 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11276: [FLINK-16029][table-planner-blink] Remove register source and sink in test cases of blink planner

flinkbot edited a comment on issue #11276: [FLINK-16029][table-planner-blink] Remove register source and sink in test cases of blink planner URL: https://github.com/apache/flink/pull/11276#issuecomment-593234780 ## CI report: * 9c5a5e022054111f3c05265e6a35bd98bb72b20a Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11626: [FLINK-16961] Bump Netty 4.X to 4.1.44

flinkbot edited a comment on issue #11626: [FLINK-16961] Bump Netty 4.X to 4.1.44 URL: https://github.com/apache/flink/pull/11626#issuecomment-608322234 ## CI report: * 10cea4c8ba6756ac31de11a5a6728a5dfc41d9c4 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11625: [FLINK-16954] Don't use JDK11 APIs in ClassRelocator

flinkbot edited a comment on issue #11625: [FLINK-16954] Don't use JDK11 APIs in ClassRelocator URL: https://github.com/apache/flink/pull/11625#issuecomment-608312573 ## CI report: * f63ceb4c101488d6df12f0314f30de2ef6aca411 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11587: [FLINK-14126][test] Ensure elasticsearch version check

flinkbot edited a comment on issue #11587: [FLINK-14126][test] Ensure elasticsearch version check URL: https://github.com/apache/flink/pull/11587#issuecomment-606986240 ## CI report: * f4dd02b0a786b1fe4f671e021edb7c4fa0a39827 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous

flinkbot edited a comment on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous URL: https://github.com/apache/flink/pull/11427#issuecomment-599949839 ## CI report: * e5e11418358bf450d1cca543916bbd7d695375b1 UNKNOWN *

[GitHub] [flink] Myasuka commented on issue #11627: [FLINK-16770][e2e] Make the checkpoint resuming e2e case pass by increasing the…

Myasuka commented on issue #11627: [FLINK-16770][e2e] Make the checkpoint resuming e2e case pass by increasing the… URL: https://github.com/apache/flink/pull/11627#issuecomment-608427988 LGTM This is an automated message

[GitHub] [flink] dawidwys commented on issue #11622: [FLINK-16913][configuration, statebackend] Migrated StateBackends to use ReadableConfig instead of Configuration

dawidwys commented on issue #11622: [FLINK-16913][configuration, statebackend] Migrated StateBackends to use ReadableConfig instead of Configuration URL: https://github.com/apache/flink/pull/11622#issuecomment-608422050 You're concerns are valid. I had a chat with @aljoscha about it and we

[jira] [Commented] (FLINK-16770) Resuming Externalized Checkpoint (rocks, incremental, scale up) end-to-end test fails with no such file

[ https://issues.apache.org/jira/browse/FLINK-16770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074561#comment-17074561 ] Piotr Nowojski commented on FLINK-16770: Thanks [~yunta] for analysing the issue and [~SleePy]

[jira] [Assigned] (FLINK-16931) Large _metadata file lead to JobManager not responding when restart

[ https://issues.apache.org/jira/browse/FLINK-16931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-16931: -- Assignee: Lu Niu > Large _metadata file lead to JobManager not responding when

[jira] [Commented] (FLINK-16931) Large _metadata file lead to JobManager not responding when restart

[ https://issues.apache.org/jira/browse/FLINK-16931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074552#comment-17074552 ] Piotr Nowojski commented on FLINK-16931: Hi [~qqibrow] :) I'm assigning the ticket to you. If

[GitHub] [flink] wangyang0918 commented on a change in pull request #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous

wangyang0918 commented on a change in pull request #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous URL: https://github.com/apache/flink/pull/11427#discussion_r402749513 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11587: [FLINK-14126][test] Ensure elasticsearch version check

flinkbot edited a comment on issue #11587: [FLINK-14126][test] Ensure elasticsearch version check URL: https://github.com/apache/flink/pull/11587#issuecomment-606986240 ## CI report: * f4dd02b0a786b1fe4f671e021edb7c4fa0a39827 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

flinkbot edited a comment on issue #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#issuecomment-603776093 ## CI report: * dee2b337e5e72d8f7b1f5098b74f2958d000fb3c UNKNOWN *

[GitHub] [flink] kl0u commented on a change in pull request #11460: [FLINK-16655][FLINK-16657] Introduce embedded executor and use it for Web Submission

kl0u commented on a change in pull request #11460: [FLINK-16655][FLINK-16657] Introduce embedded executor and use it for Web Submission URL: https://github.com/apache/flink/pull/11460#discussion_r402976673 ## File path:

[GitHub] [flink] wangyang0918 removed a comment on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous

wangyang0918 removed a comment on issue #11427: [FLINK-15790][k8s] Make FlinkKubeClient and its implementations asynchronous URL: https://github.com/apache/flink/pull/11427#issuecomment-608353239 @azagrebin Thanks for your review. I have addressed most of your comments. Since some others

[GitHub] [flink] kl0u commented on a change in pull request #11460: [FLINK-16655][FLINK-16657] Introduce embedded executor and use it for Web Submission

kl0u commented on a change in pull request #11460: [FLINK-16655][FLINK-16657] Introduce embedded executor and use it for Web Submission URL: https://github.com/apache/flink/pull/11460#discussion_r402974738 ## File path:

[GitHub] [flink] carp84 commented on issue #11622: [FLINK-16913][configuration, statebackend] Migrated StateBackends to use ReadableConfig instead of Configuration

carp84 commented on issue #11622: [FLINK-16913][configuration, statebackend] Migrated StateBackends to use ReadableConfig instead of Configuration URL: https://github.com/apache/flink/pull/11622#issuecomment-608407152 Thanks for the quick response @dawidwys . The touched

[GitHub] [flink] kl0u commented on a change in pull request #11460: [FLINK-16655][FLINK-16657] Introduce embedded executor and use it for Web Submission

kl0u commented on a change in pull request #11460: [FLINK-16655][FLINK-16657] Introduce embedded executor and use it for Web Submission URL: https://github.com/apache/flink/pull/11460#discussion_r402963398 ## File path:

[GitHub] [flink] kl0u commented on a change in pull request #11460: [FLINK-16655][FLINK-16657] Introduce embedded executor and use it for Web Submission

kl0u commented on a change in pull request #11460: [FLINK-16655][FLINK-16657] Introduce embedded executor and use it for Web Submission URL: https://github.com/apache/flink/pull/11460#discussion_r402961693 ## File path:

[GitHub] [flink] kl0u commented on a change in pull request #11460: [FLINK-16655][FLINK-16657] Introduce embedded executor and use it for Web Submission

kl0u commented on a change in pull request #11460: [FLINK-16655][FLINK-16657] Introduce embedded executor and use it for Web Submission URL: https://github.com/apache/flink/pull/11460#discussion_r402960160 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

flinkbot edited a comment on issue #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#issuecomment-603776093 ## CI report: * dee2b337e5e72d8f7b1f5098b74f2958d000fb3c UNKNOWN *

[GitHub] [flink] kl0u commented on a change in pull request #11460: [FLINK-16655][FLINK-16657] Introduce embedded executor and use it for Web Submission

kl0u commented on a change in pull request #11460: [FLINK-16655][FLINK-16657] Introduce embedded executor and use it for Web Submission URL: https://github.com/apache/flink/pull/11460#discussion_r402957085 ## File path:

[jira] [Created] (FLINK-16972) Fix non-blocking output availability logic.

Arvid Heise created FLINK-16972: --- Summary: Fix non-blocking output availability logic. Key: FLINK-16972 URL: https://issues.apache.org/jira/browse/FLINK-16972 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on issue #11598: [FLINK-16914][python] Support ArrayType in vectorized Python UDF

flinkbot edited a comment on issue #11598: [FLINK-16914][python] Support ArrayType in vectorized Python UDF URL: https://github.com/apache/flink/pull/11598#issuecomment-607168470 ## CI report: * deb7f3ddd8feaf154dacac8f5f8a46b6b34807bd Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

flinkbot edited a comment on issue #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#issuecomment-603776093 ## CI report: * dee2b337e5e72d8f7b1f5098b74f2958d000fb3c UNKNOWN *

[jira] [Commented] (FLINK-16938) SqlTimestamp has lag when convert long to Timestamp

[ https://issues.apache.org/jira/browse/FLINK-16938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074517#comment-17074517 ] YufeiLiu commented on FLINK-16938: -- Hi [~jark], but at this point, convert DataStream to Table use

[jira] [Created] (FLINK-16971) Support Python UDF in SQL Client (FLIP-114)

Wei Zhong created FLINK-16971: - Summary: Support Python UDF in SQL Client (FLIP-114) Key: FLINK-16971 URL: https://issues.apache.org/jira/browse/FLINK-16971 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on issue #11448: [FLINK-16666][python][table] Support new Python dependency configuration options in flink-java, flink-streaming-java and flink-table.

flinkbot edited a comment on issue #11448: [FLINK-1][python][table] Support new Python dependency configuration options in flink-java, flink-streaming-java and flink-table. URL: https://github.com/apache/flink/pull/11448#issuecomment-601042255 ## CI report: *

[GitHub] [flink] GJL commented on a change in pull request #11542: [FLINK-16303][rest] Enable retrieval of custom JobManager log files

GJL commented on a change in pull request #11542: [FLINK-16303][rest] Enable retrieval of custom JobManager log files URL: https://github.com/apache/flink/pull/11542#discussion_r402939130 ## File path:

[jira] [Commented] (FLINK-16938) SqlTimestamp has lag when convert long to Timestamp

[ https://issues.apache.org/jira/browse/FLINK-16938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074506#comment-17074506 ] Jark Wu commented on FLINK-16938: - Hi [~liuyufei], TIMESTAMP(3) is also called TIMESTAMP(3) WITHOUT TIME

[GitHub] [flink] GJL commented on a change in pull request #11542: [FLINK-16303][rest] Enable retrieval of custom JobManager log files

GJL commented on a change in pull request #11542: [FLINK-16303][rest] Enable retrieval of custom JobManager log files URL: https://github.com/apache/flink/pull/11542#discussion_r402936444 ## File path:

[jira] [Resolved] (FLINK-16705) LocalExecutor tears down MiniCluster before client can retrieve JobResult

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

[GitHub] [flink] tillrohrmann closed pull request #11623: [BP-1.10][FLINK-16705] Ensure MiniCluster shutdown does not interfere with JobResult retrieval

tillrohrmann closed pull request #11623: [BP-1.10][FLINK-16705] Ensure MiniCluster shutdown does not interfere with JobResult retrieval URL: https://github.com/apache/flink/pull/11623 This is an automated message from the

[GitHub] [flink] tillrohrmann commented on issue #11623: [BP-1.10][FLINK-16705] Ensure MiniCluster shutdown does not interfere with JobResult retrieval

tillrohrmann commented on issue #11623: [BP-1.10][FLINK-16705] Ensure MiniCluster shutdown does not interfere with JobResult retrieval URL: https://github.com/apache/flink/pull/11623#issuecomment-608378856 Merged manually via 128f5f7bd1da9ae50973115b38f4def3adc331e1

[GitHub] [flink] tillrohrmann closed pull request #11473: [FLINK-16705] Ensure MiniCluster shutdown does not interfere with JobResult retrieval

tillrohrmann closed pull request #11473: [FLINK-16705] Ensure MiniCluster shutdown does not interfere with JobResult retrieval URL: https://github.com/apache/flink/pull/11473 This is an automated message from the Apache Git

[GitHub] [flink] wsry commented on a change in pull request #11567: [FLINK-16645] Limit the maximum backlogs in subpartitions

wsry commented on a change in pull request #11567: [FLINK-16645] Limit the maximum backlogs in subpartitions URL: https://github.com/apache/flink/pull/11567#discussion_r402934181 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11448: [FLINK-16666][python][table] Support new Python dependency configuration options in flink-java, flink-streaming-java and flink-table.

flinkbot edited a comment on issue #11448: [FLINK-1][python][table] Support new Python dependency configuration options in flink-java, flink-streaming-java and flink-table. URL: https://github.com/apache/flink/pull/11448#issuecomment-601042255 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #11598: [FLINK-16914][python] Support ArrayType in vectorized Python UDF

flinkbot edited a comment on issue #11598: [FLINK-16914][python] Support ArrayType in vectorized Python UDF URL: https://github.com/apache/flink/pull/11598#issuecomment-607168470 ## CI report: * deb7f3ddd8feaf154dacac8f5f8a46b6b34807bd Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11628: [FLINK-14504][rest] Add Cluster DataSet REST API

flinkbot edited a comment on issue #11628: [FLINK-14504][rest] Add Cluster DataSet REST API URL: https://github.com/apache/flink/pull/11628#issuecomment-608370153 ## CI report: * 44066c510cd12ae93baf839652b1bb2b43cc8cab Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11567: [FLINK-16645] Limit the maximum backlogs in subpartitions

flinkbot edited a comment on issue #11567: [FLINK-16645] Limit the maximum backlogs in subpartitions URL: https://github.com/apache/flink/pull/11567#issuecomment-606017854 ## CI report: * 9a8522c95cba8f72afb372a6425224f7129c357f Travis:

[GitHub] [flink] mxm commented on issue #11473: [FLINK-16705] Ensure MiniCluster shutdown does not interfere with JobResult retrieval

mxm commented on issue #11473: [FLINK-16705] Ensure MiniCluster shutdown does not interfere with JobResult retrieval URL: https://github.com/apache/flink/pull/11473#issuecomment-608374884 Thanks @tillrohrmann for working with me on this. Looks like the tests are green now.

[GitHub] [flink] GJL commented on a change in pull request #11542: [FLINK-16303][rest] Enable retrieval of custom JobManager log files

GJL commented on a change in pull request #11542: [FLINK-16303][rest] Enable retrieval of custom JobManager log files URL: https://github.com/apache/flink/pull/11542#discussion_r402900127 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #11542: [FLINK-16303][rest] Enable retrieval of custom JobManager log files

GJL commented on a change in pull request #11542: [FLINK-16303][rest] Enable retrieval of custom JobManager log files URL: https://github.com/apache/flink/pull/11542#discussion_r402911592 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #11542: [FLINK-16303][rest] Enable retrieval of custom JobManager log files

GJL commented on a change in pull request #11542: [FLINK-16303][rest] Enable retrieval of custom JobManager log files URL: https://github.com/apache/flink/pull/11542#discussion_r402917989 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #11542: [FLINK-16303][rest] Enable retrieval of custom JobManager log files

GJL commented on a change in pull request #11542: [FLINK-16303][rest] Enable retrieval of custom JobManager log files URL: https://github.com/apache/flink/pull/11542#discussion_r402916736 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #11542: [FLINK-16303][rest] Enable retrieval of custom JobManager log files

GJL commented on a change in pull request #11542: [FLINK-16303][rest] Enable retrieval of custom JobManager log files URL: https://github.com/apache/flink/pull/11542#discussion_r402919659 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #11542: [FLINK-16303][rest] Enable retrieval of custom JobManager log files

GJL commented on a change in pull request #11542: [FLINK-16303][rest] Enable retrieval of custom JobManager log files URL: https://github.com/apache/flink/pull/11542#discussion_r402915166 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #11542: [FLINK-16303][rest] Enable retrieval of custom JobManager log files

GJL commented on a change in pull request #11542: [FLINK-16303][rest] Enable retrieval of custom JobManager log files URL: https://github.com/apache/flink/pull/11542#discussion_r402927567 ## File path:

[GitHub] [flink] nielsbasjes commented on issue #11592: [FLINK-16871][runtime] Make more build time information available at runtime

nielsbasjes commented on issue #11592: [FLINK-16871][runtime] Make more build time information available at runtime URL: https://github.com/apache/flink/pull/11592#issuecomment-608373807 @azagrebin / @wangyang0918 Would you be so kind to have a look at this. This is purely the

[GitHub] [flink] GJL commented on a change in pull request #11542: [FLINK-16303][rest] Enable retrieval of custom JobManager log files

GJL commented on a change in pull request #11542: [FLINK-16303][rest] Enable retrieval of custom JobManager log files URL: https://github.com/apache/flink/pull/11542#discussion_r402910819 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #11542: [FLINK-16303][rest] Enable retrieval of custom JobManager log files

GJL commented on a change in pull request #11542: [FLINK-16303][rest] Enable retrieval of custom JobManager log files URL: https://github.com/apache/flink/pull/11542#discussion_r402920867 ## File path:

[jira] [Commented] (FLINK-16549) ExecutionContextTest.testCatalogs gets stuck / Out of memory

[ https://issues.apache.org/jira/browse/FLINK-16549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074492#comment-17074492 ] Aljoscha Krettek commented on FLINK-16549: -- This doesn't seem to be Table API-related. I mean

[jira] [Commented] (FLINK-16969) Unable to use case class in flink scala shell

[ https://issues.apache.org/jira/browse/FLINK-16969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074490#comment-17074490 ] Aljoscha Krettek commented on FLINK-16969: -- I don't yet know a solution for this. The problem,

<    1   2   3   4   5   >