osdir.com

Mail Thread Index

• Date Index

[Prev Page][Next Page]

---

• [jira] [Created] (FLINK-10543) Leverage efficient timer deletion in relational operators, Fabian Hueske (JIRA)
• [jira] [Created] (FLINK-10542) Register Hive metastore as an external catalog in TableEnvironment, Xuefu Zhang (JIRA)
• Creating a slide set for a Flink intro talk, Fabian Hueske
  • <Possible follow-ups>
  • Re: Creating a slide set for a Flink intro talk, Shuyi Chen
  • Re: Creating a slide set for a Flink intro talk, jincheng sun
• [jira] [Created] (FLINK-10541) Removed unused code of LocalFlinkMiniCluster, TisonKun (JIRA)
• [jira] [Created] (FLINK-10540) Remove legacy LocalFlinkMiniCluster, TisonKun (JIRA)
• [jira] [Created] (FLINK-10539) Support specific namespace in QueryableStateClient, Jiayi Liao (JIRA)
• [jira] [Created] (FLINK-10538) standalone-job.sh causes Classpath issues, Razvan (JIRA)
• Re: Become a contributor, Zhang, Xuefu
• [jira] [Created] (FLINK-10537) Network throughput performance regression after broadcast changes, Piotr Nowojski (JIRA)
• Re: Become a contributor, Fabian Hueske
• [jira] [Created] (FLINK-10536) Flink Kinesis Consumer leading to job failure due to ProvisionedThroughputExceededException, Ravi Bhushan Ratnakar (JIRA)
• [jira] [Created] (FLINK-10535) User jar is present in the flink job manager's class path, yinhua.dai (JIRA)
• [jira] [Created] (FLINK-10534) Add idle timeout for a flink session cluster, ouyangzhe (JIRA)
• [jira] [Created] (FLINK-10533) job parallelism equals task slot number but not use all tasl slot, sean.miao (JIRA)
• Become a contributor, Zhang, Xuefu
• [jira] [Created] (FLINK-10532) Broken links in documentation, Chesnay Schepler (JIRA)
• Spreading Tasks across TaskManagers, Maximilian Michels
  • <Possible follow-ups>
  • Re: Spreading Tasks across TaskManagers, Till Rohrmann
  • Re: Spreading Tasks across TaskManagers, Thomas Weise
• [jira] [Created] (FLINK-10531) State TTL RocksDb backend end-to-end test end-to-end test failed on Travis, Till Rohrmann (JIRA)
• [jira] [Created] (FLINK-10530) ProcessFailureCancelingITCase.testCancelingOnProcessFailure failed on Travis., Kostas Kloudas (JIRA)
• [jira] [Created] (FLINK-10529) Add flink-s3-fs-base to the connectors in the travis stage file., Kostas Kloudas (JIRA)
• [jira] [Created] (FLINK-10528) Remove deprecated APIs from Table API for Flink 1.7.0, Fabian Hueske (JIRA)
• Re: [DISCUSS] Integrate Flink SQL well with Hive ecosystem, Zhang, Xuefu
  • <Possible follow-ups>
  • Re: [DISCUSS] Integrate Flink SQL well with Hive ecosystem, Zhang, Xuefu
  • Re: [DISCUSS] Integrate Flink SQL well with Hive ecosystem, Zhang, Xuefu
  • Re: [DISCUSS] Integrate Flink SQL well with Hive ecosystem, Zhang, Xuefu
  • Re: [DISCUSS] Integrate Flink SQL well with Hive ecosystem, Zhang, Xuefu
• [jira] [Created] (FLINK-10527) Cleanup constant isNewMode in YarnTestBase, vinoyang (JIRA)
• [jira] [Created] (FLINK-10526) Hadoop FileSystem not initialized properly on Yarn, Yan Yan (JIRA)
• [jira] [Created] (FLINK-10525) Deserialization schema, skip data, that couldn't be properly deserialized, Rinat Sharipov (JIRA)
• [jira] [Created] (FLINK-10524) HeartbeatManagerTest failed on travis, Chesnay Schepler (JIRA)
• [VOTE] Release flink-shaded 5.0, release candidate #1, Chesnay Schepler
  • <Possible follow-ups>
  • Re: [VOTE] Release flink-shaded 5.0, release candidate #1, Aljoscha Krettek
  • Re: [VOTE] Release flink-shaded 5.0, release candidate #1, Timo Walther
  • Re: [VOTE] Release flink-shaded 5.0, release candidate #1, Tzu-Li (Gordon) Tai
  • Re: [VOTE] Release flink-shaded 5.0, release candidate #1, vino yang
• [jira] [Created] (FLINK-10523) Add jackson-dataformat-csv to flink-shaded, Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-10522) Check if RecoverableWriter supportsResume and accordingly., Kostas Kloudas (JIRA)
• Re: [DISCUSS] Integrate Flink SQL well with Hive ecosystem, Fabian Hueske
  • <Possible follow-ups>
  • Re: [DISCUSS] Integrate Flink SQL well with Hive ecosystem, vino yang
  • Re: [DISCUSS] Integrate Flink SQL well with Hive ecosystem, Jörn Franke
  • Re: [DISCUSS] Integrate Flink SQL well with Hive ecosystem, Timo Walther
  • Re: [DISCUSS] Integrate Flink SQL well with Hive ecosystem, Rong Rong
  • Re: [DISCUSS] Integrate Flink SQL well with Hive ecosystem, Taher Koitawala
  • Re: [DISCUSS] Integrate Flink SQL well with Hive ecosystem, Taher Koitawala
  • Re: [DISCUSS] Integrate Flink SQL well with Hive ecosystem, Taher Koitawala
  • Re: [DISCUSS] Integrate Flink SQL well with Hive ecosystem, Jörn Franke
  • Re: [DISCUSS] Integrate Flink SQL well with Hive ecosystem, Bowen
  • Re: [DISCUSS] Integrate Flink SQL well with Hive ecosystem, Shuyi Chen
• [jira] [Created] (FLINK-10521) TaskManager metrics are not reported to prometheus after running a job, Florian Schmidt (JIRA)
• 回复：[DISCUSS] Flink Cluster Overview Dashboard Improvement Proposal, Zhijiang(wangzhijiang999)
• No data issued by flink window after a few hours, ? ??
• [jira] [Created] (FLINK-10520) Job save points REST API fails unless parameters are specified, Elias Levy (JIRA)
• [jira] [Created] (FLINK-10519) flink-parent:1.6.1 artifact can't be found on maven central, Florian Schmidt (JIRA)
• [DISCUSS] Integrate Flink SQL well with Hive ecosystem, Zhang, Xuefu
• [ANNOUNCE] Weekly community update #41, Till Rohrmann
• [jira] [Created] (FLINK-10518) Inefficient design in ContinuousFileMonitoringFunction, Huyen Levan (JIRA)
• [DISCUSS] Flink Cluster Overview Dashboard Improvement Proposal, Fabian Wollert
  • <Possible follow-ups>
  • Re: [DISCUSS] Flink Cluster Overview Dashboard Improvement Proposal, Fabian Wollert
  • Re: [DISCUSS] Flink Cluster Overview Dashboard Improvement Proposal, Till Rohrmann
  • Re: [DISCUSS] Flink Cluster Overview Dashboard Improvement Proposal, Jin Sun
  • Re: [DISCUSS] Flink Cluster Overview Dashboard Improvement Proposal, Robert Metzger
  • Re: [DISCUSS] Flink Cluster Overview Dashboard Improvement Proposal, Fabian Wollert
  • Re: [DISCUSS] Flink Cluster Overview Dashboard Improvement Proposal, Till Rohrmann
• [jira] [Created] (FLINK-10517) Add stability test for the REST API, Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-10516) YarnApplicationMasterRunner fail to initialize FileSystem with correct Flink Configuration during setup, Shuyi Chen (JIRA)
• 回复：[DISCUSS] [Contributing] (2) - Review Steps, Zhijiang(wangzhijiang999)
• [jira] [Created] (FLINK-10515) Improve tokenisation of program args passed as string, Andrey Zagrebin (JIRA)
• [jira] [Created] (FLINK-10514) change Tychyon to Alluxio, yangxiaoshuo (JIRA)
• [jira] [Created] (FLINK-10513) Replace TaskManagerActions#notifyFinalState with #updateTaskExecutionState, Till Rohrmann (JIRA)
• [jira] [Created] (FLINK-10512) Remove legacy REST API docs, Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-10511) Code duplication of creating RPC service in ClusterEntrypoint and AkkaRpcServiceUtils, Shimin Yang (JIRA)
• [jira] [Created] (FLINK-10510) Bump asm version to 6, Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-10509) Drop flink-storm, Chesnay Schepler (JIRA)
• [jira] [Created] (FLINK-10508) Port JobManagerITCase to new code base, tison (JIRA)
• Sharing state between subtasks, Thomas Weise
  • <Possible follow-ups>
  • Re: Sharing state between subtasks, Jamie Grier
  • Re: Sharing state between subtasks, Elias Levy
  • Re: Sharing state between subtasks, Aljoscha Krettek
  • Re: Sharing state between subtasks, Fabian Hueske
  • Re: Sharing state between subtasks, Elias Levy
  • Re: Sharing state between subtasks, Jamie Grier
  • Re: Sharing state between subtasks, Jamie Grier
  • Re: Sharing state between subtasks, Aljoscha Krettek
  • Re: Sharing state between subtasks, Elias Levy
  • Re: Sharing state between subtasks, Fabian Hueske
  • Re: Sharing state between subtasks, Thomas Weise
  • Re: Sharing state between subtasks, Elias Levy
  • Re: Sharing state between subtasks, Aljoscha Krettek
  • Re: Sharing state between subtasks, Till Rohrmann
• [jira] [Created] (FLINK-10507) Set target parallelism to maximum when using the standalone job cluster mode, Till Rohrmann (JIRA)
• [jira] [Created] (FLINK-10506) Introduce minimum, target and maximum parallelism to JobGraph, Till Rohrmann (JIRA)
• [jira] [Created] (FLINK-10505) Treat fail signal as scheduling event, Till Rohrmann (JIRA)
• [jira] [Created] (FLINK-10504) Decide actual parallelism based on available resources, Till Rohrmann (JIRA)
• [jira] [Created] (FLINK-10503) Periodically check for new resources, Till Rohrmann (JIRA)
• [jira] [Created] (FLINK-10502) Wait for resource stabilization, Till Rohrmann (JIRA)
• [jira] [Created] (FLINK-10501) Obtain resource overview of cluster, Till Rohrmann (JIRA)
• [jira] [Created] (FLINK-10500) Let ExecutionGraphDriver react to fail signal, Till Rohrmann (JIRA)
• [jira] [Created] (FLINK-10499) Introduce declarative resource management switch, Till Rohrmann (JIRA)
• [jira] [Created] (FLINK-10498) Decouple ExecutionGraph from JobMaster, Till Rohrmann (JIRA)
• [ANNOUNCE] Feature freeze for Flink 1.7: 22nd of October, Till Rohrmann
• [jira] [Created] (FLINK-10497) More fine grained control over access to REST endpoints, Till Rohrmann (JIRA)
• [jira] [Created] (FLINK-10496) CommandLineParser arguments interleaving, eugen yushin (JIRA)
• [jira] [Created] (FLINK-10495) Add HYPOT math function supported in Table API and SQL, Aleksei Izmalkin (JIRA)
• [jira] [Created] (FLINK-10494) Rename 'JobManager' to J'obMaster' for some classes in JobMaster folder, JIN SUN (JIRA)
• [jira] [Created] (FLINK-10493) Macro generated CaseClassSerializer considered harmful, Elias Levy (JIRA)
• [DISCUSS] Breaking the Scala API for Scala 2.12 Support, Aljoscha Krettek
  • <Possible follow-ups>
  • Re: [DISCUSS] Breaking the Scala API for Scala 2.12 Support, Elias Levy
  • Re: [DISCUSS] Breaking the Scala API for Scala 2.12 Support, Till Rohrmann
  • Re: [DISCUSS] Breaking the Scala API for Scala 2.12 Support, Chesnay Schepler
  • Re: [DISCUSS] Breaking the Scala API for Scala 2.12 Support, Aljoscha Krettek
  • Re: [DISCUSS] Breaking the Scala API for Scala 2.12 Support, Chesnay Schepler
  • Re: [DISCUSS] Breaking the Scala API for Scala 2.12 Support, Aljoscha Krettek
  • Re: [DISCUSS] Breaking the Scala API for Scala 2.12 Support, Chesnay Schepler
  • Re: [DISCUSS] Breaking the Scala API for Scala 2.12 Support, Aljoscha Krettek
• [ANNOUNCE] Weekly community update #40, Till Rohrmann
• [jira] [Created] (FLINK-10492) Document generic support for configuring AwsKinesisClient in the Kinesis Consumer, Tzu-Li (Gordon) Tai (JIRA)
• [jira] [Created] (FLINK-10491) Deadlock during spilling data in SpillableSubpartition, Piotr Nowojski (JIRA)
• [jira] [Created] (FLINK-10490) OperatorSnapshotUtil should probably use SavepointV2Serializer, Stefan Richter (JIRA)
• [jira] [Created] (FLINK-10489) Inconsistent window information for streams with EventTime characteristic, Alexis Sarda-Espinosa (JIRA)
• [jira] [Created] (FLINK-10488) Add DISTINCT operator for streaming tables that leverages time attributes, Fabian Hueske (JIRA)
• Future of JobManager.scala, Jin Sun
  • <Possible follow-ups>
  • Re: Future of JobManager.scala, Tzu-Li Chen
  • Re: Future of JobManager.scala, Jin Sun
• TPCH/TPCDS benchmark, Jin Sun
  • <Possible follow-ups>
  • Re: TPCH/TPCDS benchmark, Fabian Hueske
• [jira] [Created] (FLINK-10487) fix deprecated Flink SQL example, Bowen Li (JIRA)
• [jira] [Created] (FLINK-10486) Recover local mode on flink startup, Ismaël Mejía (JIRA)
• MapState support for operator state, Dániel Berecz
  • <Possible follow-ups>
  • Re: MapState support for operator state, Till Rohrmann
  • Re: MapState support for operator state, Fabian Hueske
  • MapState support for operator state, Dániel Berecz
  • Re: MapState support for operator state, Till Rohrmann
  • Re: MapState support for operator state, Dániel Berecz
• [jira] [Created] (FLINK-10485) Gremlin Support from Flink for Graph Processing, Wei Ding (JIRA)
• [jira] [Created] (FLINK-10484) New latency tracking metrics format causes metrics cardinality explosion, Jamie Grier (JIRA)
• [jira] [Created] (FLINK-10483) Can't restore from a savepoint even with Allow Non Restored State enabled, Elias Levy (JIRA)
• Flink operators for Kubernetes, Anand Swaminathan
  • <Possible follow-ups>
  • Re: Flink operators for Kubernetes, Jin Sun
  • Re: Flink operators for Kubernetes, Till Rohrmann
  • Re: Flink operators for Kubernetes, Anand Swaminathan
• [jira] [Created] (FLINK-10482) java.lang.IllegalArgumentException: Negative number of in progress checkpoints, Julio Biason (JIRA)
• Re: Flink Low level APIs How To’s, Till Rohrmann
  • <Possible follow-ups>
  • Re: Flink Low level APIs How To’s, Tzu-Li Chen
• [jira] [Created] (FLINK-10481) Wordcount end-to-end test in docker env unstable, Till Rohrmann (JIRA)
• Flink Low level APIs How To’s, Ramesh Byndoor
• [DISCUSS] Move hadoop 2.4 test profiles to cron jobs, Chesnay Schepler