[GitHub] [flink] flinkbot edited a comment on issue #11704: [FLINK-17088] [runtime][web] Search TaskManager log content based on keywords function

flinkbot edited a comment on issue #11704: [FLINK-17088] [runtime][web] Search TaskManager log content based on keywords function URL: https://github.com/apache/flink/pull/11704#issuecomment-612221335 ## CI report: * d0618cceade6291fd73c7550fc32231803343d74 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11704: [FLINK-17088] [runtime][web] Search TaskManager log content based on keywords function

flinkbot edited a comment on issue #11704: [FLINK-17088] [runtime][web] Search TaskManager log content based on keywords function URL: https://github.com/apache/flink/pull/11704#issuecomment-612221335 ## CI report: * 733d9ef3444144358896e4a51a92bb677501a532 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11466: [FLINK-15400][connectors / elasticsearch] elasticsearch table sink support dynamic index.

flinkbot edited a comment on issue #11466: [FLINK-15400][connectors / elasticsearch] elasticsearch table sink support dynamic index. URL: https://github.com/apache/flink/pull/11466#issuecomment-601789375 ## CI report: * 4c252220928052025f30b4dc4c63c0479d7c20cd UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11704: [FLINK-17088] [runtime][web] Search TaskManager log content based on keywords function

flinkbot edited a comment on issue #11704: [FLINK-17088] [runtime][web] Search TaskManager log content based on keywords function URL: https://github.com/apache/flink/pull/11704#issuecomment-612221335 ## CI report: * 733d9ef3444144358896e4a51a92bb677501a532 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11466: [FLINK-15400][connectors / elasticsearch] elasticsearch table sink support dynamic index.

flinkbot edited a comment on issue #11466: [FLINK-15400][connectors / elasticsearch] elasticsearch table sink support dynamic index. URL: https://github.com/apache/flink/pull/11466#issuecomment-601789375 ## CI report: * 4c252220928052025f30b4dc4c63c0479d7c20cd UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11466: [FLINK-15400][connectors / elasticsearch] elasticsearch table sink support dynamic index.

flinkbot edited a comment on issue #11466: [FLINK-15400][connectors / elasticsearch] elasticsearch table sink support dynamic index. URL: https://github.com/apache/flink/pull/11466#issuecomment-601789375 ## CI report: * 4c252220928052025f30b4dc4c63c0479d7c20cd UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11671: [FLINK-17052] [client] Introduce PlanGenerator

flinkbot edited a comment on issue #11671: [FLINK-17052] [client] Introduce PlanGenerator URL: https://github.com/apache/flink/pull/11671#issuecomment-610971753 ## CI report: * b7adab126357d7fb74426dcb9b5fb0b765d8eead Travis:

[jira] [Comment Edited] (FLINK-17092) Pyflink failure for BlinkStreamDependencyTests and StreamPandasUDFITTests

[ https://issues.apache.org/jira/browse/FLINK-17092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17081616#comment-17081616 ] Dian Fu edited comment on FLINK-17092 at 4/12/20, 2:07 AM: --- Update: there are

[jira] [Assigned] (FLINK-17092) Pyflink failure for BlinkStreamDependencyTests and StreamPandasUDFITTests

[ https://issues.apache.org/jira/browse/FLINK-17092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17092: --- Assignee: Wei Zhong > Pyflink failure for BlinkStreamDependencyTests and StreamPandasUDFITTests >

[GitHub] [flink] wuchong commented on issue #11482: [FLINK-16581][table] Minibatch deduplication lack state TTL bug fix

wuchong commented on issue #11482: [FLINK-16581][table] Minibatch deduplication lack state TTL bug fix URL: https://github.com/apache/flink/pull/11482#issuecomment-612550644 Hi @lsyldliu , thanks for the waiting. @Myasuka helped to support state ttl time provider for

[jira] [Commented] (FLINK-17092) Pyflink failure for BlinkStreamDependencyTests and StreamPandasUDFITTests

[ https://issues.apache.org/jira/browse/FLINK-17092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17081617#comment-17081617 ] Dian Fu commented on FLINK-17092: - cc [~zhongwei]  > Pyflink failure for BlinkStreamDependencyTests and

[jira] [Resolved] (FLINK-16949) Enhance AbstractStreamOperatorTestHarness to use customized TtlTimeProvider

[ https://issues.apache.org/jira/browse/FLINK-16949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-16949. - Resolution: Fixed Fixed in master(1.11.0): afb46450a609f44282791f784f980f2b13f53709 > Enhance

[jira] [Commented] (FLINK-17092) Pyflink failure for BlinkStreamDependencyTests and StreamPandasUDFITTests

[ https://issues.apache.org/jira/browse/FLINK-17092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17081616#comment-17081616 ] Dian Fu commented on FLINK-17092: - Update: there are two test failures: BlinkStreamDependencyTests and 

[GitHub] [flink] wuchong merged pull request #11624: [FLINK-16949] Enhance AbstractStreamOperatorTestHarness to use customized TtlTimeProvider

wuchong merged pull request #11624: [FLINK-16949] Enhance AbstractStreamOperatorTestHarness to use customized TtlTimeProvider URL: https://github.com/apache/flink/pull/11624 This is an automated message from the Apache Git

[GitHub] [flink] wuchong commented on issue #11624: [FLINK-16949] Enhance AbstractStreamOperatorTestHarness to use customized TtlTimeProvider

wuchong commented on issue #11624: [FLINK-16949] Enhance AbstractStreamOperatorTestHarness to use customized TtlTimeProvider URL: https://github.com/apache/flink/pull/11624#issuecomment-612550372 Merging... This is an

[GitHub] [flink] flinkbot edited a comment on issue #11671: [FLINK-17052] [client] Introduce PlanGenerator

flinkbot edited a comment on issue #11671: [FLINK-17052] [client] Introduce PlanGenerator URL: https://github.com/apache/flink/pull/11671#issuecomment-610971753 ## CI report: * bc01102e1595476cea82051bb992acb9427da257 Azure:

[GitHub] [flink] godfreyhe commented on issue #11671: [FLINK-17052] [client] Introduce PlanGenerator

godfreyhe commented on issue #11671: [FLINK-17052] [client] Introduce PlanGenerator URL: https://github.com/apache/flink/pull/11671#issuecomment-612549149 @flinkbot run travis This is an automated message from the Apache Git

[jira] [Commented] (FLINK-17092) Pyflink failure for BlinkStreamDependencyTests and StreamPandasUDFITTests

[ https://issues.apache.org/jira/browse/FLINK-17092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17081602#comment-17081602 ] Dian Fu commented on FLINK-17092: - Thanks [~zjwang] for reporting this issue. Will take a look! >

[GitHub] [flink] flinkbot edited a comment on issue #11671: [FLINK-17052] [client] Introduce PlanGenerator

flinkbot edited a comment on issue #11671: [FLINK-17052] [client] Introduce PlanGenerator URL: https://github.com/apache/flink/pull/11671#issuecomment-610971753 ## CI report: * bc01102e1595476cea82051bb992acb9427da257 Azure:

[GitHub] [flink] rmetzger closed pull request #11678: [hotfix] [docs] Fix english typo in stream file sinks rolling policy section

rmetzger closed pull request #11678: [hotfix] [docs] Fix english typo in stream file sinks rolling policy section URL: https://github.com/apache/flink/pull/11678 This is an automated message from the Apache Git Service. To

[GitHub] [flink] rmetzger commented on issue #11678: [hotfix] [docs] Fix english typo in stream file sinks rolling policy section

rmetzger commented on issue #11678: [hotfix] [docs] Fix english typo in stream file sinks rolling policy section URL: https://github.com/apache/flink/pull/11678#issuecomment-612471406 Thanks a lot! Merging This is an

[jira] [Created] (FLINK-17092) Pyflink failure for BlinkStreamDependencyTests and StreamPandasUDFITTests

Zhijiang created FLINK-17092: Summary: Pyflink failure for BlinkStreamDependencyTests and StreamPandasUDFITTests Key: FLINK-17092 URL: https://issues.apache.org/jira/browse/FLINK-17092 Project: Flink

[jira] [Commented] (FLINK-3344) EventTimeWindowCheckpointingITCase.testPreAggregatedTumblingTimeWindow

[ https://issues.apache.org/jira/browse/FLINK-3344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17081373#comment-17081373 ] Robert Metzger commented on FLINK-3344: --- This issue is probably caused by the broken checkpointing

[jira] [Comment Edited] (FLINK-3344) EventTimeWindowCheckpointingITCase.testPreAggregatedTumblingTimeWindow

[ https://issues.apache.org/jira/browse/FLINK-3344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17081372#comment-17081372 ] Robert Metzger edited comment on FLINK-3344 at 4/11/20, 4:47 PM: -

[jira] [Updated] (FLINK-3344) EventTimeWindowCheckpointingITCase.testPreAggregatedTumblingTimeWindow

[ https://issues.apache.org/jira/browse/FLINK-3344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3344: -- Component/s: API / DataStream >

[jira] [Reopened] (FLINK-3344) EventTimeWindowCheckpointingITCase.testPreAggregatedTumblingTimeWindow

[ https://issues.apache.org/jira/browse/FLINK-3344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reopened FLINK-3344: --- Assignee: (was: Aljoscha Krettek) Reopening as this happened again:

[jira] [Commented] (FLINK-16947) ArtifactResolutionException: Could not transfer artifact. Entry [...] has not been leased from this pool

[ https://issues.apache.org/jira/browse/FLINK-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17081371#comment-17081371 ] Robert Metzger commented on FLINK-16947:

[GitHub] [flink] flinkbot edited a comment on issue #11693: [FLINK-17072] Let Dispatcher and ResourceManager use random endpoint id

flinkbot edited a comment on issue #11693: [FLINK-17072] Let Dispatcher and ResourceManager use random endpoint id URL: https://github.com/apache/flink/pull/11693#issuecomment-611558373 ## CI report: * cf3f552de7cc9da0fee9405f80b5f4fb7f0a509a UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11671: [FLINK-17052] [client] Introduce PlanGenerator

flinkbot edited a comment on issue #11671: [FLINK-17052] [client] Introduce PlanGenerator URL: https://github.com/apache/flink/pull/11671#issuecomment-610971753 ## CI report: * b7adab126357d7fb74426dcb9b5fb0b765d8eead Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11683: [FLINK-15347] Add SupervisorActor which monitors the proper termination of AkkaRpcActors

flinkbot edited a comment on issue #11683: [FLINK-15347] Add SupervisorActor which monitors the proper termination of AkkaRpcActors URL: https://github.com/apache/flink/pull/11683#issuecomment-611422123 ## CI report: * fade42d50aa4a6937b44e1b42919220eb5ec431b UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11671: [FLINK-17052] [client] Introduce PlanGenerator

flinkbot edited a comment on issue #11671: [FLINK-17052] [client] Introduce PlanGenerator URL: https://github.com/apache/flink/pull/11671#issuecomment-610971753 ## CI report: * b7adab126357d7fb74426dcb9b5fb0b765d8eead 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] [Assigned] (FLINK-16822) The config set by SET command does not work

[ https://issues.apache.org/jira/browse/FLINK-16822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-16822: Assignee: godfrey he > The config set by SET command does not work >

[GitHub] [flink] flinkbot edited a comment on issue #11706: [FLINK-17079][CsvTableSinkFactoryBase] add numFiles and writeMode config by user's config in CsvTableSinkFactoryBase when create CsvTableSin

flinkbot edited a comment on issue #11706: [FLINK-17079][CsvTableSinkFactoryBase] add numFiles and writeMode config by user's config in CsvTableSinkFactoryBase when create CsvTableSink URL: https://github.com/apache/flink/pull/11706#issuecomment-612330052 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #11706: [FLINK-17079][CsvTableSinkFactoryBase] add numFiles and writeMode config by user's config in CsvTableSinkFactoryBase when create CsvTableSin

flinkbot edited a comment on issue #11706: [FLINK-17079][CsvTableSinkFactoryBase] add numFiles and writeMode config by user's config in CsvTableSinkFactoryBase when create CsvTableSink URL: https://github.com/apache/flink/pull/11706#issuecomment-612330052 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #11693: [FLINK-17072] Let Dispatcher and ResourceManager use random endpoint id

flinkbot edited a comment on issue #11693: [FLINK-17072] Let Dispatcher and ResourceManager use random endpoint id URL: https://github.com/apache/flink/pull/11693#issuecomment-611558373 ## CI report: * ee0a9c0b89d0fc20db71d3cb787a31923a3ddd87 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11683: [FLINK-15347] Add SupervisorActor which monitors the proper termination of AkkaRpcActors

flinkbot edited a comment on issue #11683: [FLINK-15347] Add SupervisorActor which monitors the proper termination of AkkaRpcActors URL: https://github.com/apache/flink/pull/11683#issuecomment-611422123 ## CI report: * 7d5dce14073ede4ca9ff0cebd4c92acd70c5ef61 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11693: [FLINK-17072] Let Dispatcher and ResourceManager use random endpoint id

flinkbot edited a comment on issue #11693: [FLINK-17072] Let Dispatcher and ResourceManager use random endpoint id URL: https://github.com/apache/flink/pull/11693#issuecomment-611558373 ## CI report: * ee0a9c0b89d0fc20db71d3cb787a31923a3ddd87 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11683: [FLINK-15347] Add SupervisorActor which monitors the proper termination of AkkaRpcActors

flinkbot edited a comment on issue #11683: [FLINK-15347] Add SupervisorActor which monitors the proper termination of AkkaRpcActors URL: https://github.com/apache/flink/pull/11683#issuecomment-611422123 ## CI report: * 7d5dce14073ede4ca9ff0cebd4c92acd70c5ef61 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] 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] zenfenan commented on issue #11474: FLINK-10114: Add ORC BulkWriter support for StreamingFileSink

zenfenan commented on issue #11474: FLINK-10114: Add ORC BulkWriter support for StreamingFileSink URL: https://github.com/apache/flink/pull/11474#issuecomment-612393911 @kl0u On the Vectorizer improvement, I believe we cannot have the addUserMetadata() in Vectorizer class because it needs

[GitHub] [flink] flinkbot edited a comment on issue #11701: [FLINK-17084][table] Implement input type inference and output type strategy for ARRAY/ROW/MAP built-in functions

flinkbot edited a comment on issue #11701: [FLINK-17084][table] Implement input type inference and output type strategy for ARRAY/ROW/MAP built-in functions URL: https://github.com/apache/flink/pull/11701#issuecomment-612012096 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #11701: [FLINK-17084][table] Implement input type inference and output type strategy for ARRAY/ROW/MAP built-in functions

flinkbot edited a comment on issue #11701: [FLINK-17084][table] Implement input type inference and output type strategy for ARRAY/ROW/MAP built-in functions URL: https://github.com/apache/flink/pull/11701#issuecomment-612012096 ## CI report: *

[jira] [Commented] (FLINK-12692) Support disk spilling in HeapKeyedStateBackend

[ https://issues.apache.org/jira/browse/FLINK-12692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17081207#comment-17081207 ] Yu Li commented on FLINK-12692: --- Thanks for the interest [~aldu29], we're now testing it and will upload

[GitHub] [flink] flinkbot edited a comment on issue #11705: [FLINK-16600][k8s] Fix not respecting the RestOptions.BIND_PORT for the Kubernetes setup

flinkbot edited a comment on issue #11705: [FLINK-16600][k8s] Fix not respecting the RestOptions.BIND_PORT for the Kubernetes setup URL: https://github.com/apache/flink/pull/11705#issuecomment-612309107 ## CI report: * 005f7518a1843d28e9a6fb0c9c0cf3360738f4e8 Travis:

[GitHub] [flink] KurtYoung merged pull request #11703: [hotfix] [docs] Fix typo in concepts.

KurtYoung merged pull request #11703: [hotfix] [docs] Fix typo in concepts. URL: https://github.com/apache/flink/pull/11703 This is an automated message from the Apache Git Service. To respond to the message, please log on

[jira] [Updated] (FLINK-15648) Support to configure limit for CPU requirement

[ https://issues.apache.org/jira/browse/FLINK-15648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-15648: - Summary: Support to configure limit for CPU requirement (was: Support to configure request or

[GitHub] [flink] flinkbot edited a comment on issue #11700: [FLINK-16366] [table] Introduce executeSql method in TableEnvironment and support many statements

flinkbot edited a comment on issue #11700: [FLINK-16366] [table] Introduce executeSql method in TableEnvironment and support many statements URL: https://github.com/apache/flink/pull/11700#issuecomment-612000686 ## CI report: * f52f4a10b99fa573ffeb63f16491d735cc157a4b UNKNOWN