[jira] [Commented] (FLINK-17091) AvroRowSerializationSchema doesn't support new Timestamp conversion classes

[ https://issues.apache.org/jira/browse/FLINK-17091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17081165#comment-17081165 ] Paul Lin commented on FLINK-17091: -- Working on the fix. Please assign the issue to me. >

[jira] [Created] (FLINK-17091) AvroRowSerializationSchema doesn't support new Timestamp conversion classes

Paul Lin created FLINK-17091: Summary: AvroRowSerializationSchema doesn't support new Timestamp conversion classes Key: FLINK-17091 URL: https://issues.apache.org/jira/browse/FLINK-17091 Project: Flink

[jira] [Created] (FLINK-17090) Harden preckeck for the KubernetesConfigOptions.JOB_MANAGER_CPU

Canbin Zheng created FLINK-17090: Summary: Harden preckeck for the KubernetesConfigOptions.JOB_MANAGER_CPU Key: FLINK-17090 URL: https://issues.apache.org/jira/browse/FLINK-17090 Project: Flink

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

flinkbot commented 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 commented on issue #11706: [FLINK-17079][CsvTableSinkFactoryBase] add numFiles and writeMode config by user's config in CsvTableSinkFactoryBase when create CsvTableSink

flinkbot commented 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-612327596 Thanks a lot for your contribution to

[GitHub] [flink] ThunderSuuuuu opened a new pull request #11706: [FLINK-17079][CsvTableSinkFactoryBase] add numFiles and writeMode config by user's config in CsvTableSinkFactoryBase when create CsvTab

ThunderSu opened a new pull request #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 …fig by user's config ## What is the

[jira] [Updated] (FLINK-17079) CsvTableSinkFactoryBase add numFiles and writeMode config when createTableSink

[ https://issues.apache.org/jira/browse/FLINK-17079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17079: --- Labels: pull-request-available (was: ) > CsvTableSinkFactoryBase add numFiles and

[GitHub] [flink] wuchong commented on issue #11704: [FLINK-17088] [runtime][web] Search TaskManager log content based on keywords function

wuchong commented on issue #11704: [FLINK-17088] [runtime][web] Search TaskManager log content based on keywords function URL: https://github.com/apache/flink/pull/11704#issuecomment-612314773 Hi @jinglining @GJL , could you help to review this PR? I'm not very familiar with this part.

[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:

[jira] [Commented] (FLINK-15347) ZooKeeperDefaultDispatcherRunnerTest.testResourceCleanupUnderLeadershipChange failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-15347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17081115#comment-17081115 ] Dian Fu commented on FLINK-15347: - Another instance: 

[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

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

flinkbot commented 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 UNKNOWN Bot

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

flinkbot commented 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-612306706 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[jira] [Updated] (FLINK-16600) Respect the rest.bind-port for the Kubernetes setup

[ https://issues.apache.org/jira/browse/FLINK-16600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16600: --- Labels: pull-request-available (was: ) > Respect the rest.bind-port for the Kubernetes

[GitHub] [flink] zhengcanbin opened a new pull request #11705: [FLINK-16600][k8s] Fix not respecting the RestOptions.BIND_PORT for the Kubernetes setup

zhengcanbin opened a new pull request #11705: [FLINK-16600][k8s] Fix not respecting the RestOptions.BIND_PORT for the Kubernetes setup URL: https://github.com/apache/flink/pull/11705 ## What is the purpose of the change Our current logic only takes care of RestOptions.PORT but not

[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

[jira] [Closed] (FLINK-16761) Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-16761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16761. --- Resolution: Resolved > Return JobExecutionResult for Python ExecutionEnvironment and

[jira] [Updated] (FLINK-16761) Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-16761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-16761: Issue Type: Improvement (was: Bug) > Return JobExecutionResult for Python ExecutionEnvironment

[jira] [Updated] (FLINK-16761) Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-16761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-16761: Fix Version/s: (was: 1.10.1) (was: 1.9.3) > Return JobExecutionResult

[jira] [Commented] (FLINK-16761) Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-16761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17081106#comment-17081106 ] Hequn Cheng commented on FLINK-16761: - Resolved in 1.11.0 via

[GitHub] [flink] hequn8128 merged pull request #11670: [FLINK-16761][python]Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment

hequn8128 merged pull request #11670: [FLINK-16761][python]Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment URL: https://github.com/apache/flink/pull/11670 This is an automated message from the

[GitHub] [flink] hequn8128 commented on issue #11670: [FLINK-16761][python]Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment

hequn8128 commented on issue #11670: [FLINK-16761][python]Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment URL: https://github.com/apache/flink/pull/11670#issuecomment-612299741 @SteNicholas Thanks a lot for the update. Merging...

[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 #11703: [hotfix] [docs] Fix typo in concepts.

flinkbot edited a comment on issue #11703: [hotfix] [docs] Fix typo in concepts. URL: https://github.com/apache/flink/pull/11703#issuecomment-612221287 ## CI report: * f4b5ddd31b04f7de2b977e63ddceea73a7ed4bac Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11586: [FLINK-5552][runtime] make JMXServer static per JVM

flinkbot edited a comment on issue #11586: [FLINK-5552][runtime] make JMXServer static per JVM URL: https://github.com/apache/flink/pull/11586#issuecomment-606958289 ## CI report: * 93e2ff504bdd2caed1fe63fee05fce54b9a96f56 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11651: [FLINK-16995][table-common] Add new data structure interfaces in table-common

flinkbot edited a comment on issue #11651: [FLINK-16995][table-common] Add new data structure interfaces in table-common URL: https://github.com/apache/flink/pull/11651#issuecomment-610151078 ## CI report: * 6123b4f30f049238128d277a864a02caa96d8f31 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11670: [FLINK-16761][python]Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment

flinkbot edited a comment on issue #11670: [FLINK-16761][python]Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment URL: https://github.com/apache/flink/pull/11670#issuecomment-610941752 ## CI report: * e1cdc205a9421540e08d69bc07fbeb03e9a329fc UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #11703: [hotfix] [docs] Fix typo in concepts.

flinkbot edited a comment on issue #11703: [hotfix] [docs] Fix typo in concepts. URL: https://github.com/apache/flink/pull/11703#issuecomment-612221287 ## CI report: * f4b5ddd31b04f7de2b977e63ddceea73a7ed4bac 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 #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 #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: * 7a5b8de11688078f0e6b5df1fa62741b2298cb8e Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11702: [FLINK-16667][python][client] Support new Python dependency configuration options in flink-client.

flinkbot edited a comment on issue #11702: [FLINK-16667][python][client] Support new Python dependency configuration options in flink-client. URL: https://github.com/apache/flink/pull/11702#issuecomment-612221236 ## CI report: * 592e6f6af689c4d0fa7269c90cf81feafa98cd09 Travis:

[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 #11670: [FLINK-16761][python]Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment

flinkbot edited a comment on issue #11670: [FLINK-16761][python]Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment URL: https://github.com/apache/flink/pull/11670#issuecomment-610941752 ## CI report: * e1cdc205a9421540e08d69bc07fbeb03e9a329fc UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #11702: [FLINK-16667][python][client] Support new Python dependency configuration options in flink-client.

flinkbot edited a comment on issue #11702: [FLINK-16667][python][client] Support new Python dependency configuration options in flink-client. URL: https://github.com/apache/flink/pull/11702#issuecomment-612221236 ## CI report: * 592e6f6af689c4d0fa7269c90cf81feafa98cd09 Travis:

[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: * 7a5b8de11688078f0e6b5df1fa62741b2298cb8e Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11651: [FLINK-16995][table-common] Add new data structure interfaces in table-common

flinkbot edited a comment on issue #11651: [FLINK-16995][table-common] Add new data structure interfaces in table-common URL: https://github.com/apache/flink/pull/11651#issuecomment-610151078 ## CI report: * 6123b4f30f049238128d277a864a02caa96d8f31 Travis:

[jira] [Commented] (FLINK-17089) Checkpoint fail because RocksDBException: Error While opening a file for sequentially reading

[ https://issues.apache.org/jira/browse/FLINK-17089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17081039#comment-17081039 ] Lu Niu commented on FLINK-17089: The root cause is actually user brings in rocksdb 6.1.0 in their

[GitHub] [flink] flinkbot edited a comment on issue #11624: [FLINK-16949] Enhance AbstractStreamOperatorTestHarness to use customized TtlTimeProvider

flinkbot edited a comment on issue #11624: [FLINK-16949] Enhance AbstractStreamOperatorTestHarness to use customized TtlTimeProvider URL: https://github.com/apache/flink/pull/11624#issuecomment-608048566 ## CI report: * 607d235b0cf188cde57e3a447130d6debb0c3439 Travis:

[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 #11586: [FLINK-5552][runtime] make JMXServer static per JVM

flinkbot edited a comment on issue #11586: [FLINK-5552][runtime] make JMXServer static per JVM URL: https://github.com/apache/flink/pull/11586#issuecomment-606958289 ## CI report: * 93e2ff504bdd2caed1fe63fee05fce54b9a96f56 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 #11624: [FLINK-16949] Enhance AbstractStreamOperatorTestHarness to use customized TtlTimeProvider

flinkbot edited a comment on issue #11624: [FLINK-16949] Enhance AbstractStreamOperatorTestHarness to use customized TtlTimeProvider URL: https://github.com/apache/flink/pull/11624#issuecomment-608048566 ## CI report: * 607d235b0cf188cde57e3a447130d6debb0c3439 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 #6608: [FLINK-10203]Support truncate method for old Hadoop versions in HadoopRecoverableFsDataOutputStream

flinkbot edited a comment on issue #6608: [FLINK-10203]Support truncate method for old Hadoop versions in HadoopRecoverableFsDataOutputStream URL: https://github.com/apache/flink/pull/6608#issuecomment-612218936 ## CI report: * 4e79f63f654696ed7eab4ee41d9e91ef92cf86c2 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] kl0u edited a comment on issue #11696: [FLINK-16658][FLINK-16660] Introduce the ApplicationDispatcherBootstrap and wire it to StandaloneJobEntrypoint

kl0u edited a comment on issue #11696: [FLINK-16658][FLINK-16660] Introduce the ApplicationDispatcherBootstrap and wire it to StandaloneJobEntrypoint URL: https://github.com/apache/flink/pull/11696#issuecomment-611910930 @flinkbot run azure

[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: * d28e0a3295e842d9a6131bc20a82ae70f50e515c Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11624: [FLINK-16949] Enhance AbstractStreamOperatorTestHarness to use customized TtlTimeProvider

flinkbot edited a comment on issue #11624: [FLINK-16949] Enhance AbstractStreamOperatorTestHarness to use customized TtlTimeProvider URL: https://github.com/apache/flink/pull/11624#issuecomment-608048566 ## CI report: * eb18708f59f83bdee706e5d0faaf83139e85adb8 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11586: [FLINK-5552][runtime] make JMXServer static per JVM

flinkbot edited a comment on issue #11586: [FLINK-5552][runtime] make JMXServer static per JVM URL: https://github.com/apache/flink/pull/11586#issuecomment-606958289 ## CI report: * 9944e5e1d6a5029b65e6ffea15eb431ee2896874 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11702: [FLINK-16667][python][client] Support new Python dependency configuration options in flink-client.

flinkbot edited a comment on issue #11702: [FLINK-16667][python][client] Support new Python dependency configuration options in flink-client. URL: https://github.com/apache/flink/pull/11702#issuecomment-612221236 ## CI report: * 592e6f6af689c4d0fa7269c90cf81feafa98cd09 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11651: [FLINK-16995][table-common] Add new data structure interfaces in table-common

flinkbot edited a comment on issue #11651: [FLINK-16995][table-common] Add new data structure interfaces in table-common URL: https://github.com/apache/flink/pull/11651#issuecomment-610151078 ## CI report: * f24fe42d98e90e7419aaba8c250f44f6e855e6a5 Travis:

[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: * f82a2583fb82c50376de97b616de11db678d88e6 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11670: [FLINK-16761][python]Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment

flinkbot edited a comment on issue #11670: [FLINK-16761][python]Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment URL: https://github.com/apache/flink/pull/11670#issuecomment-610941752 ## CI report: * e1cdc205a9421540e08d69bc07fbeb03e9a329fc 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 #11703: [hotfix] [docs] Fix typo in concepts.

flinkbot edited a comment on issue #11703: [hotfix] [docs] Fix typo in concepts. URL: https://github.com/apache/flink/pull/11703#issuecomment-612221287 ## CI report: * f4b5ddd31b04f7de2b977e63ddceea73a7ed4bac 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 #6608: [FLINK-10203]Support truncate method for old Hadoop versions in HadoopRecoverableFsDataOutputStream

flinkbot edited a comment on issue #6608: [FLINK-10203]Support truncate method for old Hadoop versions in HadoopRecoverableFsDataOutputStream URL: https://github.com/apache/flink/pull/6608#issuecomment-612218936 ## CI report: * 4e79f63f654696ed7eab4ee41d9e91ef92cf86c2 Travis:

[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

[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 commented on issue #11702: [FLINK-16667][python][client] Support new Python dependency configuration options in flink-client.

flinkbot commented on issue #11702: [FLINK-16667][python][client] Support new Python dependency configuration options in flink-client. URL: https://github.com/apache/flink/pull/11702#issuecomment-612221236 ## CI report: * 592e6f6af689c4d0fa7269c90cf81feafa98cd09 UNKNOWN

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

flinkbot commented 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 UNKNOWN Bot

[GitHub] [flink] flinkbot commented on issue #11703: [hotfix] [docs] Fix typo in concepts.

flinkbot commented on issue #11703: [hotfix] [docs] Fix typo in concepts. URL: https://github.com/apache/flink/pull/11703#issuecomment-612221287 ## CI report: * f4b5ddd31b04f7de2b977e63ddceea73a7ed4bac UNKNOWN Bot commands The @flinkbot bot supports the following

[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: * d28e0a3295e842d9a6131bc20a82ae70f50e515c Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11651: [FLINK-16995][table-common] Add new data structure interfaces in table-common

flinkbot edited a comment on issue #11651: [FLINK-16995][table-common] Add new data structure interfaces in table-common URL: https://github.com/apache/flink/pull/11651#issuecomment-610151078 ## CI report: * f24fe42d98e90e7419aaba8c250f44f6e855e6a5 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11670: [FLINK-16761][python]Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment

flinkbot edited a comment on issue #11670: [FLINK-16761][python]Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment URL: https://github.com/apache/flink/pull/11670#issuecomment-610941752 ## CI report: * e1cdc205a9421540e08d69bc07fbeb03e9a329fc 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: * f82a2583fb82c50376de97b616de11db678d88e6 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11524: [FLINK-16803][hive] Need to make sure partition inherit table spec wh…

flinkbot edited a comment on issue #11524: [FLINK-16803][hive] Need to make sure partition inherit table spec wh… URL: https://github.com/apache/flink/pull/11524#issuecomment-604351593 ## CI report: * f33c1297548afd19f532b4eee941c3c89e31f513 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11624: [FLINK-16949] Enhance AbstractStreamOperatorTestHarness to use customized TtlTimeProvider

flinkbot edited a comment on issue #11624: [FLINK-16949] Enhance AbstractStreamOperatorTestHarness to use customized TtlTimeProvider URL: https://github.com/apache/flink/pull/11624#issuecomment-608048566 ## CI report: * eb18708f59f83bdee706e5d0faaf83139e85adb8 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11586: [FLINK-5552][runtime] make JMXServer static per JVM

flinkbot edited a comment on issue #11586: [FLINK-5552][runtime] make JMXServer static per JVM URL: https://github.com/apache/flink/pull/11586#issuecomment-606958289 ## CI report: * 9944e5e1d6a5029b65e6ffea15eb431ee2896874 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11511: [FLINK-16771][table-planner-blink] NPE when filtering by decimal column

flinkbot edited a comment on issue #11511: [FLINK-16771][table-planner-blink] NPE when filtering by decimal column URL: https://github.com/apache/flink/pull/11511#issuecomment-603853561 ## CI report: * f28c034ca66bf8142bcfd220aefdb96487c2d9fe Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager

flinkbot edited a comment on issue #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager URL: https://github.com/apache/flink/pull/11353#issuecomment-596455079 ## CI report: *

[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 commented on issue #6608: [FLINK-10203]Support truncate method for old Hadoop versions in HadoopRecoverableFsDataOutputStream

flinkbot commented on issue #6608: [FLINK-10203]Support truncate method for old Hadoop versions in HadoopRecoverableFsDataOutputStream URL: https://github.com/apache/flink/pull/6608#issuecomment-612218936 ## CI report: * 4e79f63f654696ed7eab4ee41d9e91ef92cf86c2 UNKNOWN

[jira] [Commented] (FLINK-17012) Expose stage of task initialization

[ https://issues.apache.org/jira/browse/FLINK-17012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17080959#comment-17080959 ] Chesnay Schepler commented on FLINK-17012: -- An alternative to exposing the raw task state would

[jira] [Commented] (FLINK-17012) Expose stage of task initialization

[ https://issues.apache.org/jira/browse/FLINK-17012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17080957#comment-17080957 ] Chesnay Schepler commented on FLINK-17012: -- Non-numeric metrics are problematic as virtually no

[GitHub] [flink] JTaky commented on issue #6608: [FLINK-10203]Support truncate method for old Hadoop versions in HadoopRecoverableFsDataOutputStream

JTaky commented on issue #6608: [FLINK-10203]Support truncate method for old Hadoop versions in HadoopRecoverableFsDataOutputStream URL: https://github.com/apache/flink/pull/6608#issuecomment-612190976 Hey @art4ul. I believe you are not interested in this change anymore? If you can

[jira] [Created] (FLINK-17089) Checkpoint fail because RocksDBException: Error While opening a file for sequentially reading

Lu Niu created FLINK-17089: -- Summary: Checkpoint fail because RocksDBException: Error While opening a file for sequentially reading Key: FLINK-17089 URL: https://issues.apache.org/jira/browse/FLINK-17089

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

flinkbot commented on issue #11704: [FLINK-17088] [runtime][web] Search TaskManager log content based on keywords function URL: https://github.com/apache/flink/pull/11704#issuecomment-612152374 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[jira] [Updated] (FLINK-17088) Search TaskManager log content based on keywords function

[ https://issues.apache.org/jira/browse/FLINK-17088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17088: --- Labels: pull-request-available (was: ) > Search TaskManager log content based on keywords

[GitHub] [flink] ambition119 opened a new pull request #11704: [FLINK-17088] [runtime][web] Search TaskManager log content based on keywords function

ambition119 opened a new pull request #11704: [FLINK-17088] [runtime][web] Search TaskManager log content based on keywords function URL: https://github.com/apache/flink/pull/11704 ## What is the purpose of the change Usually the taskmanager log file has a lot of content. There are

[jira] [Created] (FLINK-17088) Search TaskManager log content based on keywords function

pingle wang created FLINK-17088: --- Summary: Search TaskManager log content based on keywords function Key: FLINK-17088 URL: https://issues.apache.org/jira/browse/FLINK-17088 Project: Flink

[GitHub] [flink] pnowojski commented on a change in pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

pnowojski commented on a change in pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint URL: https://github.com/apache/flink/pull/11687#discussion_r406825039 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Avoid caching buffers for blocked input channels before barrier alignment

zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Avoid caching buffers for blocked input channels before barrier alignment URL: https://github.com/apache/flink/pull/11351#discussion_r406818252 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Avoid caching buffers for blocked input channels before barrier alignment

zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Avoid caching buffers for blocked input channels before barrier alignment URL: https://github.com/apache/flink/pull/11351#discussion_r406816455 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

pnowojski commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r406801309 ## File path:

[GitHub] [flink] flinkbot commented on issue #11703: [hotfix] [docs] Fix typo in concepts.

flinkbot commented on issue #11703: [hotfix] [docs] Fix typo in concepts. URL: https://github.com/apache/flink/pull/11703#issuecomment-612071215 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will

[GitHub] [flink] echauchot opened a new pull request #11703: [hotfix] [docs] Fix typo in concepts.

echauchot opened a new pull request #11703: [hotfix] [docs] Fix typo in concepts. URL: https://github.com/apache/flink/pull/11703 **(The sections below can be removed for hotfixes of typos)** --> ## What is the purpose of the change This PR fixes minor typos in the

[GitHub] [flink] pnowojski commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

pnowojski commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r406774796 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

pnowojski commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r406772498 ## File path:

[jira] [Comment Edited] (FLINK-11879) Add JobGraph validators for the uses of InputSelectable, BoundedOneInput and BoundedMultiInput

[ https://issues.apache.org/jira/browse/FLINK-11879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17080538#comment-17080538 ] Yubao Liu edited comment on FLINK-11879 at 4/10/20, 2:52 PM: - [~sunhaibotb] 

[jira] [Commented] (FLINK-11879) Add JobGraph validators for the uses of InputSelectable, BoundedOneInput and BoundedMultiInput

[ https://issues.apache.org/jira/browse/FLINK-11879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17080538#comment-17080538 ] Yubao Liu commented on FLINK-11879: --- [~sunhaibotb]    I use 

[jira] [Resolved] (FLINK-17081) Batch test classes in Blink planner does not extend TestLogger

[ https://issues.apache.org/jira/browse/FLINK-17081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-17081. - Fix Version/s: 1.11.0 Assignee: Caizhi Weng Resolution: Fixed Fixed in master (1.11.0):

[GitHub] [flink] wuchong merged pull request #11689: [FLINK-17081][test] Extend some test classes with TestLogger

wuchong merged pull request #11689: [FLINK-17081][test] Extend some test classes with TestLogger URL: https://github.com/apache/flink/pull/11689 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] SteNicholas removed a comment on issue #11670: [FLINK-16761][python]Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment

SteNicholas removed a comment on issue #11670: [FLINK-16761][python]Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment URL: https://github.com/apache/flink/pull/11670#issuecomment-612033667 @flinkbot run travis

[GitHub] [flink] SteNicholas removed a comment on issue #11670: [FLINK-16761][python]Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment

SteNicholas removed a comment on issue #11670: [FLINK-16761][python]Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment URL: https://github.com/apache/flink/pull/11670#issuecomment-612033796 @flinkbot run azure

[GitHub] [flink] SteNicholas commented on issue #11670: [FLINK-16761][python]Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment

SteNicholas commented on issue #11670: [FLINK-16761][python]Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment URL: https://github.com/apache/flink/pull/11670#issuecomment-612033796 @flinkbot run azure

[GitHub] [flink] SteNicholas commented on issue #11670: [FLINK-16761][python]Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment

SteNicholas commented on issue #11670: [FLINK-16761][python]Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment URL: https://github.com/apache/flink/pull/11670#issuecomment-612033667 @flinkbot run travis

[GitHub] [flink] flinkbot edited a comment on issue #11542: [FLINK-16303][rest] Enable retrieval of custom JobManager log files

flinkbot edited a comment on issue #11542: [FLINK-16303][rest] Enable retrieval of custom JobManager log files URL: https://github.com/apache/flink/pull/11542#issuecomment-604812411 ## CI report: * c45cb2a911fbd9a775fee2725370081f5d15b764 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager

flinkbot edited a comment on issue #11353: [FLINK-16438][yarn] Make YarnResourceManager starts workers using WorkerResourceSpec requested by SlotManager URL: https://github.com/apache/flink/pull/11353#issuecomment-596455079 ## CI report: *

  1   2   3   >