[jira] [Updated] (FLINK-10934) Support per-job mode in kubernetes

[ https://issues.apache.org/jira/browse/FLINK-10934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-10934: -- Parent: (was: FLINK-9953) Issue Type: New Feature (was: Sub-task) > Support per-job mode

[GitHub] [flink] flinkbot edited a comment on issue #10324: [FLINK-11767] Introduce new TypeSerializerUpgradeTestBase

flinkbot edited a comment on issue #10324: [FLINK-11767] Introduce new TypeSerializerUpgradeTestBase URL: https://github.com/apache/flink/pull/10324#issuecomment-558557484 ## CI report: * 2bcdaedec64a5b76d23850afb79ebe38d089445c Travis:

[jira] [Commented] (FLINK-3033) Redis Source Connector

[ https://issues.apache.org/jira/browse/FLINK-3033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991221#comment-16991221 ] Guy Korland commented on FLINK-3033: Is this feature about writing a Redis Streams source connector?

[GitHub] [flink] flinkbot edited a comment on issue #9549: [FLINK-13790][sql-client] Support -q option with a sql query statemen…

flinkbot edited a comment on issue #9549: [FLINK-13790][sql-client] Support -q option with a sql query statemen… URL: https://github.com/apache/flink/pull/9549#issuecomment-525633421 ## CI report: * c074a0eeddf41241432007133491aaf39d639d63 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10059: [FLINK-14543][table] Support partition for temporary table

flinkbot edited a comment on issue #10059: [FLINK-14543][table] Support partition for temporary table URL: https://github.com/apache/flink/pull/10059#issuecomment-548289939 ## CI report: * 4937b8b139bab4957799947b841fb1ae3758ed48 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10322: [hotfix] Improve error message in JDBCUpsertTableSink

flinkbot edited a comment on issue #10322: [hotfix] Improve error message in JDBCUpsertTableSink URL: https://github.com/apache/flink/pull/10322#issuecomment-558530648 ## CI report: * 8dfd3d2d9c4bc9913e4b2de9344a0aaf38aaf23f Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10329: [FLINK-12785][StateBackend] RocksDB savepoint recovery can use a lot of unmanaged memory

flinkbot edited a comment on issue #10329: [FLINK-12785][StateBackend] RocksDB savepoint recovery can use a lot of unmanaged memory URL: https://github.com/apache/flink/pull/10329#issuecomment-558970068 ## CI report: * e3aa8e5a567a13f07598ee6fe0e8fb8e72dfb986 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #3672: [Flink-6072] TestCase CheckpointStateRestoreTest::testSetState should be fail

flinkbot edited a comment on issue #3672: [Flink-6072] TestCase CheckpointStateRestoreTest::testSetState should be fail URL: https://github.com/apache/flink/pull/3672#issuecomment-544083819 ## CI report: * c498dea78675a529d032857a00f6fbaf36c0c16e Travis:

[GitHub] [flink] flinkbot edited a comment on issue #9025: [FLINK-13149][Web Frontend] support configuration and update Angular to 8.0 version

flinkbot edited a comment on issue #9025: [FLINK-13149][Web Frontend] support configuration and update Angular to 8.0 version URL: https://github.com/apache/flink/pull/9025#issuecomment-512173118 ## CI report: * e2ae53781367b527fd4d77a4a63ae3b8f354a810 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #9289: [FLINK-13390] Clarify the exact meaning of state size when executing incremental checkpoint

flinkbot edited a comment on issue #9289: [FLINK-13390] Clarify the exact meaning of state size when executing incremental checkpoint URL: https://github.com/apache/flink/pull/9289#issuecomment-516734686 ## CI report: * a31d65fb01f4d6d8952f0eab8def4f379cd1051a Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10300: [FLINK-14926] [state backends] Make sure no resource leak of RocksObject

flinkbot edited a comment on issue #10300: [FLINK-14926] [state backends] Make sure no resource leak of RocksObject URL: https://github.com/apache/flink/pull/10300#issuecomment-557891612 ## CI report: * dae41b86e4710d0c83d3f764e6196513db26a2c8 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10314: [FLINK-14941][hbase] The AbstractTableInputFormat#nextRecord in hbase connector will handle the same rowkey twice once encountered any excep

flinkbot edited a comment on issue #10314: [FLINK-14941][hbase] The AbstractTableInputFormat#nextRecord in hbase connector will handle the same rowkey twice once encountered any exception URL: https://github.com/apache/flink/pull/10314#issuecomment-558163426 ## CI report: *

[jira] [Updated] (FLINK-15004) Choose two-phase Aggregate if the statistics is unknown

[ https://issues.apache.org/jira/browse/FLINK-15004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15004: --- Affects Version/s: (was: 1.9.0) 1.10.0 > Choose two-phase Aggregate if

[GitHub] [flink] zhijiangW commented on a change in pull request #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter.

zhijiangW commented on a change in pull request #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter. URL: https://github.com/apache/flink/pull/10492#discussion_r355313454 ## File path:

[jira] [Commented] (FLINK-15104) Performance regression on 4.12.2019 in RocksDB benchmarks

[ https://issues.apache.org/jira/browse/FLINK-15104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991243#comment-16991243 ] Piotr Nowojski commented on FLINK-15104: I'm not sure about that [~liyu]. We can wait for

[GitHub] [flink] zjffdu commented on a change in pull request #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle…

zjffdu commented on a change in pull request #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle… URL: https://github.com/apache/flink/pull/10491#discussion_r355322861 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10436: [FLINK-14920] [flink-end-to-end-perf-tests] Set up environment to run performance e2e tests

flinkbot edited a comment on issue #10436: [FLINK-14920] [flink-end-to-end-perf-tests] Set up environment to run performance e2e tests URL: https://github.com/apache/flink/pull/10436#issuecomment-562103759 ## CI report: * 3441142c77315169ce7a3b48d4d59e710c1016c2 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10468: [FLINK-14649][table sql / api] Flatten all the connector properties keys to make it easy to configure in DDL

flinkbot edited a comment on issue #10468: [FLINK-14649][table sql / api] Flatten all the connector properties keys to make it easy to configure in DDL URL: https://github.com/apache/flink/pull/10468#issuecomment-562648066 ## CI report: * 9802f136dd38c6ba22752a7761e644b7bd05e99d

[jira] [Updated] (FLINK-10939) Add documents for Flink on native k8s

[ https://issues.apache.org/jira/browse/FLINK-10939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-10939: -- Fix Version/s: 1.10.0 > Add documents for Flink on native k8s > -

[GitHub] [flink] zjffdu commented on issue #10479: [FLINK-14992][client] Add job listener to execution environments

zjffdu commented on issue #10479: [FLINK-14992][client] Add job listener to execution environments URL: https://github.com/apache/flink/pull/10479#issuecomment-563141780 I have rebased this PR and it is ready for review @aljoscha @kl0u @TisonKun 2 main changes: 1. return

[GitHub] [flink] zhijiangW commented on a change in pull request #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter.

zhijiangW commented on a change in pull request #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter. URL: https://github.com/apache/flink/pull/10492#discussion_r355344524 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter.

zhijiangW commented on a change in pull request #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter. URL: https://github.com/apache/flink/pull/10492#discussion_r355344524 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10300: [FLINK-14926] [state backends] Make sure no resource leak of RocksObject

flinkbot edited a comment on issue #10300: [FLINK-14926] [state backends] Make sure no resource leak of RocksObject URL: https://github.com/apache/flink/pull/10300#issuecomment-557891612 ## CI report: * dae41b86e4710d0c83d3f764e6196513db26a2c8 Travis:

[GitHub] [flink] zhijiangW commented on a change in pull request #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter.

zhijiangW commented on a change in pull request #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter. URL: https://github.com/apache/flink/pull/10492#discussion_r355344524 ## File path:

[jira] [Updated] (FLINK-14228) The runtime support for Bounded[One|Multi]Input#endInput does not properly implement their semantics

[ https://issues.apache.org/jira/browse/FLINK-14228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haibo Sun updated FLINK-14228: -- Fix Version/s: (was: 1.10.0) 1.11.0 > The runtime support for

[GitHub] [flink] aljoscha commented on issue #10479: [FLINK-14992][client] Add job listener to execution environments

aljoscha commented on issue #10479: [FLINK-14992][client] Add job listener to execution environments URL: https://github.com/apache/flink/pull/10479#issuecomment-563163264 The changes for the Scala Shell, and the return type of `executeAsync()` should be in separate commits.

[GitHub] [flink] aljoscha commented on issue #10479: [FLINK-14992][client] Add job listener to execution environments

aljoscha commented on issue #10479: [FLINK-14992][client] Add job listener to execution environments URL: https://github.com/apache/flink/pull/10479#issuecomment-563170033 This leaves `JobListener.onJobExecuted()` in, but it's not called anymore from the environments.

[jira] [Commented] (FLINK-13197) Verify querying Hive's view in Flink

[ https://issues.apache.org/jira/browse/FLINK-13197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991220#comment-16991220 ] Dawid Wysakowicz commented on FLINK-13197: -- And what about null handling? E.g. in hive 1.x all

[GitHub] [flink] flinkbot edited a comment on issue #10384: [FLINK-13373][docs] Remove Tutorials and Examples sections from Getting Started

flinkbot edited a comment on issue #10384: [FLINK-13373][docs] Remove Tutorials and Examples sections from Getting Started URL: https://github.com/apache/flink/pull/10384#issuecomment-560545371 ## CI report: * 31ecc456047b001112f3d7119c88989857c2d7e5 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10381: [FLINK-14513][hive] Implement listPartitionsByFilter to HiveCatalog

flinkbot edited a comment on issue #10381: [FLINK-14513][hive] Implement listPartitionsByFilter to HiveCatalog URL: https://github.com/apache/flink/pull/10381#issuecomment-560368141 ## CI report: * ebaf14134fb520e1e66c7788139fb619e8fb2be0 Travis:

[jira] [Updated] (FLINK-9953) Active Kubernetes integration

[ https://issues.apache.org/jira/browse/FLINK-9953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-9953: - Fix Version/s: 1.10.0 > Active Kubernetes integration > - > >

[GitHub] [flink] flinkbot edited a comment on issue #9877: [FLINK-14360][yarn] flink on yarn support obtain delegation token for multi hdfs.

flinkbot edited a comment on issue #9877: [FLINK-14360][yarn] flink on yarn support obtain delegation token for multi hdfs. URL: https://github.com/apache/flink/pull/9877#issuecomment-540485056 ## CI report: * fdeaa9ae3a6e7f7f9ab22ca60d17bfae4cd24670 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #7314: [FLINK-11135][YARN] Refactor Hadoop config loading in HadoopUtils

flinkbot edited a comment on issue #7314: [FLINK-11135][YARN] Refactor Hadoop config loading in HadoopUtils URL: https://github.com/apache/flink/pull/7314#issuecomment-563040815 ## CI report: * 2b4f99077d6d27409c625bf6ee303e527153d0e3 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #9870: [FLINK-14350][metrics] Introduce dedicated MetricScope

flinkbot edited a comment on issue #9870: [FLINK-14350][metrics] Introduce dedicated MetricScope URL: https://github.com/apache/flink/pull/9870#issuecomment-539998685 ## CI report: * 2f1ccc163814cd812929c0e41889e5da212d5920 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10385: [FLINK-11046][elasticsearch] Bump elasticsearch-rest-high-level-client to 7.5.0 in connectors

flinkbot edited a comment on issue #10385: [FLINK-11046][elasticsearch] Bump elasticsearch-rest-high-level-client to 7.5.0 in connectors URL: https://github.com/apache/flink/pull/10385#issuecomment-560570592 ## CI report: * 3e4c921957972856dcca1f8b3dc78e286232c093 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #8340: [FLINK-12395][table] Add more detailed javadoc for getDescription() and getDetailedDescription() in catalog object interfaces

flinkbot edited a comment on issue #8340: [FLINK-12395][table] Add more detailed javadoc for getDescription() and getDetailedDescription() in catalog object interfaces URL: https://github.com/apache/flink/pull/8340#issuecomment-561079242 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #10390: [FLINK-15004] [table-planner-blink] Choose two-phase Aggregate if the row count is unknown

flinkbot edited a comment on issue #10390: [FLINK-15004] [table-planner-blink] Choose two-phase Aggregate if the row count is unknown URL: https://github.com/apache/flink/pull/10390#issuecomment-560995750 ## CI report: * b954b01901d861cdb57d970ee7c27e659210e8df Travis:

[GitHub] [flink] flinkbot edited a comment on issue #9878: [FLINK-14149][coordination] Implement ZooKeeperLeaderElectionServiceNG

flinkbot edited a comment on issue #9878: [FLINK-14149][coordination] Implement ZooKeeperLeaderElectionServiceNG URL: https://github.com/apache/flink/pull/9878#issuecomment-540485113 ## CI report: * 868e6df849dceb88416e893aa168d5c649daf049 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #9355: [FLINK-13577][ml] Add an util class to build result row and generate …

flinkbot edited a comment on issue #9355: [FLINK-13577][ml] Add an util class to build result row and generate … URL: https://github.com/apache/flink/pull/9355#issuecomment-518089359 ## CI report: * f8f3792f7ce55735f05200c90431b20b99a42d18 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #9608: [FLINK-13776][table] Introduce new interfaces to BuiltInFunctionDefinition

flinkbot edited a comment on issue #9608: [FLINK-13776][table] Introduce new interfaces to BuiltInFunctionDefinition URL: https://github.com/apache/flink/pull/9608#issuecomment-527810896 ## CI report: * 44ce459cb0c516fd5fb0d0b7aa775231d0f572a9 Travis:

[jira] [Updated] (FLINK-14460) Active Kubernetes integration phase2 - Production Optimization

[ https://issues.apache.org/jira/browse/FLINK-14460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-14460: -- Fix Version/s: (was: 1.10.0) > Active Kubernetes integration phase2 - Production Optimization >

[GitHub] [flink] flinkbot edited a comment on issue #10371: [FLINK-14953][formats] use table type to build parquet FilterPredicate

flinkbot edited a comment on issue #10371: [FLINK-14953][formats] use table type to build parquet FilterPredicate URL: https://github.com/apache/flink/pull/10371#issuecomment-560045651 ## CI report: * 24326ffa979a4f9ed56265c0db11a874d3c4d2a2 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10377: [FLINK-15001] [table-planner-blink] The digest of sub-plan reuse should contain retraction traits for stream physical nodes

flinkbot edited a comment on issue #10377: [FLINK-15001] [table-planner-blink] The digest of sub-plan reuse should contain retraction traits for stream physical nodes URL: https://github.com/apache/flink/pull/10377#issuecomment-560290949 ## CI report: *

[jira] [Updated] (FLINK-14460) Active Kubernetes integration phase2 - Production Optimization

[ https://issues.apache.org/jira/browse/FLINK-14460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-14460: -- Fix Version/s: 1.10.0 > Active Kubernetes integration phase2 - Production Optimization >

[GitHub] [flink] flinkbot edited a comment on issue #9867: [FLINK-7958][metrics] Reporters provide default delimiter

flinkbot edited a comment on issue #9867: [FLINK-7958][metrics] Reporters provide default delimiter URL: https://github.com/apache/flink/pull/9867#issuecomment-539977808 ## CI report: * b1f3ffa22f6bbd57656e1fe9764842037d72ad41 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10378: [FLINK-14919] [flink-end-to-end-perf-tests] Add performance e2e test suite for basic operations

flinkbot edited a comment on issue #10378: [FLINK-14919] [flink-end-to-end-perf-tests] Add performance e2e test suite for basic operations URL: https://github.com/apache/flink/pull/10378#issuecomment-560291002 ## CI report: * 5a9b8cc32f275d416e8358ee148ad4daff2626ba Travis:

[jira] [Commented] (FLINK-14571) flink connector for redis

[ https://issues.apache.org/jira/browse/FLINK-14571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991223#comment-16991223 ] Guy Korland commented on FLINK-14571: - Duplicate https://issues.apache.org/jira/browse/FLINK-3034 >

[GitHub] [flink] flinkbot edited a comment on issue #10116: [FLINK-14655] Change Type of Field jobStatusListeners from CopyOnWriteArrayList to ArrayList

flinkbot edited a comment on issue #10116: [FLINK-14655] Change Type of Field jobStatusListeners from CopyOnWriteArrayList to ArrayList URL: https://github.com/apache/flink/pull/10116#issuecomment-551074133 ## CI report: * 0b629ac20bf53fd82c9f28b9d1ae60620060f59b Travis:

[GitHub] [flink] flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for …

flinkbot edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for … URL: https://github.com/apache/flink/pull/5521#issuecomment-547463841 ## CI report: * 498611c0cd8678dfd4f3e772826081f83260bb28 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #9602: [FLINK-13856][checkpoint] Reduce the delete file api when the checkpo…

flinkbot edited a comment on issue #9602: [FLINK-13856][checkpoint] Reduce the delete file api when the checkpo… URL: https://github.com/apache/flink/pull/9602#issuecomment-527413108 ## CI report: * 99c3a51ac3f941c98ac88eaead9b9989d277537f Travis:

[jira] [Commented] (FLINK-15103) Performance regression on 3.12.2019 in various benchmarks

[ https://issues.apache.org/jira/browse/FLINK-15103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991231#comment-16991231 ] Xintong Song commented on FLINK-15103: -- [~pnowojski], [~sewen] Sorry, it was my mistake to mark

[GitHub] [flink] flinkbot edited a comment on issue #9468: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak when elasticsearch6 rest high level cli…

flinkbot edited a comment on issue #9468: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak when elasticsearch6 rest high level cli… URL: https://github.com/apache/flink/pull/9468#issuecomment-522106295 ## CI report: * 78654e8f80aa0b1a01654e7684f4610eb1d3aff4 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10236: [FLINK-14703][e2e] Port the Kafka SQL related tests.

flinkbot edited a comment on issue #10236: [FLINK-14703][e2e] Port the Kafka SQL related tests. URL: https://github.com/apache/flink/pull/10236#issuecomment-554979302 ## CI report: * 271d1809c4fa83e7b7655e941e632f6c6d7318ec Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10493: [FLINK-15061][table]create/alter and table/databases properties should be case sensitive stored in catalog

flinkbot edited a comment on issue #10493: [FLINK-15061][table]create/alter and table/databases properties should be case sensitive stored in catalog URL: https://github.com/apache/flink/pull/10493#issuecomment-563111006 ## CI report: * a79225d75a53240951a4378380ff2aac457c1278

[jira] [Updated] (FLINK-13438) Support timestamp type in Hive

[ https://issues.apache.org/jira/browse/FLINK-13438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-13438: --- Summary: Support timestamp type in Hive (was: Hive source/sink/udx should respect the conversion class of

[jira] [Updated] (FLINK-15004) Choose two-phase Aggregate if the statistics is unknown

[ https://issues.apache.org/jira/browse/FLINK-15004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15004: --- Parent: (was: FLINK-14133) Issue Type: Improvement (was: Sub-task) > Choose two-phase

[jira] [Closed] (FLINK-14133) Improve batch sql and hive integrate performance milestone-1

[ https://issues.apache.org/jira/browse/FLINK-14133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-14133. -- Assignee: Jingsong Lee Resolution: Fixed > Improve batch sql and hive integrate performance

[GitHub] [flink] zhijiangW commented on a change in pull request #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter.

zhijiangW commented on a change in pull request #10492: [FLINK-15140][runtime] Fix shuffle data compression doesn't work with BroadcastRecordWriter. URL: https://github.com/apache/flink/pull/10492#discussion_r355312789 ## File path:

[jira] [Commented] (FLINK-15143) Create document for FLIP-49 TM memory model and configuration guide

[ https://issues.apache.org/jira/browse/FLINK-15143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991386#comment-16991386 ] Xintong Song commented on FLINK-15143: -- True, thanks for the pointer. I'm discussing this with

[jira] [Updated] (FLINK-13418) Avoid InfluxdbReporter to report unnecessary tags

[ https://issues.apache.org/jira/browse/FLINK-13418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-13418: - Fix Version/s: (was: 1.10.0) 1.11.0 > Avoid InfluxdbReporter to report

[GitHub] [flink] aljoscha commented on issue #10479: [FLINK-14992][client] Add job listener to execution environments

aljoscha commented on issue #10479: [FLINK-14992][client] Add job listener to execution environments URL: https://github.com/apache/flink/pull/10479#issuecomment-56314 @zjffdu Because the discussion on https://issues.apache.org/jira/browse/FLINK-15129 is not conclusive I would prefer

[GitHub] [flink] flinkbot edited a comment on issue #10486: [FLINK-15131][connector/source] Add the APIs for Source (FLIP-27).

flinkbot edited a comment on issue #10486: [FLINK-15131][connector/source] Add the APIs for Source (FLIP-27). URL: https://github.com/apache/flink/pull/10486#issuecomment-562960855 ## CI report: * 8c84da76b5e6919173d15a369a204c12d8a53da2 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10381: [FLINK-14513][hive] Implement listPartitionsByFilter to HiveCatalog

flinkbot edited a comment on issue #10381: [FLINK-14513][hive] Implement listPartitionsByFilter to HiveCatalog URL: https://github.com/apache/flink/pull/10381#issuecomment-560368141 ## CI report: * ebaf14134fb520e1e66c7788139fb619e8fb2be0 Travis:

[GitHub] [flink] KurtYoung closed pull request #10381: [FLINK-14513][hive] Implement listPartitionsByFilter to HiveCatalog

KurtYoung closed pull request #10381: [FLINK-14513][hive] Implement listPartitionsByFilter to HiveCatalog URL: https://github.com/apache/flink/pull/10381 This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] flinkbot edited a comment on issue #10479: [FLINK-14992][client] Add job listener to execution environments

flinkbot edited a comment on issue #10479: [FLINK-14992][client] Add job listener to execution environments URL: https://github.com/apache/flink/pull/10479#issuecomment-562851491 ## CI report: * a5903c83403e4628cdb00e85ab5860be9ebaadc4 Travis:

[GitHub] [flink] aljoscha commented on a change in pull request #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle…

aljoscha commented on a change in pull request #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle… URL: https://github.com/apache/flink/pull/10491#discussion_r355360041 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9768: [FLINK-14086][test][core] Add OperatingArchitecture Enum

flinkbot edited a comment on issue #9768: [FLINK-14086][test][core] Add OperatingArchitecture Enum URL: https://github.com/apache/flink/pull/9768#issuecomment-534899022 ## CI report: * 51ae12da735fd7fd1bdadd282839c9bfe7b80146 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10479: [FLINK-14992][client] Add job listener to execution environments

flinkbot edited a comment on issue #10479: [FLINK-14992][client] Add job listener to execution environments URL: https://github.com/apache/flink/pull/10479#issuecomment-562851491 ## CI report: * a5903c83403e4628cdb00e85ab5860be9ebaadc4 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle…

flinkbot edited a comment on issue #10491: [FLINK-15093][streaming-java] StreamExecutionEnvironment does not cle… URL: https://github.com/apache/flink/pull/10491#issuecomment-563083959 ## CI report: * 2e942aa60f0807a6a41fd0483237d8b571fdca1f Travis:

[GitHub] [flink] azagrebin commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes.

azagrebin commented on a change in pull request #9984: [FLINK-9495][kubernetes] Implement ResourceManager for Kubernetes. URL: https://github.com/apache/flink/pull/9984#discussion_r355385739 ## File path:

[jira] [Commented] (FLINK-15139) misc end to end test failed on 'SQL Client end-to-end test (Old planner)'

[ https://issues.apache.org/jira/browse/FLINK-15139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16991216#comment-16991216 ] Yu Li commented on FLINK-15139: --- Another two instances: https://api.travis-ci.org/v3/job/622261365/log.txt

[GitHub] [flink] flinkbot edited a comment on issue #9730: [FLINK-14151][ml] Add class for DocHashIDFVectorizerModelMapper.

flinkbot edited a comment on issue #9730: [FLINK-14151][ml] Add class for DocHashIDFVectorizerModelMapper. URL: https://github.com/apache/flink/pull/9730#issuecomment-533540803 ## CI report: * 67cf93e4ddd84ac53a64ac2e27950eda8fb1f1b2 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #9731: [FLINK-14152][ml] Add class for DocCountVectorizerMapper.

flinkbot edited a comment on issue #9731: [FLINK-14152][ml] Add class for DocCountVectorizerMapper. URL: https://github.com/apache/flink/pull/9731#issuecomment-533540895 ## CI report: * 3ae6c348886b5e395e6701407e5667d682e9bdde Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10248: [FLINK-14776][Configuration] Migrate duration and memory size ConfigOptions in RocksDBConfigurableOptions

flinkbot edited a comment on issue #10248: [FLINK-14776][Configuration] Migrate duration and memory size ConfigOptions in RocksDBConfigurableOptions URL: https://github.com/apache/flink/pull/10248#issuecomment-555408694 ## CI report: * b1bdc03483cd3b64e114edbc585e2ff7986dea97

[GitHub] [flink] flinkbot edited a comment on issue #9734: [FLINK-14155][ml] Add a wrapper class of a JSON library to provide the unified json format.

flinkbot edited a comment on issue #9734: [FLINK-14155][ml] Add a wrapper class of a JSON library to provide the unified json format. URL: https://github.com/apache/flink/pull/9734#issuecomment-533547640 ## CI report: * d0eb5e2b5a8f664a1de56dbe0ea3aa592452b7c2 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #7425: [FLINK-9457][ResourceManager][YARN] Cancel container requests when cancelling pending slot allocations

flinkbot edited a comment on issue #7425: [FLINK-9457][ResourceManager][YARN] Cancel container requests when cancelling pending slot allocations URL: https://github.com/apache/flink/pull/7425#issuecomment-545355635 ## CI report: * a1b7b6ca4ca5942f2edffa54c6be3f96d663b1bc Travis:

[GitHub] [flink] flinkbot edited a comment on issue #8706: [FLINK-12814][sql-client] Support a traditional and scrolling view of…

flinkbot edited a comment on issue #8706: [FLINK-12814][sql-client] Support a traditional and scrolling view of… URL: https://github.com/apache/flink/pull/8706#issuecomment-522740816 ## CI report: * f4a31e789e78ba3d5ab18ce50c9e8e697d3141d1 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10418: [FLINK-15050][table-planner-blink] DataFormatConverters should suppor…

flinkbot edited a comment on issue #10418: [FLINK-15050][table-planner-blink] DataFormatConverters should suppor… URL: https://github.com/apache/flink/pull/10418#issuecomment-561567846 ## CI report: * 6951e77dff9c9c4fb1945d79ef4253e5ea2c0f0f Travis:

[jira] [Created] (FLINK-15142) Extend Redis Sink Connector to Redis Streams

Guy Korland created FLINK-15142: --- Summary: Extend Redis Sink Connector to Redis Streams Key: FLINK-15142 URL: https://issues.apache.org/jira/browse/FLINK-15142 Project: Flink Issue Type: Wish

[GitHub] [flink] flinkbot edited a comment on issue #9404: [FLINK-13667][ml] Add the utility class for the Table

flinkbot edited a comment on issue #9404: [FLINK-13667][ml] Add the utility class for the Table URL: https://github.com/apache/flink/pull/9404#issuecomment-519872127 ## CI report: * 4a726770daa19b1a587c5f8d9221a95e08387592 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10144: [FLINK-14613][table-planner-blink] Fix temporal table join when containing multiple keyfields with UDF

flinkbot edited a comment on issue #10144: [FLINK-14613][table-planner-blink] Fix temporal table join when containing multiple keyfields with UDF URL: https://github.com/apache/flink/pull/10144#issuecomment-552178404 ## CI report: * c0059cd9abc4281fbc962aba9d2a2a9d7965f745

[GitHub] [flink] flinkbot edited a comment on issue #9898: [FLINK-14359][hbase] Create a module called flink-sql-connector-hbase…

flinkbot edited a comment on issue #9898: [FLINK-14359][hbase] Create a module called flink-sql-connector-hbase… URL: https://github.com/apache/flink/pull/9898#issuecomment-541648822 ## CI report: * d866c0af1e81ee0f1df132f8e3f564dbcd8faed4 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #7598: [FLINK-11333][protobuf] First-class serializer support for Protobuf types

flinkbot edited a comment on issue #7598: [FLINK-11333][protobuf] First-class serializer support for Protobuf types URL: https://github.com/apache/flink/pull/7598#issuecomment-538572354 ## CI report: * 35cb722954d3f608e5b4b0ad02f4e3570ad858cd Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10400: [FLINK-13195][sql-client] Add create table support for SqlClient

flinkbot edited a comment on issue #10400: [FLINK-13195][sql-client] Add create table support for SqlClient URL: https://github.com/apache/flink/pull/10400#issuecomment-561176735 ## CI report: * 51df4df726cfc6e077a08168c7b93c48b7d154e1 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #9648: [FLINK-13872] [docs-zh] Translate Operations Playground to Chinese

flinkbot edited a comment on issue #9648: [FLINK-13872] [docs-zh] Translate Operations Playground to Chinese URL: https://github.com/apache/flink/pull/9648#issuecomment-529346361 ## CI report: * 6def0e035c5e7f442e45a00f1f7628726aef42eb Travis:

[GitHub] [flink] flinkbot edited a comment on issue #6075: [FLINK-9407] [hdfs connector] Support orc rolling sink writer

flinkbot edited a comment on issue #6075: [FLINK-9407] [hdfs connector] Support orc rolling sink writer URL: https://github.com/apache/flink/pull/6075#issuecomment-551549608 ## CI report: * 3f5021b5d8c701f4ab35080ac71fcc8c347c Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10151: [FLINK-14231] Handle the processing-time timers when closing operators to make endInput semantics on the operator chain strict

flinkbot edited a comment on issue #10151: [FLINK-14231] Handle the processing-time timers when closing operators to make endInput semantics on the operator chain strict URL: https://github.com/apache/flink/pull/10151#issuecomment-552442468 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #9392: [FLINK-13611] [table-planner-blink] Introduce statistic generator utility to generate table & column statistics

flinkbot edited a comment on issue #9392: [FLINK-13611] [table-planner-blink] Introduce statistic generator utility to generate table & column statistics URL: https://github.com/apache/flink/pull/9392#issuecomment-519408914 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #8371: [FLINK-9679] - Add AvroSerializationSchema

flinkbot edited a comment on issue #8371: [FLINK-9679] - Add AvroSerializationSchema URL: https://github.com/apache/flink/pull/8371#issuecomment-517485163 ## CI report: * 6258756f25cfcd1fc1cc10e3b05a4ef3d612fd81 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #9914: [FLINK-14414][table-common] Support string serializable for SymbolType

flinkbot edited a comment on issue #9914: [FLINK-14414][table-common] Support string serializable for SymbolType URL: https://github.com/apache/flink/pull/9914#issuecomment-542738970 ## CI report: * 54350ad1562aab4c8eb35c3bd70e79cbc8a52511 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #9398: [FLINK-13479] [flink-cassandra-connector] Fix for Deterministic ordering for prepared statement

flinkbot edited a comment on issue #9398: [FLINK-13479] [flink-cassandra-connector] Fix for Deterministic ordering for prepared statement URL: https://github.com/apache/flink/pull/9398#issuecomment-519727123 ## CI report: * 08e406e0565f2f945437c4baeebbf0a6c4489ff3 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10411: [FLINK-15048][yarn] Properly set internal.jobgraph-path when deploy job cluster

flinkbot edited a comment on issue #10411: [FLINK-15048][yarn] Properly set internal.jobgraph-path when deploy job cluster URL: https://github.com/apache/flink/pull/10411#issuecomment-561509408 ## CI report: * 7a1e34a7131c23b5d512d6e6eddbcaea40b3a0e1 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10409: [FLINK-14918] [flink-end-to-end-perf-tests] Add performance e2e test module and scripts

flinkbot edited a comment on issue #10409: [FLINK-14918] [flink-end-to-end-perf-tests] Add performance e2e test module and scripts URL: https://github.com/apache/flink/pull/10409#issuecomment-561453485 ## CI report: * e34bce658ca4eaaf7ee2227007238e35a55bce37 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10423: [FLINK-14378][state] Cleanup rocksDB lib folder if fail to load library

flinkbot edited a comment on issue #10423: [FLINK-14378][state] Cleanup rocksDB lib folder if fail to load library URL: https://github.com/apache/flink/pull/10423#issuecomment-561775866 ## CI report: * 21086222a729879f4a3b58be52d8095fc81c2544 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #9897: [FLINK-14390][ml] Add class for SqlOperators, and add sql operations to AlgoOperator, BatchOperator and StreamOperator.

flinkbot edited a comment on issue #9897: [FLINK-14390][ml] Add class for SqlOperators, and add sql operations to AlgoOperator, BatchOperator and StreamOperator. URL: https://github.com/apache/flink/pull/9897#issuecomment-541648779 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #10415: [FLINK-15049][table-planner-blink] Compile error when hash join with …

flinkbot edited a comment on issue #10415: [FLINK-15049][table-planner-blink] Compile error when hash join with … URL: https://github.com/apache/flink/pull/10415#issuecomment-561528911 ## CI report: * e838831b098e3043b6576aec5ba38ee6bdc29422 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10155: [FLINK-14596][table] Update MapView and ListView interface to new type system

flinkbot edited a comment on issue #10155: [FLINK-14596][table] Update MapView and ListView interface to new type system URL: https://github.com/apache/flink/pull/10155#issuecomment-552734095 ## CI report: * de48b2b764d089ee987c1fb12d0831715ebf02ca Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10408: [FLINK-14992][client] Add job listener to execution environments

flinkbot edited a comment on issue #10408: [FLINK-14992][client] Add job listener to execution environments URL: https://github.com/apache/flink/pull/10408#issuecomment-561446399 ## CI report: * 26dba18b2fd51c8df67cc33eace890b5ca34e182 Travis:

[jira] [Updated] (FLINK-9953) Active Kubernetes integration

[ https://issues.apache.org/jira/browse/FLINK-9953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-9953: - Description: This is the umbrella issue tracking Flink's active Kubernetes integration. Active means in

[GitHub] [flink] flinkbot edited a comment on issue #10142: [FLINK-13095][state-processor-api] Provide an easy way to read / bootstrap window state using the State Processor API

flinkbot edited a comment on issue #10142: [FLINK-13095][state-processor-api] Provide an easy way to read / bootstrap window state using the State Processor API URL: https://github.com/apache/flink/pull/10142#issuecomment-552144134 ## CI report: *

  1   2   3   4   5   6   7   8   >