dev@flink.apache.org, 2018-11

You are viewing a plain text version of this content. The canonical link for it is here.

- [jira] [Created] (FLINK-10745) Improve record writer and serializer stack - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2018/11/01 08:57:00 UTC, 0 replies.
- [DISCUSS] Enhancing the functionality and productivity of Table API - posted by jincheng sun <su...@gmail.com> on 2018/11/01 09:07:07 UTC, 35 replies.
- 回复：[DISCUSS] Proposal of external shuffle service - posted by zhijiang <wa...@aliyun.com.INVALID> on 2018/11/01 09:18:56 UTC, 1 replies.
- Re: [DISCUSS] Change underlying Frontend Architecture for Flink Web Dashboard - posted by Yadong Xie <vt...@gmail.com> on 2018/11/01 09:28:27 UTC, 10 replies.
- Re: [DISCUSS] FLIP-27: Refactor Source Interface - posted by Piotr Nowojski <pi...@data-artisans.com> on 2018/11/01 10:07:56 UTC, 40 replies.
- Re: Flip23 - posted by Till Rohrmann <tr...@apache.org> on 2018/11/01 10:26:24 UTC, 2 replies.
- Re: Sharing state between subtasks - posted by Till Rohrmann <tr...@apache.org> on 2018/11/01 10:32:38 UTC, 1 replies.
- [jira] [Created] (FLINK-10746) Need to replace transfer.sh for Travis log upload because it shuts down - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/11/01 10:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10747) CoGroupConnectedComponentsITCase deadlocked on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/11/01 10:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10748) Jobmanager in HA setup redirects to ip address instead of hostname - posted by "Jeroen Steggink (JIRA)" <ji...@apache.org> on 2018/11/01 10:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10749) GraphOperationsITCase deadlocks on travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/11/01 11:55:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink-shaded 5.0 released - posted by Chesnay Schepler <ch...@apache.org> on 2018/11/01 12:00:48 UTC, 0 replies.
- [jira] [Created] (FLINK-10750) SocketClientSinkTest.testRetry fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/11/01 13:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10751) Checkpoints should be retained when job reaches suspended state - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2018/11/01 14:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10752) Result of AbstractYarnClusterDescriptor#validateClusterResources is ignored - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/11/01 14:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10753) Propagate and log snapshotting exceptions - posted by "Alexander Fedulov (JIRA)" <ji...@apache.org> on 2018/11/01 15:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10754) Update Jepsen tests to run with activated local recovery - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/11/01 15:50:00 UTC, 0 replies.
- Re: [DISCUSS] Integrate Flink SQL well with Hive ecosystem - posted by Bowen Li <bo...@gmail.com> on 2018/11/01 17:17:35 UTC, 12 replies.
- [jira] [Created] (FLINK-10755) Port external catalogs in Table API extension points to flink-table-common - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/11/01 21:13:00 UTC, 0 replies.
- Re: Flink operators for Kubernetes - posted by Anand Swaminathan <as...@lyft.com.INVALID> on 2018/11/02 00:15:44 UTC, 1 replies.
- Re: Demo of the K8S Flink Operator at the K8s Big Data SIG - posted by Anand Swaminathan <as...@lyft.com.INVALID> on 2018/11/02 00:19:32 UTC, 0 replies.
- [jira] [Created] (FLINK-10756) TaskManagerProcessFailureBatchRecoveryITCase did not finish on time - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/11/02 00:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10757) TaskManagerProcessFailureStreamingRecoveryITCase failed to initialize the cluster entrypoint StandaloneSessionClusterEntrypoint. - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/11/02 00:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10758) Refactor TableEnvironment so that all registration calls delegate to CatalogManager - posted by "Xuefu Zhang (JIRA)" <ji...@apache.org> on 2018/11/02 04:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10759) Adapt SQL-client configuration file to specify external catalogs and default catalog - posted by "Xuefu Zhang (JIRA)" <ji...@apache.org> on 2018/11/02 04:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10760) Create a command line tool to migrate meta objects specified in SQL client configuration - posted by "Xuefu Zhang (JIRA)" <ji...@apache.org> on 2018/11/02 04:55:00 UTC, 0 replies.
- Why dont't have a csv formatter for kafka table source - posted by Jocean shi <jo...@gmail.com> on 2018/11/02 05:43:25 UTC, 1 replies.
- [DISCUSS] Flink SQL DDL Design - posted by Shuyi Chen <su...@gmail.com> on 2018/11/02 05:56:53 UTC, 19 replies.
- Re: Please please please review : Re: PubSub connector (FLINK-9311) - posted by Niels Basjes <ni...@basj.es> on 2018/11/02 07:23:51 UTC, 2 replies.
- [jira] [Created] (FLINK-10761) MetricGroup#getAllVariables can deadlock - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/11/02 12:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10762) Do not try to request partitions in SingleInputGate per getRecord - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/11/02 12:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10763) Cannot union streams of different types in the union method of DataStream class - posted by "wangjinhai (JIRA)" <ji...@apache.org> on 2018/11/02 14:51:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10764) Add S3 entropy injection end-to-end/IT test - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/11/02 14:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10765) Modify one of the s3 tests to use the Presto S3 s3p schema - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/11/02 15:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10766) Add a link to flink-china.org in Flink website - posted by "Jark Wu (JIRA)" <ji...@apache.org> on 2018/11/02 15:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10767) Update compatibility table for Flink 1.7 - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/11/02 15:19:00 UTC, 0 replies.
- [DISCUSS]Enhancing flink scheduler by implementing blacklist mechanism - posted by yingjie <ke...@gmail.com> on 2018/11/02 15:51:32 UTC, 7 replies.
- [jira] [Created] (FLINK-10768) Move Calcite related code from TableEnvironment to CatalogManager - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/11/02 21:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10769) port InMemoryExternalCatalog to java - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/11/03 05:01:00 UTC, 0 replies.
- [ANNOUNCE] Release branch 1.7 has been created - posted by Till Rohrmann <tr...@apache.org> on 2018/11/03 11:15:18 UTC, 0 replies.
- [jira] [Created] (FLINK-10770) Some generated functions are not opened properly. - posted by "wangsan (JIRA)" <ji...@apache.org> on 2018/11/03 11:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10771) Replace hard code of job graph file path with config option for FileJobGraphRetriever - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/11/04 12:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10772) create_binary_release.sh is broken - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/11/04 17:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10773) Resume externalized checkpoint end-to-end test fails - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/11/04 18:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10774) connection leak when partition discovery is disabled and open throws exception - posted by "Steven Zhen Wu (JIRA)" <ji...@apache.org> on 2018/11/04 18:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10775) Quarantined address [akka.tcp://flink@flink-jobmanager:6123] is still unreachable or has not been restarted. Keeping it quarantined. - posted by "ChuanHaiTan (JIRA)" <ji...@apache.org> on 2018/11/05 08:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10776) Update migration tests for Flink 1.7 - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/11/05 08:38:01 UTC, 0 replies.
- [jira] [Created] (FLINK-10777) Update TypeSerializerSnapshotMigrationITCase for Flink 1.7 - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/11/05 08:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10778) Update TypeSerializerSnapshotMigrationTestBase and subclasses for 1.7 - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/11/05 08:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10779) Update Java / Scala StatefulJobSavepointMigrationITCase for 1.7 - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/11/05 08:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10780) Update Java / Scala StatefulJobWBroadcastStateMigrationITCase for 1.7 - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/11/05 08:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10781) Update BucketingSinkMigrationTest for Flink 1.7 - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/11/05 08:48:01 UTC, 0 replies.
- [jira] [Created] (FLINK-10783) Update WindowOperatorMigrationTest for 1.7 - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/11/05 08:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10782) Update AbstractKeyedOperatorRestoreTestBase for 1.7 - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/11/05 08:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10784) Update FlinkKafkaConsumerBaseMigrationTest for 1.7 - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/11/05 08:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10785) Update FlinkKinesisConsumerMigrationTest for 1.7 - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/11/05 08:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10786) Update CEPMigrationTest for 1.7 - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/11/05 08:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10787) Update AbstractNonKeyedOperatorRestoreTestBase for 1.7 - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/11/05 08:55:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10788) Update ContinuousFileProcessingMigrationTest for 1.7 - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/11/05 08:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10789) Some new serializer snapshots added after 1.6 are not implementing the new TypeSerializerSnapshot interface - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/11/05 09:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10790) Refactor all the StreamPartitioner implementations into runtime module - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2018/11/05 09:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10791) Provide end-to-end test for Kafka 0.11 connector - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/11/05 09:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10792) Extend SQL client end-to-end to test KafkaTableSink for kafka 0.11 connector - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/11/05 09:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10793) Change visibility of TtlValue and TtlSerializer to public for external tools - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/11/05 10:34:01 UTC, 0 replies.
- [jira] [Created] (FLINK-10794) Do not create checkpointStorage when checkpoint is disabled - posted by "Congxian Qiu (JIRA)" <ji...@apache.org> on 2018/11/05 12:10:00 UTC, 0 replies.
- [DISCUSS] Table API Enhancement Outline - posted by Xiaowei Jiang <xi...@gmail.com> on 2018/11/05 12:45:46 UTC, 38 replies.
- [jira] [Created] (FLINK-10795) STDDEV_POP error - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2018/11/05 13:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10796) Add a default external catalog (as FlinkInMemoryCatalog) to CatalogManager - posted by "Bowen Li (JIRA)" <ji...@apache.org> on 2018/11/05 20:34:00 UTC, 0 replies.
- [VOTE] Release 1.7.0, release candidate #1 - posted by Till Rohrmann <tr...@apache.org> on 2018/11/05 21:26:48 UTC, 9 replies.
- [jira] [Created] (FLINK-10797) "IntelliJ Setup" link is broken in Readme.md - posted by "Xiening Dai (JIRA)" <ji...@apache.org> on 2018/11/05 23:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10798) Add the version number of Flink 1.7 to MigrationVersion - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/11/06 02:35:00 UTC, 0 replies.
- [DISCUSS] Task speculative execution for Flink batch - posted by Tao Yangyu <ry...@gmail.com> on 2018/11/06 03:00:49 UTC, 9 replies.
- Confluence permission for FLIP creation - posted by "Zhang, Xuefu" <xu...@alibaba-inc.com> on 2018/11/06 03:09:26 UTC, 1 replies.
- 回复：[DISCUSS] Task speculative execution for Flink batch - posted by zhijiang <wa...@aliyun.com.INVALID> on 2018/11/06 03:28:43 UTC, 0 replies.
- [jira] [Created] (FLINK-10799) YARN mode JobManager JVM memory args add -XmsXXXm - posted by "xinchun (JIRA)" <ji...@apache.org> on 2018/11/06 03:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10800) Abstract the StreamPartitionerTest for common codes - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2018/11/06 06:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10801) Fix sql client integrate elasticsearch connector test failure - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/11/06 09:37:02 UTC, 0 replies.
- [jira] [Created] (FLINK-10802) Add metrics on vertex in job graph picture show - posted by "lining (JIRA)" <ji...@apache.org> on 2018/11/06 10:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10803) Add documentation about S3 support by the StreamingFileSink - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/11/06 10:15:00 UTC, 0 replies.
- Re: [DISCUSS] Flink Cluster Overview Dashboard Improvement Proposal - posted by lining jing <ji...@gmail.com> on 2018/11/06 10:37:31 UTC, 2 replies.
- [jira] [Created] (FLINK-10804) Transfer suppressed exceptions with SerializedThrowable - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/11/06 13:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10805) test_confluent_schema_registry.sh and test_sql_client.sh end-to-end test broken - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/11/06 15:02:00 UTC, 0 replies.
- [ANNOUNCE] Weekly community update #45 - posted by Till Rohrmann <tr...@apache.org> on 2018/11/06 16:39:06 UTC, 0 replies.
- JIRA assignment - posted by Joey Echeverria <jo...@gmail.com> on 2018/11/06 18:25:24 UTC, 6 replies.
- [jira] [Created] (FLINK-10806) Support consume from earliest offset with a new topic - posted by "Jiayi Liao (JIRA)" <ji...@apache.org> on 2018/11/07 03:41:01 UTC, 0 replies.
- [jira] [Created] (FLINK-10807) KafkaConsumer still consume removed topic after changing topics list - posted by "Jiayi Liao (JIRA)" <ji...@apache.org> on 2018/11/07 07:21:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10808) Consolidate master e2e branches - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/11/07 08:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10809) Using DataStreamUtils.reinterpretAsKeyedStream produces corrupted keyed state after restore - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/11/07 09:37:00 UTC, 0 replies.
- Replace email address destination - posted by florent tragni <fl...@precodata.com> on 2018/11/07 11:29:15 UTC, 1 replies.
- [jira] [Created] (FLINK-10810) Update DataStreamUtils.reinterpretAsKeyedStream to state limitations - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/11/07 11:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10811) Hcatalog modules needs scala suffix - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/11/07 11:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10812) Snapshot deployment broken for master - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/11/07 13:12:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10813) Automatically seach for missing scala suffixes - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/11/07 14:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10814) Kafka examples modules need scala suffix - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/11/07 14:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10815) Rethink the rescale operation, can we do it async - posted by "Shimin Yang (JIRA)" <ji...@apache.org> on 2018/11/07 16:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10816) Fix LockableTypeSerializer.duplicate() - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/11/07 16:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10817) Upgrade presto dependency to support path-style access - posted by "Adam Lamar (JIRA)" <ji...@apache.org> on 2018/11/07 20:39:00 UTC, 0 replies.
- StreamingFileSink Bug? Committing results on stream close - posted by Addison Higham <ad...@gmail.com> on 2018/11/07 22:38:41 UTC, 2 replies.
- [DISCUSS]Rethink the rescale operation, can we do it async - posted by shimin yang <ys...@gmail.com> on 2018/11/08 02:13:22 UTC, 1 replies.
- [jira] [Created] (FLINK-10818) RestartStrategies.fixedDelayRestart Occur NoResourceAvailableException: Not enough free slots available to run the job. - posted by "ambition (JIRA)" <ji...@apache.org> on 2018/11/08 03:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10819) The instability problem of CI, JobManagerHAProcessFailureRecoveryITCase.testDispatcherProcessFailure test fail. - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2018/11/08 03:35:00 UTC, 0 replies.
- Kinesis consumer e2e test - posted by Thomas Weise <th...@apache.org> on 2018/11/08 05:38:06 UTC, 5 replies.
- [jira] [Created] (FLINK-10820) Simplify the RebalancePartitioner implementation - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2018/11/08 06:01:00 UTC, 0 replies.
- how get job id which job run slot - posted by lining jing <ji...@gmail.com> on 2018/11/08 07:20:46 UTC, 1 replies.
- [jira] [Created] (FLINK-10821) Resuming Externalized Checkpoint E2E test does not Resume from Externalized Checkpoint - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/11/08 07:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10822) Configurable MetricQueryService interval - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/11/08 09:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10823) Missing scala suffixes - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/11/08 09:58:01 UTC, 0 replies.
- [jira] [Created] (FLINK-10824) Compile Flink unit test failed with 1.6.0 branch - posted by "Hongtao Zhang (JIRA)" <ji...@apache.org> on 2018/11/08 10:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10825) ConnectedComponents test instable on Travis - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/11/08 10:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10826) Heavy deployment end-to-end test produces no output on Travis - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/11/08 10:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10827) Add test for duplicate() to SerializerTestBase - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/11/08 11:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10828) Enforce that all TypeSerializers are tested through SerializerTestBase - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/11/08 11:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10829) Extend FlinkDistribution to support running jars - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/11/08 14:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10830) Consider making processing time provider pluggable - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/11/08 14:13:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10831) Consider making processing time monotonically increasing by default - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/11/08 14:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10832) StreamExecutionEnvironment.execute() does not return when all sources end - posted by "Arnaud Linz (JIRA)" <ji...@apache.org> on 2018/11/08 14:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10833) FlinkKafkaProducerITCase.testFlinkKafkaProducerFailTransactionCoordinatorBeforeNotify failed on Travis - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/11/08 15:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10834) TableAPI flatten calculated value error - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2018/11/09 03:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10835) Remove duplicated Round-robin ChannelSelector implementation in RecordWriterTest - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2018/11/09 03:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10836) Add repositories and pluginRepositories in root pom.xml - posted by "bjkonglu (JIRA)" <ji...@apache.org> on 2018/11/09 06:38:00 UTC, 0 replies.
- FLINK-9523, PR #6672 - posted by Mikhail Sokolov <m....@gmail.com> on 2018/11/09 08:47:10 UTC, 0 replies.
- [jira] [Created] (FLINK-10837) Kafka 2.0 test KafkaITCase.testOneToOneSources dead locked on deleteTestTopic? - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/11/09 08:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10838) Rewrite Kafka tests that fail Kafka brokers - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/11/09 10:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10839) Fix implementation of PojoSerializer.duplicate() w.r.t. subclass serializer - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/11/09 11:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10840) BucketingSink incorrectly clears the pendingFiles List - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/11/09 12:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10841) Reduce the number of ListObjects calls when checkpointing to S3 - posted by "Pawel Bartoszek (JIRA)" <ji...@apache.org> on 2018/11/09 13:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10842) Waiting loops are broken in e2e/common.sh - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/11/09 13:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10843) Make Kafka version definition more flexible for new Kafka table factory - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/11/09 13:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10844) ArrayIndexOutOfBoundsException during checkpoint (Flink 1.5.2) - posted by "Daniel Harper (JIRA)" <ji...@apache.org> on 2018/11/09 14:43:01 UTC, 0 replies.
- [jira] [Created] (FLINK-10845) Support DISTINCT aggregates for batch - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/11/09 16:14:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10846) Add support for IS DISTINCT FROM in code generator - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/11/09 16:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10847) Add support for IS NOT DISTINCT FROM in code generator - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/11/09 16:20:00 UTC, 0 replies.
- How to use RocksDBStateBackend predefined options - posted by Thomas Weise <th...@apache.org> on 2018/11/09 17:07:40 UTC, 6 replies.
- [jira] [Created] (FLINK-10848) Flink's Yarn ResourceManager can allocate too many excess containers - posted by "Shuyi Chen (JIRA)" <ji...@apache.org> on 2018/11/11 07:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10849) The flink Metric has no data when two or more fliter operators are used - posted by "WuXiZao (JIRA)" <ji...@apache.org> on 2018/11/12 03:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10850) Job may hang on FAILING state if taskmanager updateTaskExecutionState failed - posted by "ouyangzhe (JIRA)" <ji...@apache.org> on 2018/11/12 09:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10851) sqlUpdate support complex insert grammar - posted by "frank wang (JIRA)" <ji...@apache.org> on 2018/11/12 10:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10852) Decremented number of unfinished producers below 0. This is most likely a bug in the execution state/intermediate result partition management - posted by "ouyangzhe (JIRA)" <ji...@apache.org> on 2018/11/12 11:09:00 UTC, 0 replies.
- REST job submission - posted by Flavio Pompermaier <po...@okkam.it> on 2018/11/12 11:50:17 UTC, 2 replies.
- [jira] [Created] (FLINK-10853) Provide end-to-end test for Kafka 0.9 connector - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/11/12 12:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10854) Provide end-to-end test for Kafka 0.8 connector - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/11/12 12:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10855) CheckpointCoordinator does not delete checkpoint directory of late/failed checkpoints - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/11/12 16:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10856) Harden resume from externalized checkpoint E2E test - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/11/12 16:06:03 UTC, 0 replies.
- Memory size for network buffers - posted by Thomas Weise <th...@apache.org> on 2018/11/13 05:11:14 UTC, 1 replies.
- [jira] [Created] (FLINK-10857) Conflict between JMX and Prometheus Metrics reporter - posted by "Truong Duc Kien (JIRA)" <ji...@apache.org> on 2018/11/13 07:18:00 UTC, 0 replies.
- 回复：Memory size for network buffers - posted by zhijiang <wa...@aliyun.com.INVALID> on 2018/11/13 07:38:35 UTC, 1 replies.
- [jira] [Created] (FLINK-10858) Create Angular Scaffold in Flink Dashboard - posted by "Yadong Xie (JIRA)" <ji...@apache.org> on 2018/11/13 09:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10859) Queryable state (rocksdb) end-to-end test fails on Travis - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/11/13 09:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10860) java.lang.ArrayIndexOutOfBoundsException Error reading state - posted by "JC (JIRA)" <ji...@apache.org> on 2018/11/13 09:53:00 UTC, 0 replies.
- Flink sql joined with dimtable from mysql - posted by yelun <98...@qq.com> on 2018/11/13 10:08:14 UTC, 0 replies.
- [jira] [Created] (FLINK-10861) Kafka e2e test fails during tearing down - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/11/13 10:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10862) REST API does not show program descriptions of "simple" ProgramDescription - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2018/11/13 11:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10863) Assign uids to all operators - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/11/13 11:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10864) Support multiple Main classes per jar - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2018/11/13 11:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10865) Implement Flink's own Aliyun OSS filesystem - posted by "wujinhu (JIRA)" <ji...@apache.org> on 2018/11/13 12:18:00 UTC, 0 replies.
- Apply for Contributor Permission - posted by Shuiqiang Chen <ac...@gmail.com> on 2018/11/13 13:09:14 UTC, 6 replies.
- Re: Flink sql joined with dimtable from mysql - posted by Xiaowei Jiang <xi...@gmail.com> on 2018/11/13 13:49:19 UTC, 1 replies.
- [jira] [Created] (FLINK-10866) Queryable state can prevent cluster from starting - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/11/13 14:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10867) Add a DataSet-based CacheOperator to reuse results between jobs - posted by "Miguel E. Coimbra (JIRA)" <ji...@apache.org> on 2018/11/13 17:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10868) Flink's Yarn ResourceManager doesn't use yarn.maximum-failed-containers as limit of resource acquirement - posted by "Zhenqiu Huang (JIRA)" <ji...@apache.org> on 2018/11/13 17:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10869) Update S3 testing settings - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/11/13 17:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10870) Reconstruct Flink Dashboard Overview Module to Angular 7.0 - posted by "Yadong Xie (JIRA)" <ji...@apache.org> on 2018/11/14 03:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10871) ExecutionEnvironment & TableEnvironment should be singleton - posted by "Jeff Zhang (JIRA)" <ji...@apache.org> on 2018/11/14 04:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10872) Extend SQL client end-to-end to test KafkaTableSink for kafka connector 0.11 - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/11/14 06:18:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10873) Remove tableEnv in DataSetConversions#toTable and DataStreamConversions#toTable - posted by "Jeff Zhang (JIRA)" <ji...@apache.org> on 2018/11/14 07:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10874) Kafka 2.0 connector testMigrateFromAtLeastOnceToExactlyOnce failure - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/11/14 08:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10875) Add `toTableWithTimestamp` method in `DataStreamConversions` - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2018/11/14 08:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10876) Deadlock if closing firstly pending transactions in FlinkKafkaProducer(011).close() - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/11/14 09:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10877) Remove duplicate dependency entries in kafka connector pom - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/11/14 10:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10878) State evolution E2E test failed on travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/11/14 10:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10879) Align Flink clients on env.execute() - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2018/11/14 11:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10880) Failover strategies should not be applied to Batch Execution - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2018/11/14 12:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10881) SavepointITCase deadlocks on travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/11/14 12:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10882) Misleading job/task state for scheduled jobs - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/11/14 13:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10883) Submitting a jobs without enough slots times out due to a unspecified timeout - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/11/14 13:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10884) Flink on yarn TM container will be killed by nodemanager because of the exceeded physical memory. - posted by "wgcn (JIRA)" <ji...@apache.org> on 2018/11/14 14:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10885) Avro Confluent Schema Registry E2E test failed on Travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/11/14 14:58:02 UTC, 0 replies.
- support/docs for compression in StreamingFileSink - posted by Addison Higham <ad...@gmail.com> on 2018/11/14 20:43:22 UTC, 2 replies.
- [jira] [Created] (FLINK-10886) Event time synchronization across sources - posted by "Jamie Grier (JIRA)" <ji...@apache.org> on 2018/11/14 21:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10887) Add source watermarking tracking to the JobMaster - posted by "Jamie Grier (JIRA)" <ji...@apache.org> on 2018/11/14 21:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10888) Expose new global watermark RPC to sources - posted by "Jamie Grier (JIRA)" <ji...@apache.org> on 2018/11/14 21:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10889) Semantic inconsistency between DataSet#print and DataStream#print - posted by "Jeff Zhang (JIRA)" <ji...@apache.org> on 2018/11/15 02:55:01 UTC, 0 replies.
- Need help with Kinesis related PRs - posted by Thomas Weise <th...@apache.org> on 2018/11/15 03:01:14 UTC, 0 replies.
- [jira] [Created] (FLINK-10890) CLONE - Add DataStream HBase Sink - posted by "jocean.shi@gamil.com (JIRA)" <ji...@apache.org> on 2018/11/15 06:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10891) Upgrade Kafka client version to 2.0.1 - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/11/15 06:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10892) Flink Yarn app name is hard coded - posted by "Jeff Zhang (JIRA)" <ji...@apache.org> on 2018/11/15 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10893) Streaming File Sink s3 end-to-end test failed on travis - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/11/15 08:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10894) Resuming Externalized Checkpoint (file, async, scale down) end-to-end test failed on travis - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/11/15 08:44:01 UTC, 0 replies.
- [jira] [Created] (FLINK-10895) TypeSerializerSnapshotMigrationITCase.testSavepoint test failed on travis - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/11/15 09:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10896) Extend state schema evolution support for more composite types - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/11/15 10:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10897) Support POJO state schema evolution - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2018/11/15 11:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10898) Add yarn.application-attempts-failures-validity-interval in YarnConfigOptions - posted by "xymaqingxiang (JIRA)" <ji...@apache.org> on 2018/11/15 12:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10899) Don't explicitly set version in flink-end-to-end-tests sub modules - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/11/15 12:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10900) Mark Kafka 2.0 connector as beta feature - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/11/15 13:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10901) Jobmanager REST ip binds to ip address instead of hostname - posted by "Jeroen Steggink (JIRA)" <ji...@apache.org> on 2018/11/15 15:52:01 UTC, 0 replies.
- [jira] [Created] (FLINK-10902) Jobmanager in HA setup communicates the ip address instead of hostnames - posted by "Jeroen Steggink (JIRA)" <ji...@apache.org> on 2018/11/15 16:04:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10903) Shade Internal Akka Dependencies - posted by "Luka Jurukovski (JIRA)" <ji...@apache.org> on 2018/11/15 17:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10904) Expose Classloader before Pipeline execution - posted by "Luka Jurukovski (JIRA)" <ji...@apache.org> on 2018/11/15 17:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10905) HadoopConfigLoader logs Credentials on DEBUG level - posted by "Konstantin Knauf (JIRA)" <ji...@apache.org> on 2018/11/15 18:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10906) docker-entrypoint.sh logs credentails during startup - posted by "Konstantin Knauf (JIRA)" <ji...@apache.org> on 2018/11/15 18:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10907) Job recovery on the same JobManager causes JobManager metrics to report stale values - posted by "Mark Cho (JIRA)" <ji...@apache.org> on 2018/11/15 20:45:01 UTC, 0 replies.
- [jira] [Created] (FLINK-10908) Add yarn.application.priority in YarnConfigOptions - posted by "xymaqingxiang (JIRA)" <ji...@apache.org> on 2018/11/16 10:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10909) Possible RocksDBStateBackend performance regression with rocksdbjni-5.7.5 - posted by "Mohamed Amine ABDESSEMED (JIRA)" <ji...@apache.org> on 2018/11/16 10:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10910) Harden Kubernetes e2e test - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/11/16 15:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10911) Flink's flink-scala-shell is not working with Scala 2.12 - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/11/16 17:47:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10912) Configurable RocksDBStateBackend options factory - posted by "Thomas Weise (JIRA)" <ji...@apache.org> on 2018/11/16 18:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10913) ExecutionGraphRestartTest.testRestartAutomatically unstable on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/11/17 10:42:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10914) Prefer notifying status changed to waiting and checking in ExecutionGraph tests - posted by "TisonKun (JIRA)" <ji...@apache.org> on 2018/11/17 12:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10915) clojure context.collectWithTimestamp Will be blocked. - posted by "fengge (JIRA)" <ji...@apache.org> on 2018/11/17 14:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10916) Include duplicated user-specified uid into error message - posted by "Kirill Mikheev (JIRA)" <ji...@apache.org> on 2018/11/18 09:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10917) Bump up the version of codahale's metrics-core to 3.2.3 or higher - posted by "Dongwon Kim (JIRA)" <ji...@apache.org> on 2018/11/18 09:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10918) incremental Keyed state with RocksDB throws cannot create directory error in windows - posted by "Amit (JIRA)" <ji...@apache.org> on 2018/11/18 09:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10919) Flink binary distribution too large - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/11/18 18:27:01 UTC, 0 replies.
- [jira] [Created] (FLINK-10920) Remove Kafka examples from binary distribution - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/11/18 18:38:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10921) Prioritize shard consumers in Kinesis Consumer by event time - posted by "Thomas Weise (JIRA)" <ji...@apache.org> on 2018/11/18 19:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10922) Refactor the placement of the Flink Kafka connector end to end test module - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/11/19 06:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10923) Make SlotPool Status Machine-Readable - posted by "Konstantin Knauf (JIRA)" <ji...@apache.org> on 2018/11/19 07:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10924) StreamExecutionEnvironment method javadocs incorrect in regards to used charset - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/11/19 08:22:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10925) NPE in PythonPlanStreamer - posted by "Karel Kolman (JIRA)" <ji...@apache.org> on 2018/11/19 09:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10926) Add TIMESTAMPDIFFmath function supported in Table API and SQL - posted by "xuqianjin (JIRA)" <ji...@apache.org> on 2018/11/19 10:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10927) Resuming Externalized Checkpoint (r, inc, up) test instable - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/11/19 11:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10928) Job unable to stabilise after restart - posted by "Daniel Harper (JIRA)" <ji...@apache.org> on 2018/11/19 11:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10929) Add support for Apache Arrow - posted by "Pedro Cardoso Silva (JIRA)" <ji...@apache.org> on 2018/11/19 12:11:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10930) Refactor checkpoint directory layout - posted by "Yun Tang (JIRA)" <ji...@apache.org> on 2018/11/19 12:20:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10931) Exclude transitive dependence on Kafka-client - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/11/19 16:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10932) Initial flink-kubernetes module with empty implementation - posted by "JIN SUN (JIRA)" <ji...@apache.org> on 2018/11/19 19:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10934) Implement KubernetesJobClusterEntrypoint - posted by "JIN SUN (JIRA)" <ji...@apache.org> on 2018/11/19 21:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10933) Implement KubernetesSessionClusterEntrypoint - posted by "JIN SUN (JIRA)" <ji...@apache.org> on 2018/11/19 21:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10935) Implement KubeClient with Faric8 Kubernetes clients - posted by "JIN SUN (JIRA)" <ji...@apache.org> on 2018/11/19 21:49:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10936) Implement Command line tools - posted by "JIN SUN (JIRA)" <ji...@apache.org> on 2018/11/19 21:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10937) Add scripts to create docker image for k8s - posted by "JIN SUN (JIRA)" <ji...@apache.org> on 2018/11/19 21:54:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10938) Enable Flink on native k8s E2E Tests in Travis CI - posted by "JIN SUN (JIRA)" <ji...@apache.org> on 2018/11/19 21:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10939) Add documents for Flink on native k8s - posted by "JIN SUN (JIRA)" <ji...@apache.org> on 2018/11/19 21:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10940) Refactor the maven dependencies of Kafka 0.8 connector - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/11/20 03:25:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10941) Slots prematurely released which still contain unconsumed data - posted by "Qi (JIRA)" <ji...@apache.org> on 2018/11/20 05:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10942) Deduplicate common codes in OutputEmitterTest - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2018/11/20 05:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10943) Flink runtime test failed caused by curator dependency conflicts - posted by "Paul Lin (JIRA)" <ji...@apache.org> on 2018/11/20 08:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10944) EventTimeWindowCheckpointingITCase.testTumblingTimeWindow failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/11/20 08:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10945) Avoid resource deadlocks for finite stream jobs when resources are limited - posted by "Zhu Zhu (JIRA)" <ji...@apache.org> on 2018/11/20 09:59:00 UTC, 0 replies.
- Apply for flink contributor permission - posted by Zhu Zhu <re...@gmail.com> on 2018/11/20 10:07:51 UTC, 10 replies.
- [jira] [Created] (FLINK-10946) Resuming Externalized Checkpoint (rocks, incremental, scale up) end-to-end test failed on Travis - posted by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/11/20 10:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10947) Document handling of null keys in the data types documentation - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2018/11/20 10:44:00 UTC, 0 replies.
- [DISCUSS] Embracing Table API in Flink ML - posted by Weihua Jiang <we...@gmail.com> on 2018/11/20 12:53:28 UTC, 8 replies.
- [jira] [Created] (FLINK-10948) Add option to write out termination message with application status - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2018/11/20 13:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10949) When use flink-1.6.2's intervalJoin funtion, the thread is stucked in rockdb's seek for too long time - posted by "Liu (JIRA)" <ji...@apache.org> on 2018/11/20 13:27:01 UTC, 0 replies.
- [DISCUSS] Support Interactive Programming in Flink Table API - posted by Becket Qin <be...@gmail.com> on 2018/11/20 13:56:08 UTC, 38 replies.
- [jira] [Created] (FLINK-10950) RocksDB backend does not work on Windows due to path issue - posted by "Adam Laczynski (JIRA)" <ji...@apache.org> on 2018/11/20 14:30:00 UTC, 0 replies.
- [VOTE] Release 1.7.0, release candidate #2 - posted by Till Rohrmann <tr...@apache.org> on 2018/11/20 14:30:23 UTC, 7 replies.
- [ANNOUNCE] Weekly community update #47 - posted by Till Rohrmann <tr...@apache.org> on 2018/11/20 14:44:23 UTC, 0 replies.
- [jira] [Created] (FLINK-10951) Disable enforcing of YARN container virtual memory limits in tests - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/11/20 15:40:01 UTC, 0 replies.
- [jira] [Created] (FLINK-10952) How to stream MySQl data and Store in Flink Dataset - posted by "vinoth (JIRA)" <ji...@apache.org> on 2018/11/20 15:49:00 UTC, 0 replies.
- 回复：[DISCUSS] Embracing Table API in Flink ML - posted by Yun Gao <yu...@aliyun.com.INVALID> on 2018/11/20 16:35:59 UTC, 0 replies.
- [jira] [Created] (FLINK-10953) InterruptedException on KafkaProducer - posted by "Avi Levi (JIRA)" <ji...@apache.org> on 2018/11/20 16:40:00 UTC, 0 replies.
- [ANNOUNCE] Flink Forward San Francisco Call for Presentations closes soon - posted by Fabian Hueske <fh...@gmail.com> on 2018/11/20 16:57:31 UTC, 0 replies.
- [jira] [Created] (FLINK-10954) Hardlink from files of previous local stored state might cross devices - posted by "Yun Tang (JIRA)" <ji...@apache.org> on 2018/11/20 17:15:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10955) Extend release notes for Flink 1.7 - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/11/20 17:25:00 UTC, 0 replies.
- Question: Flink JIRA issues for simple code comment improvements - posted by Miguel Coimbra <mi...@gmail.com> on 2018/11/20 17:59:28 UTC, 2 replies.
- [jira] [Created] (FLINK-10956) Reuse same rexCall during codegen - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/11/21 02:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10957) Adapt documents about DataStream to Table conversion - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/11/21 08:09:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10958) Add overload support for user defined function - posted by "Dian Fu (JIRA)" <ji...@apache.org> on 2018/11/21 08:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10959) most taskmanger in the same node - posted by "Yee (JIRA)" <ji...@apache.org> on 2018/11/21 09:47:00 UTC, 0 replies.
- JIRA notifications - posted by Maximilian Michels <mx...@apache.org> on 2018/11/21 11:03:10 UTC, 4 replies.
- [jira] [Created] (FLINK-10960) CEP: Job Failure when .times(2) is used - posted by "Thomas Wozniakowski (JIRA)" <ji...@apache.org> on 2018/11/21 11:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10961) RuntimeException: Could not extract key when using closure - posted by "Avi Levi (JIRA)" <ji...@apache.org> on 2018/11/21 12:10:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10962) Allow correlations between subtask metrics and checkpoint metrics - posted by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/11/21 12:19:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10963) Cleanup small objects uploaded to S3 as independent objects - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/11/21 14:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10964) sql-client throws exception when pagin through finished batch query - posted by "Seth Wiesman (JIRA)" <ji...@apache.org> on 2018/11/21 14:49:02 UTC, 0 replies.
- [jira] [Created] (FLINK-10965) suggest that change $resultTypeTerm to Object at org.apache.flink.table.codegen.calls.ScalarFunctionCallGen:104 - posted by "shaomeng.wang (JIRA)" <ji...@apache.org> on 2018/11/21 15:14:00 UTC, 0 replies.
- Spring boot and Apache flink - posted by Durga Durga <du...@gmail.com> on 2018/11/21 16:30:19 UTC, 1 replies.
- [jira] [Created] (FLINK-10966) Optimize the release blocking logic in BarrierBuffer - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/11/21 16:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10967) Update kafka dependency to 2.1.0 - posted by "Ismael Juma (JIRA)" <ji...@apache.org> on 2018/11/21 17:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10968) Implement TaskManager Entrypoint - posted by "JIN SUN (JIRA)" <ji...@apache.org> on 2018/11/21 19:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10969) expose API or metric for total number of keys stored in state backend - posted by "Steven Zhen Wu (JIRA)" <ji...@apache.org> on 2018/11/21 21:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10970) expose metric for total state size in terms of bytes - posted by "Steven Zhen Wu (JIRA)" <ji...@apache.org> on 2018/11/21 21:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10971) Dependency convergence issue when building flink-s3-fs-presto - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2018/11/21 22:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10972) Enhancements to Flink Table API - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2018/11/22 01:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10973) Add Map operator to Table API - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2018/11/22 02:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10974) Add FlatMap to TableAPI - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2018/11/22 02:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10975) Add support for TimeAttribute in Map/FlatMap operator - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2018/11/22 02:48:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10976) Add Aggregate operator to Table API - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2018/11/22 02:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10977) Add UnBounded FlatAggregate operator to streaming Table API - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2018/11/22 02:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10978) Add UnBounded FlatAggregate operator to batch Table API - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2018/11/22 02:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10979) Add support for group keys in Unbounded Aggregate/FlatAggregate operator - posted by "sunjincheng (JIRA)" <ji...@apache.org> on 2018/11/22 02:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10980) Wrong statement in CEP Scala part - posted by "DuBin (JIRA)" <ji...@apache.org> on 2018/11/22 03:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10981) Add or modify metrics to show the maximum usage of InputBufferPool/OutputBufferPool to help debugging back pressure - posted by "Yun Gao (JIRA)" <ji...@apache.org> on 2018/11/22 03:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10982) Test DataStream to Table for Flink 1.6.2 - posted by "YUZHOU HONG (JIRA)" <ji...@apache.org> on 2018/11/22 04:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10983) NonHAQueryableStateFsBackendITCase failed when run mvn install - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/11/22 05:34:00 UTC, 0 replies.
- Exit pattern matching - posted by Moiz Motorwala <mo...@gmail.com> on 2018/11/22 06:26:05 UTC, 1 replies.
- Re: [DISCUSS] Long-term goal of making flink-table Scala-free - posted by Timo Walther <tw...@apache.org> on 2018/11/22 09:54:42 UTC, 17 replies.
- [jira] [Created] (FLINK-10984) Move flink-shaded-hadoop to flink-shaded - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/11/22 10:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10985) Enable multiple Job Submission in distributed Tests - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/11/22 10:39:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10986) Jepsen: Deploy Kafka Broker - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/11/22 10:44:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10987) LICENSE and NOTICE files are not correct - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/11/22 12:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10988) Improve debugging / visibility of job state - posted by "Scott Sue (JIRA)" <ji...@apache.org> on 2018/11/22 16:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10989) OrcRowInputFormat uses two different file systems - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/11/22 16:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10990) Pre-check timespan in meterview to avoid NAN - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/11/22 16:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10991) Dockerfile in flink-container does not work with RocksDBStatebackend - posted by "Konstantin Knauf (JIRA)" <ji...@apache.org> on 2018/11/22 18:23:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10992) Jepsen: Do not use /tmp as HDFS Data Directory - posted by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/11/22 21:06:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10993) Bring bloomfilter as a public API - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/11/23 07:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10994) The bug of timestampadd handles time - posted by "xuqianjin (JIRA)" <ji...@apache.org> on 2018/11/23 07:28:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10995) Copy intermediate serialization results only once for broadcast mode - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2018/11/23 08:16:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10996) Enable state ttl in cep - posted by "aitozi (JIRA)" <ji...@apache.org> on 2018/11/23 08:50:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10997) Avro-confluent-registry does not bundle any dependency - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/11/23 11:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10998) flink-metrics-ganglia has LGPL dependency - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/11/23 14:30:00 UTC, 0 replies.
- [jira] [Created] (FLINK-10999) Adding time multiple times causes Runtime : java.sql.Timestamp cannot be cast to java.lang.Long - posted by "ideal-hp (JIRA)" <ji...@apache.org> on 2018/11/24 04:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11000) Introduce Resource Blacklist Mechanism - posted by "Yingjie Cao (JIRA)" <ji...@apache.org> on 2018/11/24 05:43:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11001) Window rowtime attribute can't be renamed in Java - posted by "Hequn Cheng (JIRA)" <ji...@apache.org> on 2018/11/24 09:43:00 UTC, 0 replies.
- 回复：JIRA notifications - posted by zhijiang <wa...@aliyun.com.INVALID> on 2018/11/26 03:15:37 UTC, 0 replies.
- [jira] [Created] (FLINK-11002) Trigger.clear() will not be called after purged window - posted by "Yuan Yifan (JIRA)" <ji...@apache.org> on 2018/11/26 06:07:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11003) Document of Java Lambda Expressions has a mistake - posted by "Yangze Guo (JIRA)" <ji...@apache.org> on 2018/11/26 12:24:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11004) Wrong ProcessWindowFunction.process argument in example of Incremental Window Aggregation with ReduceFunction - posted by "Yuanyang Wu (JIRA)" <ji...@apache.org> on 2018/11/26 13:01:00 UTC, 0 replies.
- Re: Creating a slide set for a Flink intro talk - posted by Fabian Hueske <fh...@gmail.com> on 2018/11/26 13:29:44 UTC, 0 replies.
- [jira] [Created] (FLINK-11005) Define flink-sql-client uber-jar dependencies via artifactSet - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/11/26 13:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11006) Update Calcite dependency to 1.18 - posted by "Rong Rong (JIRA)" <ji...@apache.org> on 2018/11/26 15:40:00 UTC, 0 replies.
- [DISCUSS] Flink backward compatibility - posted by Thomas Weise <th...@apache.org> on 2018/11/26 16:24:01 UTC, 4 replies.
- [jira] [Created] (FLINK-11007) Update documentation to describe new checkpoint metadata file behavior - posted by "Josh Lemer (JIRA)" <ji...@apache.org> on 2018/11/26 20:19:00 UTC, 0 replies.
- 回复：[DISCUSS]Enhancing flink scheduler by implementing blacklist mechanism - posted by zhijiang <wa...@aliyun.com.INVALID> on 2018/11/27 02:39:44 UTC, 0 replies.
- [jira] [Created] (FLINK-11008) Speed up upload checkpoint files using multi-thread - posted by "Congxian Qiu (JIRA)" <ji...@apache.org> on 2018/11/27 05:31:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11009) Add support for FILTER clause for non-windowed aggregation in Table API and SQL - posted by "Dian Fu (JIRA)" <ji...@apache.org> on 2018/11/27 05:56:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11010) Flink SQL timestamp is inconsistent with currentProcessingTime() - posted by "lamber-ken (JIRA)" <ji...@apache.org> on 2018/11/27 08:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11011) Elasticsearch 6 sink end-to-end test unstable - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/11/27 08:45:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11012) Introduce abstract superclass for filesystem IT cases - posted by "Stefan Richter (JIRA)" <ji...@apache.org> on 2018/11/27 09:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11013) Fix distinct aggregates for group window in Table API - posted by "Dian Fu (JIRA)" <ji...@apache.org> on 2018/11/27 14:02:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11014) Relocate flink-metrics-graphite's dropwizard dependencies - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/11/27 14:05:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11015) Remove deprecated methods and classes from all the Kafka connectors - posted by "vinoyang (JIRA)" <ji...@apache.org> on 2018/11/27 15:30:00 UTC, 0 replies.
- Apply for contributor permission - posted by Paul Lam <pa...@gmail.com> on 2018/11/28 03:25:17 UTC, 1 replies.
- Questions about UDTF in flink SQL - posted by wangsan <wa...@163.com> on 2018/11/28 08:59:41 UTC, 0 replies.
- [jira] [Created] (FLINK-11016) flink chain have a bug？？？ - posted by "Wong (JIRA)" <ji...@apache.org> on 2018/11/28 09:20:00 UTC, 0 replies.
- Custom scheduler in Flink - posted by Felipe Gutierrez <fe...@gmail.com> on 2018/11/28 09:21:41 UTC, 5 replies.
- [jira] [Created] (FLINK-11017) Time interval for window aggregations in SQL is wrongly translated if specified with YEAR_MONTH resolution - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2018/11/28 10:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11018) Flink ignores logback.xml - posted by "prathamesh (JIRA)" <ji...@apache.org> on 2018/11/28 11:37:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11019) Expose the queryable proxy server port in taskinfo api - posted by "Jiayi Liao (JIRA)" <ji...@apache.org> on 2018/11/28 11:41:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11020) Reorder joins only to eliminate cross joins - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/11/28 13:17:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11021) ZoneOffset objects don't appear to be serialized correctly - posted by "Christina (JIRA)" <ji...@apache.org> on 2018/11/28 14:46:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11022) Update LICENSE and NOTICE files for older releases - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/11/28 16:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11023) Update LICENSE and NOTICE files for flink-connectors - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/11/28 16:43:00 UTC, 0 replies.
- [VOTE] Release 1.7.0, release candidate #3 - posted by Till Rohrmann <tr...@apache.org> on 2018/11/29 00:01:10 UTC, 7 replies.
- [jira] [Created] (FLINK-11024) Overwrite yarn configuration by setting configuration started with "flink.yarn." in flink-conf.yaml - posted by "liuzhaokun (JIRA)" <ji...@apache.org> on 2018/11/29 06:24:00 UTC, 0 replies.
- Submitting job with savepoint through StreamExecutionEnvironment - posted by Thomas Weise <th...@apache.org> on 2018/11/29 07:18:33 UTC, 4 replies.
- Looking for relevant sources related to connecting Apache Flink and Edgent. - posted by Felipe Gutierrez <fe...@gmail.com> on 2018/11/29 09:23:13 UTC, 6 replies.
- [jira] [Created] (FLINK-11025) Connector shading is inconsistent - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/11/29 09:36:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11026) Rework creation of sql-client connector/format jars - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/11/29 09:58:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11027) JobManagerHAProcessFailureRecoveryITCase#testDispatcherProcessFailure failed on Travis - posted by "Kostas Kloudas (JIRA)" <ji...@apache.org> on 2018/11/29 11:08:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11028) Disable deployment of flink-fs-tests - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/11/29 12:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11029) Incorrect parameter in Working with state doc - posted by "Yangze Guo (JIRA)" <ji...@apache.org> on 2018/11/29 13:01:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11030) Cannot use Avro logical types with ConfluentRegistryAvroDeserializationSchema - posted by "Maciej Bryński (JIRA)" <ji...@apache.org> on 2018/11/29 13:40:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11031) How to consume the Hive data in Flink using Scala - posted by "Preethi.C (JIRA)" <ji...@apache.org> on 2018/11/29 14:57:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11032) Elasticsearch (v6.3.1) sink end-to-end test unstable on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/11/29 16:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11033) Elasticsearch (v6.3.1) sink end-to-end test unstable on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/11/29 16:34:00 UTC, 0 replies.
- [RESULT] [VOTE] Release 1.7.0, release candidate #3 - posted by Till Rohrmann <tr...@apache.org> on 2018/11/29 17:28:21 UTC, 3 replies.
- [jira] [Created] (FLINK-11034) Provide "rewriting config” to file system factory - posted by "Wei-Che Wei (JIRA)" <ji...@apache.org> on 2018/11/30 03:32:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11035) Notify data available to network stack immediately after finishing BufferBuilder - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2018/11/30 07:59:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11036) Streaming classloader end-to-end test does not work on source releases - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2018/11/30 08:26:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11037) Introduce another greedy mechanism for distributing floating buffers - posted by "zhijiang (JIRA)" <ji...@apache.org> on 2018/11/30 08:33:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11038) Rewrite Kafka at-least-once it cases - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/11/30 08:56:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.7.0 released - posted by Till Rohrmann <tr...@apache.org> on 2018/11/30 09:39:54 UTC, 3 replies.
- [jira] [Created] (FLINK-11039) LogicalExchange and HashPartitioner realization - posted by "ambition (JIRA)" <ji...@apache.org> on 2018/11/30 10:34:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11040) Incorrect generic type of DataStream in broadcast_state.md - posted by "Yangze Guo (JIRA)" <ji...@apache.org> on 2018/11/30 13:00:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11041) ReinterpretDataStreamAsKeyedStreamITCase.testReinterpretAsKeyedStream failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/11/30 13:27:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11042) testFlinkKafkaProducerFailTransactionCoordinatorBeforeNotify is an invalid test - posted by "Piotr Nowojski (JIRA)" <ji...@apache.org> on 2018/11/30 13:52:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11043) Website Flink logo broken on Firefox - posted by "Patrick Lucas (JIRA)" <ji...@apache.org> on 2018/11/30 13:53:00 UTC, 0 replies.
- [jira] [Created] (FLINK-11044) RegisterTableSink docs incorrect - posted by "Kenny Gorman (JIRA)" <ji...@apache.org> on 2018/11/30 21:33:00 UTC, 0 replies.