[jira] [Closed] (FLINK-12035) StreamingFileSink E2E test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-12035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-12035. Resolution: Cannot Reproduce I already saw this one and increased the timeout on both

[jira] [Commented] (FLINK-12006) ZooKeeperHaServicesTest.testSimpleCloseAndCleanupAllData is unstable

[ https://issues.apache.org/jira/browse/FLINK-12006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16803803#comment-16803803 ] Till Rohrmann commented on FLINK-12006: --- Another instance:

[GitHub] [flink] tillrohrmann commented on issue #8065: [BP-1.7][FLINK-12021] Deploy execution in topological sorted order

tillrohrmann commented on issue #8065: [BP-1.7][FLINK-12021] Deploy execution in topological sorted order URL: https://github.com/apache/flink/pull/8065#issuecomment-477541684 Integration tests in `flink-ml` are failing. I cannot really see which tests fails but I think it is unrelated to

[GitHub] [flink] zentol commented on issue #8071: [FLINK-12051][runtime][tests] Wait for TaskExecutor to be started

zentol commented on issue #8071: [FLINK-12051][runtime][tests] Wait for TaskExecutor to be started URL: https://github.com/apache/flink/pull/8071#issuecomment-477590382 All other tests either are already waiting for the TM to start fully, or are relying on futures in their assertions.

[GitHub] [flink] flinkbot commented on issue #8073: [FLINK-12057] Refactor MemoryLogger to accept termination future instead of ActorSystem

flinkbot commented on issue #8073: [FLINK-12057] Refactor MemoryLogger to accept termination future instead of ActorSystem URL: https://github.com/apache/flink/pull/8073#issuecomment-477617556 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] zentol opened a new pull request #8073: [FLINK-12057] Refactor MemoryLogger to accept termination future instead of ActorSystem

zentol opened a new pull request #8073: [FLINK-12057] Refactor MemoryLogger to accept termination future instead of ActorSystem URL: https://github.com/apache/flink/pull/8073 ## What is the purpose of the change Small refactoring in the `MemoryLogger` to not accept an ActorSystem

[jira] [Created] (FLINK-12059) How to increase outputQueueLength/inputQueueLength

WuXiZao created FLINK-12059: --- Summary: How to increase outputQueueLength/inputQueueLength Key: FLINK-12059 URL: https://issues.apache.org/jira/browse/FLINK-12059 Project: Flink Issue Type:

[jira] [Updated] (FLINK-12048) ZooKeeperHADispatcherTest failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-12048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-12048: - Labels: test-stability (was: ) > ZooKeeperHADispatcherTest failed on Travis >

[GitHub] [flink] JingsongLi commented on a change in pull request #8066: [FLINK-12041][table-runtime-blink] Introduce ResettableExternalBuffer to blink batch

JingsongLi commented on a change in pull request #8066: [FLINK-12041][table-runtime-blink] Introduce ResettableExternalBuffer to blink batch URL: https://github.com/apache/flink/pull/8066#discussion_r269936538 ## File path:

[jira] [Commented] (FLINK-12025) Support FOR SYSTEM_TIME AS OF in temporal table

[ https://issues.apache.org/jira/browse/FLINK-12025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16803788#comment-16803788 ] Piotr Nowojski commented on FLINK-12025: Our current solution with table functions is a stop gap

[GitHub] [flink] tillrohrmann commented on issue #8061: [BP-1.8][FLINK-12021] Deploy execution in topological sorted order

tillrohrmann commented on issue #8061: [BP-1.8][FLINK-12021] Deploy execution in topological sorted order URL: https://github.com/apache/flink/pull/8061#issuecomment-477542077 Thanks for the review @zentol. Merging this PR.

[GitHub] [flink] tillrohrmann commented on issue #7935: [FLINK-11855] Fix race condition in EmbeddedLeaderService#GrantLeadershipCall

tillrohrmann commented on issue #7935: [FLINK-11855] Fix race condition in EmbeddedLeaderService#GrantLeadershipCall URL: https://github.com/apache/flink/pull/7935#issuecomment-477541789 Thanks for the review @zentol. Merging.

[GitHub] [flink] yanghua commented on issue #8055: [FLINK-12024] Bump universal Kafka connector to Kafka dependency to 2.2.0

yanghua commented on issue #8055: [FLINK-12024] Bump universal Kafka connector to Kafka dependency to 2.2.0 URL: https://github.com/apache/flink/pull/8055#issuecomment-477545456 @aljoscha OK, thanks for your reply. I will remark the kafka client version in the document.

[GitHub] [flink] becketqin commented on a change in pull request #7677: [FLINK-11249][kafka] Add migration tests for FlinkKafkaProdcuer and FlinkKafkaProducer011

becketqin commented on a change in pull request #7677: [FLINK-11249][kafka] Add migration tests for FlinkKafkaProdcuer and FlinkKafkaProducer011 URL: https://github.com/apache/flink/pull/7677#discussion_r269955444 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #8060: [FLINK-12021] Deploy execution in topological sorted order

flinkbot edited a comment on issue #8060: [FLINK-12021] Deploy execution in topological sorted order URL: https://github.com/apache/flink/pull/8060#issuecomment-477040675 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] [flink] flinkbot edited a comment on issue #7675: [FLINK-8297] [flink-rocksdb] A plan store elements of ListState as multiple key-values in rocksdb

flinkbot edited a comment on issue #7675: [FLINK-8297] [flink-rocksdb] A plan store elements of ListState as multiple key-values in rocksdb URL: https://github.com/apache/flink/pull/7675#issuecomment-462241019 Thanks a lot for your contribution to the Apache Flink project. I'm the

[GitHub] [flink] becketqin commented on a change in pull request #7677: [FLINK-11249][kafka] Add migration tests for FlinkKafkaProdcuer and FlinkKafkaProducer011

becketqin commented on a change in pull request #7677: [FLINK-11249][kafka] Add migration tests for FlinkKafkaProdcuer and FlinkKafkaProducer011 URL: https://github.com/apache/flink/pull/7677#discussion_r269900535 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #7677: [FLINK-11249][kafka] Add migration tests for FlinkKafkaProdcuer and FlinkKafkaProducer011

flinkbot edited a comment on issue #7677: [FLINK-11249][kafka] Add migration tests for FlinkKafkaProdcuer and FlinkKafkaProducer011 URL: https://github.com/apache/flink/pull/7677#issuecomment-462389051 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[GitHub] [flink] flinkbot edited a comment on issue #8057: [FLINK-12028][table] Add `addColumns`,`renameColumns`, `dropColumns` …

flinkbot edited a comment on issue #8057: [FLINK-12028][table] Add `addColumns`,`renameColumns`, `dropColumns` … URL: https://github.com/apache/flink/pull/8057#issuecomment-476975009 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[jira] [Updated] (FLINK-12051) TaskExecutorTest.testFilterOutDuplicateJobMasterRegistrations() failed locally.

[ https://issues.apache.org/jira/browse/FLINK-12051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-12051: --- Labels: test-stability (was: ) >

[jira] [Updated] (FLINK-11662) job restart when CheckpointCoordinator drop checkpointDirectory as a whole

[ https://issues.apache.org/jira/browse/FLINK-11662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11662: -- Priority: Critical (was: Major) > job restart when CheckpointCoordinator drop

[jira] [Assigned] (FLINK-11662) job restart when CheckpointCoordinator drop checkpointDirectory as a whole

[ https://issues.apache.org/jira/browse/FLINK-11662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-11662: - Assignee: (was: Till Rohrmann) > job restart when CheckpointCoordinator drop

[jira] [Assigned] (FLINK-11662) job restart when CheckpointCoordinator drop checkpointDirectory as a whole

[ https://issues.apache.org/jira/browse/FLINK-11662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-11662: - Assignee: Till Rohrmann > job restart when CheckpointCoordinator drop

[jira] [Updated] (FLINK-11662) job restart when CheckpointCoordinator drop checkpointDirectory as a whole

[ https://issues.apache.org/jira/browse/FLINK-11662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11662: -- Affects Version/s: 1.8.0 > job restart when CheckpointCoordinator drop checkpointDirectory as

[jira] [Created] (FLINK-12056) Remove legacy methods in LeaderRetrievalUtils

TisonKun created FLINK-12056: Summary: Remove legacy methods in LeaderRetrievalUtils Key: FLINK-12056 URL: https://issues.apache.org/jira/browse/FLINK-12056 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-12051) TaskExecutorTest.testFilterOutDuplicateJobMasterRegistrations() failed locally.

Kostas Kloudas created FLINK-12051: -- Summary: TaskExecutorTest.testFilterOutDuplicateJobMasterRegistrations() failed locally. Key: FLINK-12051 URL: https://issues.apache.org/jira/browse/FLINK-12051

[GitHub] [flink] flinkbot commented on issue #8069: [FLINK-12045] [core, State Backends] Support force migration between incompatible state schemas/serializers

flinkbot commented on issue #8069: [FLINK-12045] [core, State Backends] Support force migration between incompatible state schemas/serializers URL: https://github.com/apache/flink/pull/8069#issuecomment-477577484 Thanks a lot for your contribution to the Apache Flink project. I'm the

[GitHub] [flink] flinkbot edited a comment on issue #8070: [FLINK-12026][table]Remove the `xxxInternal` method from TableImpl

flinkbot edited a comment on issue #8070: [FLINK-12026][table]Remove the `xxxInternal` method from TableImpl URL: https://github.com/apache/flink/pull/8070#issuecomment-477582387 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Created] (FLINK-12052) Redistributed unevenly sized result partitions

ryantaocer created FLINK-12052: -- Summary: Redistributed unevenly sized result partitions Key: FLINK-12052 URL: https://issues.apache.org/jira/browse/FLINK-12052 Project: Flink Issue Type:

[jira] [Updated] (FLINK-12002) Adaptive Parallelism of Job Vertex Execution

[ https://issues.apache.org/jira/browse/FLINK-12002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ryantaocer updated FLINK-12002: --- Component/s: (was: Runtime / Operators) Runtime / Coordination > Adaptive

[GitHub] [flink] kl0u commented on issue #8071: [FLINK-12051][runtime][tests] Wait for TaskExecutor to be started

kl0u commented on issue #8071: [FLINK-12051][runtime][tests] Wait for TaskExecutor to be started URL: https://github.com/apache/flink/pull/8071#issuecomment-477586675 Thanks for working on this @zentol . From the number of calls to `taskExecutor.start()` in the class, I am

[GitHub] [flink] alkagin closed pull request #2149: [FLINK-4084] Add configDir parameter to CliFrontend and flink shell script

alkagin closed pull request #2149: [FLINK-4084] Add configDir parameter to CliFrontend and flink shell script URL: https://github.com/apache/flink/pull/2149 This is an automated message from the Apache Git Service. To

[jira] [Updated] (FLINK-4084) Add configDir parameter to CliFrontend and flink shell script

[ https://issues.apache.org/jira/browse/FLINK-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-4084: -- Labels: pull-request-available (was: ) > Add configDir parameter to CliFrontend and flink

[GitHub] [flink] TisonKun edited a comment on issue #8072: [FLINK-12055][client] Remove legacy class ActorSystemLoader

TisonKun edited a comment on issue #8072: [FLINK-12055][client] Remove legacy class ActorSystemLoader URL: https://github.com/apache/flink/pull/8072#issuecomment-477595990 For `pom.xml` part, it is related to [FLINK-12040](https://issues.apache.org/jira/browse/FLINK-12040). It's OK that

[GitHub] [flink] TisonKun commented on issue #8072: [FLINK-12055][client] Remove legacy class ActorSystemLoader

TisonKun commented on issue #8072: [FLINK-12055][client] Remove legacy class ActorSystemLoader URL: https://github.com/apache/flink/pull/8072#issuecomment-477595990 For `pom.xml` part, it is related [FLINK-12040](https://issues.apache.org/jira/browse/FLINK-12040). It's OK that we exclude

[jira] [Updated] (FLINK-12055) Remove legacy class ActorSystemLoader

[ https://issues.apache.org/jira/browse/FLINK-12055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12055: --- Labels: pull-request-available (was: ) > Remove legacy class ActorSystemLoader >

[jira] [Assigned] (FLINK-12054) HBaseConnectorITCase fails on Java 9

[ https://issues.apache.org/jira/browse/FLINK-12054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] leesf reassigned FLINK-12054: - Assignee: leesf > HBaseConnectorITCase fails on Java 9 > > >

[GitHub] [flink] zentol commented on a change in pull request #7927: [FLINK-11603][metrics] Port the MetricQueryService to the new RpcEndpoint

zentol commented on a change in pull request #7927: [FLINK-11603][metrics] Port the MetricQueryService to the new RpcEndpoint URL: https://github.com/apache/flink/pull/7927#discussion_r270026642 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #7927: [FLINK-11603][metrics] Port the MetricQueryService to the new RpcEndpoint

zentol commented on a change in pull request #7927: [FLINK-11603][metrics] Port the MetricQueryService to the new RpcEndpoint URL: https://github.com/apache/flink/pull/7927#discussion_r270019591 ## File path:

[GitHub] [flink] TisonKun opened a new pull request #8074: [FLINK-12056][coordinator] Remove legacy methods in LeaderRetrievalUtils

TisonKun opened a new pull request #8074: [FLINK-12056][coordinator] Remove legacy methods in LeaderRetrievalUtils URL: https://github.com/apache/flink/pull/8074 ## What is the purpose of the change Also some refactor. I insist 1. [FLINK-12056][coordination] Remove

[jira] [Updated] (FLINK-12056) Remove legacy methods in LeaderRetrievalUtils

[ https://issues.apache.org/jira/browse/FLINK-12056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12056: --- Labels: pull-request-available (was: ) > Remove legacy methods in LeaderRetrievalUtils >

[GitHub] [flink] zentol commented on a change in pull request #7807: [FLINK-11723][network] Remove KvState related components from Network…

zentol commented on a change in pull request #7807: [FLINK-11723][network] Remove KvState related components from Network… URL: https://github.com/apache/flink/pull/7807#discussion_r270034319 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #7807: [FLINK-11723][network] Remove KvState related components from Network…

zentol commented on a change in pull request #7807: [FLINK-11723][network] Remove KvState related components from Network… URL: https://github.com/apache/flink/pull/7807#discussion_r270039172 ## File path:

[GitHub] [flink] zentol commented on issue #7807: [FLINK-11723][network] Remove KvState related components from Network…

zentol commented on issue #7807: [FLINK-11723][network] Remove KvState related components from Network… URL: https://github.com/apache/flink/pull/7807#issuecomment-477628604 Please also rebase the PR. This is an automated

[GitHub] [flink] zentol commented on a change in pull request #7807: [FLINK-11723][network] Remove KvState related components from Network…

zentol commented on a change in pull request #7807: [FLINK-11723][network] Remove KvState related components from Network… URL: https://github.com/apache/flink/pull/7807#discussion_r270039681 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #7807: [FLINK-11723][network] Remove KvState related components from Network…

zentol commented on a change in pull request #7807: [FLINK-11723][network] Remove KvState related components from Network… URL: https://github.com/apache/flink/pull/7807#discussion_r270034585 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #8066: [FLINK-12041][table-runtime-blink] Introduce ResettableExternalBuffer to blink batch

JingsongLi commented on a change in pull request #8066: [FLINK-12041][table-runtime-blink] Introduce ResettableExternalBuffer to blink batch URL: https://github.com/apache/flink/pull/8066#discussion_r269940908 ## File path:

[jira] [Updated] (FLINK-12030) KafkaITCase.testMultipleSourcesOnePartition is unstable

[ https://issues.apache.org/jira/browse/FLINK-12030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-12030: - Description: This is a relevant part from the log: {code} 14:11:45,305 INFO

[jira] [Commented] (FLINK-11974) Introduce StreamOperatorSubstitutor to help table perform the whole Operator CodeGen

[ https://issues.apache.org/jira/browse/FLINK-11974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16803794#comment-16803794 ] Piotr Nowojski commented on FLINK-11974: Again, I haven't experimented with this, but shouldn't

[GitHub] [flink] zentol commented on a change in pull request #7780: [FLINK-11593][tests] Check & port TaskManagerTest to new code base

zentol commented on a change in pull request #7780: [FLINK-11593][tests] Check & port TaskManagerTest to new code base URL: https://github.com/apache/flink/pull/7780#discussion_r269962645 ## File path:

[jira] [Created] (FLINK-12055) Remove legacy class ActorSystemLoader

TisonKun created FLINK-12055: Summary: Remove legacy class ActorSystemLoader Key: FLINK-12055 URL: https://issues.apache.org/jira/browse/FLINK-12055 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-11662) Discarded checkpoint can cause Tasks to fail

[ https://issues.apache.org/jira/browse/FLINK-11662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11662: -- Description: Flink's {{CheckpointCoordinator}} discards an ongoing checkpoint as soon as it

[jira] [Created] (FLINK-12058) Cancel checkpoint operations belonging to a discarded/aborted checkpoint

Till Rohrmann created FLINK-12058: - Summary: Cancel checkpoint operations belonging to a discarded/aborted checkpoint Key: FLINK-12058 URL: https://issues.apache.org/jira/browse/FLINK-12058 Project:

[jira] [Closed] (FLINK-12055) Remove legacy ActorSystemLoader

[ https://issues.apache.org/jira/browse/FLINK-12055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-12055. Resolution: Fixed master: 048367b3a7c0ae5b57042934fb716d0ddb05db87 > Remove legacy

[jira] [Updated] (FLINK-12055) Remove legacy ActorSystemLoader

[ https://issues.apache.org/jira/browse/FLINK-12055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-12055: - Summary: Remove legacy ActorSystemLoader (was: Remove legacy class ActorSystemLoader)

[GitHub] [flink] zentol merged pull request #8072: [FLINK-12055][client] Remove legacy class ActorSystemLoader

zentol merged pull request #8072: [FLINK-12055][client] Remove legacy class ActorSystemLoader URL: https://github.com/apache/flink/pull/8072 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] KurtYoung commented on a change in pull request #8066: [FLINK-12041][table-runtime-blink] Introduce ResettableExternalBuffer to blink batch

KurtYoung commented on a change in pull request #8066: [FLINK-12041][table-runtime-blink] Introduce ResettableExternalBuffer to blink batch URL: https://github.com/apache/flink/pull/8066#discussion_r269939471 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #8047: [FLINK-12001][tests] fix the external jar path config error for AvroE…

flinkbot edited a comment on issue #8047: [FLINK-12001][tests] fix the external jar path config error for AvroE… URL: https://github.com/apache/flink/pull/8047#issuecomment-476175407 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] flinkbot edited a comment on issue #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

flinkbot edited a comment on issue #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#issuecomment-474185108 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] zentol commented on a change in pull request #7780: [FLINK-11593][tests] Check & port TaskManagerTest to new code base

zentol commented on a change in pull request #7780: [FLINK-11593][tests] Check & port TaskManagerTest to new code base URL: https://github.com/apache/flink/pull/7780#discussion_r269962993 ## File path:

[jira] [Assigned] (FLINK-12051) TaskExecutorTest.testFilterOutDuplicateJobMasterRegistrations() failed locally.

[ https://issues.apache.org/jira/browse/FLINK-12051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-12051: Assignee: Chesnay Schepler >

[GitHub] [flink] sunjincheng121 commented on issue #8070: [FLINK-12026][table]Remove the `xxxInternal` method from TableImpl

sunjincheng121 commented on issue #8070: [FLINK-12026][table]Remove the `xxxInternal` method from TableImpl URL: https://github.com/apache/flink/pull/8070#issuecomment-477582655 @flinkbot attention @dawidwys @hequn8128 This

[GitHub] [flink] TisonKun opened a new pull request #8072: [FLINK-12055][client] Remove legacy class ActorSystemLoader

TisonKun opened a new pull request #8072: [FLINK-12055][client] Remove legacy class ActorSystemLoader URL: https://github.com/apache/flink/pull/8072 ## What is the purpose of the change ## Brief change log Remove legacy class `ActorSystemLoader` Also its implementation

[GitHub] [flink] flinkbot commented on issue #8072: [FLINK-12055][client] Remove legacy class ActorSystemLoader

flinkbot commented on issue #8072: [FLINK-12055][client] Remove legacy class ActorSystemLoader URL: https://github.com/apache/flink/pull/8072#issuecomment-477595682 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[jira] [Commented] (FLINK-12025) Support FOR SYSTEM_TIME AS OF in temporal table

[ https://issues.apache.org/jira/browse/FLINK-12025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16803963#comment-16803963 ] Jark Wu commented on FLINK-12025: - Temporal table join is a big topic and should be discussed detailed

[GitHub] [flink] flinkbot commented on issue #8074: [FLINK-12056][coordinator] Remove legacy methods in LeaderRetrievalUtils

flinkbot commented on issue #8074: [FLINK-12056][coordinator] Remove legacy methods in LeaderRetrievalUtils URL: https://github.com/apache/flink/pull/8074#issuecomment-477622379 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] tillrohrmann commented on issue #8060: [FLINK-12021] Deploy execution in topological sorted order

tillrohrmann commented on issue #8060: [FLINK-12021] Deploy execution in topological sorted order URL: https://github.com/apache/flink/pull/8060#issuecomment-477541950 Thanks for the review @zentol and @shuai-xu. Merging this PR.

[GitHub] [flink] tillrohrmann commented on issue #8065: [BP-1.7][FLINK-12021] Deploy execution in topological sorted order

tillrohrmann commented on issue #8065: [BP-1.7][FLINK-12021] Deploy execution in topological sorted order URL: https://github.com/apache/flink/pull/8065#issuecomment-477542199 Thanks for the review @zentol. Merging this PR.

[GitHub] [flink] zentol commented on a change in pull request #8063: [hotfix] Remove unused construction and IOMode from NetworkEnvironmentConfiguration

zentol commented on a change in pull request #8063: [hotfix] Remove unused construction and IOMode from NetworkEnvironmentConfiguration URL: https://github.com/apache/flink/pull/8063#discussion_r269965741 ## File path:

[jira] [Closed] (FLINK-11146) Get rid of legacy codes from ClusterClient

[ https://issues.apache.org/jira/browse/FLINK-11146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-11146. Resolution: Fixed Fix Version/s: 1.9.0 master:

[GitHub] [flink] azagrebin commented on a change in pull request #8063: [hotfix] Remove unused construction and IOMode from NetworkEnvironmentConfiguration

azagrebin commented on a change in pull request #8063: [hotfix] Remove unused construction and IOMode from NetworkEnvironmentConfiguration URL: https://github.com/apache/flink/pull/8063#discussion_r269973269 ## File path:

[GitHub] [flink] sunjincheng121 commented on issue #8057: [FLINK-12028][table] Add `addColumns`,`renameColumns`, `dropColumns` …

sunjincheng121 commented on issue #8057: [FLINK-12028][table] Add `addColumns`,`renameColumns`, `dropColumns` … URL: https://github.com/apache/flink/pull/8057#issuecomment-477573514 Thanks for the reminder to rebase the code. @yanghua Thanks for pay attention to this PR @dawidwys I

[GitHub] [flink] zentol merged pull request #8043: [FLINK-11996] Remove the warning about case class maximum of 22 fields in the documentation

zentol merged pull request #8043: [FLINK-11996] Remove the warning about case class maximum of 22 fields in the documentation URL: https://github.com/apache/flink/pull/8043 This is an automated message from the Apache Git

[jira] [Assigned] (FLINK-12049) ClassLoaderUtilsTest fails on Java 9

[ https://issues.apache.org/jira/browse/FLINK-12049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] leesf reassigned FLINK-12049: - Assignee: leesf > ClassLoaderUtilsTest fails on Java 9 > > >

[jira] [Commented] (FLINK-11662) Discarded checkpoint can cause Tasks to fail

[ https://issues.apache.org/jira/browse/FLINK-11662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16803969#comment-16803969 ] Aljoscha Krettek commented on FLINK-11662: -- This also affects 1.5.x and 1.6.x, but those

[jira] [Created] (FLINK-12057) Refactor MemoryLogger to accept termination future instead of ActorSystem

Chesnay Schepler created FLINK-12057: Summary: Refactor MemoryLogger to accept termination future instead of ActorSystem Key: FLINK-12057 URL: https://issues.apache.org/jira/browse/FLINK-12057

[GitHub] [flink] yanghua commented on a change in pull request #8055: [FLINK-12024] Bump universal Kafka connector to Kafka dependency to 2.2.0

yanghua commented on a change in pull request #8055: [FLINK-12024] Bump universal Kafka connector to Kafka dependency to 2.2.0 URL: https://github.com/apache/flink/pull/8055#discussion_r270024466 ## File path: docs/dev/connectors/kafka.md ## @@ -88,7 +88,7 @@ For most

[jira] [Updated] (FLINK-12057) Refactor MemoryLogger to accept termination future instead of ActorSystem

[ https://issues.apache.org/jira/browse/FLINK-12057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12057: --- Labels: pull-request-available (was: ) > Refactor MemoryLogger to accept termination

[GitHub] [flink] yanghua commented on a change in pull request #8055: [FLINK-12024] Bump universal Kafka connector to Kafka dependency to 2.2.0

yanghua commented on a change in pull request #8055: [FLINK-12024] Bump universal Kafka connector to Kafka dependency to 2.2.0 URL: https://github.com/apache/flink/pull/8055#discussion_r269953483 ## File path: docs/dev/connectors/kafka.md ## @@ -85,7 +85,7 @@ For most

[jira] [Created] (FLINK-12053) Calculation of parallelism based on metrics/signals

ryantaocer created FLINK-12053: -- Summary: Calculation of parallelism based on metrics/signals Key: FLINK-12053 URL: https://issues.apache.org/jira/browse/FLINK-12053 Project: Flink Issue Type:

[GitHub] [flink] zentol edited a comment on issue #8071: [FLINK-12051][runtime][tests] Wait for TaskExecutor to be started

zentol edited a comment on issue #8071: [FLINK-12051][runtime][tests] Wait for TaskExecutor to be started URL: https://github.com/apache/flink/pull/8071#issuecomment-477590382 All other tests either are already waiting for the TM to start fully, or are relying on futures/timeouts

[GitHub] [flink] eliaslevy commented on issue #8055: [FLINK-12024] Bump universal Kafka connector to Kafka dependency to 2.2.0

eliaslevy commented on issue #8055: [FLINK-12024] Bump universal Kafka connector to Kafka dependency to 2.2.0 URL: https://github.com/apache/flink/pull/8055#issuecomment-477608097 That's no good, because the Kafka client is also forward compatible, except for be features. An that is

[jira] [Updated] (FLINK-11662) Discarded checkpoint can cause Tasks to fail

[ https://issues.apache.org/jira/browse/FLINK-11662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-11662: -- Attachment: taskmanager.log > Discarded checkpoint can cause Tasks to fail >

[GitHub] [flink] zentol commented on issue #8072: [FLINK-12055][client] Remove legacy class ActorSystemLoader

zentol commented on issue #8072: [FLINK-12055][client] Remove legacy class ActorSystemLoader URL: https://github.com/apache/flink/pull/8072#issuecomment-477618668 The pom change is technically not related the removal of the actor system loader, let's defer this to FLINK-12040.

[jira] [Commented] (FLINK-12040) Remove unused akka dependencies in pom.xml

[ https://issues.apache.org/jira/browse/FLINK-12040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16803986#comment-16803986 ] Chesnay Schepler commented on FLINK-12040: -- So long as this is about removing unused

[jira] [Commented] (FLINK-12046) Increase records per invocation for serializerAvro benchmark to stabilize it

[ https://issues.apache.org/jira/browse/FLINK-12046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16803725#comment-16803725 ] Yu Li commented on FLINK-12046: --- [~pnowojski] [~tzulitai] FYI. > Increase records per invocation for

[GitHub] [flink] KurtYoung commented on a change in pull request #8066: [FLINK-12041][table-runtime-blink] Introduce ResettableExternalBuffer to blink batch

KurtYoung commented on a change in pull request #8066: [FLINK-12041][table-runtime-blink] Introduce ResettableExternalBuffer to blink batch URL: https://github.com/apache/flink/pull/8066#discussion_r269910765 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #8066: [FLINK-12041][table-runtime-blink] Introduce ResettableExternalBuffer to blink batch

KurtYoung commented on a change in pull request #8066: [FLINK-12041][table-runtime-blink] Introduce ResettableExternalBuffer to blink batch URL: https://github.com/apache/flink/pull/8066#discussion_r269911663 ## File path:

[jira] [Created] (FLINK-12047) Savepoint connector to read / write / process savepoints

Tzu-Li (Gordon) Tai created FLINK-12047: --- Summary: Savepoint connector to read / write / process savepoints Key: FLINK-12047 URL: https://issues.apache.org/jira/browse/FLINK-12047 Project: Flink

[GitHub] [flink] KurtYoung commented on a change in pull request #8066: [FLINK-12041][table-runtime-blink] Introduce ResettableExternalBuffer to blink batch

KurtYoung commented on a change in pull request #8066: [FLINK-12041][table-runtime-blink] Introduce ResettableExternalBuffer to blink batch URL: https://github.com/apache/flink/pull/8066#discussion_r269913295 ## File path:

[jira] [Updated] (FLINK-12047) Savepoint connector to read / write / process savepoints

[ https://issues.apache.org/jira/browse/FLINK-12047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-12047: Description: This JIRA tracks the ongoing efforts and discussions about a means

[jira] [Commented] (FLINK-12047) Savepoint connector to read / write / process savepoints

[ https://issues.apache.org/jira/browse/FLINK-12047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16803736#comment-16803736 ] Tzu-Li (Gordon) Tai commented on FLINK-12047: - Not entirely sure what components this should

[GitHub] [flink] KurtYoung commented on a change in pull request #8066: [FLINK-12041][table-runtime-blink] Introduce ResettableExternalBuffer to blink batch

KurtYoung commented on a change in pull request #8066: [FLINK-12041][table-runtime-blink] Introduce ResettableExternalBuffer to blink batch URL: https://github.com/apache/flink/pull/8066#discussion_r269912133 ## File path:

[jira] [Commented] (FLINK-12025) Support FOR SYSTEM_TIME AS OF in temporal table

[ https://issues.apache.org/jira/browse/FLINK-12025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16803740#comment-16803740 ] Timo Walther commented on FLINK-12025: -- Yes, we were also considering this clause in early design

[jira] [Updated] (FLINK-12025) Support FOR SYSTEM_TIME AS OF in temporal table

[ https://issues.apache.org/jira/browse/FLINK-12025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-12025: - Issue Type: New Feature (was: Sub-task) Parent: (was: FLINK-11921) > Support FOR

[GitHub] [flink] hequn8128 commented on issue #8057: [FLINK-12028][table] Add `addColumns`,`renameColumns`, `dropColumns` …

hequn8128 commented on issue #8057: [FLINK-12028][table] Add `addColumns`,`renameColumns`, `dropColumns` … URL: https://github.com/apache/flink/pull/8057#issuecomment-477516546 @flinkbot approve all This is an automated

[GitHub] [flink] yanghua commented on issue #8057: [FLINK-12028][table] Add `addColumns`,`renameColumns`, `dropColumns` …

yanghua commented on issue #8057: [FLINK-12028][table] Add `addColumns`,`renameColumns`, `dropColumns` … URL: https://github.com/apache/flink/pull/8057#issuecomment-477517884 @sunjincheng121 There are some conflicts need to be resolved.

[GitHub] [flink] KurtYoung commented on issue #8051: [FLINK-12018] [table-planner-blink] Add support for generating optimized logical plan for Sort and Rank

KurtYoung commented on issue #8051: [FLINK-12018] [table-planner-blink] Add support for generating optimized logical plan for Sort and Rank URL: https://github.com/apache/flink/pull/8051#issuecomment-477519258 I'm a bit confused once i discovered `Sort`, `Limit` and `Rank` can somehow

[GitHub] [flink] KurtYoung commented on issue #8051: [FLINK-12018] [table-planner-blink] Add support for generating optimized logical plan for Sort and Rank

KurtYoung commented on issue #8051: [FLINK-12018] [table-planner-blink] Add support for generating optimized logical plan for Sort and Rank URL: https://github.com/apache/flink/pull/8051#issuecomment-477518996 BTW, could you add some more comments or examples to `Rank` related classes to

[GitHub] [flink] JingsongLi commented on a change in pull request #8066: [FLINK-12041][table-runtime-blink] Introduce ResettableExternalBuffer to blink batch

JingsongLi commented on a change in pull request #8066: [FLINK-12041][table-runtime-blink] Introduce ResettableExternalBuffer to blink batch URL: https://github.com/apache/flink/pull/8066#discussion_r269918940 ## File path:

  1   2   3   >